primitive

package

Go to main page

Versions in this module

v0

v0.5.3

Mar 16, 2021

v0.5.2

Feb 19, 2021

v0.5.1

Nov 17, 2020

v0.5.0

Nov 17, 2020

Changes in this version

+ var SessionResponseStatus_name = map[int32]string

+ var SessionResponseStatus_value = map[string]int32

type ServiceType

+ const ServiceType_UNKNOWN_SERVICE

type SessionResponseContext

+ Message string

+ Status SessionResponseStatus

+ func (m *SessionResponseContext) GetMessage() string

+ func (m *SessionResponseContext) GetStatus() SessionResponseStatus

+ type SessionResponseStatus int32

+ const SessionResponseStatus_ALREADY_EXISTS

+ const SessionResponseStatus_CANCELED

+ const SessionResponseStatus_CONFLICT

+ const SessionResponseStatus_ERROR

+ const SessionResponseStatus_FORBIDDEN

+ const SessionResponseStatus_INTERNAL

+ const SessionResponseStatus_INVALID

+ const SessionResponseStatus_NOT_FOUND

+ const SessionResponseStatus_NOT_LEADER

+ const SessionResponseStatus_NOT_SUPPORTED

+ const SessionResponseStatus_OK

+ const SessionResponseStatus_TIMEOUT

+ const SessionResponseStatus_UNAUTHORIZED

+ const SessionResponseStatus_UNAVAILABLE

+ const SessionResponseStatus_UNKNOWN

+ func (SessionResponseStatus) EnumDescriptor() ([]byte, []int)

+ func (x SessionResponseStatus) String() string

v0.4.0

Oct 12, 2020

v0.3.0

Sep 7, 2020

Changes in this version

+ var ErrIntOverflowService = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")

+ var ServiceType_name = map[int32]string

+ var ServiceType_value = map[string]int32

+ var SessionResponseType_name = map[int32]string

+ var SessionResponseType_value = map[string]int32

+ type BackupService interface

+ Backup func(writer io.Writer) error

+ type CloseSessionRequest struct

+ SessionID uint64

+ func (*CloseSessionRequest) Descriptor() ([]byte, []int)

+ func (*CloseSessionRequest) ProtoMessage()

+ 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 (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 struct

+ func (*CloseSessionResponse) Descriptor() ([]byte, []int)

+ func (*CloseSessionResponse) ProtoMessage()

+ 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 (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 interface

+ GetOperation func(id OperationID) Operation

+ RegisterStreamOperation func(id OperationID, callback func([]byte, Stream))

+ RegisterUnaryOperation func(id OperationID, callback func([]byte) ([]byte, error))

+ type Index uint64

+ type KeepAliveRequest struct

+ CommandSequence uint64

+ SessionID uint64

+ Streams map[uint64]uint64

+ func (*KeepAliveRequest) Descriptor() ([]byte, []int)

+ func (*KeepAliveRequest) ProtoMessage()

+ func (m *KeepAliveRequest) GetCommandSequence() uint64

+ func (m *KeepAliveRequest) GetSessionID() uint64

+ func (m *KeepAliveRequest) GetStreams() map[uint64]uint64

+ func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)

+ func (m *KeepAliveRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (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 struct

+ func (*KeepAliveResponse) Descriptor() ([]byte, []int)

+ func (*KeepAliveResponse) ProtoMessage()

+ 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 (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 struct

+ func NewManager(registry Registry, context PartitionContext) *Manager

+ func (m *Manager) Command(bytes []byte, stream streams.WriteStream)

+ func (m *Manager) Install(reader io.Reader) error

+ func (m *Manager) Query(bytes []byte, stream streams.WriteStream)

+ func (m *Manager) Snapshot(writer io.Writer) error

+ type OpenSessionRequest struct

+ Timeout *time.Duration

+ func (*OpenSessionRequest) Descriptor() ([]byte, []int)

+ func (*OpenSessionRequest) ProtoMessage()

+ 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 (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 struct

+ SessionID uint64

+ func (*OpenSessionResponse) Descriptor() ([]byte, []int)

+ func (*OpenSessionResponse) ProtoMessage()

+ 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 (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 interface

+ type OperationID string

+ type Partition interface

+ IsLeader func() bool

+ Leader func() string

+ MustLeader func() bool

+ Read func(ctx context.Context, input []byte, stream stream.WriteStream) error

+ Write func(ctx context.Context, input []byte, stream stream.WriteStream) error

+ type PartitionContext interface

+ Index func() Index

+ PartitionID func() PartitionID

+ Timestamp func() time.Time

+ type PartitionID int

+ type Primitive interface

+ NewService func(scheduler Scheduler, context ServiceContext) Service

+ RegisterServer func(server *grpc.Server, protocol Protocol)

+ type Protocol interface

+ Partition func(partitionID PartitionID) Partition

+ Partitions func() []Partition

+ Start func(cluster cluster.Cluster, registry Registry) error

+ Stop func() error

+ type ProtocolContext interface

+ NodeID func() string

+ type Registry interface

+ GetPrimitive func(primitiveType primitive.PrimitiveType) Primitive

+ GetPrimitives func() []Primitive

+ Register func(primitiveType primitive.PrimitiveType, primitive Primitive)

+ func NewRegistry() Registry

+ type RestoreService interface

+ Restore func(reader io.Reader) error

+ type Scheduler interface

+ Execute func(f func())

+ ScheduleIndex func(index Index, f func())

+ ScheduleOnce func(delay time.Duration, f func()) Timer

+ ScheduleRepeat func(delay time.Duration, interval time.Duration, f func()) Timer

+ type Server struct

+ Protocol Protocol

+ Type ServiceType

+ func (s *Server) DoCloseService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

+ func (s *Server) DoCloseSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

+ func (s *Server) DoCommand(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

+ func (s *Server) DoCommandStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, ...) error

+ func (s *Server) DoCreateService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

+ func (s *Server) DoDeleteService(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

+ func (s *Server) DoKeepAliveSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

+ func (s *Server) DoMetadata(ctx context.Context, serviceType primitive.PrimitiveType, namespace string, ...) ([]*ServiceId, *headers.ResponseHeader, error)

+ func (s *Server) DoOpenSession(ctx context.Context, header *headers.RequestHeader, timeout *time.Duration) (*headers.ResponseHeader, error)

+ func (s *Server) DoQuery(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

+ func (s *Server) DoQueryStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, ...) error

+ type Service interface

+ func NewService(scheduler Scheduler, context ServiceContext) Service

+ type ServiceCloseRequest struct

+ func (*ServiceCloseRequest) Descriptor() ([]byte, []int)

+ func (*ServiceCloseRequest) ProtoMessage()

+ 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 (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 struct

+ func (*ServiceCloseResponse) Descriptor() ([]byte, []int)

+ func (*ServiceCloseResponse) ProtoMessage()

+ 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 (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 struct

+ Request isServiceCommandRequest_Request

+ Service *ServiceId

+ func (*ServiceCommandRequest) Descriptor() ([]byte, []int)

+ func (*ServiceCommandRequest) ProtoMessage()

+ func (*ServiceCommandRequest) XXX_OneofWrappers() []interface{}

+ 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 (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 (m *ServiceCommandRequest) XXX_Size() int

+ func (m *ServiceCommandRequest) XXX_Unmarshal(b []byte) error

+ type ServiceCommandRequest_Close struct

+ Close *ServiceCloseRequest

+ func (m *ServiceCommandRequest_Close) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Close) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Close) Size() (n int)

+ type ServiceCommandRequest_Create struct

+ Create *ServiceCreateRequest

+ func (m *ServiceCommandRequest_Create) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Create) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Create) Size() (n int)

+ type ServiceCommandRequest_Delete struct

+ Delete *ServiceDeleteRequest

+ func (m *ServiceCommandRequest_Delete) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Delete) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Delete) Size() (n int)

+ type ServiceCommandRequest_Operation struct

+ Operation *ServiceOperationRequest

+ func (m *ServiceCommandRequest_Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandRequest_Operation) Size() (n int)

+ type ServiceCommandResponse struct

+ Response isServiceCommandResponse_Response

+ func (*ServiceCommandResponse) Descriptor() ([]byte, []int)

+ func (*ServiceCommandResponse) ProtoMessage()

+ func (*ServiceCommandResponse) XXX_OneofWrappers() []interface{}

+ 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 (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 (m *ServiceCommandResponse) XXX_Size() int

+ func (m *ServiceCommandResponse) XXX_Unmarshal(b []byte) error

+ type ServiceCommandResponse_Close struct

+ Close *ServiceCloseResponse

+ func (m *ServiceCommandResponse_Close) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Close) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Close) Size() (n int)

+ type ServiceCommandResponse_Create struct

+ Create *ServiceCreateResponse

+ func (m *ServiceCommandResponse_Create) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Create) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Create) Size() (n int)

+ type ServiceCommandResponse_Delete struct

+ Delete *ServiceDeleteResponse

+ func (m *ServiceCommandResponse_Delete) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Delete) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Delete) Size() (n int)

+ type ServiceCommandResponse_Operation struct

+ Operation *ServiceOperationResponse

+ func (m *ServiceCommandResponse_Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceCommandResponse_Operation) Size() (n int)

+ type ServiceContext interface

+ CurrentOperation func() OperationID

+ CurrentSession func() Session

+ ServiceID func() ServiceID

+ ServiceType func() ServiceType

+ Session func(id SessionID) Session

+ Sessions func() []Session

+ type ServiceCreateRequest struct

+ func (*ServiceCreateRequest) Descriptor() ([]byte, []int)

+ func (*ServiceCreateRequest) ProtoMessage()

+ 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 (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 struct

+ func (*ServiceCreateResponse) Descriptor() ([]byte, []int)

+ func (*ServiceCreateResponse) ProtoMessage()

+ 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 (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 struct

+ func (*ServiceDeleteRequest) Descriptor() ([]byte, []int)

+ func (*ServiceDeleteRequest) ProtoMessage()

+ 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 (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 struct

+ func (*ServiceDeleteResponse) Descriptor() ([]byte, []int)

+ func (*ServiceDeleteResponse) ProtoMessage()

+ 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 (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 ServiceId

+ type ServiceId struct

+ Name string

+ Namespace string

+ Type ServiceType

+ func (*ServiceId) Descriptor() ([]byte, []int)

+ func (*ServiceId) ProtoMessage()

+ func (m *ServiceId) GetName() string

+ func (m *ServiceId) GetNamespace() string

+ func (m *ServiceId) GetType() ServiceType

+ func (m *ServiceId) Marshal() (dAtA []byte, err error)

+ func (m *ServiceId) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceId) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (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 struct

+ Namespace string

+ Type ServiceType

+ func (*ServiceMetadataRequest) Descriptor() ([]byte, []int)

+ func (*ServiceMetadataRequest) ProtoMessage()

+ func (m *ServiceMetadataRequest) GetNamespace() string

+ func (m *ServiceMetadataRequest) GetType() ServiceType

+ func (m *ServiceMetadataRequest) Marshal() (dAtA []byte, err error)

+ func (m *ServiceMetadataRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (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 struct

+ Services []*ServiceId

+ func (*ServiceMetadataResponse) Descriptor() ([]byte, []int)

+ func (*ServiceMetadataResponse) ProtoMessage()

+ 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 (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 struct

+ Method string

+ Value []byte

+ func (*ServiceOperationRequest) Descriptor() ([]byte, []int)

+ func (*ServiceOperationRequest) ProtoMessage()

+ 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 (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 struct

+ Result []byte

+ func (*ServiceOperationResponse) Descriptor() ([]byte, []int)

+ func (*ServiceOperationResponse) ProtoMessage()

+ 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 (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 struct

+ Request isServiceQueryRequest_Request

+ Service *ServiceId

+ func (*ServiceQueryRequest) Descriptor() ([]byte, []int)

+ func (*ServiceQueryRequest) ProtoMessage()

+ func (*ServiceQueryRequest) XXX_OneofWrappers() []interface{}

+ 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 (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 (m *ServiceQueryRequest) XXX_Size() int

+ func (m *ServiceQueryRequest) XXX_Unmarshal(b []byte) error

+ type ServiceQueryRequest_Metadata struct

+ Metadata *ServiceMetadataRequest

+ func (m *ServiceQueryRequest_Metadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceQueryRequest_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceQueryRequest_Metadata) Size() (n int)

+ type ServiceQueryRequest_Operation struct

+ Operation *ServiceOperationRequest

+ func (m *ServiceQueryRequest_Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceQueryRequest_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceQueryRequest_Operation) Size() (n int)

+ type ServiceQueryResponse struct

+ Response isServiceQueryResponse_Response

+ func (*ServiceQueryResponse) Descriptor() ([]byte, []int)

+ func (*ServiceQueryResponse) ProtoMessage()

+ func (*ServiceQueryResponse) XXX_OneofWrappers() []interface{}

+ 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 (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 (m *ServiceQueryResponse) XXX_Size() int

+ func (m *ServiceQueryResponse) XXX_Unmarshal(b []byte) error

+ type ServiceQueryResponse_Metadata struct

+ Metadata *ServiceMetadataResponse

+ func (m *ServiceQueryResponse_Metadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceQueryResponse_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceQueryResponse_Metadata) Size() (n int)

+ type ServiceQueryResponse_Operation struct

+ Operation *ServiceOperationResponse

+ func (m *ServiceQueryResponse_Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *ServiceQueryResponse_Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ServiceQueryResponse_Operation) Size() (n int)

+ type ServiceType int32

+ const ServiceType_COUNTER

+ const ServiceType_ELECTION

+ const ServiceType_INDEXED_MAP

+ const ServiceType_LEADER_LATCH

+ const ServiceType_LIST

+ const ServiceType_LOCK

+ const ServiceType_LOG

+ const ServiceType_MAP

+ const ServiceType_SET

+ const ServiceType_UNKNOWN

+ const ServiceType_VALUE

+ func (ServiceType) EnumDescriptor() ([]byte, []int)

+ func (x ServiceType) String() string

+ type Session interface

+ ID func() SessionID

+ Stream func(id StreamID) Stream

+ Streams func() []Stream

+ StreamsOf func(op OperationID) []Stream

+ type SessionClosedService interface

+ SessionClosed func(Session)

+ type SessionCommandContext struct

+ SequenceNumber uint64

+ SessionID uint64

+ func (*SessionCommandContext) Descriptor() ([]byte, []int)

+ func (*SessionCommandContext) ProtoMessage()

+ 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 (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 struct

+ Command *ServiceCommandRequest

+ Context *SessionCommandContext

+ func (*SessionCommandRequest) Descriptor() ([]byte, []int)

+ func (*SessionCommandRequest) ProtoMessage()

+ 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 (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 struct

+ Context *SessionResponseContext

+ Response *ServiceCommandResponse

+ func (*SessionCommandResponse) Descriptor() ([]byte, []int)

+ func (*SessionCommandResponse) ProtoMessage()

+ 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 (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 interface

+ SessionExpired func(Session)

+ type SessionID uint64

+ type SessionOpenService interface

+ SessionOpen func(Session)

+ type SessionOutput struct

+ Header *headers.ResponseHeader

+ type SessionQueryContext struct

+ LastIndex uint64

+ LastSequenceNumber uint64

+ SessionID uint64

+ func (*SessionQueryContext) Descriptor() ([]byte, []int)

+ func (*SessionQueryContext) ProtoMessage()

+ 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 (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 struct

+ Context *SessionQueryContext

+ Query *ServiceQueryRequest

+ func (*SessionQueryRequest) Descriptor() ([]byte, []int)

+ func (*SessionQueryRequest) ProtoMessage()

+ 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 (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 struct

+ Context *SessionResponseContext

+ Response *ServiceQueryResponse

+ func (*SessionQueryResponse) Descriptor() ([]byte, []int)

+ func (*SessionQueryResponse) ProtoMessage()

+ 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 (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 struct

+ Request isSessionRequest_Request

+ func (*SessionRequest) Descriptor() ([]byte, []int)

+ func (*SessionRequest) ProtoMessage()

+ func (*SessionRequest) XXX_OneofWrappers() []interface{}

+ 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 (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 (m *SessionRequest) XXX_Size() int

+ func (m *SessionRequest) XXX_Unmarshal(b []byte) error

+ type SessionRequest_CloseSession struct

+ CloseSession *CloseSessionRequest

+ func (m *SessionRequest_CloseSession) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionRequest_CloseSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionRequest_CloseSession) Size() (n int)

+ type SessionRequest_Command struct

+ Command *SessionCommandRequest

+ func (m *SessionRequest_Command) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionRequest_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionRequest_Command) Size() (n int)

+ type SessionRequest_KeepAlive struct

+ KeepAlive *KeepAliveRequest

+ func (m *SessionRequest_KeepAlive) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionRequest_KeepAlive) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionRequest_KeepAlive) Size() (n int)

+ type SessionRequest_OpenSession struct

+ OpenSession *OpenSessionRequest

+ func (m *SessionRequest_OpenSession) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionRequest_OpenSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionRequest_OpenSession) Size() (n int)

+ type SessionRequest_Query struct

+ Query *SessionQueryRequest

+ func (m *SessionRequest_Query) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionRequest_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionRequest_Query) Size() (n int)

+ type SessionResponse struct

+ Response isSessionResponse_Response

+ func (*SessionResponse) Descriptor() ([]byte, []int)

+ func (*SessionResponse) ProtoMessage()

+ func (*SessionResponse) XXX_OneofWrappers() []interface{}

+ func (m *SessionResponse) GetCloseSession() *CloseSessionResponse

+ func (m *SessionResponse) GetCommand() *SessionCommandResponse

+ func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse

+ func (m *SessionResponse) GetOpenSession() *OpenSessionResponse

+ func (m *SessionResponse) GetQuery() *SessionQueryResponse

+ func (m *SessionResponse) GetResponse() isSessionResponse_Response

+ func (m *SessionResponse) Marshal() (dAtA []byte, err error)

+ func (m *SessionResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (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 (m *SessionResponse) XXX_Size() int

+ func (m *SessionResponse) XXX_Unmarshal(b []byte) error

+ type SessionResponseContext struct

+ Index uint64

+ Sequence uint64

+ StreamID uint64

+ Type SessionResponseType

+ func (*SessionResponseContext) Descriptor() ([]byte, []int)

+ func (*SessionResponseContext) ProtoMessage()

+ func (m *SessionResponseContext) GetIndex() uint64

+ func (m *SessionResponseContext) GetSequence() uint64

+ func (m *SessionResponseContext) GetStreamID() uint64

+ func (m *SessionResponseContext) GetType() SessionResponseType

+ func (m *SessionResponseContext) Marshal() (dAtA []byte, err error)

+ func (m *SessionResponseContext) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponseContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (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 SessionResponseType int32

+ const SessionResponseType_CLOSE_STREAM

+ const SessionResponseType_OPEN_STREAM

+ const SessionResponseType_RESPONSE

+ func (SessionResponseType) EnumDescriptor() ([]byte, []int)

+ func (x SessionResponseType) String() string

+ type SessionResponse_CloseSession struct

+ CloseSession *CloseSessionResponse

+ func (m *SessionResponse_CloseSession) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponse_CloseSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionResponse_CloseSession) Size() (n int)

+ type SessionResponse_Command struct

+ Command *SessionCommandResponse

+ func (m *SessionResponse_Command) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponse_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionResponse_Command) Size() (n int)

+ type SessionResponse_KeepAlive struct

+ KeepAlive *KeepAliveResponse

+ func (m *SessionResponse_KeepAlive) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponse_KeepAlive) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionResponse_KeepAlive) Size() (n int)

+ type SessionResponse_OpenSession struct

+ OpenSession *OpenSessionResponse

+ func (m *SessionResponse_OpenSession) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponse_OpenSession) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionResponse_OpenSession) Size() (n int)

+ type SessionResponse_Query struct

+ Query *SessionQueryResponse

+ func (m *SessionResponse_Query) MarshalTo(dAtA []byte) (int, error)

+ func (m *SessionResponse_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SessionResponse_Query) Size() (n int)

+ type SessionServer struct

+ func (s *SessionServer) CloseSession(ctx context.Context, request *api.CloseSessionRequest) (*api.CloseSessionResponse, error)

+ func (s *SessionServer) KeepAlive(ctx context.Context, request *api.KeepAliveRequest) (*api.KeepAliveResponse, error)

+ func (s *SessionServer) OpenSession(ctx context.Context, request *api.OpenSessionRequest) (*api.OpenSessionResponse, error)

+ type SessionServiceSnapshot struct

+ ServiceId ServiceId

+ Streams []*SessionStreamSnapshot

+ func (*SessionServiceSnapshot) Descriptor() ([]byte, []int)

+ func (*SessionServiceSnapshot) ProtoMessage()

+ 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 (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 struct

+ CommandSequence uint64

+ Services []*SessionServiceSnapshot

+ SessionID uint64

+ Timeout time.Duration

+ Timestamp time.Time

+ func (*SessionSnapshot) Descriptor() ([]byte, []int)

+ func (*SessionSnapshot) ProtoMessage()

+ 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 (m *SessionSnapshot) Reset()

+ func (m *SessionSnapshot) Size() (n int)

+ func (m *SessionSnapshot) String() string

+ func (m *SessionSnapshot) Unmarshal(dAtA []byte) error

+ func (m *SessionSnapshot) XXX_DiscardUnknown()

+ func (m *SessionSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SessionSnapshot) XXX_Merge(src proto.Message)

+ func (m *SessionSnapshot) XXX_Size() int

+ func (m *SessionSnapshot) XXX_Unmarshal(b []byte) error

+ type SessionStreamSnapshot struct

+ LastCompleted uint64

+ SequenceNumber uint64

+ StreamId uint64

+ Type string

+ func (*SessionStreamSnapshot) Descriptor() ([]byte, []int)

+ func (*SessionStreamSnapshot) ProtoMessage()

+ 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 (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 interface

+ Command func(bytes []byte, stream streams.WriteStream)

+ Install func(reader io.Reader) error

+ Query func(bytes []byte, stream streams.WriteStream)

+ Snapshot func(writer io.Writer) error

+ type Stream interface

+ ID func() StreamID

+ OperationID func() OperationID

+ Session func() Session

+ type StreamID uint64

+ type StreamingOperation interface

+ Execute func(bytes []byte, stream Stream)

+ type Timer interface

+ Cancel func()

+ type UnaryOperation interface

+ Execute func(bytes []byte) ([]byte, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL