Lines Matching refs:schemaGRPCClient
188 type schemaGRPCClient struct { struct
232 c := &schemaGRPCClient{
249 func (c *schemaGRPCClient) Connection() *grpc.ClientConn { argument
256 func (c *schemaGRPCClient) setGoogleClientInfo(keyval ...string) { argument
264 func (c *schemaGRPCClient) Close() error { argument
268 func (c *schemaGRPCClient) CreateSchema(ctx context.Context, req *pubsubpb.CreateSchemaRequest, opt… argument
284 func (c *schemaGRPCClient) GetSchema(ctx context.Context, req *pubsubpb.GetSchemaRequest, opts ...g… argument
300 func (c *schemaGRPCClient) ListSchemas(ctx context.Context, req *pubsubpb.ListSchemasRequest, opts … argument
344 func (c *schemaGRPCClient) DeleteSchema(ctx context.Context, req *pubsubpb.DeleteSchemaRequest, opt… argument
356 func (c *schemaGRPCClient) ValidateSchema(ctx context.Context, req *pubsubpb.ValidateSchemaRequest,… argument
372 func (c *schemaGRPCClient) ValidateMessage(ctx context.Context, req *pubsubpb.ValidateMessageReques… argument
388 func (c *schemaGRPCClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts .… argument
403 func (c *schemaGRPCClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts .… argument
418 func (c *schemaGRPCClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsReq… argument