abstract class SchemaServiceClient extends SchemaServiceClientPowerApi with SchemaService with AkkaGrpcClient
- Annotations
- @AkkaGrpcGenerated()
- Source
- SchemaServiceClient.java
- Alphabetic
- By Inheritance
- SchemaServiceClient
- AkkaGrpcClient
- SchemaService
- SchemaServiceClientPowerApi
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SchemaServiceClient()
Abstract Value Members
- abstract def close(): CompletionStage[Done]
- Definition Classes
- AkkaGrpcClient
- abstract def closed(): CompletionStage[Done]
- Definition Classes
- AkkaGrpcClient
- abstract def commitSchema(in: CommitSchemaRequest): CompletionStage[Schema]
Commits a new schema revision to an existing schema.
Commits a new schema revision to an existing schema.
- Definition Classes
- SchemaService
- abstract def createSchema(in: CreateSchemaRequest): CompletionStage[Schema]
Creates a schema.
Creates a schema.
- Definition Classes
- SchemaService
- abstract def deleteSchema(in: DeleteSchemaRequest): CompletionStage[Empty]
Deletes a schema.
Deletes a schema.
- Definition Classes
- SchemaService
- abstract def deleteSchemaRevision(in: DeleteSchemaRevisionRequest): CompletionStage[Schema]
Deletes a specific schema revision.
Deletes a specific schema revision.
- Definition Classes
- SchemaService
- abstract def getSchema(in: GetSchemaRequest): CompletionStage[Schema]
Gets a schema.
Gets a schema.
- Definition Classes
- SchemaService
- abstract def listSchemaRevisions(in: ListSchemaRevisionsRequest): CompletionStage[ListSchemaRevisionsResponse]
Lists all schema revisions for the named schema.
Lists all schema revisions for the named schema.
- Definition Classes
- SchemaService
- abstract def listSchemas(in: ListSchemasRequest): CompletionStage[ListSchemasResponse]
Lists schemas in a project.
Lists schemas in a project.
- Definition Classes
- SchemaService
- abstract def rollbackSchema(in: RollbackSchemaRequest): CompletionStage[Schema]
Creates a new schema revision that is a copy of the provided revision_id.
Creates a new schema revision that is a copy of the provided revision_id.
- Definition Classes
- SchemaService
- abstract def validateMessage(in: ValidateMessageRequest): CompletionStage[ValidateMessageResponse]
Validates a message against a schema.
Validates a message against a schema.
- Definition Classes
- SchemaService
- abstract def validateSchema(in: ValidateSchemaRequest): CompletionStage[ValidateSchemaResponse]
Validates a schema.
Validates a schema.
- Definition Classes
- SchemaService
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addRequestHeader(key: String, value: String): SchemaServiceClient
The same client instance decorated to add the given key and value to the metadata of any request issued.
The same client instance decorated to add the given key and value to the metadata of any request issued.
- Definition Classes
- SchemaServiceClient → AkkaGrpcClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def commitSchema(): SingleResponseRequestBuilder[CommitSchemaRequest, Schema]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer commitSchema(com.google.pubsub.v1.CommitSchemaRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- def createSchema(): SingleResponseRequestBuilder[CreateSchemaRequest, Schema]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer createSchema(com.google.pubsub.v1.CreateSchemaRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- def deleteSchema(): SingleResponseRequestBuilder[DeleteSchemaRequest, Empty]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer deleteSchema(com.google.pubsub.v1.DeleteSchemaRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- def deleteSchemaRevision(): SingleResponseRequestBuilder[DeleteSchemaRevisionRequest, Schema]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer deleteSchemaRevision(com.google.pubsub.v1.DeleteSchemaRevisionRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def getSchema(): SingleResponseRequestBuilder[GetSchemaRequest, Schema]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer getSchema(com.google.pubsub.v1.GetSchemaRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def listSchemaRevisions(): SingleResponseRequestBuilder[ListSchemaRevisionsRequest, ListSchemaRevisionsResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer listSchemaRevisions(com.google.pubsub.v1.ListSchemaRevisionsRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- def listSchemas(): SingleResponseRequestBuilder[ListSchemasRequest, ListSchemasResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer listSchemas(com.google.pubsub.v1.ListSchemasRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def rollbackSchema(): SingleResponseRequestBuilder[RollbackSchemaRequest, Schema]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer rollbackSchema(com.google.pubsub.v1.RollbackSchemaRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def validateMessage(): SingleResponseRequestBuilder[ValidateMessageRequest, ValidateMessageResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer validateMessage(com.google.pubsub.v1.ValidateMessageRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- def validateSchema(): SingleResponseRequestBuilder[ValidateSchemaRequest, ValidateSchemaResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer validateSchema(com.google.pubsub.v1.ValidateSchemaRequest) if possible.
- Definition Classes
- SchemaServiceClientPowerApi
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])