Documentation ¶
Index ¶
- Variables
- type BackupService
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)
- func (m *CloseSessionRequest) GetSessionID() uint64
- func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionRequest) ProtoMessage()
- func (m *CloseSessionRequest) Reset()
- func (m *CloseSessionRequest) Size() (n int)
- func (m *CloseSessionRequest) String() string
- func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error
- func (m *CloseSessionRequest) XXX_DiscardUnknown()
- func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionRequest) XXX_Merge(src proto.Message)
- func (m *CloseSessionRequest) XXX_Size() int
- func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)
- func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseSessionResponse) ProtoMessage()
- func (m *CloseSessionResponse) Reset()
- func (m *CloseSessionResponse) Size() (n int)
- func (m *CloseSessionResponse) String() string
- func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error
- func (m *CloseSessionResponse) XXX_DiscardUnknown()
- func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseSessionResponse) XXX_Merge(src proto.Message)
- func (m *CloseSessionResponse) XXX_Size() int
- func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error
- type Executor
- type Index
- type KeepAliveRequest
- func (*KeepAliveRequest) Descriptor() ([]byte, []int)
- func (m *KeepAliveRequest) GetCommandSequence() uint64
- func (m *KeepAliveRequest) GetSessionID() uint64
- func (m *KeepAliveRequest) GetStreams() map[uint64]uint64
- func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveRequest) ProtoMessage()
- func (m *KeepAliveRequest) Reset()
- func (m *KeepAliveRequest) Size() (n int)
- func (m *KeepAliveRequest) String() string
- func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
- func (m *KeepAliveRequest) XXX_DiscardUnknown()
- func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
- func (m *KeepAliveRequest) XXX_Size() int
- func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
- type KeepAliveResponse
- func (*KeepAliveResponse) Descriptor() ([]byte, []int)
- func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveResponse) ProtoMessage()
- func (m *KeepAliveResponse) Reset()
- func (m *KeepAliveResponse) Size() (n int)
- func (m *KeepAliveResponse) String() string
- func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
- func (m *KeepAliveResponse) XXX_DiscardUnknown()
- func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
- func (m *KeepAliveResponse) XXX_Size() int
- func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
- type Manager
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetTimeout() *time.Duration
- func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionRequest) ProtoMessage()
- func (m *OpenSessionRequest) Reset()
- func (m *OpenSessionRequest) Size() (n int)
- func (m *OpenSessionRequest) String() string
- func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
- func (m *OpenSessionRequest) XXX_DiscardUnknown()
- func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
- func (m *OpenSessionRequest) XXX_Size() int
- func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)
- func (m *OpenSessionResponse) GetSessionID() uint64
- func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionResponse) ProtoMessage()
- func (m *OpenSessionResponse) Reset()
- func (m *OpenSessionResponse) Size() (n int)
- func (m *OpenSessionResponse) String() string
- func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
- func (m *OpenSessionResponse) XXX_DiscardUnknown()
- func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
- func (m *OpenSessionResponse) XXX_Size() int
- func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
- type Operation
- type OperationID
- type Partition
- type PartitionContext
- type PartitionID
- type Primitive
- type Protocol
- type ProtocolContext
- type Registry
- type RestoreService
- type Scheduler
- type Server
- func (s *Server) DoCloseService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
- func (s *Server) DoCloseSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
- func (s *Server) DoCommand(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
- func (s *Server) DoCommandStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, ...) error
- func (s *Server) DoCreateService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
- func (s *Server) DoDeleteService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
- func (s *Server) DoKeepAliveSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
- func (s *Server) DoMetadata(ctx context.Context, serviceType primitive.PrimitiveType, namespace string, ...) ([]*ServiceId, *headers.ResponseHeader, error)
- func (s *Server) DoOpenSession(ctx context.Context, header *headers.RequestHeader, timeout *time.Duration) (*headers.ResponseHeader, error)
- func (s *Server) DoQuery(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
- func (s *Server) DoQueryStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, ...) error
- type Service
- type ServiceCloseRequest
- func (*ServiceCloseRequest) Descriptor() ([]byte, []int)
- func (m *ServiceCloseRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceCloseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceCloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceCloseRequest) ProtoMessage()
- func (m *ServiceCloseRequest) Reset()
- func (m *ServiceCloseRequest) Size() (n int)
- func (m *ServiceCloseRequest) String() string
- func (m *ServiceCloseRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceCloseRequest) XXX_DiscardUnknown()
- func (m *ServiceCloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceCloseRequest) XXX_Merge(src proto.Message)
- func (m *ServiceCloseRequest) XXX_Size() int
- func (m *ServiceCloseRequest) XXX_Unmarshal(b []byte) error
- type ServiceCloseResponse
- func (*ServiceCloseResponse) Descriptor() ([]byte, []int)
- func (m *ServiceCloseResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceCloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceCloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceCloseResponse) ProtoMessage()
- func (m *ServiceCloseResponse) Reset()
- func (m *ServiceCloseResponse) Size() (n int)
- func (m *ServiceCloseResponse) String() string
- func (m *ServiceCloseResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceCloseResponse) XXX_DiscardUnknown()
- func (m *ServiceCloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceCloseResponse) XXX_Merge(src proto.Message)
- func (m *ServiceCloseResponse) XXX_Size() int
- func (m *ServiceCloseResponse) XXX_Unmarshal(b []byte) error
- type ServiceCommandRequest
- func (*ServiceCommandRequest) Descriptor() ([]byte, []int)
- func (m *ServiceCommandRequest) GetClose() *ServiceCloseRequest
- func (m *ServiceCommandRequest) GetCreate() *ServiceCreateRequest
- func (m *ServiceCommandRequest) GetDelete() *ServiceDeleteRequest
- func (m *ServiceCommandRequest) GetOperation() *ServiceOperationRequest
- func (m *ServiceCommandRequest) GetRequest() isServiceCommandRequest_Request
- func (m *ServiceCommandRequest) GetService() *ServiceId
- func (m *ServiceCommandRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceCommandRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceCommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceCommandRequest) ProtoMessage()
- func (m *ServiceCommandRequest) Reset()
- func (m *ServiceCommandRequest) Size() (n int)
- func (m *ServiceCommandRequest) String() string
- func (m *ServiceCommandRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceCommandRequest) XXX_DiscardUnknown()
- func (m *ServiceCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceCommandRequest) XXX_Merge(src proto.Message)
- func (*ServiceCommandRequest) XXX_OneofWrappers() []interface{}
- func (m *ServiceCommandRequest) XXX_Size() int
- func (m *ServiceCommandRequest) XXX_Unmarshal(b []byte) error
- type ServiceCommandRequest_Close
- type ServiceCommandRequest_Create
- type ServiceCommandRequest_Delete
- type ServiceCommandRequest_Operation
- type ServiceCommandResponse
- func (*ServiceCommandResponse) Descriptor() ([]byte, []int)
- func (m *ServiceCommandResponse) GetClose() *ServiceCloseResponse
- func (m *ServiceCommandResponse) GetCreate() *ServiceCreateResponse
- func (m *ServiceCommandResponse) GetDelete() *ServiceDeleteResponse
- func (m *ServiceCommandResponse) GetOperation() *ServiceOperationResponse
- func (m *ServiceCommandResponse) GetResponse() isServiceCommandResponse_Response
- func (m *ServiceCommandResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceCommandResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceCommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceCommandResponse) ProtoMessage()
- func (m *ServiceCommandResponse) Reset()
- func (m *ServiceCommandResponse) Size() (n int)
- func (m *ServiceCommandResponse) String() string
- func (m *ServiceCommandResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceCommandResponse) XXX_DiscardUnknown()
- func (m *ServiceCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceCommandResponse) XXX_Merge(src proto.Message)
- func (*ServiceCommandResponse) XXX_OneofWrappers() []interface{}
- func (m *ServiceCommandResponse) XXX_Size() int
- func (m *ServiceCommandResponse) XXX_Unmarshal(b []byte) error
- type ServiceCommandResponse_Close
- type ServiceCommandResponse_Create
- type ServiceCommandResponse_Delete
- type ServiceCommandResponse_Operation
- type ServiceContext
- type ServiceCreateRequest
- func (*ServiceCreateRequest) Descriptor() ([]byte, []int)
- func (m *ServiceCreateRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceCreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceCreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceCreateRequest) ProtoMessage()
- func (m *ServiceCreateRequest) Reset()
- func (m *ServiceCreateRequest) Size() (n int)
- func (m *ServiceCreateRequest) String() string
- func (m *ServiceCreateRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceCreateRequest) XXX_DiscardUnknown()
- func (m *ServiceCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceCreateRequest) XXX_Merge(src proto.Message)
- func (m *ServiceCreateRequest) XXX_Size() int
- func (m *ServiceCreateRequest) XXX_Unmarshal(b []byte) error
- type ServiceCreateResponse
- func (*ServiceCreateResponse) Descriptor() ([]byte, []int)
- func (m *ServiceCreateResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceCreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceCreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceCreateResponse) ProtoMessage()
- func (m *ServiceCreateResponse) Reset()
- func (m *ServiceCreateResponse) Size() (n int)
- func (m *ServiceCreateResponse) String() string
- func (m *ServiceCreateResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceCreateResponse) XXX_DiscardUnknown()
- func (m *ServiceCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceCreateResponse) XXX_Merge(src proto.Message)
- func (m *ServiceCreateResponse) XXX_Size() int
- func (m *ServiceCreateResponse) XXX_Unmarshal(b []byte) error
- type ServiceDeleteRequest
- func (*ServiceDeleteRequest) Descriptor() ([]byte, []int)
- func (m *ServiceDeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceDeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceDeleteRequest) ProtoMessage()
- func (m *ServiceDeleteRequest) Reset()
- func (m *ServiceDeleteRequest) Size() (n int)
- func (m *ServiceDeleteRequest) String() string
- func (m *ServiceDeleteRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceDeleteRequest) XXX_DiscardUnknown()
- func (m *ServiceDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceDeleteRequest) XXX_Merge(src proto.Message)
- func (m *ServiceDeleteRequest) XXX_Size() int
- func (m *ServiceDeleteRequest) XXX_Unmarshal(b []byte) error
- type ServiceDeleteResponse
- func (*ServiceDeleteResponse) Descriptor() ([]byte, []int)
- func (m *ServiceDeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceDeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceDeleteResponse) ProtoMessage()
- func (m *ServiceDeleteResponse) Reset()
- func (m *ServiceDeleteResponse) Size() (n int)
- func (m *ServiceDeleteResponse) String() string
- func (m *ServiceDeleteResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceDeleteResponse) XXX_DiscardUnknown()
- func (m *ServiceDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceDeleteResponse) XXX_Merge(src proto.Message)
- func (m *ServiceDeleteResponse) XXX_Size() int
- func (m *ServiceDeleteResponse) XXX_Unmarshal(b []byte) error
- type ServiceID
- type ServiceId
- func (*ServiceId) Descriptor() ([]byte, []int)
- func (m *ServiceId) GetName() string
- func (m *ServiceId) GetNamespace() string
- func (m *ServiceId) GetType() ServiceType
- func (m *ServiceId) Marshal() (dAtA []byte, err error)
- func (m *ServiceId) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceId) ProtoMessage()
- func (m *ServiceId) Reset()
- func (m *ServiceId) Size() (n int)
- func (m *ServiceId) String() string
- func (m *ServiceId) Unmarshal(dAtA []byte) error
- func (m *ServiceId) XXX_DiscardUnknown()
- func (m *ServiceId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceId) XXX_Merge(src proto.Message)
- func (m *ServiceId) XXX_Size() int
- func (m *ServiceId) XXX_Unmarshal(b []byte) error
- type ServiceMetadataRequest
- func (*ServiceMetadataRequest) Descriptor() ([]byte, []int)
- func (m *ServiceMetadataRequest) GetNamespace() string
- func (m *ServiceMetadataRequest) GetType() ServiceType
- func (m *ServiceMetadataRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceMetadataRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceMetadataRequest) ProtoMessage()
- func (m *ServiceMetadataRequest) Reset()
- func (m *ServiceMetadataRequest) Size() (n int)
- func (m *ServiceMetadataRequest) String() string
- func (m *ServiceMetadataRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceMetadataRequest) XXX_DiscardUnknown()
- func (m *ServiceMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceMetadataRequest) XXX_Merge(src proto.Message)
- func (m *ServiceMetadataRequest) XXX_Size() int
- func (m *ServiceMetadataRequest) XXX_Unmarshal(b []byte) error
- type ServiceMetadataResponse
- func (*ServiceMetadataResponse) Descriptor() ([]byte, []int)
- func (m *ServiceMetadataResponse) GetServices() []*ServiceId
- func (m *ServiceMetadataResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceMetadataResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceMetadataResponse) ProtoMessage()
- func (m *ServiceMetadataResponse) Reset()
- func (m *ServiceMetadataResponse) Size() (n int)
- func (m *ServiceMetadataResponse) String() string
- func (m *ServiceMetadataResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceMetadataResponse) XXX_DiscardUnknown()
- func (m *ServiceMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceMetadataResponse) XXX_Merge(src proto.Message)
- func (m *ServiceMetadataResponse) XXX_Size() int
- func (m *ServiceMetadataResponse) XXX_Unmarshal(b []byte) error
- type ServiceOperationRequest
- func (*ServiceOperationRequest) Descriptor() ([]byte, []int)
- func (m *ServiceOperationRequest) GetMethod() string
- func (m *ServiceOperationRequest) GetValue() []byte
- func (m *ServiceOperationRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceOperationRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceOperationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceOperationRequest) ProtoMessage()
- func (m *ServiceOperationRequest) Reset()
- func (m *ServiceOperationRequest) Size() (n int)
- func (m *ServiceOperationRequest) String() string
- func (m *ServiceOperationRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceOperationRequest) XXX_DiscardUnknown()
- func (m *ServiceOperationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceOperationRequest) XXX_Merge(src proto.Message)
- func (m *ServiceOperationRequest) XXX_Size() int
- func (m *ServiceOperationRequest) XXX_Unmarshal(b []byte) error
- type ServiceOperationResponse
- func (*ServiceOperationResponse) Descriptor() ([]byte, []int)
- func (m *ServiceOperationResponse) GetResult() []byte
- func (m *ServiceOperationResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceOperationResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceOperationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceOperationResponse) ProtoMessage()
- func (m *ServiceOperationResponse) Reset()
- func (m *ServiceOperationResponse) Size() (n int)
- func (m *ServiceOperationResponse) String() string
- func (m *ServiceOperationResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceOperationResponse) XXX_DiscardUnknown()
- func (m *ServiceOperationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceOperationResponse) XXX_Merge(src proto.Message)
- func (m *ServiceOperationResponse) XXX_Size() int
- func (m *ServiceOperationResponse) XXX_Unmarshal(b []byte) error
- type ServiceQueryRequest
- func (*ServiceQueryRequest) Descriptor() ([]byte, []int)
- func (m *ServiceQueryRequest) GetMetadata() *ServiceMetadataRequest
- func (m *ServiceQueryRequest) GetOperation() *ServiceOperationRequest
- func (m *ServiceQueryRequest) GetRequest() isServiceQueryRequest_Request
- func (m *ServiceQueryRequest) GetService() *ServiceId
- func (m *ServiceQueryRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceQueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceQueryRequest) ProtoMessage()
- func (m *ServiceQueryRequest) Reset()
- func (m *ServiceQueryRequest) Size() (n int)
- func (m *ServiceQueryRequest) String() string
- func (m *ServiceQueryRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceQueryRequest) XXX_DiscardUnknown()
- func (m *ServiceQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceQueryRequest) XXX_Merge(src proto.Message)
- func (*ServiceQueryRequest) XXX_OneofWrappers() []interface{}
- func (m *ServiceQueryRequest) XXX_Size() int
- func (m *ServiceQueryRequest) XXX_Unmarshal(b []byte) error
- type ServiceQueryRequest_Metadata
- type ServiceQueryRequest_Operation
- type ServiceQueryResponse
- func (*ServiceQueryResponse) Descriptor() ([]byte, []int)
- func (m *ServiceQueryResponse) GetMetadata() *ServiceMetadataResponse
- func (m *ServiceQueryResponse) GetOperation() *ServiceOperationResponse
- func (m *ServiceQueryResponse) GetResponse() isServiceQueryResponse_Response
- func (m *ServiceQueryResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceQueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceQueryResponse) ProtoMessage()
- func (m *ServiceQueryResponse) Reset()
- func (m *ServiceQueryResponse) Size() (n int)
- func (m *ServiceQueryResponse) String() string
- func (m *ServiceQueryResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceQueryResponse) XXX_DiscardUnknown()
- func (m *ServiceQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceQueryResponse) XXX_Merge(src proto.Message)
- func (*ServiceQueryResponse) XXX_OneofWrappers() []interface{}
- func (m *ServiceQueryResponse) XXX_Size() int
- func (m *ServiceQueryResponse) XXX_Unmarshal(b []byte) error
- type ServiceQueryResponse_Metadata
- type ServiceQueryResponse_Operation
- type ServiceType
- type Session
- type SessionClosedService
- type SessionCommandContext
- func (*SessionCommandContext) Descriptor() ([]byte, []int)
- func (m *SessionCommandContext) GetSequenceNumber() uint64
- func (m *SessionCommandContext) GetSessionID() uint64
- func (m *SessionCommandContext) Marshal() (dAtA []byte, err error)
- func (m *SessionCommandContext) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionCommandContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionCommandContext) ProtoMessage()
- func (m *SessionCommandContext) Reset()
- func (m *SessionCommandContext) Size() (n int)
- func (m *SessionCommandContext) String() string
- func (m *SessionCommandContext) Unmarshal(dAtA []byte) error
- func (m *SessionCommandContext) XXX_DiscardUnknown()
- func (m *SessionCommandContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionCommandContext) XXX_Merge(src proto.Message)
- func (m *SessionCommandContext) XXX_Size() int
- func (m *SessionCommandContext) XXX_Unmarshal(b []byte) error
- type SessionCommandRequest
- func (*SessionCommandRequest) Descriptor() ([]byte, []int)
- func (m *SessionCommandRequest) GetCommand() *ServiceCommandRequest
- func (m *SessionCommandRequest) GetContext() *SessionCommandContext
- func (m *SessionCommandRequest) Marshal() (dAtA []byte, err error)
- func (m *SessionCommandRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionCommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionCommandRequest) ProtoMessage()
- func (m *SessionCommandRequest) Reset()
- func (m *SessionCommandRequest) Size() (n int)
- func (m *SessionCommandRequest) String() string
- func (m *SessionCommandRequest) Unmarshal(dAtA []byte) error
- func (m *SessionCommandRequest) XXX_DiscardUnknown()
- func (m *SessionCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionCommandRequest) XXX_Merge(src proto.Message)
- func (m *SessionCommandRequest) XXX_Size() int
- func (m *SessionCommandRequest) XXX_Unmarshal(b []byte) error
- type SessionCommandResponse
- func (*SessionCommandResponse) Descriptor() ([]byte, []int)
- func (m *SessionCommandResponse) GetContext() *SessionResponseContext
- func (m *SessionCommandResponse) GetResponse() *ServiceCommandResponse
- func (m *SessionCommandResponse) Marshal() (dAtA []byte, err error)
- func (m *SessionCommandResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionCommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionCommandResponse) ProtoMessage()
- func (m *SessionCommandResponse) Reset()
- func (m *SessionCommandResponse) Size() (n int)
- func (m *SessionCommandResponse) String() string
- func (m *SessionCommandResponse) Unmarshal(dAtA []byte) error
- func (m *SessionCommandResponse) XXX_DiscardUnknown()
- func (m *SessionCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionCommandResponse) XXX_Merge(src proto.Message)
- func (m *SessionCommandResponse) XXX_Size() int
- func (m *SessionCommandResponse) XXX_Unmarshal(b []byte) error
- type SessionExpiredService
- type SessionID
- type SessionOpenService
- type SessionOutput
- type SessionQueryContext
- func (*SessionQueryContext) Descriptor() ([]byte, []int)
- func (m *SessionQueryContext) GetLastIndex() uint64
- func (m *SessionQueryContext) GetLastSequenceNumber() uint64
- func (m *SessionQueryContext) GetSessionID() uint64
- func (m *SessionQueryContext) Marshal() (dAtA []byte, err error)
- func (m *SessionQueryContext) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionQueryContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionQueryContext) ProtoMessage()
- func (m *SessionQueryContext) Reset()
- func (m *SessionQueryContext) Size() (n int)
- func (m *SessionQueryContext) String() string
- func (m *SessionQueryContext) Unmarshal(dAtA []byte) error
- func (m *SessionQueryContext) XXX_DiscardUnknown()
- func (m *SessionQueryContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionQueryContext) XXX_Merge(src proto.Message)
- func (m *SessionQueryContext) XXX_Size() int
- func (m *SessionQueryContext) XXX_Unmarshal(b []byte) error
- type SessionQueryRequest
- func (*SessionQueryRequest) Descriptor() ([]byte, []int)
- func (m *SessionQueryRequest) GetContext() *SessionQueryContext
- func (m *SessionQueryRequest) GetQuery() *ServiceQueryRequest
- func (m *SessionQueryRequest) Marshal() (dAtA []byte, err error)
- func (m *SessionQueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionQueryRequest) ProtoMessage()
- func (m *SessionQueryRequest) Reset()
- func (m *SessionQueryRequest) Size() (n int)
- func (m *SessionQueryRequest) String() string
- func (m *SessionQueryRequest) Unmarshal(dAtA []byte) error
- func (m *SessionQueryRequest) XXX_DiscardUnknown()
- func (m *SessionQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionQueryRequest) XXX_Merge(src proto.Message)
- func (m *SessionQueryRequest) XXX_Size() int
- func (m *SessionQueryRequest) XXX_Unmarshal(b []byte) error
- type SessionQueryResponse
- func (*SessionQueryResponse) Descriptor() ([]byte, []int)
- func (m *SessionQueryResponse) GetContext() *SessionResponseContext
- func (m *SessionQueryResponse) GetResponse() *ServiceQueryResponse
- func (m *SessionQueryResponse) Marshal() (dAtA []byte, err error)
- func (m *SessionQueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionQueryResponse) ProtoMessage()
- func (m *SessionQueryResponse) Reset()
- func (m *SessionQueryResponse) Size() (n int)
- func (m *SessionQueryResponse) String() string
- func (m *SessionQueryResponse) Unmarshal(dAtA []byte) error
- func (m *SessionQueryResponse) XXX_DiscardUnknown()
- func (m *SessionQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionQueryResponse) XXX_Merge(src proto.Message)
- func (m *SessionQueryResponse) XXX_Size() int
- func (m *SessionQueryResponse) XXX_Unmarshal(b []byte) error
- type SessionRequest
- func (*SessionRequest) Descriptor() ([]byte, []int)
- func (m *SessionRequest) GetCloseSession() *CloseSessionRequest
- func (m *SessionRequest) GetCommand() *SessionCommandRequest
- func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest
- func (m *SessionRequest) GetOpenSession() *OpenSessionRequest
- func (m *SessionRequest) GetQuery() *SessionQueryRequest
- func (m *SessionRequest) GetRequest() isSessionRequest_Request
- func (m *SessionRequest) Marshal() (dAtA []byte, err error)
- func (m *SessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionRequest) ProtoMessage()
- func (m *SessionRequest) Reset()
- func (m *SessionRequest) Size() (n int)
- func (m *SessionRequest) String() string
- func (m *SessionRequest) Unmarshal(dAtA []byte) error
- func (m *SessionRequest) XXX_DiscardUnknown()
- func (m *SessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionRequest) XXX_Merge(src proto.Message)
- func (*SessionRequest) XXX_OneofWrappers() []interface{}
- func (m *SessionRequest) XXX_Size() int
- func (m *SessionRequest) XXX_Unmarshal(b []byte) error
- type SessionRequest_CloseSession
- type SessionRequest_Command
- type SessionRequest_KeepAlive
- type SessionRequest_OpenSession
- type SessionRequest_Query
- type SessionResponse
- func (*SessionResponse) Descriptor() ([]byte, []int)
- func (m *SessionResponse) GetCloseSession() *CloseSessionResponse
- func (m *SessionResponse) GetCommand() *SessionCommandResponse
- func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse
- func (m *SessionResponse) GetOpenSession() *OpenSessionResponse
- func (m *SessionResponse) GetQuery() *SessionQueryResponse
- func (m *SessionResponse) GetResponse() isSessionResponse_Response
- func (m *SessionResponse) Marshal() (dAtA []byte, err error)
- func (m *SessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionResponse) ProtoMessage()
- func (m *SessionResponse) Reset()
- func (m *SessionResponse) Size() (n int)
- func (m *SessionResponse) String() string
- func (m *SessionResponse) Unmarshal(dAtA []byte) error
- func (m *SessionResponse) XXX_DiscardUnknown()
- func (m *SessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionResponse) XXX_Merge(src proto.Message)
- func (*SessionResponse) XXX_OneofWrappers() []interface{}
- func (m *SessionResponse) XXX_Size() int
- func (m *SessionResponse) XXX_Unmarshal(b []byte) error
- type SessionResponseContext
- func (*SessionResponseContext) Descriptor() ([]byte, []int)
- func (m *SessionResponseContext) GetIndex() uint64
- func (m *SessionResponseContext) GetMessage() string
- func (m *SessionResponseContext) GetSequence() uint64
- func (m *SessionResponseContext) GetStatus() SessionResponseStatus
- func (m *SessionResponseContext) GetStreamID() uint64
- func (m *SessionResponseContext) GetType() SessionResponseType
- func (m *SessionResponseContext) Marshal() (dAtA []byte, err error)
- func (m *SessionResponseContext) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionResponseContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionResponseContext) ProtoMessage()
- func (m *SessionResponseContext) Reset()
- func (m *SessionResponseContext) Size() (n int)
- func (m *SessionResponseContext) String() string
- func (m *SessionResponseContext) Unmarshal(dAtA []byte) error
- func (m *SessionResponseContext) XXX_DiscardUnknown()
- func (m *SessionResponseContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionResponseContext) XXX_Merge(src proto.Message)
- func (m *SessionResponseContext) XXX_Size() int
- func (m *SessionResponseContext) XXX_Unmarshal(b []byte) error
- type SessionResponseStatus
- type SessionResponseType
- type SessionResponse_CloseSession
- type SessionResponse_Command
- type SessionResponse_KeepAlive
- type SessionResponse_OpenSession
- type SessionResponse_Query
- type SessionServer
- func (s *SessionServer) CloseSession(ctx context.Context, request *api.CloseSessionRequest) (*api.CloseSessionResponse, error)
- func (s *SessionServer) KeepAlive(ctx context.Context, request *api.KeepAliveRequest) (*api.KeepAliveResponse, error)
- func (s *SessionServer) OpenSession(ctx context.Context, request *api.OpenSessionRequest) (*api.OpenSessionResponse, error)
- type SessionServiceSnapshot
- func (*SessionServiceSnapshot) Descriptor() ([]byte, []int)
- func (m *SessionServiceSnapshot) GetServiceId() ServiceId
- func (m *SessionServiceSnapshot) GetStreams() []*SessionStreamSnapshot
- func (m *SessionServiceSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SessionServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionServiceSnapshot) ProtoMessage()
- func (m *SessionServiceSnapshot) Reset()
- func (m *SessionServiceSnapshot) Size() (n int)
- func (m *SessionServiceSnapshot) String() string
- func (m *SessionServiceSnapshot) Unmarshal(dAtA []byte) error
- func (m *SessionServiceSnapshot) XXX_DiscardUnknown()
- func (m *SessionServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionServiceSnapshot) XXX_Merge(src proto.Message)
- func (m *SessionServiceSnapshot) XXX_Size() int
- func (m *SessionServiceSnapshot) XXX_Unmarshal(b []byte) error
- type SessionSnapshot
- func (*SessionSnapshot) Descriptor() ([]byte, []int)
- func (m *SessionSnapshot) GetCommandSequence() uint64
- func (m *SessionSnapshot) GetServices() []*SessionServiceSnapshot
- func (m *SessionSnapshot) GetSessionID() uint64
- func (m *SessionSnapshot) GetTimeout() time.Duration
- func (m *SessionSnapshot) GetTimestamp() time.Time
- func (m *SessionSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SessionSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionSnapshot) ProtoMessage()
- func (m *SessionSnapshot) Reset()
- func (m *SessionSnapshot) Size() (n int)
- func (m *SessionSnapshot) String() string
- func (m *SessionSnapshot) Unmarshal(dAtA []byte) error
- func (m *SessionSnapshot) XXX_DiscardUnknown()
- func (m *SessionSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionSnapshot) XXX_Merge(src proto.Message)
- func (m *SessionSnapshot) XXX_Size() int
- func (m *SessionSnapshot) XXX_Unmarshal(b []byte) error
- type SessionStreamSnapshot
- func (*SessionStreamSnapshot) Descriptor() ([]byte, []int)
- func (m *SessionStreamSnapshot) GetLastCompleted() uint64
- func (m *SessionStreamSnapshot) GetSequenceNumber() uint64
- func (m *SessionStreamSnapshot) GetStreamId() uint64
- func (m *SessionStreamSnapshot) GetType() string
- func (m *SessionStreamSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SessionStreamSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionStreamSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionStreamSnapshot) ProtoMessage()
- func (m *SessionStreamSnapshot) Reset()
- func (m *SessionStreamSnapshot) Size() (n int)
- func (m *SessionStreamSnapshot) String() string
- func (m *SessionStreamSnapshot) Unmarshal(dAtA []byte) error
- func (m *SessionStreamSnapshot) XXX_DiscardUnknown()
- func (m *SessionStreamSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionStreamSnapshot) XXX_Merge(src proto.Message)
- func (m *SessionStreamSnapshot) XXX_Size() int
- func (m *SessionStreamSnapshot) XXX_Unmarshal(b []byte) error
- type StateMachine
- type Stream
- type StreamID
- type StreamingOperation
- type Timer
- type UnaryOperation
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowService = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group") )
var ServiceType_name = map[int32]string{
0: "UNKNOWN_SERVICE",
1: "COUNTER",
2: "ELECTION",
3: "INDEXED_MAP",
4: "LEADER_LATCH",
5: "LIST",
6: "LOCK",
7: "LOG",
8: "MAP",
9: "SET",
10: "VALUE",
}
var ServiceType_value = map[string]int32{
"UNKNOWN_SERVICE": 0,
"COUNTER": 1,
"ELECTION": 2,
"INDEXED_MAP": 3,
"LEADER_LATCH": 4,
"LIST": 5,
"LOCK": 6,
"LOG": 7,
"MAP": 8,
"SET": 9,
"VALUE": 10,
}
var SessionResponseStatus_name = map[int32]string{
0: "OK",
1: "ERROR",
2: "NOT_LEADER",
3: "UNKNOWN",
4: "CANCELED",
5: "NOT_FOUND",
6: "ALREADY_EXISTS",
7: "UNAUTHORIZED",
8: "FORBIDDEN",
9: "CONFLICT",
10: "INVALID",
11: "UNAVAILABLE",
12: "NOT_SUPPORTED",
13: "TIMEOUT",
14: "INTERNAL",
}
var SessionResponseStatus_value = map[string]int32{
"OK": 0,
"ERROR": 1,
"NOT_LEADER": 2,
"UNKNOWN": 3,
"CANCELED": 4,
"NOT_FOUND": 5,
"ALREADY_EXISTS": 6,
"UNAUTHORIZED": 7,
"FORBIDDEN": 8,
"CONFLICT": 9,
"INVALID": 10,
"UNAVAILABLE": 11,
"NOT_SUPPORTED": 12,
"TIMEOUT": 13,
"INTERNAL": 14,
}
var SessionResponseType_name = map[int32]string{
0: "RESPONSE",
1: "OPEN_STREAM",
2: "CLOSE_STREAM",
}
var SessionResponseType_value = map[string]int32{
"RESPONSE": 0,
"OPEN_STREAM": 1,
"CLOSE_STREAM": 2,
}
Functions ¶
This section is empty.
Types ¶
type BackupService ¶
type BackupService interface { // Backup is called to take a snapshot of the service state Backup(writer io.Writer) error }
BackupService is an interface for backing up a service
type CloseSessionRequest ¶
type CloseSessionRequest struct {
SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}
func (*CloseSessionRequest) Descriptor ¶
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
func (*CloseSessionRequest) GetSessionID ¶
func (m *CloseSessionRequest) GetSessionID() uint64
func (*CloseSessionRequest) Marshal ¶
func (m *CloseSessionRequest) Marshal() (dAtA []byte, err error)
func (*CloseSessionRequest) MarshalTo ¶
func (m *CloseSessionRequest) MarshalTo(dAtA []byte) (int, error)
func (*CloseSessionRequest) MarshalToSizedBuffer ¶
func (m *CloseSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) Reset ¶
func (m *CloseSessionRequest) Reset()
func (*CloseSessionRequest) Size ¶
func (m *CloseSessionRequest) Size() (n int)
func (*CloseSessionRequest) String ¶
func (m *CloseSessionRequest) String() string
func (*CloseSessionRequest) Unmarshal ¶
func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error
func (*CloseSessionRequest) XXX_DiscardUnknown ¶
func (m *CloseSessionRequest) XXX_DiscardUnknown()
func (*CloseSessionRequest) XXX_Marshal ¶
func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseSessionRequest) XXX_Merge ¶
func (m *CloseSessionRequest) XXX_Merge(src proto.Message)
func (*CloseSessionRequest) XXX_Size ¶
func (m *CloseSessionRequest) XXX_Size() int
func (*CloseSessionRequest) XXX_Unmarshal ¶
func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error
type CloseSessionResponse ¶
type CloseSessionResponse struct { }
func (*CloseSessionResponse) Descriptor ¶
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
func (*CloseSessionResponse) Marshal ¶
func (m *CloseSessionResponse) Marshal() (dAtA []byte, err error)
func (*CloseSessionResponse) MarshalTo ¶
func (m *CloseSessionResponse) MarshalTo(dAtA []byte) (int, error)
func (*CloseSessionResponse) MarshalToSizedBuffer ¶
func (m *CloseSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) Reset ¶
func (m *CloseSessionResponse) Reset()
func (*CloseSessionResponse) Size ¶
func (m *CloseSessionResponse) Size() (n int)
func (*CloseSessionResponse) String ¶
func (m *CloseSessionResponse) String() string
func (*CloseSessionResponse) Unmarshal ¶
func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error
func (*CloseSessionResponse) XXX_DiscardUnknown ¶
func (m *CloseSessionResponse) XXX_DiscardUnknown()
func (*CloseSessionResponse) XXX_Marshal ¶
func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CloseSessionResponse) XXX_Merge ¶
func (m *CloseSessionResponse) XXX_Merge(src proto.Message)
func (*CloseSessionResponse) XXX_Size ¶
func (m *CloseSessionResponse) XXX_Size() int
func (*CloseSessionResponse) XXX_Unmarshal ¶
func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error
type Executor ¶
type Executor interface { // RegisterUnaryOperation registers a unary primitive operation RegisterUnaryOperation(id OperationID, callback func([]byte) ([]byte, error)) // RegisterStreamOperation registers a new primitive operation RegisterStreamOperation(id OperationID, callback func([]byte, Stream)) // GetOperation returns an operation by name GetOperation(id OperationID) Operation }
Executor executes primitive operations
type KeepAliveRequest ¶
type KeepAliveRequest struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` CommandSequence uint64 `protobuf:"varint,2,opt,name=command_sequence,json=commandSequence,proto3" json:"command_sequence,omitempty"` Streams map[uint64]uint64 `` /* 157-byte string literal not displayed */ }
func (*KeepAliveRequest) Descriptor ¶
func (*KeepAliveRequest) Descriptor() ([]byte, []int)
func (*KeepAliveRequest) GetCommandSequence ¶
func (m *KeepAliveRequest) GetCommandSequence() uint64
func (*KeepAliveRequest) GetSessionID ¶
func (m *KeepAliveRequest) GetSessionID() uint64
func (*KeepAliveRequest) GetStreams ¶
func (m *KeepAliveRequest) GetStreams() map[uint64]uint64
func (*KeepAliveRequest) Marshal ¶
func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
func (*KeepAliveRequest) MarshalToSizedBuffer ¶
func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeepAliveRequest) ProtoMessage ¶
func (*KeepAliveRequest) ProtoMessage()
func (*KeepAliveRequest) Reset ¶
func (m *KeepAliveRequest) Reset()
func (*KeepAliveRequest) Size ¶
func (m *KeepAliveRequest) Size() (n int)
func (*KeepAliveRequest) String ¶
func (m *KeepAliveRequest) String() string
func (*KeepAliveRequest) Unmarshal ¶
func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
func (*KeepAliveRequest) XXX_DiscardUnknown ¶
func (m *KeepAliveRequest) XXX_DiscardUnknown()
func (*KeepAliveRequest) XXX_Marshal ¶
func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepAliveRequest) XXX_Merge ¶
func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
func (*KeepAliveRequest) XXX_Size ¶
func (m *KeepAliveRequest) XXX_Size() int
func (*KeepAliveRequest) XXX_Unmarshal ¶
func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
type KeepAliveResponse ¶
type KeepAliveResponse struct { }
func (*KeepAliveResponse) Descriptor ¶
func (*KeepAliveResponse) Descriptor() ([]byte, []int)
func (*KeepAliveResponse) Marshal ¶
func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
func (*KeepAliveResponse) MarshalTo ¶
func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
func (*KeepAliveResponse) MarshalToSizedBuffer ¶
func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeepAliveResponse) ProtoMessage ¶
func (*KeepAliveResponse) ProtoMessage()
func (*KeepAliveResponse) Reset ¶
func (m *KeepAliveResponse) Reset()
func (*KeepAliveResponse) Size ¶
func (m *KeepAliveResponse) Size() (n int)
func (*KeepAliveResponse) String ¶
func (m *KeepAliveResponse) String() string
func (*KeepAliveResponse) Unmarshal ¶
func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
func (*KeepAliveResponse) XXX_DiscardUnknown ¶
func (m *KeepAliveResponse) XXX_DiscardUnknown()
func (*KeepAliveResponse) XXX_Marshal ¶
func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepAliveResponse) XXX_Merge ¶
func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
func (*KeepAliveResponse) XXX_Size ¶
func (m *KeepAliveResponse) XXX_Size() int
func (*KeepAliveResponse) XXX_Unmarshal ¶
func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager is a Manager implementation for primitives that support sessions
func NewManager ¶
func NewManager(registry Registry, context PartitionContext) *Manager
NewManager returns an initialized Manager
func (*Manager) Command ¶
func (m *Manager) Command(bytes []byte, stream streams.WriteStream)
Command handles a service command
type OpenSessionRequest ¶
type OpenSessionRequest struct {
Timeout *time.Duration `protobuf:"bytes,1,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}
func (*OpenSessionRequest) Descriptor ¶
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
func (*OpenSessionRequest) GetTimeout ¶
func (m *OpenSessionRequest) GetTimeout() *time.Duration
func (*OpenSessionRequest) Marshal ¶
func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
func (*OpenSessionRequest) MarshalTo ¶
func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
func (*OpenSessionRequest) MarshalToSizedBuffer ¶
func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) Reset ¶
func (m *OpenSessionRequest) Reset()
func (*OpenSessionRequest) Size ¶
func (m *OpenSessionRequest) Size() (n int)
func (*OpenSessionRequest) String ¶
func (m *OpenSessionRequest) String() string
func (*OpenSessionRequest) Unmarshal ¶
func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
func (*OpenSessionRequest) XXX_DiscardUnknown ¶
func (m *OpenSessionRequest) XXX_DiscardUnknown()
func (*OpenSessionRequest) XXX_Marshal ¶
func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenSessionRequest) XXX_Merge ¶
func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
func (*OpenSessionRequest) XXX_Size ¶
func (m *OpenSessionRequest) XXX_Size() int
func (*OpenSessionRequest) XXX_Unmarshal ¶
func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
type OpenSessionResponse ¶
type OpenSessionResponse struct {
SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}
func (*OpenSessionResponse) Descriptor ¶
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
func (*OpenSessionResponse) GetSessionID ¶
func (m *OpenSessionResponse) GetSessionID() uint64
func (*OpenSessionResponse) Marshal ¶
func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
func (*OpenSessionResponse) MarshalTo ¶
func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
func (*OpenSessionResponse) MarshalToSizedBuffer ¶
func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) Reset ¶
func (m *OpenSessionResponse) Reset()
func (*OpenSessionResponse) Size ¶
func (m *OpenSessionResponse) Size() (n int)
func (*OpenSessionResponse) String ¶
func (m *OpenSessionResponse) String() string
func (*OpenSessionResponse) Unmarshal ¶
func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
func (*OpenSessionResponse) XXX_DiscardUnknown ¶
func (m *OpenSessionResponse) XXX_DiscardUnknown()
func (*OpenSessionResponse) XXX_Marshal ¶
func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenSessionResponse) XXX_Merge ¶
func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
func (*OpenSessionResponse) XXX_Size ¶
func (m *OpenSessionResponse) XXX_Size() int
func (*OpenSessionResponse) XXX_Unmarshal ¶
func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
type Operation ¶
type Operation interface{}
Operation is the base interface for primitive operations
type Partition ¶
type Partition interface { // MustLeader returns whether the client can only be used on the leader MustLeader() bool // IsLeader returns whether the client is the leader IsLeader() bool // Leader returns the current leader Leader() string // Write sends a write request Write(ctx context.Context, input []byte, stream stream.WriteStream) error // Read sends a read request Read(ctx context.Context, input []byte, stream stream.WriteStream) error }
Partition is the interface for a partition client
type PartitionContext ¶
type PartitionContext interface { ProtocolContext // PartitionID is the partition identifier PartitionID() PartitionID // Index returns the current index of the service Index() Index // Timestamp returns a deterministic, monotonically increasing timestamp Timestamp() time.Time }
PartitionContext provides the current state of the partition
type Primitive ¶
type Primitive interface { // RegisterServer registers the primitive server with the gRPC server RegisterServer(server *grpc.Server, protocol Protocol) // NewService creates a new primitive service NewService(scheduler Scheduler, context ServiceContext) Service }
Primitive is a primitive type
type Protocol ¶
type Protocol interface { // Partition returns a partition Partition(partitionID PartitionID) Partition // Partitions returns the protocol partitions Partitions() []Partition // Start starts the protocol Start(cluster cluster.Cluster, registry Registry) error // Stop stops the protocol Stop() error }
Protocol is the interface to be implemented by replication protocols
type ProtocolContext ¶
type ProtocolContext interface { // NodeID is the local node identifier NodeID() string }
ProtocolContext provides the current state of the protocol
type Registry ¶
type Registry interface { // Register registers a primitive Register(primitiveType primitive.PrimitiveType, primitive Primitive) // GetPrimitives gets a list of primitives GetPrimitives() []Primitive // GetPrimitive gets a primitive by type GetPrimitive(primitiveType primitive.PrimitiveType) Primitive }
Registry is a primitive registry
type RestoreService ¶
type RestoreService interface { // Restore is called to restore the service state from a snapshot Restore(reader io.Reader) error }
RestoreService is an interface for restoring up a service
type Scheduler ¶
type Scheduler interface { // Execute executes a function asynchronously Execute(f func()) // ScheduleOnce schedules a function to be run once after the given delay ScheduleOnce(delay time.Duration, f func()) Timer // ScheduleRepeat schedules a function to run repeatedly every interval starting after the given delay ScheduleRepeat(delay time.Duration, interval time.Duration, f func()) Timer // ScheduleIndex schedules a function to run at a specific index ScheduleIndex(index Index, f func()) }
Scheduler provides deterministic scheduling for a state machine
type Server ¶
type Server struct { Protocol Protocol Type ServiceType }
Server is a base server for servers that support sessions
func (*Server) DoCloseService ¶
func (s *Server) DoCloseService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
DoCloseService closes the service
func (*Server) DoCloseSession ¶
func (s *Server) DoCloseSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
DoCloseSession closes a session
func (*Server) DoCommand ¶
func (s *Server) DoCommand(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
DoCommand submits a command to the service
func (*Server) DoCommandStream ¶
func (s *Server) DoCommandStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, stream streams.WriteStream) error
DoCommandStream submits a streaming command to the service
func (*Server) DoCreateService ¶
func (s *Server) DoCreateService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
DoCreateService creates the service
func (*Server) DoDeleteService ¶
func (s *Server) DoDeleteService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
DoDeleteService deletes the service
func (*Server) DoKeepAliveSession ¶
func (s *Server) DoKeepAliveSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
DoKeepAliveSession keeps a session alive
func (*Server) DoMetadata ¶
func (s *Server) DoMetadata(ctx context.Context, serviceType primitive.PrimitiveType, namespace string, header *headers.RequestHeader) ([]*ServiceId, *headers.ResponseHeader, error)
DoMetadata submits a metadata query to the service
func (*Server) DoOpenSession ¶
func (s *Server) DoOpenSession(ctx context.Context, header *headers.RequestHeader, timeout *time.Duration) (*headers.ResponseHeader, error)
DoOpenSession opens a new session
func (*Server) DoQuery ¶
func (s *Server) DoQuery(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
DoQuery submits a query to the service
func (*Server) DoQueryStream ¶
func (s *Server) DoQueryStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, stream streams.WriteStream) error
DoQueryStream submits a streaming query to the service
type Service ¶
type Service interface { BackupService RestoreService Executor Scheduler // contains filtered or unexported methods }
Service is a primitive service
func NewService ¶
func NewService(scheduler Scheduler, context ServiceContext) Service
NewService creates a new primitive service
type ServiceCloseRequest ¶
type ServiceCloseRequest struct { }
func (*ServiceCloseRequest) Descriptor ¶
func (*ServiceCloseRequest) Descriptor() ([]byte, []int)
func (*ServiceCloseRequest) Marshal ¶
func (m *ServiceCloseRequest) Marshal() (dAtA []byte, err error)
func (*ServiceCloseRequest) MarshalTo ¶
func (m *ServiceCloseRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCloseRequest) MarshalToSizedBuffer ¶
func (m *ServiceCloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCloseRequest) ProtoMessage ¶
func (*ServiceCloseRequest) ProtoMessage()
func (*ServiceCloseRequest) Reset ¶
func (m *ServiceCloseRequest) Reset()
func (*ServiceCloseRequest) Size ¶
func (m *ServiceCloseRequest) Size() (n int)
func (*ServiceCloseRequest) String ¶
func (m *ServiceCloseRequest) String() string
func (*ServiceCloseRequest) Unmarshal ¶
func (m *ServiceCloseRequest) Unmarshal(dAtA []byte) error
func (*ServiceCloseRequest) XXX_DiscardUnknown ¶
func (m *ServiceCloseRequest) XXX_DiscardUnknown()
func (*ServiceCloseRequest) XXX_Marshal ¶
func (m *ServiceCloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceCloseRequest) XXX_Merge ¶
func (m *ServiceCloseRequest) XXX_Merge(src proto.Message)
func (*ServiceCloseRequest) XXX_Size ¶
func (m *ServiceCloseRequest) XXX_Size() int
func (*ServiceCloseRequest) XXX_Unmarshal ¶
func (m *ServiceCloseRequest) XXX_Unmarshal(b []byte) error
type ServiceCloseResponse ¶
type ServiceCloseResponse struct { }
func (*ServiceCloseResponse) Descriptor ¶
func (*ServiceCloseResponse) Descriptor() ([]byte, []int)
func (*ServiceCloseResponse) Marshal ¶
func (m *ServiceCloseResponse) Marshal() (dAtA []byte, err error)
func (*ServiceCloseResponse) MarshalTo ¶
func (m *ServiceCloseResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCloseResponse) MarshalToSizedBuffer ¶
func (m *ServiceCloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCloseResponse) ProtoMessage ¶
func (*ServiceCloseResponse) ProtoMessage()
func (*ServiceCloseResponse) Reset ¶
func (m *ServiceCloseResponse) Reset()
func (*ServiceCloseResponse) Size ¶
func (m *ServiceCloseResponse) Size() (n int)
func (*ServiceCloseResponse) String ¶
func (m *ServiceCloseResponse) String() string
func (*ServiceCloseResponse) Unmarshal ¶
func (m *ServiceCloseResponse) Unmarshal(dAtA []byte) error
func (*ServiceCloseResponse) XXX_DiscardUnknown ¶
func (m *ServiceCloseResponse) XXX_DiscardUnknown()
func (*ServiceCloseResponse) XXX_Marshal ¶
func (m *ServiceCloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceCloseResponse) XXX_Merge ¶
func (m *ServiceCloseResponse) XXX_Merge(src proto.Message)
func (*ServiceCloseResponse) XXX_Size ¶
func (m *ServiceCloseResponse) XXX_Size() int
func (*ServiceCloseResponse) XXX_Unmarshal ¶
func (m *ServiceCloseResponse) XXX_Unmarshal(b []byte) error
type ServiceCommandRequest ¶
type ServiceCommandRequest struct { Service *ServiceId `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // Types that are valid to be assigned to Request: // *ServiceCommandRequest_Operation // *ServiceCommandRequest_Create // *ServiceCommandRequest_Close // *ServiceCommandRequest_Delete Request isServiceCommandRequest_Request `protobuf_oneof:"request"` }
func (*ServiceCommandRequest) Descriptor ¶
func (*ServiceCommandRequest) Descriptor() ([]byte, []int)
func (*ServiceCommandRequest) GetClose ¶
func (m *ServiceCommandRequest) GetClose() *ServiceCloseRequest
func (*ServiceCommandRequest) GetCreate ¶
func (m *ServiceCommandRequest) GetCreate() *ServiceCreateRequest
func (*ServiceCommandRequest) GetDelete ¶
func (m *ServiceCommandRequest) GetDelete() *ServiceDeleteRequest
func (*ServiceCommandRequest) GetOperation ¶
func (m *ServiceCommandRequest) GetOperation() *ServiceOperationRequest
func (*ServiceCommandRequest) GetRequest ¶
func (m *ServiceCommandRequest) GetRequest() isServiceCommandRequest_Request
func (*ServiceCommandRequest) GetService ¶
func (m *ServiceCommandRequest) GetService() *ServiceId
func (*ServiceCommandRequest) Marshal ¶
func (m *ServiceCommandRequest) Marshal() (dAtA []byte, err error)
func (*ServiceCommandRequest) MarshalTo ¶
func (m *ServiceCommandRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandRequest) MarshalToSizedBuffer ¶
func (m *ServiceCommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandRequest) ProtoMessage ¶
func (*ServiceCommandRequest) ProtoMessage()
func (*ServiceCommandRequest) Reset ¶
func (m *ServiceCommandRequest) Reset()
func (*ServiceCommandRequest) Size ¶
func (m *ServiceCommandRequest) Size() (n int)
func (*ServiceCommandRequest) String ¶
func (m *ServiceCommandRequest) String() string
func (*ServiceCommandRequest) Unmarshal ¶
func (m *ServiceCommandRequest) Unmarshal(dAtA []byte) error
func (*ServiceCommandRequest) XXX_DiscardUnknown ¶
func (m *ServiceCommandRequest) XXX_DiscardUnknown()
func (*ServiceCommandRequest) XXX_Marshal ¶
func (m *ServiceCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceCommandRequest) XXX_Merge ¶
func (m *ServiceCommandRequest) XXX_Merge(src proto.Message)
func (*ServiceCommandRequest) XXX_OneofWrappers ¶
func (*ServiceCommandRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServiceCommandRequest) XXX_Size ¶
func (m *ServiceCommandRequest) XXX_Size() int
func (*ServiceCommandRequest) XXX_Unmarshal ¶
func (m *ServiceCommandRequest) XXX_Unmarshal(b []byte) error
type ServiceCommandRequest_Close ¶
type ServiceCommandRequest_Close struct {
Close *ServiceCloseRequest `protobuf:"bytes,4,opt,name=close,proto3,oneof" json:"close,omitempty"`
}
func (*ServiceCommandRequest_Close) MarshalTo ¶
func (m *ServiceCommandRequest_Close) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Close) MarshalToSizedBuffer ¶
func (m *ServiceCommandRequest_Close) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Close) Size ¶
func (m *ServiceCommandRequest_Close) Size() (n int)
type ServiceCommandRequest_Create ¶
type ServiceCommandRequest_Create struct {
Create *ServiceCreateRequest `protobuf:"bytes,3,opt,name=create,proto3,oneof" json:"create,omitempty"`
}
func (*ServiceCommandRequest_Create) MarshalTo ¶
func (m *ServiceCommandRequest_Create) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Create) MarshalToSizedBuffer ¶
func (m *ServiceCommandRequest_Create) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Create) Size ¶
func (m *ServiceCommandRequest_Create) Size() (n int)
type ServiceCommandRequest_Delete ¶
type ServiceCommandRequest_Delete struct {
Delete *ServiceDeleteRequest `protobuf:"bytes,5,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
}
func (*ServiceCommandRequest_Delete) MarshalTo ¶
func (m *ServiceCommandRequest_Delete) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Delete) MarshalToSizedBuffer ¶
func (m *ServiceCommandRequest_Delete) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Delete) Size ¶
func (m *ServiceCommandRequest_Delete) Size() (n int)
type ServiceCommandRequest_Operation ¶
type ServiceCommandRequest_Operation struct {
Operation *ServiceOperationRequest `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}
func (*ServiceCommandRequest_Operation) MarshalTo ¶
func (m *ServiceCommandRequest_Operation) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Operation) MarshalToSizedBuffer ¶
func (m *ServiceCommandRequest_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandRequest_Operation) Size ¶
func (m *ServiceCommandRequest_Operation) Size() (n int)
type ServiceCommandResponse ¶
type ServiceCommandResponse struct { // Types that are valid to be assigned to Response: // *ServiceCommandResponse_Operation // *ServiceCommandResponse_Create // *ServiceCommandResponse_Close // *ServiceCommandResponse_Delete Response isServiceCommandResponse_Response `protobuf_oneof:"response"` }
func (*ServiceCommandResponse) Descriptor ¶
func (*ServiceCommandResponse) Descriptor() ([]byte, []int)
func (*ServiceCommandResponse) GetClose ¶
func (m *ServiceCommandResponse) GetClose() *ServiceCloseResponse
func (*ServiceCommandResponse) GetCreate ¶
func (m *ServiceCommandResponse) GetCreate() *ServiceCreateResponse
func (*ServiceCommandResponse) GetDelete ¶
func (m *ServiceCommandResponse) GetDelete() *ServiceDeleteResponse
func (*ServiceCommandResponse) GetOperation ¶
func (m *ServiceCommandResponse) GetOperation() *ServiceOperationResponse
func (*ServiceCommandResponse) GetResponse ¶
func (m *ServiceCommandResponse) GetResponse() isServiceCommandResponse_Response
func (*ServiceCommandResponse) Marshal ¶
func (m *ServiceCommandResponse) Marshal() (dAtA []byte, err error)
func (*ServiceCommandResponse) MarshalTo ¶
func (m *ServiceCommandResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandResponse) MarshalToSizedBuffer ¶
func (m *ServiceCommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandResponse) ProtoMessage ¶
func (*ServiceCommandResponse) ProtoMessage()
func (*ServiceCommandResponse) Reset ¶
func (m *ServiceCommandResponse) Reset()
func (*ServiceCommandResponse) Size ¶
func (m *ServiceCommandResponse) Size() (n int)
func (*ServiceCommandResponse) String ¶
func (m *ServiceCommandResponse) String() string
func (*ServiceCommandResponse) Unmarshal ¶
func (m *ServiceCommandResponse) Unmarshal(dAtA []byte) error
func (*ServiceCommandResponse) XXX_DiscardUnknown ¶
func (m *ServiceCommandResponse) XXX_DiscardUnknown()
func (*ServiceCommandResponse) XXX_Marshal ¶
func (m *ServiceCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceCommandResponse) XXX_Merge ¶
func (m *ServiceCommandResponse) XXX_Merge(src proto.Message)
func (*ServiceCommandResponse) XXX_OneofWrappers ¶
func (*ServiceCommandResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServiceCommandResponse) XXX_Size ¶
func (m *ServiceCommandResponse) XXX_Size() int
func (*ServiceCommandResponse) XXX_Unmarshal ¶
func (m *ServiceCommandResponse) XXX_Unmarshal(b []byte) error
type ServiceCommandResponse_Close ¶
type ServiceCommandResponse_Close struct {
Close *ServiceCloseResponse `protobuf:"bytes,3,opt,name=close,proto3,oneof" json:"close,omitempty"`
}
func (*ServiceCommandResponse_Close) MarshalTo ¶
func (m *ServiceCommandResponse_Close) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Close) MarshalToSizedBuffer ¶
func (m *ServiceCommandResponse_Close) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Close) Size ¶
func (m *ServiceCommandResponse_Close) Size() (n int)
type ServiceCommandResponse_Create ¶
type ServiceCommandResponse_Create struct {
Create *ServiceCreateResponse `protobuf:"bytes,2,opt,name=create,proto3,oneof" json:"create,omitempty"`
}
func (*ServiceCommandResponse_Create) MarshalTo ¶
func (m *ServiceCommandResponse_Create) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Create) MarshalToSizedBuffer ¶
func (m *ServiceCommandResponse_Create) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Create) Size ¶
func (m *ServiceCommandResponse_Create) Size() (n int)
type ServiceCommandResponse_Delete ¶
type ServiceCommandResponse_Delete struct {
Delete *ServiceDeleteResponse `protobuf:"bytes,4,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
}
func (*ServiceCommandResponse_Delete) MarshalTo ¶
func (m *ServiceCommandResponse_Delete) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Delete) MarshalToSizedBuffer ¶
func (m *ServiceCommandResponse_Delete) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Delete) Size ¶
func (m *ServiceCommandResponse_Delete) Size() (n int)
type ServiceCommandResponse_Operation ¶
type ServiceCommandResponse_Operation struct {
Operation *ServiceOperationResponse `protobuf:"bytes,1,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}
func (*ServiceCommandResponse_Operation) MarshalTo ¶
func (m *ServiceCommandResponse_Operation) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Operation) MarshalToSizedBuffer ¶
func (m *ServiceCommandResponse_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCommandResponse_Operation) Size ¶
func (m *ServiceCommandResponse_Operation) Size() (n int)
type ServiceContext ¶
type ServiceContext interface { PartitionContext // ServiceID is the service identifier ServiceID() ServiceID // ServiceType returns the service type ServiceType() ServiceType // CurrentOperation returns the current operation identifier CurrentOperation() OperationID // CurrentSession returns the current session CurrentSession() Session // Session returns the session with the given identifier Session(id SessionID) Session // Sessions returns a list of open sessions Sessions() []Session }
ServiceContext provides information about the context within which a service is running
type ServiceCreateRequest ¶
type ServiceCreateRequest struct { }
func (*ServiceCreateRequest) Descriptor ¶
func (*ServiceCreateRequest) Descriptor() ([]byte, []int)
func (*ServiceCreateRequest) Marshal ¶
func (m *ServiceCreateRequest) Marshal() (dAtA []byte, err error)
func (*ServiceCreateRequest) MarshalTo ¶
func (m *ServiceCreateRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCreateRequest) MarshalToSizedBuffer ¶
func (m *ServiceCreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCreateRequest) ProtoMessage ¶
func (*ServiceCreateRequest) ProtoMessage()
func (*ServiceCreateRequest) Reset ¶
func (m *ServiceCreateRequest) Reset()
func (*ServiceCreateRequest) Size ¶
func (m *ServiceCreateRequest) Size() (n int)
func (*ServiceCreateRequest) String ¶
func (m *ServiceCreateRequest) String() string
func (*ServiceCreateRequest) Unmarshal ¶
func (m *ServiceCreateRequest) Unmarshal(dAtA []byte) error
func (*ServiceCreateRequest) XXX_DiscardUnknown ¶
func (m *ServiceCreateRequest) XXX_DiscardUnknown()
func (*ServiceCreateRequest) XXX_Marshal ¶
func (m *ServiceCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceCreateRequest) XXX_Merge ¶
func (m *ServiceCreateRequest) XXX_Merge(src proto.Message)
func (*ServiceCreateRequest) XXX_Size ¶
func (m *ServiceCreateRequest) XXX_Size() int
func (*ServiceCreateRequest) XXX_Unmarshal ¶
func (m *ServiceCreateRequest) XXX_Unmarshal(b []byte) error
type ServiceCreateResponse ¶
type ServiceCreateResponse struct { }
func (*ServiceCreateResponse) Descriptor ¶
func (*ServiceCreateResponse) Descriptor() ([]byte, []int)
func (*ServiceCreateResponse) Marshal ¶
func (m *ServiceCreateResponse) Marshal() (dAtA []byte, err error)
func (*ServiceCreateResponse) MarshalTo ¶
func (m *ServiceCreateResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceCreateResponse) MarshalToSizedBuffer ¶
func (m *ServiceCreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceCreateResponse) ProtoMessage ¶
func (*ServiceCreateResponse) ProtoMessage()
func (*ServiceCreateResponse) Reset ¶
func (m *ServiceCreateResponse) Reset()
func (*ServiceCreateResponse) Size ¶
func (m *ServiceCreateResponse) Size() (n int)
func (*ServiceCreateResponse) String ¶
func (m *ServiceCreateResponse) String() string
func (*ServiceCreateResponse) Unmarshal ¶
func (m *ServiceCreateResponse) Unmarshal(dAtA []byte) error
func (*ServiceCreateResponse) XXX_DiscardUnknown ¶
func (m *ServiceCreateResponse) XXX_DiscardUnknown()
func (*ServiceCreateResponse) XXX_Marshal ¶
func (m *ServiceCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceCreateResponse) XXX_Merge ¶
func (m *ServiceCreateResponse) XXX_Merge(src proto.Message)
func (*ServiceCreateResponse) XXX_Size ¶
func (m *ServiceCreateResponse) XXX_Size() int
func (*ServiceCreateResponse) XXX_Unmarshal ¶
func (m *ServiceCreateResponse) XXX_Unmarshal(b []byte) error
type ServiceDeleteRequest ¶
type ServiceDeleteRequest struct { }
func (*ServiceDeleteRequest) Descriptor ¶
func (*ServiceDeleteRequest) Descriptor() ([]byte, []int)
func (*ServiceDeleteRequest) Marshal ¶
func (m *ServiceDeleteRequest) Marshal() (dAtA []byte, err error)
func (*ServiceDeleteRequest) MarshalTo ¶
func (m *ServiceDeleteRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceDeleteRequest) MarshalToSizedBuffer ¶
func (m *ServiceDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceDeleteRequest) ProtoMessage ¶
func (*ServiceDeleteRequest) ProtoMessage()
func (*ServiceDeleteRequest) Reset ¶
func (m *ServiceDeleteRequest) Reset()
func (*ServiceDeleteRequest) Size ¶
func (m *ServiceDeleteRequest) Size() (n int)
func (*ServiceDeleteRequest) String ¶
func (m *ServiceDeleteRequest) String() string
func (*ServiceDeleteRequest) Unmarshal ¶
func (m *ServiceDeleteRequest) Unmarshal(dAtA []byte) error
func (*ServiceDeleteRequest) XXX_DiscardUnknown ¶
func (m *ServiceDeleteRequest) XXX_DiscardUnknown()
func (*ServiceDeleteRequest) XXX_Marshal ¶
func (m *ServiceDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceDeleteRequest) XXX_Merge ¶
func (m *ServiceDeleteRequest) XXX_Merge(src proto.Message)
func (*ServiceDeleteRequest) XXX_Size ¶
func (m *ServiceDeleteRequest) XXX_Size() int
func (*ServiceDeleteRequest) XXX_Unmarshal ¶
func (m *ServiceDeleteRequest) XXX_Unmarshal(b []byte) error
type ServiceDeleteResponse ¶
type ServiceDeleteResponse struct { }
func (*ServiceDeleteResponse) Descriptor ¶
func (*ServiceDeleteResponse) Descriptor() ([]byte, []int)
func (*ServiceDeleteResponse) Marshal ¶
func (m *ServiceDeleteResponse) Marshal() (dAtA []byte, err error)
func (*ServiceDeleteResponse) MarshalTo ¶
func (m *ServiceDeleteResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceDeleteResponse) MarshalToSizedBuffer ¶
func (m *ServiceDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceDeleteResponse) ProtoMessage ¶
func (*ServiceDeleteResponse) ProtoMessage()
func (*ServiceDeleteResponse) Reset ¶
func (m *ServiceDeleteResponse) Reset()
func (*ServiceDeleteResponse) Size ¶
func (m *ServiceDeleteResponse) Size() (n int)
func (*ServiceDeleteResponse) String ¶
func (m *ServiceDeleteResponse) String() string
func (*ServiceDeleteResponse) Unmarshal ¶
func (m *ServiceDeleteResponse) Unmarshal(dAtA []byte) error
func (*ServiceDeleteResponse) XXX_DiscardUnknown ¶
func (m *ServiceDeleteResponse) XXX_DiscardUnknown()
func (*ServiceDeleteResponse) XXX_Marshal ¶
func (m *ServiceDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceDeleteResponse) XXX_Merge ¶
func (m *ServiceDeleteResponse) XXX_Merge(src proto.Message)
func (*ServiceDeleteResponse) XXX_Size ¶
func (m *ServiceDeleteResponse) XXX_Size() int
func (*ServiceDeleteResponse) XXX_Unmarshal ¶
func (m *ServiceDeleteResponse) XXX_Unmarshal(b []byte) error
type ServiceId ¶
type ServiceId struct { Type ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.ServiceType" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` }
func (*ServiceId) Descriptor ¶
func (*ServiceId) GetNamespace ¶
func (*ServiceId) GetType ¶
func (m *ServiceId) GetType() ServiceType
func (*ServiceId) MarshalToSizedBuffer ¶
func (*ServiceId) ProtoMessage ¶
func (*ServiceId) ProtoMessage()
func (*ServiceId) XXX_DiscardUnknown ¶
func (m *ServiceId) XXX_DiscardUnknown()
func (*ServiceId) XXX_Marshal ¶
func (*ServiceId) XXX_Unmarshal ¶
type ServiceMetadataRequest ¶
type ServiceMetadataRequest struct { Type ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.ServiceType" json:"type,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` }
func (*ServiceMetadataRequest) Descriptor ¶
func (*ServiceMetadataRequest) Descriptor() ([]byte, []int)
func (*ServiceMetadataRequest) GetNamespace ¶
func (m *ServiceMetadataRequest) GetNamespace() string
func (*ServiceMetadataRequest) GetType ¶
func (m *ServiceMetadataRequest) GetType() ServiceType
func (*ServiceMetadataRequest) Marshal ¶
func (m *ServiceMetadataRequest) Marshal() (dAtA []byte, err error)
func (*ServiceMetadataRequest) MarshalTo ¶
func (m *ServiceMetadataRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceMetadataRequest) MarshalToSizedBuffer ¶
func (m *ServiceMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceMetadataRequest) ProtoMessage ¶
func (*ServiceMetadataRequest) ProtoMessage()
func (*ServiceMetadataRequest) Reset ¶
func (m *ServiceMetadataRequest) Reset()
func (*ServiceMetadataRequest) Size ¶
func (m *ServiceMetadataRequest) Size() (n int)
func (*ServiceMetadataRequest) String ¶
func (m *ServiceMetadataRequest) String() string
func (*ServiceMetadataRequest) Unmarshal ¶
func (m *ServiceMetadataRequest) Unmarshal(dAtA []byte) error
func (*ServiceMetadataRequest) XXX_DiscardUnknown ¶
func (m *ServiceMetadataRequest) XXX_DiscardUnknown()
func (*ServiceMetadataRequest) XXX_Marshal ¶
func (m *ServiceMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceMetadataRequest) XXX_Merge ¶
func (m *ServiceMetadataRequest) XXX_Merge(src proto.Message)
func (*ServiceMetadataRequest) XXX_Size ¶
func (m *ServiceMetadataRequest) XXX_Size() int
func (*ServiceMetadataRequest) XXX_Unmarshal ¶
func (m *ServiceMetadataRequest) XXX_Unmarshal(b []byte) error
type ServiceMetadataResponse ¶
type ServiceMetadataResponse struct {
Services []*ServiceId `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}
func (*ServiceMetadataResponse) Descriptor ¶
func (*ServiceMetadataResponse) Descriptor() ([]byte, []int)
func (*ServiceMetadataResponse) GetServices ¶
func (m *ServiceMetadataResponse) GetServices() []*ServiceId
func (*ServiceMetadataResponse) Marshal ¶
func (m *ServiceMetadataResponse) Marshal() (dAtA []byte, err error)
func (*ServiceMetadataResponse) MarshalTo ¶
func (m *ServiceMetadataResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceMetadataResponse) MarshalToSizedBuffer ¶
func (m *ServiceMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceMetadataResponse) ProtoMessage ¶
func (*ServiceMetadataResponse) ProtoMessage()
func (*ServiceMetadataResponse) Reset ¶
func (m *ServiceMetadataResponse) Reset()
func (*ServiceMetadataResponse) Size ¶
func (m *ServiceMetadataResponse) Size() (n int)
func (*ServiceMetadataResponse) String ¶
func (m *ServiceMetadataResponse) String() string
func (*ServiceMetadataResponse) Unmarshal ¶
func (m *ServiceMetadataResponse) Unmarshal(dAtA []byte) error
func (*ServiceMetadataResponse) XXX_DiscardUnknown ¶
func (m *ServiceMetadataResponse) XXX_DiscardUnknown()
func (*ServiceMetadataResponse) XXX_Marshal ¶
func (m *ServiceMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceMetadataResponse) XXX_Merge ¶
func (m *ServiceMetadataResponse) XXX_Merge(src proto.Message)
func (*ServiceMetadataResponse) XXX_Size ¶
func (m *ServiceMetadataResponse) XXX_Size() int
func (*ServiceMetadataResponse) XXX_Unmarshal ¶
func (m *ServiceMetadataResponse) XXX_Unmarshal(b []byte) error
type ServiceOperationRequest ¶
type ServiceOperationRequest struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*ServiceOperationRequest) Descriptor ¶
func (*ServiceOperationRequest) Descriptor() ([]byte, []int)
func (*ServiceOperationRequest) GetMethod ¶
func (m *ServiceOperationRequest) GetMethod() string
func (*ServiceOperationRequest) GetValue ¶
func (m *ServiceOperationRequest) GetValue() []byte
func (*ServiceOperationRequest) Marshal ¶
func (m *ServiceOperationRequest) Marshal() (dAtA []byte, err error)
func (*ServiceOperationRequest) MarshalTo ¶
func (m *ServiceOperationRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceOperationRequest) MarshalToSizedBuffer ¶
func (m *ServiceOperationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceOperationRequest) ProtoMessage ¶
func (*ServiceOperationRequest) ProtoMessage()
func (*ServiceOperationRequest) Reset ¶
func (m *ServiceOperationRequest) Reset()
func (*ServiceOperationRequest) Size ¶
func (m *ServiceOperationRequest) Size() (n int)
func (*ServiceOperationRequest) String ¶
func (m *ServiceOperationRequest) String() string
func (*ServiceOperationRequest) Unmarshal ¶
func (m *ServiceOperationRequest) Unmarshal(dAtA []byte) error
func (*ServiceOperationRequest) XXX_DiscardUnknown ¶
func (m *ServiceOperationRequest) XXX_DiscardUnknown()
func (*ServiceOperationRequest) XXX_Marshal ¶
func (m *ServiceOperationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceOperationRequest) XXX_Merge ¶
func (m *ServiceOperationRequest) XXX_Merge(src proto.Message)
func (*ServiceOperationRequest) XXX_Size ¶
func (m *ServiceOperationRequest) XXX_Size() int
func (*ServiceOperationRequest) XXX_Unmarshal ¶
func (m *ServiceOperationRequest) XXX_Unmarshal(b []byte) error
type ServiceOperationResponse ¶
type ServiceOperationResponse struct {
Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}
func (*ServiceOperationResponse) Descriptor ¶
func (*ServiceOperationResponse) Descriptor() ([]byte, []int)
func (*ServiceOperationResponse) GetResult ¶
func (m *ServiceOperationResponse) GetResult() []byte
func (*ServiceOperationResponse) Marshal ¶
func (m *ServiceOperationResponse) Marshal() (dAtA []byte, err error)
func (*ServiceOperationResponse) MarshalTo ¶
func (m *ServiceOperationResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceOperationResponse) MarshalToSizedBuffer ¶
func (m *ServiceOperationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceOperationResponse) ProtoMessage ¶
func (*ServiceOperationResponse) ProtoMessage()
func (*ServiceOperationResponse) Reset ¶
func (m *ServiceOperationResponse) Reset()
func (*ServiceOperationResponse) Size ¶
func (m *ServiceOperationResponse) Size() (n int)
func (*ServiceOperationResponse) String ¶
func (m *ServiceOperationResponse) String() string
func (*ServiceOperationResponse) Unmarshal ¶
func (m *ServiceOperationResponse) Unmarshal(dAtA []byte) error
func (*ServiceOperationResponse) XXX_DiscardUnknown ¶
func (m *ServiceOperationResponse) XXX_DiscardUnknown()
func (*ServiceOperationResponse) XXX_Marshal ¶
func (m *ServiceOperationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceOperationResponse) XXX_Merge ¶
func (m *ServiceOperationResponse) XXX_Merge(src proto.Message)
func (*ServiceOperationResponse) XXX_Size ¶
func (m *ServiceOperationResponse) XXX_Size() int
func (*ServiceOperationResponse) XXX_Unmarshal ¶
func (m *ServiceOperationResponse) XXX_Unmarshal(b []byte) error
type ServiceQueryRequest ¶
type ServiceQueryRequest struct { Service *ServiceId `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // Types that are valid to be assigned to Request: // *ServiceQueryRequest_Operation // *ServiceQueryRequest_Metadata Request isServiceQueryRequest_Request `protobuf_oneof:"request"` }
func (*ServiceQueryRequest) Descriptor ¶
func (*ServiceQueryRequest) Descriptor() ([]byte, []int)
func (*ServiceQueryRequest) GetMetadata ¶
func (m *ServiceQueryRequest) GetMetadata() *ServiceMetadataRequest
func (*ServiceQueryRequest) GetOperation ¶
func (m *ServiceQueryRequest) GetOperation() *ServiceOperationRequest
func (*ServiceQueryRequest) GetRequest ¶
func (m *ServiceQueryRequest) GetRequest() isServiceQueryRequest_Request
func (*ServiceQueryRequest) GetService ¶
func (m *ServiceQueryRequest) GetService() *ServiceId
func (*ServiceQueryRequest) Marshal ¶
func (m *ServiceQueryRequest) Marshal() (dAtA []byte, err error)
func (*ServiceQueryRequest) MarshalTo ¶
func (m *ServiceQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*ServiceQueryRequest) MarshalToSizedBuffer ¶
func (m *ServiceQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceQueryRequest) ProtoMessage ¶
func (*ServiceQueryRequest) ProtoMessage()
func (*ServiceQueryRequest) Reset ¶
func (m *ServiceQueryRequest) Reset()
func (*ServiceQueryRequest) Size ¶
func (m *ServiceQueryRequest) Size() (n int)
func (*ServiceQueryRequest) String ¶
func (m *ServiceQueryRequest) String() string
func (*ServiceQueryRequest) Unmarshal ¶
func (m *ServiceQueryRequest) Unmarshal(dAtA []byte) error
func (*ServiceQueryRequest) XXX_DiscardUnknown ¶
func (m *ServiceQueryRequest) XXX_DiscardUnknown()
func (*ServiceQueryRequest) XXX_Marshal ¶
func (m *ServiceQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceQueryRequest) XXX_Merge ¶
func (m *ServiceQueryRequest) XXX_Merge(src proto.Message)
func (*ServiceQueryRequest) XXX_OneofWrappers ¶
func (*ServiceQueryRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServiceQueryRequest) XXX_Size ¶
func (m *ServiceQueryRequest) XXX_Size() int
func (*ServiceQueryRequest) XXX_Unmarshal ¶
func (m *ServiceQueryRequest) XXX_Unmarshal(b []byte) error
type ServiceQueryRequest_Metadata ¶
type ServiceQueryRequest_Metadata struct {
Metadata *ServiceMetadataRequest `protobuf:"bytes,3,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}
func (*ServiceQueryRequest_Metadata) MarshalTo ¶
func (m *ServiceQueryRequest_Metadata) MarshalTo(dAtA []byte) (int, error)
func (*ServiceQueryRequest_Metadata) MarshalToSizedBuffer ¶
func (m *ServiceQueryRequest_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceQueryRequest_Metadata) Size ¶
func (m *ServiceQueryRequest_Metadata) Size() (n int)
type ServiceQueryRequest_Operation ¶
type ServiceQueryRequest_Operation struct {
Operation *ServiceOperationRequest `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}
func (*ServiceQueryRequest_Operation) MarshalTo ¶
func (m *ServiceQueryRequest_Operation) MarshalTo(dAtA []byte) (int, error)
func (*ServiceQueryRequest_Operation) MarshalToSizedBuffer ¶
func (m *ServiceQueryRequest_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceQueryRequest_Operation) Size ¶
func (m *ServiceQueryRequest_Operation) Size() (n int)
type ServiceQueryResponse ¶
type ServiceQueryResponse struct { // Types that are valid to be assigned to Response: // *ServiceQueryResponse_Operation // *ServiceQueryResponse_Metadata Response isServiceQueryResponse_Response `protobuf_oneof:"response"` }
func (*ServiceQueryResponse) Descriptor ¶
func (*ServiceQueryResponse) Descriptor() ([]byte, []int)
func (*ServiceQueryResponse) GetMetadata ¶
func (m *ServiceQueryResponse) GetMetadata() *ServiceMetadataResponse
func (*ServiceQueryResponse) GetOperation ¶
func (m *ServiceQueryResponse) GetOperation() *ServiceOperationResponse
func (*ServiceQueryResponse) GetResponse ¶
func (m *ServiceQueryResponse) GetResponse() isServiceQueryResponse_Response
func (*ServiceQueryResponse) Marshal ¶
func (m *ServiceQueryResponse) Marshal() (dAtA []byte, err error)
func (*ServiceQueryResponse) MarshalTo ¶
func (m *ServiceQueryResponse) MarshalTo(dAtA []byte) (int, error)
func (*ServiceQueryResponse) MarshalToSizedBuffer ¶
func (m *ServiceQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceQueryResponse) ProtoMessage ¶
func (*ServiceQueryResponse) ProtoMessage()
func (*ServiceQueryResponse) Reset ¶
func (m *ServiceQueryResponse) Reset()
func (*ServiceQueryResponse) Size ¶
func (m *ServiceQueryResponse) Size() (n int)
func (*ServiceQueryResponse) String ¶
func (m *ServiceQueryResponse) String() string
func (*ServiceQueryResponse) Unmarshal ¶
func (m *ServiceQueryResponse) Unmarshal(dAtA []byte) error
func (*ServiceQueryResponse) XXX_DiscardUnknown ¶
func (m *ServiceQueryResponse) XXX_DiscardUnknown()
func (*ServiceQueryResponse) XXX_Marshal ¶
func (m *ServiceQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceQueryResponse) XXX_Merge ¶
func (m *ServiceQueryResponse) XXX_Merge(src proto.Message)
func (*ServiceQueryResponse) XXX_OneofWrappers ¶
func (*ServiceQueryResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServiceQueryResponse) XXX_Size ¶
func (m *ServiceQueryResponse) XXX_Size() int
func (*ServiceQueryResponse) XXX_Unmarshal ¶
func (m *ServiceQueryResponse) XXX_Unmarshal(b []byte) error
type ServiceQueryResponse_Metadata ¶
type ServiceQueryResponse_Metadata struct {
Metadata *ServiceMetadataResponse `protobuf:"bytes,3,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}
func (*ServiceQueryResponse_Metadata) MarshalTo ¶
func (m *ServiceQueryResponse_Metadata) MarshalTo(dAtA []byte) (int, error)
func (*ServiceQueryResponse_Metadata) MarshalToSizedBuffer ¶
func (m *ServiceQueryResponse_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceQueryResponse_Metadata) Size ¶
func (m *ServiceQueryResponse_Metadata) Size() (n int)
type ServiceQueryResponse_Operation ¶
type ServiceQueryResponse_Operation struct {
Operation *ServiceOperationResponse `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}
func (*ServiceQueryResponse_Operation) MarshalTo ¶
func (m *ServiceQueryResponse_Operation) MarshalTo(dAtA []byte) (int, error)
func (*ServiceQueryResponse_Operation) MarshalToSizedBuffer ¶
func (m *ServiceQueryResponse_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceQueryResponse_Operation) Size ¶
func (m *ServiceQueryResponse_Operation) Size() (n int)
type ServiceType ¶
type ServiceType int32
const ( ServiceType_UNKNOWN_SERVICE ServiceType = 0 ServiceType_COUNTER ServiceType = 1 ServiceType_ELECTION ServiceType = 2 ServiceType_INDEXED_MAP ServiceType = 3 ServiceType_LEADER_LATCH ServiceType = 4 ServiceType_LIST ServiceType = 5 ServiceType_LOCK ServiceType = 6 ServiceType_LOG ServiceType = 7 ServiceType_MAP ServiceType = 8 ServiceType_SET ServiceType = 9 ServiceType_VALUE ServiceType = 10 )
func (ServiceType) EnumDescriptor ¶
func (ServiceType) EnumDescriptor() ([]byte, []int)
func (ServiceType) String ¶
func (x ServiceType) String() string
type Session ¶
type Session interface { // ID returns the session identifier ID() SessionID // Streams returns all open streams Streams() []Stream // Stream returns a stream by ID Stream(id StreamID) Stream // StreamsOf returns all open streams for the given operation StreamsOf(op OperationID) []Stream }
Session is a service session
type SessionClosedService ¶
type SessionClosedService interface { // SessionClosed is called when a session is closed for a service SessionClosed(Session) }
SessionClosedService is an interface for listening to session closed events
type SessionCommandContext ¶
type SessionCommandContext struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` SequenceNumber uint64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` }
func (*SessionCommandContext) Descriptor ¶
func (*SessionCommandContext) Descriptor() ([]byte, []int)
func (*SessionCommandContext) GetSequenceNumber ¶
func (m *SessionCommandContext) GetSequenceNumber() uint64
func (*SessionCommandContext) GetSessionID ¶
func (m *SessionCommandContext) GetSessionID() uint64
func (*SessionCommandContext) Marshal ¶
func (m *SessionCommandContext) Marshal() (dAtA []byte, err error)
func (*SessionCommandContext) MarshalTo ¶
func (m *SessionCommandContext) MarshalTo(dAtA []byte) (int, error)
func (*SessionCommandContext) MarshalToSizedBuffer ¶
func (m *SessionCommandContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionCommandContext) ProtoMessage ¶
func (*SessionCommandContext) ProtoMessage()
func (*SessionCommandContext) Reset ¶
func (m *SessionCommandContext) Reset()
func (*SessionCommandContext) Size ¶
func (m *SessionCommandContext) Size() (n int)
func (*SessionCommandContext) String ¶
func (m *SessionCommandContext) String() string
func (*SessionCommandContext) Unmarshal ¶
func (m *SessionCommandContext) Unmarshal(dAtA []byte) error
func (*SessionCommandContext) XXX_DiscardUnknown ¶
func (m *SessionCommandContext) XXX_DiscardUnknown()
func (*SessionCommandContext) XXX_Marshal ¶
func (m *SessionCommandContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionCommandContext) XXX_Merge ¶
func (m *SessionCommandContext) XXX_Merge(src proto.Message)
func (*SessionCommandContext) XXX_Size ¶
func (m *SessionCommandContext) XXX_Size() int
func (*SessionCommandContext) XXX_Unmarshal ¶
func (m *SessionCommandContext) XXX_Unmarshal(b []byte) error
type SessionCommandRequest ¶
type SessionCommandRequest struct { Context *SessionCommandContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Command *ServiceCommandRequest `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"` }
func (*SessionCommandRequest) Descriptor ¶
func (*SessionCommandRequest) Descriptor() ([]byte, []int)
func (*SessionCommandRequest) GetCommand ¶
func (m *SessionCommandRequest) GetCommand() *ServiceCommandRequest
func (*SessionCommandRequest) GetContext ¶
func (m *SessionCommandRequest) GetContext() *SessionCommandContext
func (*SessionCommandRequest) Marshal ¶
func (m *SessionCommandRequest) Marshal() (dAtA []byte, err error)
func (*SessionCommandRequest) MarshalTo ¶
func (m *SessionCommandRequest) MarshalTo(dAtA []byte) (int, error)
func (*SessionCommandRequest) MarshalToSizedBuffer ¶
func (m *SessionCommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionCommandRequest) ProtoMessage ¶
func (*SessionCommandRequest) ProtoMessage()
func (*SessionCommandRequest) Reset ¶
func (m *SessionCommandRequest) Reset()
func (*SessionCommandRequest) Size ¶
func (m *SessionCommandRequest) Size() (n int)
func (*SessionCommandRequest) String ¶
func (m *SessionCommandRequest) String() string
func (*SessionCommandRequest) Unmarshal ¶
func (m *SessionCommandRequest) Unmarshal(dAtA []byte) error
func (*SessionCommandRequest) XXX_DiscardUnknown ¶
func (m *SessionCommandRequest) XXX_DiscardUnknown()
func (*SessionCommandRequest) XXX_Marshal ¶
func (m *SessionCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionCommandRequest) XXX_Merge ¶
func (m *SessionCommandRequest) XXX_Merge(src proto.Message)
func (*SessionCommandRequest) XXX_Size ¶
func (m *SessionCommandRequest) XXX_Size() int
func (*SessionCommandRequest) XXX_Unmarshal ¶
func (m *SessionCommandRequest) XXX_Unmarshal(b []byte) error
type SessionCommandResponse ¶
type SessionCommandResponse struct { Context *SessionResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Response *ServiceCommandResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` }
func (*SessionCommandResponse) Descriptor ¶
func (*SessionCommandResponse) Descriptor() ([]byte, []int)
func (*SessionCommandResponse) GetContext ¶
func (m *SessionCommandResponse) GetContext() *SessionResponseContext
func (*SessionCommandResponse) GetResponse ¶
func (m *SessionCommandResponse) GetResponse() *ServiceCommandResponse
func (*SessionCommandResponse) Marshal ¶
func (m *SessionCommandResponse) Marshal() (dAtA []byte, err error)
func (*SessionCommandResponse) MarshalTo ¶
func (m *SessionCommandResponse) MarshalTo(dAtA []byte) (int, error)
func (*SessionCommandResponse) MarshalToSizedBuffer ¶
func (m *SessionCommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionCommandResponse) ProtoMessage ¶
func (*SessionCommandResponse) ProtoMessage()
func (*SessionCommandResponse) Reset ¶
func (m *SessionCommandResponse) Reset()
func (*SessionCommandResponse) Size ¶
func (m *SessionCommandResponse) Size() (n int)
func (*SessionCommandResponse) String ¶
func (m *SessionCommandResponse) String() string
func (*SessionCommandResponse) Unmarshal ¶
func (m *SessionCommandResponse) Unmarshal(dAtA []byte) error
func (*SessionCommandResponse) XXX_DiscardUnknown ¶
func (m *SessionCommandResponse) XXX_DiscardUnknown()
func (*SessionCommandResponse) XXX_Marshal ¶
func (m *SessionCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionCommandResponse) XXX_Merge ¶
func (m *SessionCommandResponse) XXX_Merge(src proto.Message)
func (*SessionCommandResponse) XXX_Size ¶
func (m *SessionCommandResponse) XXX_Size() int
func (*SessionCommandResponse) XXX_Unmarshal ¶
func (m *SessionCommandResponse) XXX_Unmarshal(b []byte) error
type SessionExpiredService ¶
type SessionExpiredService interface { // SessionExpired is called when a session is expired for a service SessionExpired(Session) }
SessionExpiredService is an interface for listening to session expired events
type SessionOpenService ¶
type SessionOpenService interface { // SessionOpen is called when a session is opened for a service SessionOpen(Session) }
SessionOpenService is an interface for listening to session open events
type SessionOutput ¶
type SessionOutput struct { streams.Result Header *headers.ResponseHeader }
SessionOutput is a result for session-supporting servers containing session header information
type SessionQueryContext ¶
type SessionQueryContext struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` LastSequenceNumber uint64 `protobuf:"varint,2,opt,name=last_sequence_number,json=lastSequenceNumber,proto3" json:"last_sequence_number,omitempty"` LastIndex uint64 `protobuf:"varint,3,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"` }
func (*SessionQueryContext) Descriptor ¶
func (*SessionQueryContext) Descriptor() ([]byte, []int)
func (*SessionQueryContext) GetLastIndex ¶
func (m *SessionQueryContext) GetLastIndex() uint64
func (*SessionQueryContext) GetLastSequenceNumber ¶
func (m *SessionQueryContext) GetLastSequenceNumber() uint64
func (*SessionQueryContext) GetSessionID ¶
func (m *SessionQueryContext) GetSessionID() uint64
func (*SessionQueryContext) Marshal ¶
func (m *SessionQueryContext) Marshal() (dAtA []byte, err error)
func (*SessionQueryContext) MarshalTo ¶
func (m *SessionQueryContext) MarshalTo(dAtA []byte) (int, error)
func (*SessionQueryContext) MarshalToSizedBuffer ¶
func (m *SessionQueryContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionQueryContext) ProtoMessage ¶
func (*SessionQueryContext) ProtoMessage()
func (*SessionQueryContext) Reset ¶
func (m *SessionQueryContext) Reset()
func (*SessionQueryContext) Size ¶
func (m *SessionQueryContext) Size() (n int)
func (*SessionQueryContext) String ¶
func (m *SessionQueryContext) String() string
func (*SessionQueryContext) Unmarshal ¶
func (m *SessionQueryContext) Unmarshal(dAtA []byte) error
func (*SessionQueryContext) XXX_DiscardUnknown ¶
func (m *SessionQueryContext) XXX_DiscardUnknown()
func (*SessionQueryContext) XXX_Marshal ¶
func (m *SessionQueryContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionQueryContext) XXX_Merge ¶
func (m *SessionQueryContext) XXX_Merge(src proto.Message)
func (*SessionQueryContext) XXX_Size ¶
func (m *SessionQueryContext) XXX_Size() int
func (*SessionQueryContext) XXX_Unmarshal ¶
func (m *SessionQueryContext) XXX_Unmarshal(b []byte) error
type SessionQueryRequest ¶
type SessionQueryRequest struct { Context *SessionQueryContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Query *ServiceQueryRequest `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` }
func (*SessionQueryRequest) Descriptor ¶
func (*SessionQueryRequest) Descriptor() ([]byte, []int)
func (*SessionQueryRequest) GetContext ¶
func (m *SessionQueryRequest) GetContext() *SessionQueryContext
func (*SessionQueryRequest) GetQuery ¶
func (m *SessionQueryRequest) GetQuery() *ServiceQueryRequest
func (*SessionQueryRequest) Marshal ¶
func (m *SessionQueryRequest) Marshal() (dAtA []byte, err error)
func (*SessionQueryRequest) MarshalTo ¶
func (m *SessionQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*SessionQueryRequest) MarshalToSizedBuffer ¶
func (m *SessionQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionQueryRequest) ProtoMessage ¶
func (*SessionQueryRequest) ProtoMessage()
func (*SessionQueryRequest) Reset ¶
func (m *SessionQueryRequest) Reset()
func (*SessionQueryRequest) Size ¶
func (m *SessionQueryRequest) Size() (n int)
func (*SessionQueryRequest) String ¶
func (m *SessionQueryRequest) String() string
func (*SessionQueryRequest) Unmarshal ¶
func (m *SessionQueryRequest) Unmarshal(dAtA []byte) error
func (*SessionQueryRequest) XXX_DiscardUnknown ¶
func (m *SessionQueryRequest) XXX_DiscardUnknown()
func (*SessionQueryRequest) XXX_Marshal ¶
func (m *SessionQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionQueryRequest) XXX_Merge ¶
func (m *SessionQueryRequest) XXX_Merge(src proto.Message)
func (*SessionQueryRequest) XXX_Size ¶
func (m *SessionQueryRequest) XXX_Size() int
func (*SessionQueryRequest) XXX_Unmarshal ¶
func (m *SessionQueryRequest) XXX_Unmarshal(b []byte) error
type SessionQueryResponse ¶
type SessionQueryResponse struct { Context *SessionResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Response *ServiceQueryResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` }
func (*SessionQueryResponse) Descriptor ¶
func (*SessionQueryResponse) Descriptor() ([]byte, []int)
func (*SessionQueryResponse) GetContext ¶
func (m *SessionQueryResponse) GetContext() *SessionResponseContext
func (*SessionQueryResponse) GetResponse ¶
func (m *SessionQueryResponse) GetResponse() *ServiceQueryResponse
func (*SessionQueryResponse) Marshal ¶
func (m *SessionQueryResponse) Marshal() (dAtA []byte, err error)
func (*SessionQueryResponse) MarshalTo ¶
func (m *SessionQueryResponse) MarshalTo(dAtA []byte) (int, error)
func (*SessionQueryResponse) MarshalToSizedBuffer ¶
func (m *SessionQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionQueryResponse) ProtoMessage ¶
func (*SessionQueryResponse) ProtoMessage()
func (*SessionQueryResponse) Reset ¶
func (m *SessionQueryResponse) Reset()
func (*SessionQueryResponse) Size ¶
func (m *SessionQueryResponse) Size() (n int)
func (*SessionQueryResponse) String ¶
func (m *SessionQueryResponse) String() string
func (*SessionQueryResponse) Unmarshal ¶
func (m *SessionQueryResponse) Unmarshal(dAtA []byte) error
func (*SessionQueryResponse) XXX_DiscardUnknown ¶
func (m *SessionQueryResponse) XXX_DiscardUnknown()
func (*SessionQueryResponse) XXX_Marshal ¶
func (m *SessionQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionQueryResponse) XXX_Merge ¶
func (m *SessionQueryResponse) XXX_Merge(src proto.Message)
func (*SessionQueryResponse) XXX_Size ¶
func (m *SessionQueryResponse) XXX_Size() int
func (*SessionQueryResponse) XXX_Unmarshal ¶
func (m *SessionQueryResponse) XXX_Unmarshal(b []byte) error
type SessionRequest ¶
type SessionRequest struct { // Types that are valid to be assigned to Request: // *SessionRequest_OpenSession // *SessionRequest_KeepAlive // *SessionRequest_CloseSession // *SessionRequest_Command // *SessionRequest_Query Request isSessionRequest_Request `protobuf_oneof:"request"` }
func (*SessionRequest) Descriptor ¶
func (*SessionRequest) Descriptor() ([]byte, []int)
func (*SessionRequest) GetCloseSession ¶
func (m *SessionRequest) GetCloseSession() *CloseSessionRequest
func (*SessionRequest) GetCommand ¶
func (m *SessionRequest) GetCommand() *SessionCommandRequest
func (*SessionRequest) GetKeepAlive ¶
func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest
func (*SessionRequest) GetOpenSession ¶
func (m *SessionRequest) GetOpenSession() *OpenSessionRequest
func (*SessionRequest) GetQuery ¶
func (m *SessionRequest) GetQuery() *SessionQueryRequest
func (*SessionRequest) GetRequest ¶
func (m *SessionRequest) GetRequest() isSessionRequest_Request
func (*SessionRequest) Marshal ¶
func (m *SessionRequest) Marshal() (dAtA []byte, err error)
func (*SessionRequest) MarshalToSizedBuffer ¶
func (m *SessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest) ProtoMessage ¶
func (*SessionRequest) ProtoMessage()
func (*SessionRequest) Reset ¶
func (m *SessionRequest) Reset()
func (*SessionRequest) Size ¶
func (m *SessionRequest) Size() (n int)
func (*SessionRequest) String ¶
func (m *SessionRequest) String() string
func (*SessionRequest) Unmarshal ¶
func (m *SessionRequest) Unmarshal(dAtA []byte) error
func (*SessionRequest) XXX_DiscardUnknown ¶
func (m *SessionRequest) XXX_DiscardUnknown()
func (*SessionRequest) XXX_Marshal ¶
func (m *SessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionRequest) XXX_Merge ¶
func (m *SessionRequest) XXX_Merge(src proto.Message)
func (*SessionRequest) XXX_OneofWrappers ¶
func (*SessionRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SessionRequest) XXX_Size ¶
func (m *SessionRequest) XXX_Size() int
func (*SessionRequest) XXX_Unmarshal ¶
func (m *SessionRequest) XXX_Unmarshal(b []byte) error
type SessionRequest_CloseSession ¶
type SessionRequest_CloseSession struct {
CloseSession *CloseSessionRequest `protobuf:"bytes,3,opt,name=close_session,json=closeSession,proto3,oneof" json:"close_session,omitempty"`
}
func (*SessionRequest_CloseSession) MarshalTo ¶
func (m *SessionRequest_CloseSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_CloseSession) MarshalToSizedBuffer ¶
func (m *SessionRequest_CloseSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_CloseSession) Size ¶
func (m *SessionRequest_CloseSession) Size() (n int)
type SessionRequest_Command ¶
type SessionRequest_Command struct {
Command *SessionCommandRequest `protobuf:"bytes,4,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func (*SessionRequest_Command) MarshalTo ¶
func (m *SessionRequest_Command) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_Command) MarshalToSizedBuffer ¶
func (m *SessionRequest_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_Command) Size ¶
func (m *SessionRequest_Command) Size() (n int)
type SessionRequest_KeepAlive ¶
type SessionRequest_KeepAlive struct {
KeepAlive *KeepAliveRequest `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3,oneof" json:"keep_alive,omitempty"`
}
func (*SessionRequest_KeepAlive) MarshalTo ¶
func (m *SessionRequest_KeepAlive) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_KeepAlive) MarshalToSizedBuffer ¶
func (m *SessionRequest_KeepAlive) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_KeepAlive) Size ¶
func (m *SessionRequest_KeepAlive) Size() (n int)
type SessionRequest_OpenSession ¶
type SessionRequest_OpenSession struct {
OpenSession *OpenSessionRequest `protobuf:"bytes,1,opt,name=open_session,json=openSession,proto3,oneof" json:"open_session,omitempty"`
}
func (*SessionRequest_OpenSession) MarshalTo ¶
func (m *SessionRequest_OpenSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_OpenSession) MarshalToSizedBuffer ¶
func (m *SessionRequest_OpenSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_OpenSession) Size ¶
func (m *SessionRequest_OpenSession) Size() (n int)
type SessionRequest_Query ¶
type SessionRequest_Query struct {
Query *SessionQueryRequest `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func (*SessionRequest_Query) MarshalTo ¶
func (m *SessionRequest_Query) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_Query) MarshalToSizedBuffer ¶
func (m *SessionRequest_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_Query) Size ¶
func (m *SessionRequest_Query) Size() (n int)
type SessionResponse ¶
type SessionResponse struct { // Types that are valid to be assigned to Response: // *SessionResponse_OpenSession // *SessionResponse_KeepAlive // *SessionResponse_CloseSession // *SessionResponse_Command // *SessionResponse_Query Response isSessionResponse_Response `protobuf_oneof:"response"` }
func (*SessionResponse) Descriptor ¶
func (*SessionResponse) Descriptor() ([]byte, []int)
func (*SessionResponse) GetCloseSession ¶
func (m *SessionResponse) GetCloseSession() *CloseSessionResponse
func (*SessionResponse) GetCommand ¶
func (m *SessionResponse) GetCommand() *SessionCommandResponse
func (*SessionResponse) GetKeepAlive ¶
func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse
func (*SessionResponse) GetOpenSession ¶
func (m *SessionResponse) GetOpenSession() *OpenSessionResponse
func (*SessionResponse) GetQuery ¶
func (m *SessionResponse) GetQuery() *SessionQueryResponse
func (*SessionResponse) GetResponse ¶
func (m *SessionResponse) GetResponse() isSessionResponse_Response
func (*SessionResponse) Marshal ¶
func (m *SessionResponse) Marshal() (dAtA []byte, err error)
func (*SessionResponse) MarshalToSizedBuffer ¶
func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse) ProtoMessage ¶
func (*SessionResponse) ProtoMessage()
func (*SessionResponse) Reset ¶
func (m *SessionResponse) Reset()
func (*SessionResponse) Size ¶
func (m *SessionResponse) Size() (n int)
func (*SessionResponse) String ¶
func (m *SessionResponse) String() string
func (*SessionResponse) Unmarshal ¶
func (m *SessionResponse) Unmarshal(dAtA []byte) error
func (*SessionResponse) XXX_DiscardUnknown ¶
func (m *SessionResponse) XXX_DiscardUnknown()
func (*SessionResponse) XXX_Marshal ¶
func (m *SessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionResponse) XXX_Merge ¶
func (m *SessionResponse) XXX_Merge(src proto.Message)
func (*SessionResponse) XXX_OneofWrappers ¶
func (*SessionResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SessionResponse) XXX_Size ¶
func (m *SessionResponse) XXX_Size() int
func (*SessionResponse) XXX_Unmarshal ¶
func (m *SessionResponse) XXX_Unmarshal(b []byte) error
type SessionResponseContext ¶
type SessionResponseContext struct { StreamID uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` Type SessionResponseType `protobuf:"varint,4,opt,name=type,proto3,enum=atomix.service.SessionResponseType" json:"type,omitempty"` Status SessionResponseStatus `protobuf:"varint,5,opt,name=status,proto3,enum=atomix.service.SessionResponseStatus" json:"status,omitempty"` Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"` }
func (*SessionResponseContext) Descriptor ¶
func (*SessionResponseContext) Descriptor() ([]byte, []int)
func (*SessionResponseContext) GetIndex ¶
func (m *SessionResponseContext) GetIndex() uint64
func (*SessionResponseContext) GetMessage ¶
func (m *SessionResponseContext) GetMessage() string
func (*SessionResponseContext) GetSequence ¶
func (m *SessionResponseContext) GetSequence() uint64
func (*SessionResponseContext) GetStatus ¶
func (m *SessionResponseContext) GetStatus() SessionResponseStatus
func (*SessionResponseContext) GetStreamID ¶
func (m *SessionResponseContext) GetStreamID() uint64
func (*SessionResponseContext) GetType ¶
func (m *SessionResponseContext) GetType() SessionResponseType
func (*SessionResponseContext) Marshal ¶
func (m *SessionResponseContext) Marshal() (dAtA []byte, err error)
func (*SessionResponseContext) MarshalTo ¶
func (m *SessionResponseContext) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponseContext) MarshalToSizedBuffer ¶
func (m *SessionResponseContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponseContext) ProtoMessage ¶
func (*SessionResponseContext) ProtoMessage()
func (*SessionResponseContext) Reset ¶
func (m *SessionResponseContext) Reset()
func (*SessionResponseContext) Size ¶
func (m *SessionResponseContext) Size() (n int)
func (*SessionResponseContext) String ¶
func (m *SessionResponseContext) String() string
func (*SessionResponseContext) Unmarshal ¶
func (m *SessionResponseContext) Unmarshal(dAtA []byte) error
func (*SessionResponseContext) XXX_DiscardUnknown ¶
func (m *SessionResponseContext) XXX_DiscardUnknown()
func (*SessionResponseContext) XXX_Marshal ¶
func (m *SessionResponseContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionResponseContext) XXX_Merge ¶
func (m *SessionResponseContext) XXX_Merge(src proto.Message)
func (*SessionResponseContext) XXX_Size ¶
func (m *SessionResponseContext) XXX_Size() int
func (*SessionResponseContext) XXX_Unmarshal ¶
func (m *SessionResponseContext) XXX_Unmarshal(b []byte) error
type SessionResponseStatus ¶
type SessionResponseStatus int32
const ( SessionResponseStatus_OK SessionResponseStatus = 0 SessionResponseStatus_ERROR SessionResponseStatus = 1 SessionResponseStatus_NOT_LEADER SessionResponseStatus = 2 SessionResponseStatus_UNKNOWN SessionResponseStatus = 3 SessionResponseStatus_CANCELED SessionResponseStatus = 4 SessionResponseStatus_NOT_FOUND SessionResponseStatus = 5 SessionResponseStatus_ALREADY_EXISTS SessionResponseStatus = 6 SessionResponseStatus_UNAUTHORIZED SessionResponseStatus = 7 SessionResponseStatus_FORBIDDEN SessionResponseStatus = 8 SessionResponseStatus_CONFLICT SessionResponseStatus = 9 SessionResponseStatus_INVALID SessionResponseStatus = 10 SessionResponseStatus_UNAVAILABLE SessionResponseStatus = 11 SessionResponseStatus_NOT_SUPPORTED SessionResponseStatus = 12 SessionResponseStatus_TIMEOUT SessionResponseStatus = 13 SessionResponseStatus_INTERNAL SessionResponseStatus = 14 )
func (SessionResponseStatus) EnumDescriptor ¶
func (SessionResponseStatus) EnumDescriptor() ([]byte, []int)
func (SessionResponseStatus) String ¶
func (x SessionResponseStatus) String() string
type SessionResponseType ¶
type SessionResponseType int32
const ( SessionResponseType_RESPONSE SessionResponseType = 0 SessionResponseType_OPEN_STREAM SessionResponseType = 1 SessionResponseType_CLOSE_STREAM SessionResponseType = 2 )
func (SessionResponseType) EnumDescriptor ¶
func (SessionResponseType) EnumDescriptor() ([]byte, []int)
func (SessionResponseType) String ¶
func (x SessionResponseType) String() string
type SessionResponse_CloseSession ¶
type SessionResponse_CloseSession struct {
CloseSession *CloseSessionResponse `protobuf:"bytes,3,opt,name=close_session,json=closeSession,proto3,oneof" json:"close_session,omitempty"`
}
func (*SessionResponse_CloseSession) MarshalTo ¶
func (m *SessionResponse_CloseSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_CloseSession) MarshalToSizedBuffer ¶
func (m *SessionResponse_CloseSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_CloseSession) Size ¶
func (m *SessionResponse_CloseSession) Size() (n int)
type SessionResponse_Command ¶
type SessionResponse_Command struct {
Command *SessionCommandResponse `protobuf:"bytes,4,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func (*SessionResponse_Command) MarshalTo ¶
func (m *SessionResponse_Command) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_Command) MarshalToSizedBuffer ¶
func (m *SessionResponse_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_Command) Size ¶
func (m *SessionResponse_Command) Size() (n int)
type SessionResponse_KeepAlive ¶
type SessionResponse_KeepAlive struct {
KeepAlive *KeepAliveResponse `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3,oneof" json:"keep_alive,omitempty"`
}
func (*SessionResponse_KeepAlive) MarshalTo ¶
func (m *SessionResponse_KeepAlive) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_KeepAlive) MarshalToSizedBuffer ¶
func (m *SessionResponse_KeepAlive) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_KeepAlive) Size ¶
func (m *SessionResponse_KeepAlive) Size() (n int)
type SessionResponse_OpenSession ¶
type SessionResponse_OpenSession struct {
OpenSession *OpenSessionResponse `protobuf:"bytes,1,opt,name=open_session,json=openSession,proto3,oneof" json:"open_session,omitempty"`
}
func (*SessionResponse_OpenSession) MarshalTo ¶
func (m *SessionResponse_OpenSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_OpenSession) MarshalToSizedBuffer ¶
func (m *SessionResponse_OpenSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_OpenSession) Size ¶
func (m *SessionResponse_OpenSession) Size() (n int)
type SessionResponse_Query ¶
type SessionResponse_Query struct {
Query *SessionQueryResponse `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func (*SessionResponse_Query) MarshalTo ¶
func (m *SessionResponse_Query) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_Query) MarshalToSizedBuffer ¶
func (m *SessionResponse_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_Query) Size ¶
func (m *SessionResponse_Query) Size() (n int)
type SessionServer ¶
type SessionServer struct {
*Server
}
SessionServer is an implementation of SessionServiceServer for session management
func (*SessionServer) CloseSession ¶
func (s *SessionServer) CloseSession(ctx context.Context, request *api.CloseSessionRequest) (*api.CloseSessionResponse, error)
CloseSession closes a session
func (*SessionServer) KeepAlive ¶
func (s *SessionServer) KeepAlive(ctx context.Context, request *api.KeepAliveRequest) (*api.KeepAliveResponse, error)
KeepAlive keeps a session alive
func (*SessionServer) OpenSession ¶
func (s *SessionServer) OpenSession(ctx context.Context, request *api.OpenSessionRequest) (*api.OpenSessionResponse, error)
OpenSession opens a new session
type SessionServiceSnapshot ¶
type SessionServiceSnapshot struct { ServiceId ServiceId `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id"` Streams []*SessionStreamSnapshot `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"` }
Session service snapshot
func (*SessionServiceSnapshot) Descriptor ¶
func (*SessionServiceSnapshot) Descriptor() ([]byte, []int)
func (*SessionServiceSnapshot) GetServiceId ¶
func (m *SessionServiceSnapshot) GetServiceId() ServiceId
func (*SessionServiceSnapshot) GetStreams ¶
func (m *SessionServiceSnapshot) GetStreams() []*SessionStreamSnapshot
func (*SessionServiceSnapshot) Marshal ¶
func (m *SessionServiceSnapshot) Marshal() (dAtA []byte, err error)
func (*SessionServiceSnapshot) MarshalTo ¶
func (m *SessionServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*SessionServiceSnapshot) MarshalToSizedBuffer ¶
func (m *SessionServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionServiceSnapshot) ProtoMessage ¶
func (*SessionServiceSnapshot) ProtoMessage()
func (*SessionServiceSnapshot) Reset ¶
func (m *SessionServiceSnapshot) Reset()
func (*SessionServiceSnapshot) Size ¶
func (m *SessionServiceSnapshot) Size() (n int)
func (*SessionServiceSnapshot) String ¶
func (m *SessionServiceSnapshot) String() string
func (*SessionServiceSnapshot) Unmarshal ¶
func (m *SessionServiceSnapshot) Unmarshal(dAtA []byte) error
func (*SessionServiceSnapshot) XXX_DiscardUnknown ¶
func (m *SessionServiceSnapshot) XXX_DiscardUnknown()
func (*SessionServiceSnapshot) XXX_Marshal ¶
func (m *SessionServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionServiceSnapshot) XXX_Merge ¶
func (m *SessionServiceSnapshot) XXX_Merge(src proto.Message)
func (*SessionServiceSnapshot) XXX_Size ¶
func (m *SessionServiceSnapshot) XXX_Size() int
func (*SessionServiceSnapshot) XXX_Unmarshal ¶
func (m *SessionServiceSnapshot) XXX_Unmarshal(b []byte) error
type SessionSnapshot ¶
type SessionSnapshot struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` Timeout time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout"` Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"` CommandSequence uint64 `protobuf:"varint,4,opt,name=command_sequence,json=commandSequence,proto3" json:"command_sequence,omitempty"` Services []*SessionServiceSnapshot `protobuf:"bytes,7,rep,name=services,proto3" json:"services,omitempty"` }
Service session
func (*SessionSnapshot) Descriptor ¶
func (*SessionSnapshot) Descriptor() ([]byte, []int)
func (*SessionSnapshot) GetCommandSequence ¶
func (m *SessionSnapshot) GetCommandSequence() uint64
func (*SessionSnapshot) GetServices ¶
func (m *SessionSnapshot) GetServices() []*SessionServiceSnapshot
func (*SessionSnapshot) GetSessionID ¶
func (m *SessionSnapshot) GetSessionID() uint64
func (*SessionSnapshot) GetTimeout ¶
func (m *SessionSnapshot) GetTimeout() time.Duration
func (*SessionSnapshot) GetTimestamp ¶
func (m *SessionSnapshot) GetTimestamp() time.Time
func (*SessionSnapshot) Marshal ¶
func (m *SessionSnapshot) Marshal() (dAtA []byte, err error)
func (*SessionSnapshot) MarshalToSizedBuffer ¶
func (m *SessionSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionSnapshot) ProtoMessage ¶
func (*SessionSnapshot) ProtoMessage()
func (*SessionSnapshot) Reset ¶
func (m *SessionSnapshot) Reset()
func (*SessionSnapshot) Size ¶
func (m *SessionSnapshot) Size() (n int)
func (*SessionSnapshot) String ¶
func (m *SessionSnapshot) String() string
func (*SessionSnapshot) Unmarshal ¶
func (m *SessionSnapshot) Unmarshal(dAtA []byte) error
func (*SessionSnapshot) XXX_DiscardUnknown ¶
func (m *SessionSnapshot) XXX_DiscardUnknown()
func (*SessionSnapshot) XXX_Marshal ¶
func (m *SessionSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionSnapshot) XXX_Merge ¶
func (m *SessionSnapshot) XXX_Merge(src proto.Message)
func (*SessionSnapshot) XXX_Size ¶
func (m *SessionSnapshot) XXX_Size() int
func (*SessionSnapshot) XXX_Unmarshal ¶
func (m *SessionSnapshot) XXX_Unmarshal(b []byte) error
type SessionStreamSnapshot ¶
type SessionStreamSnapshot struct { StreamId uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` SequenceNumber uint64 `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` LastCompleted uint64 `protobuf:"varint,4,opt,name=last_completed,json=lastCompleted,proto3" json:"last_completed,omitempty"` }
Service session stream
func (*SessionStreamSnapshot) Descriptor ¶
func (*SessionStreamSnapshot) Descriptor() ([]byte, []int)
func (*SessionStreamSnapshot) GetLastCompleted ¶
func (m *SessionStreamSnapshot) GetLastCompleted() uint64
func (*SessionStreamSnapshot) GetSequenceNumber ¶
func (m *SessionStreamSnapshot) GetSequenceNumber() uint64
func (*SessionStreamSnapshot) GetStreamId ¶
func (m *SessionStreamSnapshot) GetStreamId() uint64
func (*SessionStreamSnapshot) GetType ¶
func (m *SessionStreamSnapshot) GetType() string
func (*SessionStreamSnapshot) Marshal ¶
func (m *SessionStreamSnapshot) Marshal() (dAtA []byte, err error)
func (*SessionStreamSnapshot) MarshalTo ¶
func (m *SessionStreamSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*SessionStreamSnapshot) MarshalToSizedBuffer ¶
func (m *SessionStreamSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionStreamSnapshot) ProtoMessage ¶
func (*SessionStreamSnapshot) ProtoMessage()
func (*SessionStreamSnapshot) Reset ¶
func (m *SessionStreamSnapshot) Reset()
func (*SessionStreamSnapshot) Size ¶
func (m *SessionStreamSnapshot) Size() (n int)
func (*SessionStreamSnapshot) String ¶
func (m *SessionStreamSnapshot) String() string
func (*SessionStreamSnapshot) Unmarshal ¶
func (m *SessionStreamSnapshot) Unmarshal(dAtA []byte) error
func (*SessionStreamSnapshot) XXX_DiscardUnknown ¶
func (m *SessionStreamSnapshot) XXX_DiscardUnknown()
func (*SessionStreamSnapshot) XXX_Marshal ¶
func (m *SessionStreamSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionStreamSnapshot) XXX_Merge ¶
func (m *SessionStreamSnapshot) XXX_Merge(src proto.Message)
func (*SessionStreamSnapshot) XXX_Size ¶
func (m *SessionStreamSnapshot) XXX_Size() int
func (*SessionStreamSnapshot) XXX_Unmarshal ¶
func (m *SessionStreamSnapshot) XXX_Unmarshal(b []byte) error
type StateMachine ¶
type StateMachine interface { // Snapshot writes the state machine snapshot to the given writer Snapshot(writer io.Writer) error // Install reads the state machine snapshot from the given reader Install(reader io.Reader) error // Command applies a command to the state machine Command(bytes []byte, stream streams.WriteStream) // Query applies a query to the state machine Query(bytes []byte, stream streams.WriteStream) }
StateMachine applies commands from a protocol to a collection of state machines
type Stream ¶
type Stream interface { streams.WriteStream // ID returns the stream identifier ID() StreamID // OperationID returns the stream operation identifier OperationID() OperationID // Session returns the stream session Session() Session }
Stream is a service stream
type StreamingOperation ¶
type StreamingOperation interface { // Execute executes the operation Execute(bytes []byte, stream Stream) }
StreamingOperation is a primitive operation that returns a stream
type Timer ¶
type Timer interface {
// Cancel cancels the timer, preventing it from running in the future
Cancel()
}
Timer is a cancellable timer
type UnaryOperation ¶
type UnaryOperation interface { // Execute executes the operation Execute(bytes []byte) ([]byte, error) }
UnaryOperation is a primitive operation that returns a result