Documentation ¶
Index ¶
- Variables
- 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 CommandRequest
- func (*CommandRequest) Descriptor() ([]byte, []int)
- func (m *CommandRequest) GetCommand() []byte
- func (m *CommandRequest) GetContext() *RequestContext
- func (m *CommandRequest) GetName() string
- func (m *CommandRequest) Marshal() (dAtA []byte, err error)
- func (m *CommandRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandRequest) ProtoMessage()
- func (m *CommandRequest) Reset()
- func (m *CommandRequest) Size() (n int)
- func (m *CommandRequest) String() string
- func (m *CommandRequest) Unmarshal(dAtA []byte) error
- func (m *CommandRequest) XXX_DiscardUnknown()
- func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandRequest) XXX_Merge(src proto.Message)
- func (m *CommandRequest) XXX_Size() int
- func (m *CommandRequest) XXX_Unmarshal(b []byte) error
- type CommandResponse
- func (*CommandResponse) Descriptor() ([]byte, []int)
- func (m *CommandResponse) GetContext() *ResponseContext
- func (m *CommandResponse) GetOutput() []byte
- func (m *CommandResponse) Marshal() (dAtA []byte, err error)
- func (m *CommandResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandResponse) ProtoMessage()
- func (m *CommandResponse) Reset()
- func (m *CommandResponse) Size() (n int)
- func (m *CommandResponse) String() string
- func (m *CommandResponse) Unmarshal(dAtA []byte) error
- func (m *CommandResponse) XXX_DiscardUnknown()
- func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandResponse) XXX_Merge(src proto.Message)
- func (m *CommandResponse) XXX_Size() int
- func (m *CommandResponse) XXX_Unmarshal(b []byte) error
- type Context
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) Size() (n int)
- func (m *CreateRequest) String() string
- func (m *CreateRequest) Unmarshal(dAtA []byte) error
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) Size() (n int)
- func (m *CreateResponse) String() string
- func (m *CreateResponse) Unmarshal(dAtA []byte) error
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) Size() (n int)
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteRequest) XXX_DiscardUnknown()
- func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRequest) XXX_Size() int
- func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
- func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) Size() (n int)
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) Unmarshal(dAtA []byte) error
- func (m *DeleteResponse) XXX_DiscardUnknown()
- func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteResponse) XXX_Merge(src proto.Message)
- func (m *DeleteResponse) XXX_Size() int
- func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
- type Executor
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetValue() string
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type KeepAliveRequest
- func (*KeepAliveRequest) Descriptor() ([]byte, []int)
- func (m *KeepAliveRequest) GetCommandSequence() uint64
- func (m *KeepAliveRequest) GetSessionID() uint64
- func (m *KeepAliveRequest) GetStreams() map[uint64]uint64
- func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveRequest) ProtoMessage()
- func (m *KeepAliveRequest) Reset()
- func (m *KeepAliveRequest) Size() (n int)
- func (m *KeepAliveRequest) String() string
- func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
- func (m *KeepAliveRequest) XXX_DiscardUnknown()
- func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
- func (m *KeepAliveRequest) XXX_Size() int
- func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
- type KeepAliveResponse
- func (*KeepAliveResponse) Descriptor() ([]byte, []int)
- func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
- func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeepAliveResponse) ProtoMessage()
- func (m *KeepAliveResponse) Reset()
- func (m *KeepAliveResponse) Size() (n int)
- func (m *KeepAliveResponse) String() string
- func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
- func (m *KeepAliveResponse) XXX_DiscardUnknown()
- func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
- func (m *KeepAliveResponse) XXX_Size() int
- func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
- type MetadataRequest
- func (*MetadataRequest) Descriptor() ([]byte, []int)
- func (m *MetadataRequest) GetNamespace() string
- func (m *MetadataRequest) GetType() string
- func (m *MetadataRequest) Marshal() (dAtA []byte, err error)
- func (m *MetadataRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MetadataRequest) ProtoMessage()
- func (m *MetadataRequest) Reset()
- func (m *MetadataRequest) Size() (n int)
- func (m *MetadataRequest) String() string
- func (m *MetadataRequest) Unmarshal(dAtA []byte) error
- func (m *MetadataRequest) XXX_DiscardUnknown()
- func (m *MetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetadataRequest) XXX_Merge(src proto.Message)
- func (m *MetadataRequest) XXX_Size() int
- func (m *MetadataRequest) XXX_Unmarshal(b []byte) error
- type MetadataResponse
- func (*MetadataResponse) Descriptor() ([]byte, []int)
- func (m *MetadataResponse) GetServices() []*ServiceId
- func (m *MetadataResponse) Marshal() (dAtA []byte, err error)
- func (m *MetadataResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MetadataResponse) ProtoMessage()
- func (m *MetadataResponse) Reset()
- func (m *MetadataResponse) Size() (n int)
- func (m *MetadataResponse) String() string
- func (m *MetadataResponse) Unmarshal(dAtA []byte) error
- func (m *MetadataResponse) XXX_DiscardUnknown()
- func (m *MetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetadataResponse) XXX_Merge(src proto.Message)
- func (m *MetadataResponse) XXX_Size() int
- func (m *MetadataResponse) XXX_Unmarshal(b []byte) error
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)
- func (m *OpenSessionRequest) GetTimeout() *time.Duration
- func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionRequest) ProtoMessage()
- func (m *OpenSessionRequest) Reset()
- func (m *OpenSessionRequest) Size() (n int)
- func (m *OpenSessionRequest) String() string
- func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
- func (m *OpenSessionRequest) XXX_DiscardUnknown()
- func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
- func (m *OpenSessionRequest) XXX_Size() int
- func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)
- func (m *OpenSessionResponse) GetSessionID() uint64
- func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
- func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenSessionResponse) ProtoMessage()
- func (m *OpenSessionResponse) Reset()
- func (m *OpenSessionResponse) Size() (n int)
- func (m *OpenSessionResponse) String() string
- func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
- func (m *OpenSessionResponse) XXX_DiscardUnknown()
- func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
- func (m *OpenSessionResponse) XXX_Size() int
- func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
- type Operation
- type OperationType
- type PrimitiveEvent
- func (*PrimitiveEvent) Descriptor() ([]byte, []int)
- func (m *PrimitiveEvent) GetType() string
- func (m *PrimitiveEvent) GetValue() []byte
- func (m *PrimitiveEvent) Marshal() (dAtA []byte, err error)
- func (m *PrimitiveEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *PrimitiveEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrimitiveEvent) ProtoMessage()
- func (m *PrimitiveEvent) Reset()
- func (m *PrimitiveEvent) Size() (n int)
- func (m *PrimitiveEvent) String() string
- func (m *PrimitiveEvent) Unmarshal(dAtA []byte) error
- func (m *PrimitiveEvent) XXX_DiscardUnknown()
- func (m *PrimitiveEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimitiveEvent) XXX_Merge(src proto.Message)
- func (m *PrimitiveEvent) XXX_Size() int
- func (m *PrimitiveEvent) XXX_Unmarshal(b []byte) error
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (m *QueryRequest) GetContext() *RequestContext
- func (m *QueryRequest) GetName() string
- func (m *QueryRequest) GetQuery() []byte
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- func (m *QueryRequest) XXX_DiscardUnknown()
- func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryRequest) XXX_Merge(src proto.Message)
- func (m *QueryRequest) XXX_Size() int
- func (m *QueryRequest) XXX_Unmarshal(b []byte) error
- type QueryResponse
- func (*QueryResponse) Descriptor() ([]byte, []int)
- func (m *QueryResponse) GetContext() *ResponseContext
- func (m *QueryResponse) GetOutput() []byte
- func (m *QueryResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryResponse) ProtoMessage()
- func (m *QueryResponse) Reset()
- func (m *QueryResponse) Size() (n int)
- func (m *QueryResponse) String() string
- func (m *QueryResponse) Unmarshal(dAtA []byte) error
- func (m *QueryResponse) XXX_DiscardUnknown()
- func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryResponse) XXX_Merge(src proto.Message)
- func (m *QueryResponse) XXX_Size() int
- func (m *QueryResponse) XXX_Unmarshal(b []byte) error
- type RequestContext
- func (*RequestContext) Descriptor() ([]byte, []int)
- func (m *RequestContext) GetIndex() uint64
- func (m *RequestContext) Marshal() (dAtA []byte, err error)
- func (m *RequestContext) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestContext) ProtoMessage()
- func (m *RequestContext) Reset()
- func (m *RequestContext) Size() (n int)
- func (m *RequestContext) String() string
- func (m *RequestContext) Unmarshal(dAtA []byte) error
- func (m *RequestContext) XXX_DiscardUnknown()
- func (m *RequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestContext) XXX_Merge(src proto.Message)
- func (m *RequestContext) XXX_Size() int
- func (m *RequestContext) XXX_Unmarshal(b []byte) error
- type ResponseContext
- func (*ResponseContext) Descriptor() ([]byte, []int)
- func (m *ResponseContext) GetIndex() uint64
- func (m *ResponseContext) GetType() ResponseType
- func (m *ResponseContext) Marshal() (dAtA []byte, err error)
- func (m *ResponseContext) MarshalTo(dAtA []byte) (int, error)
- func (m *ResponseContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResponseContext) ProtoMessage()
- func (m *ResponseContext) Reset()
- func (m *ResponseContext) Size() (n int)
- func (m *ResponseContext) String() string
- func (m *ResponseContext) Unmarshal(dAtA []byte) error
- func (m *ResponseContext) XXX_DiscardUnknown()
- func (m *ResponseContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseContext) XXX_Merge(src proto.Message)
- func (m *ResponseContext) XXX_Size() int
- func (m *ResponseContext) XXX_Unmarshal(b []byte) error
- type ResponseType
- type Scheduler
- type Service
- type ServiceId
- func (*ServiceId) Descriptor() ([]byte, []int)
- func (m *ServiceId) GetName() string
- func (m *ServiceId) GetNamespace() 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 ServiceRequest
- func (*ServiceRequest) Descriptor() ([]byte, []int)
- func (m *ServiceRequest) GetCommand() []byte
- func (m *ServiceRequest) GetCreate() *CreateRequest
- func (m *ServiceRequest) GetDelete() *DeleteRequest
- func (m *ServiceRequest) GetId() *ServiceId
- func (m *ServiceRequest) GetMetadata() *MetadataRequest
- func (m *ServiceRequest) GetQuery() []byte
- func (m *ServiceRequest) GetRequest() isServiceRequest_Request
- func (m *ServiceRequest) Marshal() (dAtA []byte, err error)
- func (m *ServiceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceRequest) ProtoMessage()
- func (m *ServiceRequest) Reset()
- func (m *ServiceRequest) Size() (n int)
- func (m *ServiceRequest) String() string
- func (m *ServiceRequest) Unmarshal(dAtA []byte) error
- func (m *ServiceRequest) XXX_DiscardUnknown()
- func (m *ServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceRequest) XXX_Merge(src proto.Message)
- func (*ServiceRequest) XXX_OneofWrappers() []interface{}
- func (m *ServiceRequest) XXX_Size() int
- func (m *ServiceRequest) XXX_Unmarshal(b []byte) error
- type ServiceRequest_Command
- type ServiceRequest_Create
- type ServiceRequest_Delete
- type ServiceRequest_Metadata
- type ServiceRequest_Query
- type ServiceResponse
- func (*ServiceResponse) Descriptor() ([]byte, []int)
- func (m *ServiceResponse) GetCommand() []byte
- func (m *ServiceResponse) GetCreate() *CreateResponse
- func (m *ServiceResponse) GetDelete() *DeleteResponse
- func (m *ServiceResponse) GetMetadata() *MetadataResponse
- func (m *ServiceResponse) GetQuery() []byte
- func (m *ServiceResponse) GetResponse() isServiceResponse_Response
- func (m *ServiceResponse) Marshal() (dAtA []byte, err error)
- func (m *ServiceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceResponse) ProtoMessage()
- func (m *ServiceResponse) Reset()
- func (m *ServiceResponse) Size() (n int)
- func (m *ServiceResponse) String() string
- func (m *ServiceResponse) Unmarshal(dAtA []byte) error
- func (m *ServiceResponse) XXX_DiscardUnknown()
- func (m *ServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceResponse) XXX_Merge(src proto.Message)
- func (*ServiceResponse) XXX_OneofWrappers() []interface{}
- func (m *ServiceResponse) XXX_Size() int
- func (m *ServiceResponse) XXX_Unmarshal(b []byte) error
- type ServiceResponse_Command
- type ServiceResponse_Create
- type ServiceResponse_Delete
- type ServiceResponse_Metadata
- type ServiceResponse_Query
- type ServiceSnapshot
- func (*ServiceSnapshot) Descriptor() ([]byte, []int)
- func (m *ServiceSnapshot) GetIndex() uint64
- func (m *ServiceSnapshot) GetSnapshot() []byte
- func (m *ServiceSnapshot) Marshal() (dAtA []byte, err error)
- func (m *ServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceSnapshot) ProtoMessage()
- func (m *ServiceSnapshot) Reset()
- func (m *ServiceSnapshot) Size() (n int)
- func (m *ServiceSnapshot) String() string
- func (m *ServiceSnapshot) Unmarshal(dAtA []byte) error
- func (m *ServiceSnapshot) XXX_DiscardUnknown()
- func (m *ServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceSnapshot) XXX_Merge(src proto.Message)
- func (m *ServiceSnapshot) XXX_Size() int
- func (m *ServiceSnapshot) XXX_Unmarshal(b []byte) error
- type Session
- 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) GetContext() *SessionCommandContext
- func (m *SessionCommandRequest) GetInput() []byte
- func (m *SessionCommandRequest) GetName() string
- 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) GetOutput() []byte
- 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 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) GetInput() []byte
- func (m *SessionQueryRequest) GetName() string
- 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) GetOutput() []byte
- func (m *SessionQueryResponse) Marshal() (dAtA []byte, err error)
- func (m *SessionQueryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionQueryResponse) ProtoMessage()
- func (m *SessionQueryResponse) Reset()
- func (m *SessionQueryResponse) Size() (n int)
- func (m *SessionQueryResponse) String() string
- func (m *SessionQueryResponse) Unmarshal(dAtA []byte) error
- func (m *SessionQueryResponse) XXX_DiscardUnknown()
- func (m *SessionQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionQueryResponse) XXX_Merge(src proto.Message)
- func (m *SessionQueryResponse) XXX_Size() int
- func (m *SessionQueryResponse) XXX_Unmarshal(b []byte) error
- type SessionRequest
- func (*SessionRequest) Descriptor() ([]byte, []int)
- func (m *SessionRequest) GetCloseSession() *CloseSessionRequest
- func (m *SessionRequest) GetCommand() *SessionCommandRequest
- func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest
- func (m *SessionRequest) GetOpenSession() *OpenSessionRequest
- func (m *SessionRequest) GetQuery() *SessionQueryRequest
- func (m *SessionRequest) GetRequest() isSessionRequest_Request
- func (m *SessionRequest) Marshal() (dAtA []byte, err error)
- func (m *SessionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionRequest) ProtoMessage()
- func (m *SessionRequest) Reset()
- func (m *SessionRequest) Size() (n int)
- func (m *SessionRequest) String() string
- func (m *SessionRequest) Unmarshal(dAtA []byte) error
- func (m *SessionRequest) XXX_DiscardUnknown()
- func (m *SessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionRequest) XXX_Merge(src proto.Message)
- func (*SessionRequest) XXX_OneofWrappers() []interface{}
- func (m *SessionRequest) XXX_Size() int
- func (m *SessionRequest) XXX_Unmarshal(b []byte) error
- type SessionRequest_CloseSession
- type SessionRequest_Command
- type SessionRequest_KeepAlive
- type SessionRequest_OpenSession
- type SessionRequest_Query
- type SessionResponse
- func (*SessionResponse) Descriptor() ([]byte, []int)
- func (m *SessionResponse) GetCloseSession() *CloseSessionResponse
- func (m *SessionResponse) GetCommand() *SessionCommandResponse
- func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse
- func (m *SessionResponse) GetOpenSession() *OpenSessionResponse
- func (m *SessionResponse) GetQuery() *SessionQueryResponse
- func (m *SessionResponse) GetResponse() isSessionResponse_Response
- func (m *SessionResponse) Marshal() (dAtA []byte, err error)
- func (m *SessionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionResponse) ProtoMessage()
- func (m *SessionResponse) Reset()
- func (m *SessionResponse) Size() (n int)
- func (m *SessionResponse) String() string
- func (m *SessionResponse) Unmarshal(dAtA []byte) error
- func (m *SessionResponse) XXX_DiscardUnknown()
- func (m *SessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionResponse) XXX_Merge(src proto.Message)
- func (*SessionResponse) XXX_OneofWrappers() []interface{}
- func (m *SessionResponse) XXX_Size() int
- func (m *SessionResponse) XXX_Unmarshal(b []byte) error
- type SessionResponseContext
- func (*SessionResponseContext) Descriptor() ([]byte, []int)
- func (m *SessionResponseContext) GetIndex() uint64
- func (m *SessionResponseContext) GetSequence() uint64
- func (m *SessionResponseContext) GetStreamID() uint64
- func (m *SessionResponseContext) GetType() ResponseType
- 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 SessionResponse_CloseSession
- type SessionResponse_Command
- type SessionResponse_KeepAlive
- type SessionResponse_OpenSession
- type SessionResponse_Query
- type SessionSnapshot
- func (*SessionSnapshot) Descriptor() ([]byte, []int)
- func (m *SessionSnapshot) GetCommandSequence() uint64
- func (m *SessionSnapshot) GetLastApplied() uint64
- func (m *SessionSnapshot) GetSessionID() uint64
- func (m *SessionSnapshot) GetStreams() []*SessionStreamSnapshot
- func (m *SessionSnapshot) GetTimeout() time.Duration
- func (m *SessionSnapshot) GetTimestamp() time.Time
- func (m *SessionSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SessionSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionSnapshot) ProtoMessage()
- func (m *SessionSnapshot) Reset()
- func (m *SessionSnapshot) Size() (n int)
- func (m *SessionSnapshot) String() string
- func (m *SessionSnapshot) Unmarshal(dAtA []byte) error
- func (m *SessionSnapshot) XXX_DiscardUnknown()
- func (m *SessionSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionSnapshot) XXX_Merge(src proto.Message)
- func (m *SessionSnapshot) XXX_Size() int
- func (m *SessionSnapshot) XXX_Unmarshal(b []byte) error
- type SessionStreamSnapshot
- func (*SessionStreamSnapshot) Descriptor() ([]byte, []int)
- func (m *SessionStreamSnapshot) GetLastCompleted() uint64
- func (m *SessionStreamSnapshot) GetSequenceNumber() uint64
- func (m *SessionStreamSnapshot) GetStreamId() uint64
- func (m *SessionStreamSnapshot) GetType() string
- func (m *SessionStreamSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SessionStreamSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionStreamSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionStreamSnapshot) ProtoMessage()
- func (m *SessionStreamSnapshot) Reset()
- func (m *SessionStreamSnapshot) Size() (n int)
- func (m *SessionStreamSnapshot) String() string
- func (m *SessionStreamSnapshot) Unmarshal(dAtA []byte) error
- func (m *SessionStreamSnapshot) XXX_DiscardUnknown()
- func (m *SessionStreamSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionStreamSnapshot) XXX_Merge(src proto.Message)
- func (m *SessionStreamSnapshot) XXX_Size() int
- func (m *SessionStreamSnapshot) XXX_Unmarshal(b []byte) error
- type SessionizedService
- func (s *SessionizedService) CanDelete(index uint64) bool
- func (s *SessionizedService) Command(bytes []byte, stream streams.WriteStream)
- func (s *SessionizedService) Install(reader io.Reader) error
- func (s *SessionizedService) OnClose(f func(*Session))
- func (s *SessionizedService) OnExpire(f func(*Session))
- func (s *SessionizedService) OnOpen(f func(*Session))
- func (s *SessionizedService) Query(bytes []byte, stream streams.WriteStream)
- func (s *SessionizedService) Session() *Session
- func (s *SessionizedService) Sessions() map[uint64]*Session
- func (s *SessionizedService) Snapshot(writer io.Writer) error
- type SessionizedServiceSnapshot
- func (*SessionizedServiceSnapshot) Descriptor() ([]byte, []int)
- func (m *SessionizedServiceSnapshot) GetIndex() uint64
- func (m *SessionizedServiceSnapshot) GetSessions() []*SessionSnapshot
- func (m *SessionizedServiceSnapshot) GetTimestamp() uint64
- func (m *SessionizedServiceSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SessionizedServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SessionizedServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SessionizedServiceSnapshot) ProtoMessage()
- func (m *SessionizedServiceSnapshot) Reset()
- func (m *SessionizedServiceSnapshot) Size() (n int)
- func (m *SessionizedServiceSnapshot) String() string
- func (m *SessionizedServiceSnapshot) Unmarshal(dAtA []byte) error
- func (m *SessionizedServiceSnapshot) XXX_DiscardUnknown()
- func (m *SessionizedServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SessionizedServiceSnapshot) XXX_Merge(src proto.Message)
- func (m *SessionizedServiceSnapshot) XXX_Size() int
- func (m *SessionizedServiceSnapshot) XXX_Unmarshal(b []byte) error
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)
- func (m *SetRequest) GetValue() string
- func (m *SetRequest) Marshal() (dAtA []byte, err error)
- func (m *SetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetRequest) ProtoMessage()
- func (m *SetRequest) Reset()
- func (m *SetRequest) Size() (n int)
- func (m *SetRequest) String() string
- func (m *SetRequest) Unmarshal(dAtA []byte) error
- func (m *SetRequest) XXX_DiscardUnknown()
- func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetRequest) XXX_Merge(src proto.Message)
- func (m *SetRequest) XXX_Size() int
- func (m *SetRequest) XXX_Unmarshal(b []byte) error
- type SetResponse
- func (*SetResponse) Descriptor() ([]byte, []int)
- func (m *SetResponse) Marshal() (dAtA []byte, err error)
- func (m *SetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetResponse) ProtoMessage()
- func (m *SetResponse) Reset()
- func (m *SetResponse) Size() (n int)
- func (m *SetResponse) String() string
- func (m *SetResponse) Unmarshal(dAtA []byte) error
- func (m *SetResponse) XXX_DiscardUnknown()
- func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetResponse) XXX_Merge(src proto.Message)
- func (m *SetResponse) XXX_Size() int
- func (m *SetResponse) XXX_Unmarshal(b []byte) error
- type SimpleService
- type SimpleServiceSnapshot
- func (*SimpleServiceSnapshot) Descriptor() ([]byte, []int)
- func (m *SimpleServiceSnapshot) GetIndex() int64
- func (m *SimpleServiceSnapshot) GetTimestamp() *time.Time
- func (m *SimpleServiceSnapshot) Marshal() (dAtA []byte, err error)
- func (m *SimpleServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *SimpleServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SimpleServiceSnapshot) ProtoMessage()
- func (m *SimpleServiceSnapshot) Reset()
- func (m *SimpleServiceSnapshot) Size() (n int)
- func (m *SimpleServiceSnapshot) String() string
- func (m *SimpleServiceSnapshot) Unmarshal(dAtA []byte) error
- func (m *SimpleServiceSnapshot) XXX_DiscardUnknown()
- func (m *SimpleServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SimpleServiceSnapshot) XXX_Merge(src proto.Message)
- func (m *SimpleServiceSnapshot) XXX_Size() int
- func (m *SimpleServiceSnapshot) XXX_Unmarshal(b []byte) error
- type StreamingOperation
- type TestService
- type TestValueSnapshot
- func (*TestValueSnapshot) Descriptor() ([]byte, []int)
- func (m *TestValueSnapshot) GetValue() string
- func (m *TestValueSnapshot) Marshal() (dAtA []byte, err error)
- func (m *TestValueSnapshot) MarshalTo(dAtA []byte) (int, error)
- func (m *TestValueSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TestValueSnapshot) ProtoMessage()
- func (m *TestValueSnapshot) Reset()
- func (m *TestValueSnapshot) Size() (n int)
- func (m *TestValueSnapshot) String() string
- func (m *TestValueSnapshot) Unmarshal(dAtA []byte) error
- func (m *TestValueSnapshot) XXX_DiscardUnknown()
- func (m *TestValueSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestValueSnapshot) XXX_Merge(src proto.Message)
- func (m *TestValueSnapshot) XXX_Size() int
- func (m *TestValueSnapshot) XXX_Unmarshal(b []byte) error
- type Timer
- type UnaryOperation
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowService = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthSession = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSession = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSession = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTest = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTest = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTest = fmt.Errorf("proto: unexpected end of group") )
var ResponseType_name = map[int32]string{
0: "RESPONSE",
1: "OPEN_STREAM",
2: "CLOSE_STREAM",
}
var ResponseType_value = map[string]int32{
"RESPONSE": 0,
"OPEN_STREAM": 1,
"CLOSE_STREAM": 2,
}
Functions ¶
This section is empty.
Types ¶
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 CommandRequest ¶
type CommandRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Command []byte `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` }
func (*CommandRequest) Descriptor ¶
func (*CommandRequest) Descriptor() ([]byte, []int)
func (*CommandRequest) GetCommand ¶
func (m *CommandRequest) GetCommand() []byte
func (*CommandRequest) GetContext ¶
func (m *CommandRequest) GetContext() *RequestContext
func (*CommandRequest) GetName ¶
func (m *CommandRequest) GetName() string
func (*CommandRequest) Marshal ¶
func (m *CommandRequest) Marshal() (dAtA []byte, err error)
func (*CommandRequest) MarshalToSizedBuffer ¶
func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandRequest) ProtoMessage ¶
func (*CommandRequest) ProtoMessage()
func (*CommandRequest) Reset ¶
func (m *CommandRequest) Reset()
func (*CommandRequest) Size ¶
func (m *CommandRequest) Size() (n int)
func (*CommandRequest) String ¶
func (m *CommandRequest) String() string
func (*CommandRequest) Unmarshal ¶
func (m *CommandRequest) Unmarshal(dAtA []byte) error
func (*CommandRequest) XXX_DiscardUnknown ¶
func (m *CommandRequest) XXX_DiscardUnknown()
func (*CommandRequest) XXX_Marshal ¶
func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandRequest) XXX_Merge ¶
func (m *CommandRequest) XXX_Merge(src proto.Message)
func (*CommandRequest) XXX_Size ¶
func (m *CommandRequest) XXX_Size() int
func (*CommandRequest) XXX_Unmarshal ¶
func (m *CommandRequest) XXX_Unmarshal(b []byte) error
type CommandResponse ¶
type CommandResponse struct { Context *ResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Output []byte `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` }
func (*CommandResponse) Descriptor ¶
func (*CommandResponse) Descriptor() ([]byte, []int)
func (*CommandResponse) GetContext ¶
func (m *CommandResponse) GetContext() *ResponseContext
func (*CommandResponse) GetOutput ¶
func (m *CommandResponse) GetOutput() []byte
func (*CommandResponse) Marshal ¶
func (m *CommandResponse) Marshal() (dAtA []byte, err error)
func (*CommandResponse) MarshalToSizedBuffer ¶
func (m *CommandResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandResponse) ProtoMessage ¶
func (*CommandResponse) ProtoMessage()
func (*CommandResponse) Reset ¶
func (m *CommandResponse) Reset()
func (*CommandResponse) Size ¶
func (m *CommandResponse) Size() (n int)
func (*CommandResponse) String ¶
func (m *CommandResponse) String() string
func (*CommandResponse) Unmarshal ¶
func (m *CommandResponse) Unmarshal(dAtA []byte) error
func (*CommandResponse) XXX_DiscardUnknown ¶
func (m *CommandResponse) XXX_DiscardUnknown()
func (*CommandResponse) XXX_Marshal ¶
func (m *CommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandResponse) XXX_Merge ¶
func (m *CommandResponse) XXX_Merge(src proto.Message)
func (*CommandResponse) XXX_Size ¶
func (m *CommandResponse) XXX_Size() int
func (*CommandResponse) XXX_Unmarshal ¶
func (m *CommandResponse) XXX_Unmarshal(b []byte) error
type Context ¶
type Context interface { // Node is the local node identifier Node() string // Name is the service name Name() string // Namespace is the service namespace name Namespace() string // Index returns the current index of the state machine Index() uint64 // Timestamp returns a deterministic, monotonically increasing timestamp Timestamp() time.Time // OperationType returns the type of the operation currently being executed against the state machine OperationType() OperationType }
Context provides information about the context within which a state machine is running
type CreateRequest ¶
type CreateRequest struct { }
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) Marshal ¶
func (m *CreateRequest) Marshal() (dAtA []byte, err error)
func (*CreateRequest) MarshalToSizedBuffer ¶
func (m *CreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) Size ¶
func (m *CreateRequest) Size() (n int)
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) Unmarshal ¶
func (m *CreateRequest) Unmarshal(dAtA []byte) error
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct { }
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) Marshal ¶
func (m *CreateResponse) Marshal() (dAtA []byte, err error)
func (*CreateResponse) MarshalToSizedBuffer ¶
func (m *CreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) Size ¶
func (m *CreateResponse) Size() (n int)
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) Unmarshal ¶
func (m *CreateResponse) Unmarshal(dAtA []byte) error
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type DeleteRequest ¶
type DeleteRequest struct { }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) Marshal ¶
func (m *DeleteRequest) Marshal() (dAtA []byte, err error)
func (*DeleteRequest) MarshalToSizedBuffer ¶
func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) Size ¶
func (m *DeleteRequest) Size() (n int)
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) Unmarshal ¶
func (m *DeleteRequest) Unmarshal(dAtA []byte) error
func (*DeleteRequest) XXX_DiscardUnknown ¶
func (m *DeleteRequest) XXX_DiscardUnknown()
func (*DeleteRequest) XXX_Marshal ¶
func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRequest) XXX_Merge ¶
func (m *DeleteRequest) XXX_Merge(src proto.Message)
func (*DeleteRequest) XXX_Size ¶
func (m *DeleteRequest) XXX_Size() int
func (*DeleteRequest) XXX_Unmarshal ¶
func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
type DeleteResponse ¶
type DeleteResponse struct { }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) Marshal ¶
func (m *DeleteResponse) Marshal() (dAtA []byte, err error)
func (*DeleteResponse) MarshalToSizedBuffer ¶
func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) Size ¶
func (m *DeleteResponse) Size() (n int)
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) Unmarshal ¶
func (m *DeleteResponse) Unmarshal(dAtA []byte) error
func (*DeleteResponse) XXX_DiscardUnknown ¶
func (m *DeleteResponse) XXX_DiscardUnknown()
func (*DeleteResponse) XXX_Marshal ¶
func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteResponse) XXX_Merge ¶
func (m *DeleteResponse) XXX_Merge(src proto.Message)
func (*DeleteResponse) XXX_Size ¶
func (m *DeleteResponse) XXX_Size() int
func (*DeleteResponse) XXX_Unmarshal ¶
func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
type Executor ¶
type Executor interface { // RegisterUnaryOperation registers a unary primitive operation RegisterUnaryOperation(name string, callback func([]byte) ([]byte, error)) // RegisterStreamOperation registers a new primitive operation RegisterStreamOperation(name string, callback func([]byte, stream.WriteStream)) // GetOperation returns an operation by name GetOperation(name string) Operation }
Executor executes primitive operations
type GetRequest ¶
type GetRequest struct { }
Get request
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
Get response
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetValue ¶
func (m *GetResponse) GetValue() string
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) MarshalToSizedBuffer ¶
func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type KeepAliveRequest ¶
type KeepAliveRequest struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` CommandSequence uint64 `protobuf:"varint,2,opt,name=command_sequence,json=commandSequence,proto3" json:"command_sequence,omitempty"` Streams map[uint64]uint64 `` /* 157-byte string literal not displayed */ }
func (*KeepAliveRequest) Descriptor ¶
func (*KeepAliveRequest) Descriptor() ([]byte, []int)
func (*KeepAliveRequest) GetCommandSequence ¶
func (m *KeepAliveRequest) GetCommandSequence() uint64
func (*KeepAliveRequest) GetSessionID ¶
func (m *KeepAliveRequest) GetSessionID() uint64
func (*KeepAliveRequest) GetStreams ¶
func (m *KeepAliveRequest) GetStreams() map[uint64]uint64
func (*KeepAliveRequest) Marshal ¶
func (m *KeepAliveRequest) Marshal() (dAtA []byte, err error)
func (*KeepAliveRequest) MarshalToSizedBuffer ¶
func (m *KeepAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeepAliveRequest) ProtoMessage ¶
func (*KeepAliveRequest) ProtoMessage()
func (*KeepAliveRequest) Reset ¶
func (m *KeepAliveRequest) Reset()
func (*KeepAliveRequest) Size ¶
func (m *KeepAliveRequest) Size() (n int)
func (*KeepAliveRequest) String ¶
func (m *KeepAliveRequest) String() string
func (*KeepAliveRequest) Unmarshal ¶
func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error
func (*KeepAliveRequest) XXX_DiscardUnknown ¶
func (m *KeepAliveRequest) XXX_DiscardUnknown()
func (*KeepAliveRequest) XXX_Marshal ¶
func (m *KeepAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepAliveRequest) XXX_Merge ¶
func (m *KeepAliveRequest) XXX_Merge(src proto.Message)
func (*KeepAliveRequest) XXX_Size ¶
func (m *KeepAliveRequest) XXX_Size() int
func (*KeepAliveRequest) XXX_Unmarshal ¶
func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error
type KeepAliveResponse ¶
type KeepAliveResponse struct { }
func (*KeepAliveResponse) Descriptor ¶
func (*KeepAliveResponse) Descriptor() ([]byte, []int)
func (*KeepAliveResponse) Marshal ¶
func (m *KeepAliveResponse) Marshal() (dAtA []byte, err error)
func (*KeepAliveResponse) MarshalTo ¶
func (m *KeepAliveResponse) MarshalTo(dAtA []byte) (int, error)
func (*KeepAliveResponse) MarshalToSizedBuffer ¶
func (m *KeepAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeepAliveResponse) ProtoMessage ¶
func (*KeepAliveResponse) ProtoMessage()
func (*KeepAliveResponse) Reset ¶
func (m *KeepAliveResponse) Reset()
func (*KeepAliveResponse) Size ¶
func (m *KeepAliveResponse) Size() (n int)
func (*KeepAliveResponse) String ¶
func (m *KeepAliveResponse) String() string
func (*KeepAliveResponse) Unmarshal ¶
func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error
func (*KeepAliveResponse) XXX_DiscardUnknown ¶
func (m *KeepAliveResponse) XXX_DiscardUnknown()
func (*KeepAliveResponse) XXX_Marshal ¶
func (m *KeepAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeepAliveResponse) XXX_Merge ¶
func (m *KeepAliveResponse) XXX_Merge(src proto.Message)
func (*KeepAliveResponse) XXX_Size ¶
func (m *KeepAliveResponse) XXX_Size() int
func (*KeepAliveResponse) XXX_Unmarshal ¶
func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error
type MetadataRequest ¶
type MetadataRequest struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` }
func (*MetadataRequest) Descriptor ¶
func (*MetadataRequest) Descriptor() ([]byte, []int)
func (*MetadataRequest) GetNamespace ¶
func (m *MetadataRequest) GetNamespace() string
func (*MetadataRequest) GetType ¶
func (m *MetadataRequest) GetType() string
func (*MetadataRequest) Marshal ¶
func (m *MetadataRequest) Marshal() (dAtA []byte, err error)
func (*MetadataRequest) MarshalToSizedBuffer ¶
func (m *MetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MetadataRequest) ProtoMessage ¶
func (*MetadataRequest) ProtoMessage()
func (*MetadataRequest) Reset ¶
func (m *MetadataRequest) Reset()
func (*MetadataRequest) Size ¶
func (m *MetadataRequest) Size() (n int)
func (*MetadataRequest) String ¶
func (m *MetadataRequest) String() string
func (*MetadataRequest) Unmarshal ¶
func (m *MetadataRequest) Unmarshal(dAtA []byte) error
func (*MetadataRequest) XXX_DiscardUnknown ¶
func (m *MetadataRequest) XXX_DiscardUnknown()
func (*MetadataRequest) XXX_Marshal ¶
func (m *MetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetadataRequest) XXX_Merge ¶
func (m *MetadataRequest) XXX_Merge(src proto.Message)
func (*MetadataRequest) XXX_Size ¶
func (m *MetadataRequest) XXX_Size() int
func (*MetadataRequest) XXX_Unmarshal ¶
func (m *MetadataRequest) XXX_Unmarshal(b []byte) error
type MetadataResponse ¶
type MetadataResponse struct {
Services []*ServiceId `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}
func (*MetadataResponse) Descriptor ¶
func (*MetadataResponse) Descriptor() ([]byte, []int)
func (*MetadataResponse) GetServices ¶
func (m *MetadataResponse) GetServices() []*ServiceId
func (*MetadataResponse) Marshal ¶
func (m *MetadataResponse) Marshal() (dAtA []byte, err error)
func (*MetadataResponse) MarshalToSizedBuffer ¶
func (m *MetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MetadataResponse) ProtoMessage ¶
func (*MetadataResponse) ProtoMessage()
func (*MetadataResponse) Reset ¶
func (m *MetadataResponse) Reset()
func (*MetadataResponse) Size ¶
func (m *MetadataResponse) Size() (n int)
func (*MetadataResponse) String ¶
func (m *MetadataResponse) String() string
func (*MetadataResponse) Unmarshal ¶
func (m *MetadataResponse) Unmarshal(dAtA []byte) error
func (*MetadataResponse) XXX_DiscardUnknown ¶
func (m *MetadataResponse) XXX_DiscardUnknown()
func (*MetadataResponse) XXX_Marshal ¶
func (m *MetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetadataResponse) XXX_Merge ¶
func (m *MetadataResponse) XXX_Merge(src proto.Message)
func (*MetadataResponse) XXX_Size ¶
func (m *MetadataResponse) XXX_Size() int
func (*MetadataResponse) XXX_Unmarshal ¶
func (m *MetadataResponse) XXX_Unmarshal(b []byte) error
type OpenSessionRequest ¶
type OpenSessionRequest struct {
Timeout *time.Duration `protobuf:"bytes,1,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}
func (*OpenSessionRequest) Descriptor ¶
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
func (*OpenSessionRequest) GetTimeout ¶
func (m *OpenSessionRequest) GetTimeout() *time.Duration
func (*OpenSessionRequest) Marshal ¶
func (m *OpenSessionRequest) Marshal() (dAtA []byte, err error)
func (*OpenSessionRequest) MarshalTo ¶
func (m *OpenSessionRequest) MarshalTo(dAtA []byte) (int, error)
func (*OpenSessionRequest) MarshalToSizedBuffer ¶
func (m *OpenSessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) Reset ¶
func (m *OpenSessionRequest) Reset()
func (*OpenSessionRequest) Size ¶
func (m *OpenSessionRequest) Size() (n int)
func (*OpenSessionRequest) String ¶
func (m *OpenSessionRequest) String() string
func (*OpenSessionRequest) Unmarshal ¶
func (m *OpenSessionRequest) Unmarshal(dAtA []byte) error
func (*OpenSessionRequest) XXX_DiscardUnknown ¶
func (m *OpenSessionRequest) XXX_DiscardUnknown()
func (*OpenSessionRequest) XXX_Marshal ¶
func (m *OpenSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenSessionRequest) XXX_Merge ¶
func (m *OpenSessionRequest) XXX_Merge(src proto.Message)
func (*OpenSessionRequest) XXX_Size ¶
func (m *OpenSessionRequest) XXX_Size() int
func (*OpenSessionRequest) XXX_Unmarshal ¶
func (m *OpenSessionRequest) XXX_Unmarshal(b []byte) error
type OpenSessionResponse ¶
type OpenSessionResponse struct {
SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}
func (*OpenSessionResponse) Descriptor ¶
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
func (*OpenSessionResponse) GetSessionID ¶
func (m *OpenSessionResponse) GetSessionID() uint64
func (*OpenSessionResponse) Marshal ¶
func (m *OpenSessionResponse) Marshal() (dAtA []byte, err error)
func (*OpenSessionResponse) MarshalTo ¶
func (m *OpenSessionResponse) MarshalTo(dAtA []byte) (int, error)
func (*OpenSessionResponse) MarshalToSizedBuffer ¶
func (m *OpenSessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) Reset ¶
func (m *OpenSessionResponse) Reset()
func (*OpenSessionResponse) Size ¶
func (m *OpenSessionResponse) Size() (n int)
func (*OpenSessionResponse) String ¶
func (m *OpenSessionResponse) String() string
func (*OpenSessionResponse) Unmarshal ¶
func (m *OpenSessionResponse) Unmarshal(dAtA []byte) error
func (*OpenSessionResponse) XXX_DiscardUnknown ¶
func (m *OpenSessionResponse) XXX_DiscardUnknown()
func (*OpenSessionResponse) XXX_Marshal ¶
func (m *OpenSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OpenSessionResponse) XXX_Merge ¶
func (m *OpenSessionResponse) XXX_Merge(src proto.Message)
func (*OpenSessionResponse) XXX_Size ¶
func (m *OpenSessionResponse) XXX_Size() int
func (*OpenSessionResponse) XXX_Unmarshal ¶
func (m *OpenSessionResponse) XXX_Unmarshal(b []byte) error
type Operation ¶
type Operation interface{}
Operation is the base interface for primitive operations
type OperationType ¶
type OperationType string
OperationType is the type for a service operation
const ( // OpTypeCommand is an OperationType indicating a command operation OpTypeCommand OperationType = "command" // OpTypeQuery is an OperationType indicating a query operation OpTypeQuery OperationType = "query" )
type PrimitiveEvent ¶
type PrimitiveEvent struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*PrimitiveEvent) Descriptor ¶
func (*PrimitiveEvent) Descriptor() ([]byte, []int)
func (*PrimitiveEvent) GetType ¶
func (m *PrimitiveEvent) GetType() string
func (*PrimitiveEvent) GetValue ¶
func (m *PrimitiveEvent) GetValue() []byte
func (*PrimitiveEvent) Marshal ¶
func (m *PrimitiveEvent) Marshal() (dAtA []byte, err error)
func (*PrimitiveEvent) MarshalToSizedBuffer ¶
func (m *PrimitiveEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimitiveEvent) ProtoMessage ¶
func (*PrimitiveEvent) ProtoMessage()
func (*PrimitiveEvent) Reset ¶
func (m *PrimitiveEvent) Reset()
func (*PrimitiveEvent) Size ¶
func (m *PrimitiveEvent) Size() (n int)
func (*PrimitiveEvent) String ¶
func (m *PrimitiveEvent) String() string
func (*PrimitiveEvent) Unmarshal ¶
func (m *PrimitiveEvent) Unmarshal(dAtA []byte) error
func (*PrimitiveEvent) XXX_DiscardUnknown ¶
func (m *PrimitiveEvent) XXX_DiscardUnknown()
func (*PrimitiveEvent) XXX_Marshal ¶
func (m *PrimitiveEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimitiveEvent) XXX_Merge ¶
func (m *PrimitiveEvent) XXX_Merge(src proto.Message)
func (*PrimitiveEvent) XXX_Size ¶
func (m *PrimitiveEvent) XXX_Size() int
func (*PrimitiveEvent) XXX_Unmarshal ¶
func (m *PrimitiveEvent) XXX_Unmarshal(b []byte) error
type QueryRequest ¶
type QueryRequest struct { Context *RequestContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Query []byte `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` }
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) GetContext ¶
func (m *QueryRequest) GetContext() *RequestContext
func (*QueryRequest) GetName ¶
func (m *QueryRequest) GetName() string
func (*QueryRequest) GetQuery ¶
func (m *QueryRequest) GetQuery() []byte
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) MarshalToSizedBuffer ¶
func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
func (*QueryRequest) XXX_DiscardUnknown ¶
func (m *QueryRequest) XXX_DiscardUnknown()
func (*QueryRequest) XXX_Marshal ¶
func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryRequest) XXX_Merge ¶
func (m *QueryRequest) XXX_Merge(src proto.Message)
func (*QueryRequest) XXX_Size ¶
func (m *QueryRequest) XXX_Size() int
func (*QueryRequest) XXX_Unmarshal ¶
func (m *QueryRequest) XXX_Unmarshal(b []byte) error
type QueryResponse ¶
type QueryResponse struct { Context *ResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Output []byte `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` }
func (*QueryResponse) Descriptor ¶
func (*QueryResponse) Descriptor() ([]byte, []int)
func (*QueryResponse) GetContext ¶
func (m *QueryResponse) GetContext() *ResponseContext
func (*QueryResponse) GetOutput ¶
func (m *QueryResponse) GetOutput() []byte
func (*QueryResponse) Marshal ¶
func (m *QueryResponse) Marshal() (dAtA []byte, err error)
func (*QueryResponse) MarshalToSizedBuffer ¶
func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryResponse) ProtoMessage ¶
func (*QueryResponse) ProtoMessage()
func (*QueryResponse) Reset ¶
func (m *QueryResponse) Reset()
func (*QueryResponse) Size ¶
func (m *QueryResponse) Size() (n int)
func (*QueryResponse) String ¶
func (m *QueryResponse) String() string
func (*QueryResponse) Unmarshal ¶
func (m *QueryResponse) Unmarshal(dAtA []byte) error
func (*QueryResponse) XXX_DiscardUnknown ¶
func (m *QueryResponse) XXX_DiscardUnknown()
func (*QueryResponse) XXX_Marshal ¶
func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryResponse) XXX_Merge ¶
func (m *QueryResponse) XXX_Merge(src proto.Message)
func (*QueryResponse) XXX_Size ¶
func (m *QueryResponse) XXX_Size() int
func (*QueryResponse) XXX_Unmarshal ¶
func (m *QueryResponse) XXX_Unmarshal(b []byte) error
type RequestContext ¶
type RequestContext struct {
Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
}
func (*RequestContext) Descriptor ¶
func (*RequestContext) Descriptor() ([]byte, []int)
func (*RequestContext) GetIndex ¶
func (m *RequestContext) GetIndex() uint64
func (*RequestContext) Marshal ¶
func (m *RequestContext) Marshal() (dAtA []byte, err error)
func (*RequestContext) MarshalToSizedBuffer ¶
func (m *RequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequestContext) ProtoMessage ¶
func (*RequestContext) ProtoMessage()
func (*RequestContext) Reset ¶
func (m *RequestContext) Reset()
func (*RequestContext) Size ¶
func (m *RequestContext) Size() (n int)
func (*RequestContext) String ¶
func (m *RequestContext) String() string
func (*RequestContext) Unmarshal ¶
func (m *RequestContext) Unmarshal(dAtA []byte) error
func (*RequestContext) XXX_DiscardUnknown ¶
func (m *RequestContext) XXX_DiscardUnknown()
func (*RequestContext) XXX_Marshal ¶
func (m *RequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestContext) XXX_Merge ¶
func (m *RequestContext) XXX_Merge(src proto.Message)
func (*RequestContext) XXX_Size ¶
func (m *RequestContext) XXX_Size() int
func (*RequestContext) XXX_Unmarshal ¶
func (m *RequestContext) XXX_Unmarshal(b []byte) error
type ResponseContext ¶
type ResponseContext struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Type ResponseType `protobuf:"varint,2,opt,name=type,proto3,enum=atomix.service.ResponseType" json:"type,omitempty"` }
func (*ResponseContext) Descriptor ¶
func (*ResponseContext) Descriptor() ([]byte, []int)
func (*ResponseContext) GetIndex ¶
func (m *ResponseContext) GetIndex() uint64
func (*ResponseContext) GetType ¶
func (m *ResponseContext) GetType() ResponseType
func (*ResponseContext) Marshal ¶
func (m *ResponseContext) Marshal() (dAtA []byte, err error)
func (*ResponseContext) MarshalToSizedBuffer ¶
func (m *ResponseContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResponseContext) ProtoMessage ¶
func (*ResponseContext) ProtoMessage()
func (*ResponseContext) Reset ¶
func (m *ResponseContext) Reset()
func (*ResponseContext) Size ¶
func (m *ResponseContext) Size() (n int)
func (*ResponseContext) String ¶
func (m *ResponseContext) String() string
func (*ResponseContext) Unmarshal ¶
func (m *ResponseContext) Unmarshal(dAtA []byte) error
func (*ResponseContext) XXX_DiscardUnknown ¶
func (m *ResponseContext) XXX_DiscardUnknown()
func (*ResponseContext) XXX_Marshal ¶
func (m *ResponseContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseContext) XXX_Merge ¶
func (m *ResponseContext) XXX_Merge(src proto.Message)
func (*ResponseContext) XXX_Size ¶
func (m *ResponseContext) XXX_Size() int
func (*ResponseContext) XXX_Unmarshal ¶
func (m *ResponseContext) XXX_Unmarshal(b []byte) error
type ResponseType ¶
type ResponseType int32
const ( ResponseType_RESPONSE ResponseType = 0 ResponseType_OPEN_STREAM ResponseType = 1 ResponseType_CLOSE_STREAM ResponseType = 2 )
func (ResponseType) EnumDescriptor ¶
func (ResponseType) EnumDescriptor() ([]byte, []int)
func (ResponseType) String ¶
func (x ResponseType) String() string
type Scheduler ¶
type Scheduler interface { // Execute executes a function asynchronously Execute(f func()) // ScheduleOnce schedules a function to be run once after the given delay ScheduleOnce(delay time.Duration, f func()) Timer // ScheduleRepeat schedules a function to run repeatedly every interval starting after the given delay ScheduleRepeat(delay time.Duration, interval time.Duration, f func()) Timer // ScheduleIndex schedules a function to run at a specific index ScheduleIndex(index uint64, f func()) }
Scheduler provides deterministic scheduling for a state machine
type Service ¶
type Service 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 // CanDelete returns a bool indicating whether the node can delete changes up to the given index without affecting // the correctness of the state machine CanDelete(index uint64) bool // 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) }
Service is an interface for primitive services
type ServiceId ¶
type ServiceId struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` }
func (*ServiceId) Descriptor ¶
func (*ServiceId) GetNamespace ¶
func (*ServiceId) 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 ServiceRequest ¶
type ServiceRequest struct { Id *ServiceId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are valid to be assigned to Request: // *ServiceRequest_Create // *ServiceRequest_Delete // *ServiceRequest_Metadata // *ServiceRequest_Command // *ServiceRequest_Query Request isServiceRequest_Request `protobuf_oneof:"request"` }
func (*ServiceRequest) Descriptor ¶
func (*ServiceRequest) Descriptor() ([]byte, []int)
func (*ServiceRequest) GetCommand ¶
func (m *ServiceRequest) GetCommand() []byte
func (*ServiceRequest) GetCreate ¶
func (m *ServiceRequest) GetCreate() *CreateRequest
func (*ServiceRequest) GetDelete ¶
func (m *ServiceRequest) GetDelete() *DeleteRequest
func (*ServiceRequest) GetId ¶
func (m *ServiceRequest) GetId() *ServiceId
func (*ServiceRequest) GetMetadata ¶
func (m *ServiceRequest) GetMetadata() *MetadataRequest
func (*ServiceRequest) GetQuery ¶
func (m *ServiceRequest) GetQuery() []byte
func (*ServiceRequest) GetRequest ¶
func (m *ServiceRequest) GetRequest() isServiceRequest_Request
func (*ServiceRequest) Marshal ¶
func (m *ServiceRequest) Marshal() (dAtA []byte, err error)
func (*ServiceRequest) MarshalToSizedBuffer ¶
func (m *ServiceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceRequest) ProtoMessage ¶
func (*ServiceRequest) ProtoMessage()
func (*ServiceRequest) Reset ¶
func (m *ServiceRequest) Reset()
func (*ServiceRequest) Size ¶
func (m *ServiceRequest) Size() (n int)
func (*ServiceRequest) String ¶
func (m *ServiceRequest) String() string
func (*ServiceRequest) Unmarshal ¶
func (m *ServiceRequest) Unmarshal(dAtA []byte) error
func (*ServiceRequest) XXX_DiscardUnknown ¶
func (m *ServiceRequest) XXX_DiscardUnknown()
func (*ServiceRequest) XXX_Marshal ¶
func (m *ServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceRequest) XXX_Merge ¶
func (m *ServiceRequest) XXX_Merge(src proto.Message)
func (*ServiceRequest) XXX_OneofWrappers ¶
func (*ServiceRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServiceRequest) XXX_Size ¶
func (m *ServiceRequest) XXX_Size() int
func (*ServiceRequest) XXX_Unmarshal ¶
func (m *ServiceRequest) XXX_Unmarshal(b []byte) error
type ServiceRequest_Command ¶
type ServiceRequest_Command struct {
Command []byte `protobuf:"bytes,5,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func (*ServiceRequest_Command) MarshalTo ¶
func (m *ServiceRequest_Command) MarshalTo(dAtA []byte) (int, error)
func (*ServiceRequest_Command) MarshalToSizedBuffer ¶
func (m *ServiceRequest_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceRequest_Command) Size ¶
func (m *ServiceRequest_Command) Size() (n int)
type ServiceRequest_Create ¶
type ServiceRequest_Create struct {
Create *CreateRequest `protobuf:"bytes,2,opt,name=create,proto3,oneof" json:"create,omitempty"`
}
func (*ServiceRequest_Create) MarshalTo ¶
func (m *ServiceRequest_Create) MarshalTo(dAtA []byte) (int, error)
func (*ServiceRequest_Create) MarshalToSizedBuffer ¶
func (m *ServiceRequest_Create) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceRequest_Create) Size ¶
func (m *ServiceRequest_Create) Size() (n int)
type ServiceRequest_Delete ¶
type ServiceRequest_Delete struct {
Delete *DeleteRequest `protobuf:"bytes,3,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
}
func (*ServiceRequest_Delete) MarshalTo ¶
func (m *ServiceRequest_Delete) MarshalTo(dAtA []byte) (int, error)
func (*ServiceRequest_Delete) MarshalToSizedBuffer ¶
func (m *ServiceRequest_Delete) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceRequest_Delete) Size ¶
func (m *ServiceRequest_Delete) Size() (n int)
type ServiceRequest_Metadata ¶
type ServiceRequest_Metadata struct {
Metadata *MetadataRequest `protobuf:"bytes,4,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}
func (*ServiceRequest_Metadata) MarshalTo ¶
func (m *ServiceRequest_Metadata) MarshalTo(dAtA []byte) (int, error)
func (*ServiceRequest_Metadata) MarshalToSizedBuffer ¶
func (m *ServiceRequest_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceRequest_Metadata) Size ¶
func (m *ServiceRequest_Metadata) Size() (n int)
type ServiceRequest_Query ¶
type ServiceRequest_Query struct {
Query []byte `protobuf:"bytes,6,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func (*ServiceRequest_Query) MarshalTo ¶
func (m *ServiceRequest_Query) MarshalTo(dAtA []byte) (int, error)
func (*ServiceRequest_Query) MarshalToSizedBuffer ¶
func (m *ServiceRequest_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceRequest_Query) Size ¶
func (m *ServiceRequest_Query) Size() (n int)
type ServiceResponse ¶
type ServiceResponse struct { // Types that are valid to be assigned to Response: // *ServiceResponse_Create // *ServiceResponse_Delete // *ServiceResponse_Metadata // *ServiceResponse_Command // *ServiceResponse_Query Response isServiceResponse_Response `protobuf_oneof:"response"` }
func (*ServiceResponse) Descriptor ¶
func (*ServiceResponse) Descriptor() ([]byte, []int)
func (*ServiceResponse) GetCommand ¶
func (m *ServiceResponse) GetCommand() []byte
func (*ServiceResponse) GetCreate ¶
func (m *ServiceResponse) GetCreate() *CreateResponse
func (*ServiceResponse) GetDelete ¶
func (m *ServiceResponse) GetDelete() *DeleteResponse
func (*ServiceResponse) GetMetadata ¶
func (m *ServiceResponse) GetMetadata() *MetadataResponse
func (*ServiceResponse) GetQuery ¶
func (m *ServiceResponse) GetQuery() []byte
func (*ServiceResponse) GetResponse ¶
func (m *ServiceResponse) GetResponse() isServiceResponse_Response
func (*ServiceResponse) Marshal ¶
func (m *ServiceResponse) Marshal() (dAtA []byte, err error)
func (*ServiceResponse) MarshalToSizedBuffer ¶
func (m *ServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceResponse) ProtoMessage ¶
func (*ServiceResponse) ProtoMessage()
func (*ServiceResponse) Reset ¶
func (m *ServiceResponse) Reset()
func (*ServiceResponse) Size ¶
func (m *ServiceResponse) Size() (n int)
func (*ServiceResponse) String ¶
func (m *ServiceResponse) String() string
func (*ServiceResponse) Unmarshal ¶
func (m *ServiceResponse) Unmarshal(dAtA []byte) error
func (*ServiceResponse) XXX_DiscardUnknown ¶
func (m *ServiceResponse) XXX_DiscardUnknown()
func (*ServiceResponse) XXX_Marshal ¶
func (m *ServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceResponse) XXX_Merge ¶
func (m *ServiceResponse) XXX_Merge(src proto.Message)
func (*ServiceResponse) XXX_OneofWrappers ¶
func (*ServiceResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ServiceResponse) XXX_Size ¶
func (m *ServiceResponse) XXX_Size() int
func (*ServiceResponse) XXX_Unmarshal ¶
func (m *ServiceResponse) XXX_Unmarshal(b []byte) error
type ServiceResponse_Command ¶
type ServiceResponse_Command struct {
Command []byte `protobuf:"bytes,4,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func (*ServiceResponse_Command) MarshalTo ¶
func (m *ServiceResponse_Command) MarshalTo(dAtA []byte) (int, error)
func (*ServiceResponse_Command) MarshalToSizedBuffer ¶
func (m *ServiceResponse_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceResponse_Command) Size ¶
func (m *ServiceResponse_Command) Size() (n int)
type ServiceResponse_Create ¶
type ServiceResponse_Create struct {
Create *CreateResponse `protobuf:"bytes,1,opt,name=create,proto3,oneof" json:"create,omitempty"`
}
func (*ServiceResponse_Create) MarshalTo ¶
func (m *ServiceResponse_Create) MarshalTo(dAtA []byte) (int, error)
func (*ServiceResponse_Create) MarshalToSizedBuffer ¶
func (m *ServiceResponse_Create) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceResponse_Create) Size ¶
func (m *ServiceResponse_Create) Size() (n int)
type ServiceResponse_Delete ¶
type ServiceResponse_Delete struct {
Delete *DeleteResponse `protobuf:"bytes,2,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
}
func (*ServiceResponse_Delete) MarshalTo ¶
func (m *ServiceResponse_Delete) MarshalTo(dAtA []byte) (int, error)
func (*ServiceResponse_Delete) MarshalToSizedBuffer ¶
func (m *ServiceResponse_Delete) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceResponse_Delete) Size ¶
func (m *ServiceResponse_Delete) Size() (n int)
type ServiceResponse_Metadata ¶
type ServiceResponse_Metadata struct {
Metadata *MetadataResponse `protobuf:"bytes,3,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}
func (*ServiceResponse_Metadata) MarshalTo ¶
func (m *ServiceResponse_Metadata) MarshalTo(dAtA []byte) (int, error)
func (*ServiceResponse_Metadata) MarshalToSizedBuffer ¶
func (m *ServiceResponse_Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceResponse_Metadata) Size ¶
func (m *ServiceResponse_Metadata) Size() (n int)
type ServiceResponse_Query ¶
type ServiceResponse_Query struct {
Query []byte `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func (*ServiceResponse_Query) MarshalTo ¶
func (m *ServiceResponse_Query) MarshalTo(dAtA []byte) (int, error)
func (*ServiceResponse_Query) MarshalToSizedBuffer ¶
func (m *ServiceResponse_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceResponse_Query) Size ¶
func (m *ServiceResponse_Query) Size() (n int)
type ServiceSnapshot ¶
type ServiceSnapshot struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Snapshot []byte `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"` }
func (*ServiceSnapshot) Descriptor ¶
func (*ServiceSnapshot) Descriptor() ([]byte, []int)
func (*ServiceSnapshot) GetIndex ¶
func (m *ServiceSnapshot) GetIndex() uint64
func (*ServiceSnapshot) GetSnapshot ¶
func (m *ServiceSnapshot) GetSnapshot() []byte
func (*ServiceSnapshot) Marshal ¶
func (m *ServiceSnapshot) Marshal() (dAtA []byte, err error)
func (*ServiceSnapshot) MarshalToSizedBuffer ¶
func (m *ServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceSnapshot) ProtoMessage ¶
func (*ServiceSnapshot) ProtoMessage()
func (*ServiceSnapshot) Reset ¶
func (m *ServiceSnapshot) Reset()
func (*ServiceSnapshot) Size ¶
func (m *ServiceSnapshot) Size() (n int)
func (*ServiceSnapshot) String ¶
func (m *ServiceSnapshot) String() string
func (*ServiceSnapshot) Unmarshal ¶
func (m *ServiceSnapshot) Unmarshal(dAtA []byte) error
func (*ServiceSnapshot) XXX_DiscardUnknown ¶
func (m *ServiceSnapshot) XXX_DiscardUnknown()
func (*ServiceSnapshot) XXX_Marshal ¶
func (m *ServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceSnapshot) XXX_Merge ¶
func (m *ServiceSnapshot) XXX_Merge(src proto.Message)
func (*ServiceSnapshot) XXX_Size ¶
func (m *ServiceSnapshot) XXX_Size() int
func (*ServiceSnapshot) XXX_Unmarshal ¶
func (m *ServiceSnapshot) XXX_Unmarshal(b []byte) error
type Session ¶
type Session struct { ID uint64 Timeout time.Duration LastUpdated time.Time // contains filtered or unexported fields }
Session manages the ordering of request and response streams for a single client
func (*Session) Stream ¶
func (s *Session) Stream(id uint64) streams.WriteStream
Stream returns the given stream
func (*Session) Streams ¶
func (s *Session) Streams() []streams.WriteStream
Streams returns a slice of all open streams of any type owned by the session
type SessionCommandContext ¶
type SessionCommandContext struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` SequenceNumber uint64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` }
func (*SessionCommandContext) Descriptor ¶
func (*SessionCommandContext) Descriptor() ([]byte, []int)
func (*SessionCommandContext) GetSequenceNumber ¶
func (m *SessionCommandContext) GetSequenceNumber() uint64
func (*SessionCommandContext) GetSessionID ¶
func (m *SessionCommandContext) GetSessionID() uint64
func (*SessionCommandContext) Marshal ¶
func (m *SessionCommandContext) Marshal() (dAtA []byte, err error)
func (*SessionCommandContext) MarshalTo ¶
func (m *SessionCommandContext) MarshalTo(dAtA []byte) (int, error)
func (*SessionCommandContext) MarshalToSizedBuffer ¶
func (m *SessionCommandContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionCommandContext) ProtoMessage ¶
func (*SessionCommandContext) ProtoMessage()
func (*SessionCommandContext) Reset ¶
func (m *SessionCommandContext) Reset()
func (*SessionCommandContext) Size ¶
func (m *SessionCommandContext) Size() (n int)
func (*SessionCommandContext) String ¶
func (m *SessionCommandContext) String() string
func (*SessionCommandContext) Unmarshal ¶
func (m *SessionCommandContext) Unmarshal(dAtA []byte) error
func (*SessionCommandContext) XXX_DiscardUnknown ¶
func (m *SessionCommandContext) XXX_DiscardUnknown()
func (*SessionCommandContext) XXX_Marshal ¶
func (m *SessionCommandContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionCommandContext) XXX_Merge ¶
func (m *SessionCommandContext) XXX_Merge(src proto.Message)
func (*SessionCommandContext) XXX_Size ¶
func (m *SessionCommandContext) XXX_Size() int
func (*SessionCommandContext) XXX_Unmarshal ¶
func (m *SessionCommandContext) XXX_Unmarshal(b []byte) error
type SessionCommandRequest ¶
type SessionCommandRequest struct { Context *SessionCommandContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Input []byte `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"` }
func (*SessionCommandRequest) Descriptor ¶
func (*SessionCommandRequest) Descriptor() ([]byte, []int)
func (*SessionCommandRequest) GetContext ¶
func (m *SessionCommandRequest) GetContext() *SessionCommandContext
func (*SessionCommandRequest) GetInput ¶
func (m *SessionCommandRequest) GetInput() []byte
func (*SessionCommandRequest) GetName ¶
func (m *SessionCommandRequest) GetName() string
func (*SessionCommandRequest) Marshal ¶
func (m *SessionCommandRequest) Marshal() (dAtA []byte, err error)
func (*SessionCommandRequest) MarshalTo ¶
func (m *SessionCommandRequest) MarshalTo(dAtA []byte) (int, error)
func (*SessionCommandRequest) MarshalToSizedBuffer ¶
func (m *SessionCommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionCommandRequest) ProtoMessage ¶
func (*SessionCommandRequest) ProtoMessage()
func (*SessionCommandRequest) Reset ¶
func (m *SessionCommandRequest) Reset()
func (*SessionCommandRequest) Size ¶
func (m *SessionCommandRequest) Size() (n int)
func (*SessionCommandRequest) String ¶
func (m *SessionCommandRequest) String() string
func (*SessionCommandRequest) Unmarshal ¶
func (m *SessionCommandRequest) Unmarshal(dAtA []byte) error
func (*SessionCommandRequest) XXX_DiscardUnknown ¶
func (m *SessionCommandRequest) XXX_DiscardUnknown()
func (*SessionCommandRequest) XXX_Marshal ¶
func (m *SessionCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionCommandRequest) XXX_Merge ¶
func (m *SessionCommandRequest) XXX_Merge(src proto.Message)
func (*SessionCommandRequest) XXX_Size ¶
func (m *SessionCommandRequest) XXX_Size() int
func (*SessionCommandRequest) XXX_Unmarshal ¶
func (m *SessionCommandRequest) XXX_Unmarshal(b []byte) error
type SessionCommandResponse ¶
type SessionCommandResponse struct { Context *SessionResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Output []byte `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` }
func (*SessionCommandResponse) Descriptor ¶
func (*SessionCommandResponse) Descriptor() ([]byte, []int)
func (*SessionCommandResponse) GetContext ¶
func (m *SessionCommandResponse) GetContext() *SessionResponseContext
func (*SessionCommandResponse) GetOutput ¶
func (m *SessionCommandResponse) GetOutput() []byte
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 SessionQueryContext ¶
type SessionQueryContext struct { SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` LastSequenceNumber uint64 `protobuf:"varint,2,opt,name=last_sequence_number,json=lastSequenceNumber,proto3" json:"last_sequence_number,omitempty"` LastIndex uint64 `protobuf:"varint,3,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"` }
func (*SessionQueryContext) Descriptor ¶
func (*SessionQueryContext) Descriptor() ([]byte, []int)
func (*SessionQueryContext) GetLastIndex ¶
func (m *SessionQueryContext) GetLastIndex() uint64
func (*SessionQueryContext) GetLastSequenceNumber ¶
func (m *SessionQueryContext) GetLastSequenceNumber() uint64
func (*SessionQueryContext) GetSessionID ¶
func (m *SessionQueryContext) GetSessionID() uint64
func (*SessionQueryContext) Marshal ¶
func (m *SessionQueryContext) Marshal() (dAtA []byte, err error)
func (*SessionQueryContext) MarshalTo ¶
func (m *SessionQueryContext) MarshalTo(dAtA []byte) (int, error)
func (*SessionQueryContext) MarshalToSizedBuffer ¶
func (m *SessionQueryContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionQueryContext) ProtoMessage ¶
func (*SessionQueryContext) ProtoMessage()
func (*SessionQueryContext) Reset ¶
func (m *SessionQueryContext) Reset()
func (*SessionQueryContext) Size ¶
func (m *SessionQueryContext) Size() (n int)
func (*SessionQueryContext) String ¶
func (m *SessionQueryContext) String() string
func (*SessionQueryContext) Unmarshal ¶
func (m *SessionQueryContext) Unmarshal(dAtA []byte) error
func (*SessionQueryContext) XXX_DiscardUnknown ¶
func (m *SessionQueryContext) XXX_DiscardUnknown()
func (*SessionQueryContext) XXX_Marshal ¶
func (m *SessionQueryContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionQueryContext) XXX_Merge ¶
func (m *SessionQueryContext) XXX_Merge(src proto.Message)
func (*SessionQueryContext) XXX_Size ¶
func (m *SessionQueryContext) XXX_Size() int
func (*SessionQueryContext) XXX_Unmarshal ¶
func (m *SessionQueryContext) XXX_Unmarshal(b []byte) error
type SessionQueryRequest ¶
type SessionQueryRequest struct { Context *SessionQueryContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Input []byte `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"` }
func (*SessionQueryRequest) Descriptor ¶
func (*SessionQueryRequest) Descriptor() ([]byte, []int)
func (*SessionQueryRequest) GetContext ¶
func (m *SessionQueryRequest) GetContext() *SessionQueryContext
func (*SessionQueryRequest) GetInput ¶
func (m *SessionQueryRequest) GetInput() []byte
func (*SessionQueryRequest) GetName ¶
func (m *SessionQueryRequest) GetName() string
func (*SessionQueryRequest) Marshal ¶
func (m *SessionQueryRequest) Marshal() (dAtA []byte, err error)
func (*SessionQueryRequest) MarshalTo ¶
func (m *SessionQueryRequest) MarshalTo(dAtA []byte) (int, error)
func (*SessionQueryRequest) MarshalToSizedBuffer ¶
func (m *SessionQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionQueryRequest) ProtoMessage ¶
func (*SessionQueryRequest) ProtoMessage()
func (*SessionQueryRequest) Reset ¶
func (m *SessionQueryRequest) Reset()
func (*SessionQueryRequest) Size ¶
func (m *SessionQueryRequest) Size() (n int)
func (*SessionQueryRequest) String ¶
func (m *SessionQueryRequest) String() string
func (*SessionQueryRequest) Unmarshal ¶
func (m *SessionQueryRequest) Unmarshal(dAtA []byte) error
func (*SessionQueryRequest) XXX_DiscardUnknown ¶
func (m *SessionQueryRequest) XXX_DiscardUnknown()
func (*SessionQueryRequest) XXX_Marshal ¶
func (m *SessionQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionQueryRequest) XXX_Merge ¶
func (m *SessionQueryRequest) XXX_Merge(src proto.Message)
func (*SessionQueryRequest) XXX_Size ¶
func (m *SessionQueryRequest) XXX_Size() int
func (*SessionQueryRequest) XXX_Unmarshal ¶
func (m *SessionQueryRequest) XXX_Unmarshal(b []byte) error
type SessionQueryResponse ¶
type SessionQueryResponse struct { Context *SessionResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Output []byte `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` }
func (*SessionQueryResponse) Descriptor ¶
func (*SessionQueryResponse) Descriptor() ([]byte, []int)
func (*SessionQueryResponse) GetContext ¶
func (m *SessionQueryResponse) GetContext() *SessionResponseContext
func (*SessionQueryResponse) GetOutput ¶
func (m *SessionQueryResponse) GetOutput() []byte
func (*SessionQueryResponse) Marshal ¶
func (m *SessionQueryResponse) Marshal() (dAtA []byte, err error)
func (*SessionQueryResponse) MarshalTo ¶
func (m *SessionQueryResponse) MarshalTo(dAtA []byte) (int, error)
func (*SessionQueryResponse) MarshalToSizedBuffer ¶
func (m *SessionQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionQueryResponse) ProtoMessage ¶
func (*SessionQueryResponse) ProtoMessage()
func (*SessionQueryResponse) Reset ¶
func (m *SessionQueryResponse) Reset()
func (*SessionQueryResponse) Size ¶
func (m *SessionQueryResponse) Size() (n int)
func (*SessionQueryResponse) String ¶
func (m *SessionQueryResponse) String() string
func (*SessionQueryResponse) Unmarshal ¶
func (m *SessionQueryResponse) Unmarshal(dAtA []byte) error
func (*SessionQueryResponse) XXX_DiscardUnknown ¶
func (m *SessionQueryResponse) XXX_DiscardUnknown()
func (*SessionQueryResponse) XXX_Marshal ¶
func (m *SessionQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionQueryResponse) XXX_Merge ¶
func (m *SessionQueryResponse) XXX_Merge(src proto.Message)
func (*SessionQueryResponse) XXX_Size ¶
func (m *SessionQueryResponse) XXX_Size() int
func (*SessionQueryResponse) XXX_Unmarshal ¶
func (m *SessionQueryResponse) XXX_Unmarshal(b []byte) error
type SessionRequest ¶
type SessionRequest struct { // Types that are valid to be assigned to Request: // *SessionRequest_OpenSession // *SessionRequest_KeepAlive // *SessionRequest_CloseSession // *SessionRequest_Command // *SessionRequest_Query Request isSessionRequest_Request `protobuf_oneof:"request"` }
func (*SessionRequest) Descriptor ¶
func (*SessionRequest) Descriptor() ([]byte, []int)
func (*SessionRequest) GetCloseSession ¶
func (m *SessionRequest) GetCloseSession() *CloseSessionRequest
func (*SessionRequest) GetCommand ¶
func (m *SessionRequest) GetCommand() *SessionCommandRequest
func (*SessionRequest) GetKeepAlive ¶
func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest
func (*SessionRequest) GetOpenSession ¶
func (m *SessionRequest) GetOpenSession() *OpenSessionRequest
func (*SessionRequest) GetQuery ¶
func (m *SessionRequest) GetQuery() *SessionQueryRequest
func (*SessionRequest) GetRequest ¶
func (m *SessionRequest) GetRequest() isSessionRequest_Request
func (*SessionRequest) Marshal ¶
func (m *SessionRequest) Marshal() (dAtA []byte, err error)
func (*SessionRequest) MarshalToSizedBuffer ¶
func (m *SessionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest) ProtoMessage ¶
func (*SessionRequest) ProtoMessage()
func (*SessionRequest) Reset ¶
func (m *SessionRequest) Reset()
func (*SessionRequest) Size ¶
func (m *SessionRequest) Size() (n int)
func (*SessionRequest) String ¶
func (m *SessionRequest) String() string
func (*SessionRequest) Unmarshal ¶
func (m *SessionRequest) Unmarshal(dAtA []byte) error
func (*SessionRequest) XXX_DiscardUnknown ¶
func (m *SessionRequest) XXX_DiscardUnknown()
func (*SessionRequest) XXX_Marshal ¶
func (m *SessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionRequest) XXX_Merge ¶
func (m *SessionRequest) XXX_Merge(src proto.Message)
func (*SessionRequest) XXX_OneofWrappers ¶
func (*SessionRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SessionRequest) XXX_Size ¶
func (m *SessionRequest) XXX_Size() int
func (*SessionRequest) XXX_Unmarshal ¶
func (m *SessionRequest) XXX_Unmarshal(b []byte) error
type SessionRequest_CloseSession ¶
type SessionRequest_CloseSession struct {
CloseSession *CloseSessionRequest `protobuf:"bytes,3,opt,name=close_session,json=closeSession,proto3,oneof" json:"close_session,omitempty"`
}
func (*SessionRequest_CloseSession) MarshalTo ¶
func (m *SessionRequest_CloseSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_CloseSession) MarshalToSizedBuffer ¶
func (m *SessionRequest_CloseSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_CloseSession) Size ¶
func (m *SessionRequest_CloseSession) Size() (n int)
type SessionRequest_Command ¶
type SessionRequest_Command struct {
Command *SessionCommandRequest `protobuf:"bytes,4,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func (*SessionRequest_Command) MarshalTo ¶
func (m *SessionRequest_Command) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_Command) MarshalToSizedBuffer ¶
func (m *SessionRequest_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_Command) Size ¶
func (m *SessionRequest_Command) Size() (n int)
type SessionRequest_KeepAlive ¶
type SessionRequest_KeepAlive struct {
KeepAlive *KeepAliveRequest `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3,oneof" json:"keep_alive,omitempty"`
}
func (*SessionRequest_KeepAlive) MarshalTo ¶
func (m *SessionRequest_KeepAlive) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_KeepAlive) MarshalToSizedBuffer ¶
func (m *SessionRequest_KeepAlive) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_KeepAlive) Size ¶
func (m *SessionRequest_KeepAlive) Size() (n int)
type SessionRequest_OpenSession ¶
type SessionRequest_OpenSession struct {
OpenSession *OpenSessionRequest `protobuf:"bytes,1,opt,name=open_session,json=openSession,proto3,oneof" json:"open_session,omitempty"`
}
func (*SessionRequest_OpenSession) MarshalTo ¶
func (m *SessionRequest_OpenSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_OpenSession) MarshalToSizedBuffer ¶
func (m *SessionRequest_OpenSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_OpenSession) Size ¶
func (m *SessionRequest_OpenSession) Size() (n int)
type SessionRequest_Query ¶
type SessionRequest_Query struct {
Query *SessionQueryRequest `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func (*SessionRequest_Query) MarshalTo ¶
func (m *SessionRequest_Query) MarshalTo(dAtA []byte) (int, error)
func (*SessionRequest_Query) MarshalToSizedBuffer ¶
func (m *SessionRequest_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionRequest_Query) Size ¶
func (m *SessionRequest_Query) Size() (n int)
type SessionResponse ¶
type SessionResponse struct { // Types that are valid to be assigned to Response: // *SessionResponse_OpenSession // *SessionResponse_KeepAlive // *SessionResponse_CloseSession // *SessionResponse_Command // *SessionResponse_Query Response isSessionResponse_Response `protobuf_oneof:"response"` }
func (*SessionResponse) Descriptor ¶
func (*SessionResponse) Descriptor() ([]byte, []int)
func (*SessionResponse) GetCloseSession ¶
func (m *SessionResponse) GetCloseSession() *CloseSessionResponse
func (*SessionResponse) GetCommand ¶
func (m *SessionResponse) GetCommand() *SessionCommandResponse
func (*SessionResponse) GetKeepAlive ¶
func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse
func (*SessionResponse) GetOpenSession ¶
func (m *SessionResponse) GetOpenSession() *OpenSessionResponse
func (*SessionResponse) GetQuery ¶
func (m *SessionResponse) GetQuery() *SessionQueryResponse
func (*SessionResponse) GetResponse ¶
func (m *SessionResponse) GetResponse() isSessionResponse_Response
func (*SessionResponse) Marshal ¶
func (m *SessionResponse) Marshal() (dAtA []byte, err error)
func (*SessionResponse) MarshalToSizedBuffer ¶
func (m *SessionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse) ProtoMessage ¶
func (*SessionResponse) ProtoMessage()
func (*SessionResponse) Reset ¶
func (m *SessionResponse) Reset()
func (*SessionResponse) Size ¶
func (m *SessionResponse) Size() (n int)
func (*SessionResponse) String ¶
func (m *SessionResponse) String() string
func (*SessionResponse) Unmarshal ¶
func (m *SessionResponse) Unmarshal(dAtA []byte) error
func (*SessionResponse) XXX_DiscardUnknown ¶
func (m *SessionResponse) XXX_DiscardUnknown()
func (*SessionResponse) XXX_Marshal ¶
func (m *SessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionResponse) XXX_Merge ¶
func (m *SessionResponse) XXX_Merge(src proto.Message)
func (*SessionResponse) XXX_OneofWrappers ¶
func (*SessionResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SessionResponse) XXX_Size ¶
func (m *SessionResponse) XXX_Size() int
func (*SessionResponse) XXX_Unmarshal ¶
func (m *SessionResponse) XXX_Unmarshal(b []byte) error
type SessionResponseContext ¶
type SessionResponseContext struct { StreamID uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"` Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` Type ResponseType `protobuf:"varint,4,opt,name=type,proto3,enum=atomix.service.ResponseType" json:"type,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) GetStreamID ¶
func (m *SessionResponseContext) GetStreamID() uint64
func (*SessionResponseContext) GetType ¶
func (m *SessionResponseContext) GetType() ResponseType
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 SessionResponse_CloseSession ¶
type SessionResponse_CloseSession struct {
CloseSession *CloseSessionResponse `protobuf:"bytes,3,opt,name=close_session,json=closeSession,proto3,oneof" json:"close_session,omitempty"`
}
func (*SessionResponse_CloseSession) MarshalTo ¶
func (m *SessionResponse_CloseSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_CloseSession) MarshalToSizedBuffer ¶
func (m *SessionResponse_CloseSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_CloseSession) Size ¶
func (m *SessionResponse_CloseSession) Size() (n int)
type SessionResponse_Command ¶
type SessionResponse_Command struct {
Command *SessionCommandResponse `protobuf:"bytes,4,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func (*SessionResponse_Command) MarshalTo ¶
func (m *SessionResponse_Command) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_Command) MarshalToSizedBuffer ¶
func (m *SessionResponse_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_Command) Size ¶
func (m *SessionResponse_Command) Size() (n int)
type SessionResponse_KeepAlive ¶
type SessionResponse_KeepAlive struct {
KeepAlive *KeepAliveResponse `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3,oneof" json:"keep_alive,omitempty"`
}
func (*SessionResponse_KeepAlive) MarshalTo ¶
func (m *SessionResponse_KeepAlive) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_KeepAlive) MarshalToSizedBuffer ¶
func (m *SessionResponse_KeepAlive) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_KeepAlive) Size ¶
func (m *SessionResponse_KeepAlive) Size() (n int)
type SessionResponse_OpenSession ¶
type SessionResponse_OpenSession struct {
OpenSession *OpenSessionResponse `protobuf:"bytes,1,opt,name=open_session,json=openSession,proto3,oneof" json:"open_session,omitempty"`
}
func (*SessionResponse_OpenSession) MarshalTo ¶
func (m *SessionResponse_OpenSession) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_OpenSession) MarshalToSizedBuffer ¶
func (m *SessionResponse_OpenSession) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_OpenSession) Size ¶
func (m *SessionResponse_OpenSession) Size() (n int)
type SessionResponse_Query ¶
type SessionResponse_Query struct {
Query *SessionQueryResponse `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func (*SessionResponse_Query) MarshalTo ¶
func (m *SessionResponse_Query) MarshalTo(dAtA []byte) (int, error)
func (*SessionResponse_Query) MarshalToSizedBuffer ¶
func (m *SessionResponse_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionResponse_Query) Size ¶
func (m *SessionResponse_Query) Size() (n int)
type 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"` LastApplied uint64 `protobuf:"varint,5,opt,name=last_applied,json=lastApplied,proto3" json:"last_applied,omitempty"` Streams []*SessionStreamSnapshot `protobuf:"bytes,6,rep,name=streams,proto3" json:"streams,omitempty"` }
Service session
func (*SessionSnapshot) Descriptor ¶
func (*SessionSnapshot) Descriptor() ([]byte, []int)
func (*SessionSnapshot) GetCommandSequence ¶
func (m *SessionSnapshot) GetCommandSequence() uint64
func (*SessionSnapshot) GetLastApplied ¶
func (m *SessionSnapshot) GetLastApplied() uint64
func (*SessionSnapshot) GetSessionID ¶
func (m *SessionSnapshot) GetSessionID() uint64
func (*SessionSnapshot) GetStreams ¶
func (m *SessionSnapshot) GetStreams() []*SessionStreamSnapshot
func (*SessionSnapshot) GetTimeout ¶
func (m *SessionSnapshot) GetTimeout() time.Duration
func (*SessionSnapshot) GetTimestamp ¶
func (m *SessionSnapshot) GetTimestamp() time.Time
func (*SessionSnapshot) Marshal ¶
func (m *SessionSnapshot) Marshal() (dAtA []byte, err error)
func (*SessionSnapshot) MarshalToSizedBuffer ¶
func (m *SessionSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionSnapshot) ProtoMessage ¶
func (*SessionSnapshot) ProtoMessage()
func (*SessionSnapshot) Reset ¶
func (m *SessionSnapshot) Reset()
func (*SessionSnapshot) Size ¶
func (m *SessionSnapshot) Size() (n int)
func (*SessionSnapshot) String ¶
func (m *SessionSnapshot) String() string
func (*SessionSnapshot) Unmarshal ¶
func (m *SessionSnapshot) Unmarshal(dAtA []byte) error
func (*SessionSnapshot) XXX_DiscardUnknown ¶
func (m *SessionSnapshot) XXX_DiscardUnknown()
func (*SessionSnapshot) XXX_Marshal ¶
func (m *SessionSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionSnapshot) XXX_Merge ¶
func (m *SessionSnapshot) XXX_Merge(src proto.Message)
func (*SessionSnapshot) XXX_Size ¶
func (m *SessionSnapshot) XXX_Size() int
func (*SessionSnapshot) XXX_Unmarshal ¶
func (m *SessionSnapshot) XXX_Unmarshal(b []byte) error
type SessionStreamSnapshot ¶
type SessionStreamSnapshot struct { StreamId uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` SequenceNumber uint64 `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` LastCompleted uint64 `protobuf:"varint,4,opt,name=last_completed,json=lastCompleted,proto3" json:"last_completed,omitempty"` }
Service session stream
func (*SessionStreamSnapshot) Descriptor ¶
func (*SessionStreamSnapshot) Descriptor() ([]byte, []int)
func (*SessionStreamSnapshot) GetLastCompleted ¶
func (m *SessionStreamSnapshot) GetLastCompleted() uint64
func (*SessionStreamSnapshot) GetSequenceNumber ¶
func (m *SessionStreamSnapshot) GetSequenceNumber() uint64
func (*SessionStreamSnapshot) GetStreamId ¶
func (m *SessionStreamSnapshot) GetStreamId() uint64
func (*SessionStreamSnapshot) GetType ¶
func (m *SessionStreamSnapshot) GetType() string
func (*SessionStreamSnapshot) Marshal ¶
func (m *SessionStreamSnapshot) Marshal() (dAtA []byte, err error)
func (*SessionStreamSnapshot) MarshalTo ¶
func (m *SessionStreamSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*SessionStreamSnapshot) MarshalToSizedBuffer ¶
func (m *SessionStreamSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionStreamSnapshot) ProtoMessage ¶
func (*SessionStreamSnapshot) ProtoMessage()
func (*SessionStreamSnapshot) Reset ¶
func (m *SessionStreamSnapshot) Reset()
func (*SessionStreamSnapshot) Size ¶
func (m *SessionStreamSnapshot) Size() (n int)
func (*SessionStreamSnapshot) String ¶
func (m *SessionStreamSnapshot) String() string
func (*SessionStreamSnapshot) Unmarshal ¶
func (m *SessionStreamSnapshot) Unmarshal(dAtA []byte) error
func (*SessionStreamSnapshot) XXX_DiscardUnknown ¶
func (m *SessionStreamSnapshot) XXX_DiscardUnknown()
func (*SessionStreamSnapshot) XXX_Marshal ¶
func (m *SessionStreamSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionStreamSnapshot) XXX_Merge ¶
func (m *SessionStreamSnapshot) XXX_Merge(src proto.Message)
func (*SessionStreamSnapshot) XXX_Size ¶
func (m *SessionStreamSnapshot) XXX_Size() int
func (*SessionStreamSnapshot) XXX_Unmarshal ¶
func (m *SessionStreamSnapshot) XXX_Unmarshal(b []byte) error
type SessionizedService ¶
type SessionizedService struct { Service // contains filtered or unexported fields }
SessionizedService is a Service implementation for primitives that support sessions
func NewSessionizedService ¶
func NewSessionizedService(parent Context) *SessionizedService
NewSessionizedService returns an initialized SessionizedService
func (*SessionizedService) CanDelete ¶
func (s *SessionizedService) CanDelete(index uint64) bool
CanDelete returns a boolean indicating whether entries up to the given index can be deleted
func (*SessionizedService) Command ¶
func (s *SessionizedService) Command(bytes []byte, stream streams.WriteStream)
Command handles a service command
func (*SessionizedService) Install ¶
func (s *SessionizedService) Install(reader io.Reader) error
Install installs a snapshot of the service
func (*SessionizedService) OnClose ¶
func (s *SessionizedService) OnClose(f func(*Session))
OnClose is called when a session is closed by the client
func (*SessionizedService) OnExpire ¶
func (s *SessionizedService) OnExpire(f func(*Session))
OnExpire is called when a session is expired by the server
func (*SessionizedService) OnOpen ¶
func (s *SessionizedService) OnOpen(f func(*Session))
OnOpen is called when a session is opened
func (*SessionizedService) Query ¶
func (s *SessionizedService) Query(bytes []byte, stream streams.WriteStream)
Query handles a service query
func (*SessionizedService) Session ¶
func (s *SessionizedService) Session() *Session
Session returns the currently active session
func (*SessionizedService) Sessions ¶
func (s *SessionizedService) Sessions() map[uint64]*Session
Sessions returns a map of currently active sessions
type SessionizedServiceSnapshot ¶
type SessionizedServiceSnapshot struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Sessions []*SessionSnapshot `protobuf:"bytes,3,rep,name=sessions,proto3" json:"sessions,omitempty"` }
Sessionized service snapshot
func (*SessionizedServiceSnapshot) Descriptor ¶
func (*SessionizedServiceSnapshot) Descriptor() ([]byte, []int)
func (*SessionizedServiceSnapshot) GetIndex ¶
func (m *SessionizedServiceSnapshot) GetIndex() uint64
func (*SessionizedServiceSnapshot) GetSessions ¶
func (m *SessionizedServiceSnapshot) GetSessions() []*SessionSnapshot
func (*SessionizedServiceSnapshot) GetTimestamp ¶
func (m *SessionizedServiceSnapshot) GetTimestamp() uint64
func (*SessionizedServiceSnapshot) Marshal ¶
func (m *SessionizedServiceSnapshot) Marshal() (dAtA []byte, err error)
func (*SessionizedServiceSnapshot) MarshalTo ¶
func (m *SessionizedServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*SessionizedServiceSnapshot) MarshalToSizedBuffer ¶
func (m *SessionizedServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SessionizedServiceSnapshot) ProtoMessage ¶
func (*SessionizedServiceSnapshot) ProtoMessage()
func (*SessionizedServiceSnapshot) Reset ¶
func (m *SessionizedServiceSnapshot) Reset()
func (*SessionizedServiceSnapshot) Size ¶
func (m *SessionizedServiceSnapshot) Size() (n int)
func (*SessionizedServiceSnapshot) String ¶
func (m *SessionizedServiceSnapshot) String() string
func (*SessionizedServiceSnapshot) Unmarshal ¶
func (m *SessionizedServiceSnapshot) Unmarshal(dAtA []byte) error
func (*SessionizedServiceSnapshot) XXX_DiscardUnknown ¶
func (m *SessionizedServiceSnapshot) XXX_DiscardUnknown()
func (*SessionizedServiceSnapshot) XXX_Marshal ¶
func (m *SessionizedServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionizedServiceSnapshot) XXX_Merge ¶
func (m *SessionizedServiceSnapshot) XXX_Merge(src proto.Message)
func (*SessionizedServiceSnapshot) XXX_Size ¶
func (m *SessionizedServiceSnapshot) XXX_Size() int
func (*SessionizedServiceSnapshot) XXX_Unmarshal ¶
func (m *SessionizedServiceSnapshot) XXX_Unmarshal(b []byte) error
type SetRequest ¶
type SetRequest struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
Set request
func (*SetRequest) Descriptor ¶
func (*SetRequest) Descriptor() ([]byte, []int)
func (*SetRequest) GetValue ¶
func (m *SetRequest) GetValue() string
func (*SetRequest) Marshal ¶
func (m *SetRequest) Marshal() (dAtA []byte, err error)
func (*SetRequest) MarshalToSizedBuffer ¶
func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) Reset ¶
func (m *SetRequest) Reset()
func (*SetRequest) Size ¶
func (m *SetRequest) Size() (n int)
func (*SetRequest) String ¶
func (m *SetRequest) String() string
func (*SetRequest) Unmarshal ¶
func (m *SetRequest) Unmarshal(dAtA []byte) error
func (*SetRequest) XXX_DiscardUnknown ¶
func (m *SetRequest) XXX_DiscardUnknown()
func (*SetRequest) XXX_Marshal ¶
func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetRequest) XXX_Merge ¶
func (m *SetRequest) XXX_Merge(src proto.Message)
func (*SetRequest) XXX_Size ¶
func (m *SetRequest) XXX_Size() int
func (*SetRequest) XXX_Unmarshal ¶
func (m *SetRequest) XXX_Unmarshal(b []byte) error
type SetResponse ¶
type SetResponse struct { }
Set response
func (*SetResponse) Descriptor ¶
func (*SetResponse) Descriptor() ([]byte, []int)
func (*SetResponse) Marshal ¶
func (m *SetResponse) Marshal() (dAtA []byte, err error)
func (*SetResponse) MarshalToSizedBuffer ¶
func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) Reset ¶
func (m *SetResponse) Reset()
func (*SetResponse) Size ¶
func (m *SetResponse) Size() (n int)
func (*SetResponse) String ¶
func (m *SetResponse) String() string
func (*SetResponse) Unmarshal ¶
func (m *SetResponse) Unmarshal(dAtA []byte) error
func (*SetResponse) XXX_DiscardUnknown ¶
func (m *SetResponse) XXX_DiscardUnknown()
func (*SetResponse) XXX_Marshal ¶
func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetResponse) XXX_Merge ¶
func (m *SetResponse) XXX_Merge(src proto.Message)
func (*SetResponse) XXX_Size ¶
func (m *SetResponse) XXX_Size() int
func (*SetResponse) XXX_Unmarshal ¶
func (m *SetResponse) XXX_Unmarshal(b []byte) error
type SimpleService ¶
type SimpleService struct { Service // contains filtered or unexported fields }
SimpleService is a Service implementation for primitive that do not support sessions
func NewSimpleService ¶
func NewSimpleService(parent Context) *SimpleService
NewSimpleService returns a new simple primitive service
func (*SimpleService) Command ¶
func (s *SimpleService) Command(bytes []byte, stream streams.WriteStream)
Command handles a service command
func (*SimpleService) Install ¶
func (s *SimpleService) Install(reader io.Reader) error
Install installs a snapshot to the service
func (*SimpleService) Query ¶
func (s *SimpleService) Query(bytes []byte, stream streams.WriteStream)
Query handles a service query
type SimpleServiceSnapshot ¶
type SimpleServiceSnapshot struct { Index int64 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"` Timestamp *time.Time `protobuf:"bytes,5,opt,name=timestamp,proto3,stdtime" json:"timestamp,omitempty"` }
Simple service snapshot
func (*SimpleServiceSnapshot) Descriptor ¶
func (*SimpleServiceSnapshot) Descriptor() ([]byte, []int)
func (*SimpleServiceSnapshot) GetIndex ¶
func (m *SimpleServiceSnapshot) GetIndex() int64
func (*SimpleServiceSnapshot) GetTimestamp ¶
func (m *SimpleServiceSnapshot) GetTimestamp() *time.Time
func (*SimpleServiceSnapshot) Marshal ¶
func (m *SimpleServiceSnapshot) Marshal() (dAtA []byte, err error)
func (*SimpleServiceSnapshot) MarshalTo ¶
func (m *SimpleServiceSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*SimpleServiceSnapshot) MarshalToSizedBuffer ¶
func (m *SimpleServiceSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SimpleServiceSnapshot) ProtoMessage ¶
func (*SimpleServiceSnapshot) ProtoMessage()
func (*SimpleServiceSnapshot) Reset ¶
func (m *SimpleServiceSnapshot) Reset()
func (*SimpleServiceSnapshot) Size ¶
func (m *SimpleServiceSnapshot) Size() (n int)
func (*SimpleServiceSnapshot) String ¶
func (m *SimpleServiceSnapshot) String() string
func (*SimpleServiceSnapshot) Unmarshal ¶
func (m *SimpleServiceSnapshot) Unmarshal(dAtA []byte) error
func (*SimpleServiceSnapshot) XXX_DiscardUnknown ¶
func (m *SimpleServiceSnapshot) XXX_DiscardUnknown()
func (*SimpleServiceSnapshot) XXX_Marshal ¶
func (m *SimpleServiceSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SimpleServiceSnapshot) XXX_Merge ¶
func (m *SimpleServiceSnapshot) XXX_Merge(src proto.Message)
func (*SimpleServiceSnapshot) XXX_Size ¶
func (m *SimpleServiceSnapshot) XXX_Size() int
func (*SimpleServiceSnapshot) XXX_Unmarshal ¶
func (m *SimpleServiceSnapshot) XXX_Unmarshal(b []byte) error
type StreamingOperation ¶
type StreamingOperation interface { // Execute executes the operation Execute(bytes []byte, stream stream.WriteStream) }
StreamingOperation is a primitive operation that returns a stream
type TestService ¶
type TestService struct { *SessionizedService // contains filtered or unexported fields }
TestService is a state machine for a test primitive
func (*TestService) Backup ¶
func (s *TestService) Backup() ([]byte, error)
Backup backs up the map service
func (*TestService) Get ¶
func (s *TestService) Get(value []byte) ([]byte, error)
Get gets the value
func (*TestService) Restore ¶
func (s *TestService) Restore(bytes []byte) error
Restore restores the map service
type TestValueSnapshot ¶
type TestValueSnapshot struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
Test value snapshot
func (*TestValueSnapshot) Descriptor ¶
func (*TestValueSnapshot) Descriptor() ([]byte, []int)
func (*TestValueSnapshot) GetValue ¶
func (m *TestValueSnapshot) GetValue() string
func (*TestValueSnapshot) Marshal ¶
func (m *TestValueSnapshot) Marshal() (dAtA []byte, err error)
func (*TestValueSnapshot) MarshalTo ¶
func (m *TestValueSnapshot) MarshalTo(dAtA []byte) (int, error)
func (*TestValueSnapshot) MarshalToSizedBuffer ¶
func (m *TestValueSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TestValueSnapshot) ProtoMessage ¶
func (*TestValueSnapshot) ProtoMessage()
func (*TestValueSnapshot) Reset ¶
func (m *TestValueSnapshot) Reset()
func (*TestValueSnapshot) Size ¶
func (m *TestValueSnapshot) Size() (n int)
func (*TestValueSnapshot) String ¶
func (m *TestValueSnapshot) String() string
func (*TestValueSnapshot) Unmarshal ¶
func (m *TestValueSnapshot) Unmarshal(dAtA []byte) error
func (*TestValueSnapshot) XXX_DiscardUnknown ¶
func (m *TestValueSnapshot) XXX_DiscardUnknown()
func (*TestValueSnapshot) XXX_Marshal ¶
func (m *TestValueSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestValueSnapshot) XXX_Merge ¶
func (m *TestValueSnapshot) XXX_Merge(src proto.Message)
func (*TestValueSnapshot) XXX_Size ¶
func (m *TestValueSnapshot) XXX_Size() int
func (*TestValueSnapshot) XXX_Unmarshal ¶
func (m *TestValueSnapshot) XXX_Unmarshal(b []byte) error
type Timer ¶
type Timer interface {
// Cancel cancels the timer, preventing it from running in the future
Cancel()
}
Timer is a cancellable timer
type UnaryOperation ¶
type UnaryOperation interface { // Execute executes the operation Execute(bytes []byte) ([]byte, error) }
UnaryOperation is a primitive operation that returns a result