public sealed class SchemaServiceClientImpl : SchemaServiceClient
Reference documentation and code samples for the Cloud Pub/Sub v1 API class SchemaServiceClientImpl.
SchemaService client wrapper implementation, for convenient use.
Namespace
Google.Cloud.PubSub.V1Assembly
Google.Cloud.PubSub.V1.dll
Remarks
Service for doing schema-related operations.
Constructors
SchemaServiceClientImpl(SchemaService.SchemaServiceClient, SchemaServiceSettings, ILogger)
public SchemaServiceClientImpl(SchemaService.SchemaServiceClient grpcClient, SchemaServiceSettings settings, ILogger logger)
Constructs a client wrapper for the SchemaService service, with the specified gRPC client and settings.
Parameters | |
---|---|
Name | Description |
grpcClient | SchemaService.SchemaServiceClient The underlying gRPC client. |
settings | SchemaServiceSettings The base SchemaServiceSettings used within this client. |
logger | ILogger Optional ILogger to use within this client. |
Properties
GrpcClient
public override SchemaService.SchemaServiceClient GrpcClient { get; }
The underlying gRPC SchemaService client
Property Value | |
---|---|
Type | Description |
SchemaService.SchemaServiceClient |
IAMPolicyClient
public override IAMPolicyClient IAMPolicyClient { get; }
The IAMPolicyClient associated with this client.
Property Value | |
---|---|
Type | Description |
IAMPolicyClient |
Methods
CommitSchema(CommitSchemaRequest, CallSettings)
public override Schema CommitSchema(CommitSchemaRequest request, CallSettings callSettings = null)
Commits a new schema revision to an existing schema.
Parameters | |
---|---|
Name | Description |
request | CommitSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Schema | The RPC response. |
CommitSchemaAsync(CommitSchemaRequest, CallSettings)
public override Task<Schema> CommitSchemaAsync(CommitSchemaRequest request, CallSettings callSettings = null)
Commits a new schema revision to an existing schema.
Parameters | |
---|---|
Name | Description |
request | CommitSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Schema> | A Task containing the RPC response. |
CreateSchema(CreateSchemaRequest, CallSettings)
public override Schema CreateSchema(CreateSchemaRequest request, CallSettings callSettings = null)
Creates a schema.
Parameters | |
---|---|
Name | Description |
request | CreateSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Schema | The RPC response. |
CreateSchemaAsync(CreateSchemaRequest, CallSettings)
public override Task<Schema> CreateSchemaAsync(CreateSchemaRequest request, CallSettings callSettings = null)
Creates a schema.
Parameters | |
---|---|
Name | Description |
request | CreateSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Schema> | A Task containing the RPC response. |
DeleteSchema(DeleteSchemaRequest, CallSettings)
public override void DeleteSchema(DeleteSchemaRequest request, CallSettings callSettings = null)
Deletes a schema.
Parameters | |
---|---|
Name | Description |
request | DeleteSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
DeleteSchemaAsync(DeleteSchemaRequest, CallSettings)
public override Task DeleteSchemaAsync(DeleteSchemaRequest request, CallSettings callSettings = null)
Deletes a schema.
Parameters | |
---|---|
Name | Description |
request | DeleteSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task | A Task containing the RPC response. |
DeleteSchemaRevision(DeleteSchemaRevisionRequest, CallSettings)
public override Schema DeleteSchemaRevision(DeleteSchemaRevisionRequest request, CallSettings callSettings = null)
Deletes a specific schema revision.
Parameters | |
---|---|
Name | Description |
request | DeleteSchemaRevisionRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Schema | The RPC response. |
DeleteSchemaRevisionAsync(DeleteSchemaRevisionRequest, CallSettings)
public override Task<Schema> DeleteSchemaRevisionAsync(DeleteSchemaRevisionRequest request, CallSettings callSettings = null)
Deletes a specific schema revision.
Parameters | |
---|---|
Name | Description |
request | DeleteSchemaRevisionRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Schema> | A Task containing the RPC response. |
GetSchema(GetSchemaRequest, CallSettings)
public override Schema GetSchema(GetSchemaRequest request, CallSettings callSettings = null)
Gets a schema.
Parameters | |
---|---|
Name | Description |
request | GetSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Schema | The RPC response. |
GetSchemaAsync(GetSchemaRequest, CallSettings)
public override Task<Schema> GetSchemaAsync(GetSchemaRequest request, CallSettings callSettings = null)
Gets a schema.
Parameters | |
---|---|
Name | Description |
request | GetSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Schema> | A Task containing the RPC response. |
ListSchemaRevisions(ListSchemaRevisionsRequest, CallSettings)
public override PagedEnumerable<ListSchemaRevisionsResponse, Schema> ListSchemaRevisions(ListSchemaRevisionsRequest request, CallSettings callSettings = null)
Lists all schema revisions for the named schema.
Parameters | |
---|---|
Name | Description |
request | ListSchemaRevisionsRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListSchemaRevisionsResponse, Schema> | A pageable sequence of Schema resources. |
ListSchemaRevisionsAsync(ListSchemaRevisionsRequest, CallSettings)
public override PagedAsyncEnumerable<ListSchemaRevisionsResponse, Schema> ListSchemaRevisionsAsync(ListSchemaRevisionsRequest request, CallSettings callSettings = null)
Lists all schema revisions for the named schema.
Parameters | |
---|---|
Name | Description |
request | ListSchemaRevisionsRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListSchemaRevisionsResponse, Schema> | A pageable asynchronous sequence of Schema resources. |
ListSchemas(ListSchemasRequest, CallSettings)
public override PagedEnumerable<ListSchemasResponse, Schema> ListSchemas(ListSchemasRequest request, CallSettings callSettings = null)
Lists schemas in a project.
Parameters | |
---|---|
Name | Description |
request | ListSchemasRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedEnumerable<ListSchemasResponse, Schema> | A pageable sequence of Schema resources. |
ListSchemasAsync(ListSchemasRequest, CallSettings)
public override PagedAsyncEnumerable<ListSchemasResponse, Schema> ListSchemasAsync(ListSchemasRequest request, CallSettings callSettings = null)
Lists schemas in a project.
Parameters | |
---|---|
Name | Description |
request | ListSchemasRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
PagedAsyncEnumerable<ListSchemasResponse, Schema> | A pageable asynchronous sequence of Schema resources. |
RollbackSchema(RollbackSchemaRequest, CallSettings)
public override Schema RollbackSchema(RollbackSchemaRequest request, CallSettings callSettings = null)
Creates a new schema revision that is a copy of the provided revision_id.
Parameters | |
---|---|
Name | Description |
request | RollbackSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Schema | The RPC response. |
RollbackSchemaAsync(RollbackSchemaRequest, CallSettings)
public override Task<Schema> RollbackSchemaAsync(RollbackSchemaRequest request, CallSettings callSettings = null)
Creates a new schema revision that is a copy of the provided revision_id.
Parameters | |
---|---|
Name | Description |
request | RollbackSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<Schema> | A Task containing the RPC response. |
ValidateMessage(ValidateMessageRequest, CallSettings)
public override ValidateMessageResponse ValidateMessage(ValidateMessageRequest request, CallSettings callSettings = null)
Validates a message against a schema.
Parameters | |
---|---|
Name | Description |
request | ValidateMessageRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
ValidateMessageResponse | The RPC response. |
ValidateMessageAsync(ValidateMessageRequest, CallSettings)
public override Task<ValidateMessageResponse> ValidateMessageAsync(ValidateMessageRequest request, CallSettings callSettings = null)
Validates a message against a schema.
Parameters | |
---|---|
Name | Description |
request | ValidateMessageRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<ValidateMessageResponse> | A Task containing the RPC response. |
ValidateSchema(ValidateSchemaRequest, CallSettings)
public override ValidateSchemaResponse ValidateSchema(ValidateSchemaRequest request, CallSettings callSettings = null)
Validates a schema.
Parameters | |
---|---|
Name | Description |
request | ValidateSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
ValidateSchemaResponse | The RPC response. |
ValidateSchemaAsync(ValidateSchemaRequest, CallSettings)
public override Task<ValidateSchemaResponse> ValidateSchemaAsync(ValidateSchemaRequest request, CallSettings callSettings = null)
Validates a schema.
Parameters | |
---|---|
Name | Description |
request | ValidateSchemaRequest The request object containing all of the parameters for the API call. |
callSettings | CallSettings If not null, applies overrides to this RPC call. |
Returns | |
---|---|
Type | Description |
Task<ValidateSchemaResponse> | A Task containing the RPC response. |