Reference documentation and code samples for the Managed Service for Apache Kafka V1 API class Google::Cloud::ManagedKafka::SchemaRegistry::V1::ManagedSchemaRegistry::Rest::ServiceStub.
REST service stub for the ManagedSchemaRegistry service. Service stub contains baseline method implementations including transcoding, making the REST call, and deserialing the response.
Inherits
- Object
Methods
#check_compatibility
def check_compatibility(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CheckCompatibilityResponse
Baseline implementation for the check_compatibility REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CheckCompatibilityRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CheckCompatibilityResponse)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CheckCompatibilityResponse) — A result object deserialized from the server's reply
- (::ArgumentError)
#create_schema_registry
def create_schema_registry(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaRegistry
Baseline implementation for the create_schema_registry REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CreateSchemaRegistryRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaRegistry)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaRegistry) — A result object deserialized from the server's reply
- (::ArgumentError)
#create_version
def create_version(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CreateVersionResponse
Baseline implementation for the create_version REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CreateVersionRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CreateVersionResponse)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::CreateVersionResponse) — A result object deserialized from the server's reply
- (::ArgumentError)
#delete_schema_config
def delete_schema_config(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig
Baseline implementation for the delete_schema_config REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::DeleteSchemaConfigRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig) — A result object deserialized from the server's reply
- (::ArgumentError)
#delete_schema_mode
def delete_schema_mode(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode
Baseline implementation for the delete_schema_mode REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::DeleteSchemaModeRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode) — A result object deserialized from the server's reply
- (::ArgumentError)
#delete_schema_registry
def delete_schema_registry(request_pb, options = nil) { |result, operation| ... } -> ::Google::Protobuf::Empty
Baseline implementation for the delete_schema_registry REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::DeleteSchemaRegistryRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Protobuf::Empty)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Protobuf::Empty) — A result object deserialized from the server's reply
- (::ArgumentError)
#delete_subject
def delete_subject(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the delete_subject REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::DeleteSubjectRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#delete_version
def delete_version(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the delete_version REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::DeleteVersionRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#endpoint
def endpoint() -> String
The effective endpoint
- (String)
#get_context
def get_context(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::Context
Baseline implementation for the get_context REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetContextRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::Context)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::Context) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_raw_schema
def get_raw_schema(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the get_raw_schema REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetSchemaRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_raw_schema_version
def get_raw_schema_version(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the get_raw_schema_version REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetVersionRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_schema
def get_schema(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::Schema
Baseline implementation for the get_schema REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetSchemaRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::Schema)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::Schema) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_schema_config
def get_schema_config(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig
Baseline implementation for the get_schema_config REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetSchemaConfigRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_schema_mode
def get_schema_mode(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode
Baseline implementation for the get_schema_mode REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetSchemaModeRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_schema_registry
def get_schema_registry(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaRegistry
Baseline implementation for the get_schema_registry REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetSchemaRegistryRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaRegistry)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaRegistry) — A result object deserialized from the server's reply
- (::ArgumentError)
#get_version
def get_version(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaVersion
Baseline implementation for the get_version REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::GetVersionRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaVersion)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaVersion) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_contexts
def list_contexts(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_contexts REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListContextsRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_referenced_schemas
def list_referenced_schemas(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_referenced_schemas REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListReferencedSchemasRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_schema_registries
def list_schema_registries(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSchemaRegistriesResponse
Baseline implementation for the list_schema_registries REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSchemaRegistriesRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSchemaRegistriesResponse)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSchemaRegistriesResponse) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_schema_types
def list_schema_types(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_schema_types REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSchemaTypesRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_schema_versions
def list_schema_versions(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_schema_versions REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSchemaVersionsRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_subjects
def list_subjects(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_subjects REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSubjectsRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_subjects_by_schema_id
def list_subjects_by_schema_id(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_subjects_by_schema_id REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListSubjectsBySchemaIdRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#list_versions
def list_versions(request_pb, options = nil) { |result, operation| ... } -> ::Google::Api::HttpBody
Baseline implementation for the list_versions REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::ListVersionsRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Api::HttpBody)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Api::HttpBody) — A result object deserialized from the server's reply
- (::ArgumentError)
#logger
def logger(stub: false) -> Logger
The logger used for request/response debug logging.
- (Logger)
#lookup_version
def lookup_version(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaVersion
Baseline implementation for the lookup_version REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::LookupVersionRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaVersion)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaVersion) — A result object deserialized from the server's reply
- (::ArgumentError)
#universe_domain
def universe_domain() -> String
The effective universe domain
- (String)
#update_schema_config
def update_schema_config(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig
Baseline implementation for the update_schema_config REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::UpdateSchemaConfigRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaConfig) — A result object deserialized from the server's reply
- (::ArgumentError)
#update_schema_mode
def update_schema_mode(request_pb, options = nil) { |result, operation| ... } -> ::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode
Baseline implementation for the update_schema_mode REST call
- request_pb (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::UpdateSchemaModeRequest) — A request object representing the call parameters. Required.
- options (::Gapic::CallOptions) — Overrides the default settings for this call, e.g, timeout, retries etc. Optional.
- (result, operation) — Access the result along with the TransportOperation object
- result (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode)
- operation (::Gapic::Rest::TransportOperation)
- (::Google::Cloud::ManagedKafka::SchemaRegistry::V1::SchemaMode) — A result object deserialized from the server's reply
- (::ArgumentError)