Documentation ¶
Index ¶
- Variables
- func GetErrorFromStatus(status SessionResponseStatus) error
- func RegisterStorageServiceServer(s *grpc.Server, srv StorageServiceServer)
- type BackupService
- type ClientID
- 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() []SessionStreamContext
- 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 NewServiceFunc
- type Node
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetClientID() string
- 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 Protocol
- type Registry
- type RestoreService
- type Scheduler
- type Server
- 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) GetCluster() string
- func (m *ServiceId) GetName() string
- func (m *ServiceId) GetType() string
- 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) GetType() string
- 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 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 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) GetStatus() SessionResponseStatus
- func (m *SessionResponse) GetType() SessionResponseType
- 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 SessionResponseCode
- type SessionResponseContext
- func (*SessionResponseContext) Descriptor() ([]byte, []int)
- func (m *SessionResponseContext) GetIndex() uint64
- func (m *SessionResponseContext) GetSequence() uint64
- func (m *SessionResponseContext) GetSessionID() uint64
- func (m *SessionResponseContext) GetStreamID() uint64
- 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
- func (*SessionResponseStatus) Descriptor() ([]byte, []int)
- func (m *SessionResponseStatus) GetCode() SessionResponseCode
- func (m *SessionResponseStatus) GetLeader() string
- func (m *SessionResponseStatus) GetMessage() string
- func (m *SessionResponseStatus) Marshal() (dAtA []byte, err error)
- func (m *SessionResponseStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionResponseStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionResponseStatus) ProtoMessage()
- func (m *SessionResponseStatus) Reset()
- func (m *SessionResponseStatus) Size() (n int)
- func (m *SessionResponseStatus) String() string
- func (m *SessionResponseStatus) Unmarshal(dAtA []byte) error
- func (m *SessionResponseStatus) XXX_DiscardUnknown()
- func (m *SessionResponseStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionResponseStatus) XXX_Merge(src proto.Message)
- func (m *SessionResponseStatus) XXX_Size() int
- func (m *SessionResponseStatus) XXX_Unmarshal(b []byte) error
- type SessionResponseType
- type SessionResponse_CloseSession
- type SessionResponse_Command
- type SessionResponse_KeepAlive
- type SessionResponse_OpenSession
- type SessionResponse_Query
- 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 SessionStreamContext
- func (*SessionStreamContext) Descriptor() ([]byte, []int)
- func (m *SessionStreamContext) GetResponseID() uint64
- func (m *SessionStreamContext) GetStreamID() uint64
- func (m *SessionStreamContext) Marshal() (dAtA []byte, err error)
- func (m *SessionStreamContext) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionStreamContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionStreamContext) ProtoMessage()
- func (m *SessionStreamContext) Reset()
- func (m *SessionStreamContext) Size() (n int)
- func (m *SessionStreamContext) String() string
- func (m *SessionStreamContext) Unmarshal(dAtA []byte) error
- func (m *SessionStreamContext) XXX_DiscardUnknown()
- func (m *SessionStreamContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionStreamContext) XXX_Merge(src proto.Message)
- func (m *SessionStreamContext) XXX_Size() int
- func (m *SessionStreamContext) 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 StorageRequest
- func (*StorageRequest) Descriptor() ([]byte, []int)
- func (m *StorageRequest) GetPartitionID() uint32
- func (m *StorageRequest) GetRequest() *SessionRequest
- func (m *StorageRequest) Marshal() (dAtA []byte, err error)
- func (m *StorageRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageRequest) ProtoMessage()
- func (m *StorageRequest) Reset()
- func (m *StorageRequest) Size() (n int)
- func (m *StorageRequest) String() string
- func (m *StorageRequest) Unmarshal(dAtA []byte) error
- func (m *StorageRequest) XXX_DiscardUnknown()
- func (m *StorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageRequest) XXX_Merge(src proto.Message)
- func (m *StorageRequest) XXX_Size() int
- func (m *StorageRequest) XXX_Unmarshal(b []byte) error
- type StorageResponse
- func (*StorageResponse) Descriptor() ([]byte, []int)
- func (m *StorageResponse) GetPartitionID() uint32
- func (m *StorageResponse) GetResponse() *SessionResponse
- func (m *StorageResponse) Marshal() (dAtA []byte, err error)
- func (m *StorageResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageResponse) ProtoMessage()
- func (m *StorageResponse) Reset()
- func (m *StorageResponse) Size() (n int)
- func (m *StorageResponse) String() string
- func (m *StorageResponse) Unmarshal(dAtA []byte) error
- func (m *StorageResponse) XXX_DiscardUnknown()
- func (m *StorageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageResponse) XXX_Merge(src proto.Message)
- func (m *StorageResponse) XXX_Size() int
- func (m *StorageResponse) XXX_Unmarshal(b []byte) error
- type StorageServiceClient
- type StorageServiceServer
- type StorageService_RequestClient
- type StorageService_RequestServer
- type Stream
- type StreamCloser
- type StreamID
- type StreamingOperation
- type Timer
- type UnaryOperation
- type UnimplementedStorageServiceServer
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 SessionResponseCode_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 SessionResponseCode_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 ¶
func GetErrorFromStatus ¶
func GetErrorFromStatus(status SessionResponseStatus) error
GetErrorFromStatus creates a typed error from a response status
func RegisterStorageServiceServer ¶
func RegisterStorageServiceServer(s *grpc.Server, srv StorageServiceServer)
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, Session) ([]byte, error)) // RegisterStreamOperation registers a new primitive operation RegisterStreamOperation(id OperationID, callback func([]byte, Session, Stream) (StreamCloser, error)) // 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 []SessionStreamContext `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams"` }
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() []SessionStreamContext
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(cluster cluster.Cluster, 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 NewServiceFunc ¶
type NewServiceFunc func(scheduler Scheduler, context ServiceContext) Service
NewServiceFunc is a function for creating a primitive service
type Node ¶
Node is an Atomix node
func (*Node) RegisterService ¶
func (n *Node) RegisterService(t string, f NewServiceFunc)
RegisterService registers a primitive service
type OpenSessionRequest ¶
type OpenSessionRequest struct { ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` Timeout *time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"` }
func (*OpenSessionRequest) Descriptor ¶
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
func (*OpenSessionRequest) GetClientID ¶
func (m *OpenSessionRequest) GetClientID() string
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 // ExecuteCommand executes a write request ExecuteCommand(ctx context.Context, input []byte, stream stream.WriteStream) error // ExecuteQuery executes a read request ExecuteQuery(ctx context.Context, input []byte, stream stream.WriteStream) error }
Partition is the interface for a partition client
type PartitionContext ¶
type PartitionContext interface { // 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 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 Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry is the default primitive registry
func (*Registry) GetService ¶
func (r *Registry) GetService(primitiveType string) NewServiceFunc
func (*Registry) GetServices ¶
func (r *Registry) GetServices() []NewServiceFunc
func (*Registry) Register ¶
func (r *Registry) Register(primitiveType string, primitive NewServiceFunc)
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 { // Time returns the current time Time() time.Time // Run executes a function asynchronously Run(f func()) // RunAfter schedules a function to be run once after the given delay RunAfter(d time.Duration, f func()) Timer // RepeatAfter schedules a function to run repeatedly every interval starting after the given delay RepeatAfter(d time.Duration, i time.Duration, f func()) Timer // RunAt schedules a function to be run once after the given delay RunAt(t time.Time, f func()) Timer // RepeatAt schedules a function to run repeatedly every interval starting after the given delay RepeatAt(t time.Time, i time.Duration, f func()) Timer // RunAtIndex schedules a function to run at a specific index RunAtIndex(index Index, f func()) }
Scheduler provides deterministic scheduling for a state machine
type Server ¶
type Server struct {
Protocol Protocol
}
Server is a base server for servers that support sessions
func (*Server) Request ¶
func (s *Server) Request(request *StorageRequest, stream StorageService_RequestServer) error
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"` // 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() string // 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 string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` }
func (*ServiceId) Descriptor ¶
func (*ServiceId) GetCluster ¶ added in v0.6.2
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 string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
}
func (*ServiceMetadataRequest) Descriptor ¶
func (*ServiceMetadataRequest) Descriptor() ([]byte, []int)
func (*ServiceMetadataRequest) GetType ¶
func (m *ServiceMetadataRequest) GetType() string
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 Session ¶
type Session interface { // ID returns the session identifier ID() SessionID // ClientID returns the client identifier ClientID() ClientID // 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"` Command ServiceCommandRequest `protobuf:"bytes,2,opt,name=command,proto3" json:"command"` }
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"` Response ServiceCommandResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response"` }
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 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"` Query ServiceQueryRequest `protobuf:"bytes,2,opt,name=query,proto3" json:"query"` }
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"` Response ServiceQueryResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response"` }
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 { Type SessionResponseType `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.SessionResponseType" json:"type,omitempty"` Status SessionResponseStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status"` // 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) GetStatus ¶
func (m *SessionResponse) GetStatus() SessionResponseStatus
func (*SessionResponse) GetType ¶
func (m *SessionResponse) GetType() SessionResponseType
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 SessionResponseCode ¶
type SessionResponseCode int32
const ( SessionResponseCode_OK SessionResponseCode = 0 SessionResponseCode_ERROR SessionResponseCode = 1 SessionResponseCode_NOT_LEADER SessionResponseCode = 2 SessionResponseCode_UNKNOWN SessionResponseCode = 3 SessionResponseCode_CANCELED SessionResponseCode = 4 SessionResponseCode_NOT_FOUND SessionResponseCode = 5 SessionResponseCode_ALREADY_EXISTS SessionResponseCode = 6 SessionResponseCode_UNAUTHORIZED SessionResponseCode = 7 SessionResponseCode_FORBIDDEN SessionResponseCode = 8 SessionResponseCode_CONFLICT SessionResponseCode = 9 SessionResponseCode_INVALID SessionResponseCode = 10 SessionResponseCode_UNAVAILABLE SessionResponseCode = 11 SessionResponseCode_NOT_SUPPORTED SessionResponseCode = 12 SessionResponseCode_TIMEOUT SessionResponseCode = 13 SessionResponseCode_INTERNAL SessionResponseCode = 14 )
func (SessionResponseCode) EnumDescriptor ¶
func (SessionResponseCode) EnumDescriptor() ([]byte, []int)
func (SessionResponseCode) String ¶
func (x SessionResponseCode) String() string
type SessionResponseContext ¶
type SessionResponseContext struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` StreamID uint64 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` Index uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` Sequence uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"` }
func (*SessionResponseContext) Descriptor ¶
func (*SessionResponseContext) Descriptor() ([]byte, []int)
func (*SessionResponseContext) GetIndex ¶
func (m *SessionResponseContext) GetIndex() uint64
func (*SessionResponseContext) GetSequence ¶
func (m *SessionResponseContext) GetSequence() uint64
func (*SessionResponseContext) GetSessionID ¶
func (m *SessionResponseContext) GetSessionID() uint64
func (*SessionResponseContext) GetStreamID ¶
func (m *SessionResponseContext) GetStreamID() uint64
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 struct { Code SessionResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=atomix.service.SessionResponseCode" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Leader string `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"` }
func (*SessionResponseStatus) Descriptor ¶
func (*SessionResponseStatus) Descriptor() ([]byte, []int)
func (*SessionResponseStatus) GetCode ¶
func (m *SessionResponseStatus) GetCode() SessionResponseCode
func (*SessionResponseStatus) GetLeader ¶
func (m *SessionResponseStatus) GetLeader() string
func (*SessionResponseStatus) GetMessage ¶
func (m *SessionResponseStatus) GetMessage() string
func (*SessionResponseStatus) Marshal ¶
func (m *SessionResponseStatus) Marshal() (dAtA []byte, err error)
func (*SessionResponseStatus) MarshalTo ¶
func (m *SessionResponseStatus) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponseStatus) MarshalToSizedBuffer ¶
func (m *SessionResponseStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponseStatus) ProtoMessage ¶
func (*SessionResponseStatus) ProtoMessage()
func (*SessionResponseStatus) Reset ¶
func (m *SessionResponseStatus) Reset()
func (*SessionResponseStatus) Size ¶
func (m *SessionResponseStatus) Size() (n int)
func (*SessionResponseStatus) String ¶
func (m *SessionResponseStatus) String() string
func (*SessionResponseStatus) Unmarshal ¶
func (m *SessionResponseStatus) Unmarshal(dAtA []byte) error
func (*SessionResponseStatus) XXX_DiscardUnknown ¶
func (m *SessionResponseStatus) XXX_DiscardUnknown()
func (*SessionResponseStatus) XXX_Marshal ¶
func (m *SessionResponseStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionResponseStatus) XXX_Merge ¶
func (m *SessionResponseStatus) XXX_Merge(src proto.Message)
func (*SessionResponseStatus) XXX_Size ¶
func (m *SessionResponseStatus) XXX_Size() int
func (*SessionResponseStatus) XXX_Unmarshal ¶
func (m *SessionResponseStatus) XXX_Unmarshal(b []byte) error
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,5,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,6,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,4,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,3,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,7,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 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 SessionStreamContext ¶
type SessionStreamContext struct { StreamID uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` ResponseID uint64 `protobuf:"varint,2,opt,name=response_id,json=responseId,proto3" json:"response_id,omitempty"` }
func (*SessionStreamContext) Descriptor ¶
func (*SessionStreamContext) Descriptor() ([]byte, []int)
func (*SessionStreamContext) GetResponseID ¶
func (m *SessionStreamContext) GetResponseID() uint64
func (*SessionStreamContext) GetStreamID ¶
func (m *SessionStreamContext) GetStreamID() uint64
func (*SessionStreamContext) Marshal ¶
func (m *SessionStreamContext) Marshal() (dAtA []byte, err error)
func (*SessionStreamContext) MarshalTo ¶
func (m *SessionStreamContext) MarshalTo(dAtA []byte) (int, error)
func (*SessionStreamContext) MarshalToSizedBuffer ¶
func (m *SessionStreamContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionStreamContext) ProtoMessage ¶
func (*SessionStreamContext) ProtoMessage()
func (*SessionStreamContext) Reset ¶
func (m *SessionStreamContext) Reset()
func (*SessionStreamContext) Size ¶
func (m *SessionStreamContext) Size() (n int)
func (*SessionStreamContext) String ¶
func (m *SessionStreamContext) String() string
func (*SessionStreamContext) Unmarshal ¶
func (m *SessionStreamContext) Unmarshal(dAtA []byte) error
func (*SessionStreamContext) XXX_DiscardUnknown ¶
func (m *SessionStreamContext) XXX_DiscardUnknown()
func (*SessionStreamContext) XXX_Marshal ¶
func (m *SessionStreamContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionStreamContext) XXX_Merge ¶
func (m *SessionStreamContext) XXX_Merge(src proto.Message)
func (*SessionStreamContext) XXX_Size ¶
func (m *SessionStreamContext) XXX_Size() int
func (*SessionStreamContext) XXX_Unmarshal ¶
func (m *SessionStreamContext) 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 StorageRequest ¶
type StorageRequest struct { PartitionID uint32 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` Request *SessionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` }
func (*StorageRequest) Descriptor ¶
func (*StorageRequest) Descriptor() ([]byte, []int)
func (*StorageRequest) GetPartitionID ¶
func (m *StorageRequest) GetPartitionID() uint32
func (*StorageRequest) GetRequest ¶
func (m *StorageRequest) GetRequest() *SessionRequest
func (*StorageRequest) Marshal ¶
func (m *StorageRequest) Marshal() (dAtA []byte, err error)
func (*StorageRequest) MarshalToSizedBuffer ¶
func (m *StorageRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageRequest) ProtoMessage ¶
func (*StorageRequest) ProtoMessage()
func (*StorageRequest) Reset ¶
func (m *StorageRequest) Reset()
func (*StorageRequest) Size ¶
func (m *StorageRequest) Size() (n int)
func (*StorageRequest) String ¶
func (m *StorageRequest) String() string
func (*StorageRequest) Unmarshal ¶
func (m *StorageRequest) Unmarshal(dAtA []byte) error
func (*StorageRequest) XXX_DiscardUnknown ¶
func (m *StorageRequest) XXX_DiscardUnknown()
func (*StorageRequest) XXX_Marshal ¶
func (m *StorageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageRequest) XXX_Merge ¶
func (m *StorageRequest) XXX_Merge(src proto.Message)
func (*StorageRequest) XXX_Size ¶
func (m *StorageRequest) XXX_Size() int
func (*StorageRequest) XXX_Unmarshal ¶
func (m *StorageRequest) XXX_Unmarshal(b []byte) error
type StorageResponse ¶
type StorageResponse struct { PartitionID uint32 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` Response *SessionResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` }
func (*StorageResponse) Descriptor ¶
func (*StorageResponse) Descriptor() ([]byte, []int)
func (*StorageResponse) GetPartitionID ¶
func (m *StorageResponse) GetPartitionID() uint32
func (*StorageResponse) GetResponse ¶
func (m *StorageResponse) GetResponse() *SessionResponse
func (*StorageResponse) Marshal ¶
func (m *StorageResponse) Marshal() (dAtA []byte, err error)
func (*StorageResponse) MarshalToSizedBuffer ¶
func (m *StorageResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageResponse) ProtoMessage ¶
func (*StorageResponse) ProtoMessage()
func (*StorageResponse) Reset ¶
func (m *StorageResponse) Reset()
func (*StorageResponse) Size ¶
func (m *StorageResponse) Size() (n int)
func (*StorageResponse) String ¶
func (m *StorageResponse) String() string
func (*StorageResponse) Unmarshal ¶
func (m *StorageResponse) Unmarshal(dAtA []byte) error
func (*StorageResponse) XXX_DiscardUnknown ¶
func (m *StorageResponse) XXX_DiscardUnknown()
func (*StorageResponse) XXX_Marshal ¶
func (m *StorageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageResponse) XXX_Merge ¶
func (m *StorageResponse) XXX_Merge(src proto.Message)
func (*StorageResponse) XXX_Size ¶
func (m *StorageResponse) XXX_Size() int
func (*StorageResponse) XXX_Unmarshal ¶
func (m *StorageResponse) XXX_Unmarshal(b []byte) error
type StorageServiceClient ¶
type StorageServiceClient interface {
Request(ctx context.Context, in *StorageRequest, opts ...grpc.CallOption) (StorageService_RequestClient, error)
}
StorageServiceClient is the client API for StorageService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStorageServiceClient ¶
func NewStorageServiceClient(cc *grpc.ClientConn) StorageServiceClient
type StorageServiceServer ¶
type StorageServiceServer interface {
Request(*StorageRequest, StorageService_RequestServer) error
}
StorageServiceServer is the server API for StorageService service.
type StorageService_RequestClient ¶
type StorageService_RequestClient interface { Recv() (*StorageResponse, error) grpc.ClientStream }
type StorageService_RequestServer ¶
type StorageService_RequestServer interface { Send(*StorageResponse) error grpc.ServerStream }
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 StreamCloser ¶
type StreamCloser func()
StreamCloser is a function to be called when a stream is closed
type StreamingOperation ¶
type StreamingOperation interface { // Execute executes the operation Execute(bytes []byte, session Session, stream Stream) (StreamCloser, error) }
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, session Session) ([]byte, error) }
UnaryOperation is a primitive operation that returns a result
type UnimplementedStorageServiceServer ¶
type UnimplementedStorageServiceServer struct { }
UnimplementedStorageServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedStorageServiceServer) Request ¶
func (*UnimplementedStorageServiceServer) Request(req *StorageRequest, srv StorageService_RequestServer) error
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |