Class SchemaServiceGrpc.SchemaServiceFutureStub (1.116.4)

1.151.0 (latest) 1.150.1 1.149.0 1.148.0 1.147.0 1.145.0 1.143.1 1.142.0 1.141.5 1.140.2 1.139.4 1.138.0 1.137.1 1.136.1 1.135.0 1.134.2 1.133.1 1.132.2 1.131.0 1.130.0 1.129.6 1.127.3 1.126.6 1.125.13 1.123.18 1.122.2 1.121.1 1.120.24 1.119.1 1.118.0 1.117.0 1.116.4 1.115.5

public static final class SchemaServiceGrpc.SchemaServiceFutureStub extends AbstractFutureStub<SchemaServiceGrpc.SchemaServiceFutureStub>

Service for doing schema-related operations.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractFutureStub > SchemaServiceGrpc.SchemaServiceFutureStub

Inherited Members

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build(Channel channel, CallOptions callOptions)

protected SchemaServiceGrpc.SchemaServiceFutureStub build(Channel channel, CallOptions callOptions)

Parameters

Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns

Type	Description
SchemaServiceGrpc.SchemaServiceFutureStub

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createSchema(CreateSchemaRequest request)

public ListenableFuture<Schema> createSchema(CreateSchemaRequest request)

Creates a schema.

Parameter

Name	Description
request	CreateSchemaRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Schema>

deleteSchema(DeleteSchemaRequest request)

public ListenableFuture<Empty> deleteSchema(DeleteSchemaRequest request)

Deletes a schema.

Parameter

Name	Description
request	DeleteSchemaRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Empty>

getSchema(GetSchemaRequest request)

public ListenableFuture<Schema> getSchema(GetSchemaRequest request)

Gets a schema.

Parameter

Name	Description
request	GetSchemaRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<Schema>

listSchemas(ListSchemasRequest request)

public ListenableFuture<ListSchemasResponse> listSchemas(ListSchemasRequest request)

Lists schemas in a project.

Parameter

Name	Description
request	ListSchemasRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<ListSchemasResponse>

validateMessage(ValidateMessageRequest request)

public ListenableFuture<ValidateMessageResponse> validateMessage(ValidateMessageRequest request)

Validates a message against a schema.

Parameter

Name	Description
request	ValidateMessageRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<ValidateMessageResponse>

validateSchema(ValidateSchemaRequest request)

public ListenableFuture<ValidateSchemaResponse> validateSchema(ValidateSchemaRequest request)

Validates a schema.

Parameter

Name	Description
request	ValidateSchemaRequest

Returns

Type	Description
com.google.common.util.concurrent.ListenableFuture<ValidateSchemaResponse>