Package cloud.google.com/go/spanner/adapter/apiv1/adapterpb (v1.84.1)

var File_google_spanner_adapter_v1_adapter_proto protoreflect.FileDescriptor

func RegisterAdapterServer(s *grpc.Server, srv AdapterServer)

type AdaptMessageRequest struct {

	// Required. The database session in which the adapter request is processed.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Identifier for the underlying wire protocol.
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Optional. Uninterpreted bytes from the underlying wire protocol.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// Optional. Opaque request state passed by the client to the server.
	Attachments map[string]string `protobuf:"bytes,4,rep,name=attachments,proto3" json:"attachments,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// contains filtered or unexported fields
}

func (*AdaptMessageRequest) Descriptor() ([]byte, []int)

func (x *AdaptMessageRequest) GetAttachments() map[string]string

func (x *AdaptMessageRequest) GetName() string

func (x *AdaptMessageRequest) GetPayload() []byte

func (x *AdaptMessageRequest) GetProtocol() string

func (*AdaptMessageRequest) ProtoMessage()

func (x *AdaptMessageRequest) ProtoReflect() protoreflect.Message

func (x *AdaptMessageRequest) Reset()

func (x *AdaptMessageRequest) String() string

type AdaptMessageResponse struct {

	// Optional. Uninterpreted bytes from the underlying wire protocol.
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Optional. Opaque state updates to be applied by the client.
	StateUpdates map[string]string `protobuf:"bytes,2,rep,name=state_updates,json=stateUpdates,proto3" json:"state_updates,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Optional. Indicates whether this is the last
	// [AdaptMessageResponse][google.spanner.adapter.v1.AdaptMessageResponse] in
	// the stream. This field may be optionally set by the server. Clients should
	// not rely on this field being set in all cases.
	Last bool `protobuf:"varint,3,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

func (*AdaptMessageResponse) Descriptor() ([]byte, []int)

func (x *AdaptMessageResponse) GetLast() bool

func (x *AdaptMessageResponse) GetPayload() []byte

func (x *AdaptMessageResponse) GetStateUpdates() map[string]string

func (*AdaptMessageResponse) ProtoMessage()

func (x *AdaptMessageResponse) ProtoReflect() protoreflect.Message

func (x *AdaptMessageResponse) Reset()

func (x *AdaptMessageResponse) String() string

type AdapterClient interface {
	// Creates a new session to be used for requests made by the adapter.
	// A session identifies a specific incarnation of a database resource and is
	// meant to be reused across many `AdaptMessage` calls.
	CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*Session, error)
	// Handles a single message from the client and returns the result as a
	// stream. The server will interpret the message frame and respond with
	// message frames to the client.
	AdaptMessage(ctx context.Context, in *AdaptMessageRequest, opts ...grpc.CallOption) (Adapter_AdaptMessageClient, error)
}

func NewAdapterClient(cc grpc.ClientConnInterface) AdapterClient

type AdapterServer interface {
	// Creates a new session to be used for requests made by the adapter.
	// A session identifies a specific incarnation of a database resource and is
	// meant to be reused across many `AdaptMessage` calls.
	CreateSession(context.Context, *CreateSessionRequest) (*Session, error)
	// Handles a single message from the client and returns the result as a
	// stream. The server will interpret the message frame and respond with
	// message frames to the client.
	AdaptMessage(*AdaptMessageRequest, Adapter_AdaptMessageServer) error
}

type Adapter_AdaptMessageClient interface {
	Recv() (*AdaptMessageResponse, error)
	grpc.ClientStream
}

type Adapter_AdaptMessageServer interface {
	Send(*AdaptMessageResponse) error
	grpc.ServerStream
}

type CreateSessionRequest struct {

	// Required. The database in which the new session is created.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The session to create.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionRequest) Descriptor() ([]byte, []int)

func (x *CreateSessionRequest) GetParent() string

func (x *CreateSessionRequest) GetSession() *Session

func (*CreateSessionRequest) ProtoMessage()

func (x *CreateSessionRequest) ProtoReflect() protoreflect.Message

func (x *CreateSessionRequest) Reset()

func (x *CreateSessionRequest) String() string

type Session struct {

	// Identifier. The name of the session. This is always system-assigned.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor() ([]byte, []int)

func (x *Session) GetName() string

func (*Session) ProtoMessage()

func (x *Session) ProtoReflect() protoreflect.Message

func (x *Session) Reset()

func (x *Session) String() string

type UnimplementedAdapterServer struct {
}

func (*UnimplementedAdapterServer) AdaptMessage(*AdaptMessageRequest, Adapter_AdaptMessageServer) error

func (*UnimplementedAdapterServer) CreateSession(context.Context, *CreateSessionRequest) (*Session, error)