primitive

package
v0.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 13, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ServiceType_name = map[int32]string{
	0:  "UNKNOWN_SERVICE",
	1:  "COUNTER",
	2:  "ELECTION",
	3:  "INDEXED_MAP",
	4:  "LEADER_LATCH",
	5:  "LIST",
	6:  "LOCK",
	7:  "LOG",
	8:  "MAP",
	9:  "SET",
	10: "VALUE",
}
View Source 
var ServiceType_value = map[string]int32{
	"UNKNOWN_SERVICE": 0,
	"COUNTER":         1,
	"ELECTION":        2,
	"INDEXED_MAP":     3,
	"LEADER_LATCH":    4,
	"LIST":            5,
	"LOCK":            6,
	"LOG":             7,
	"MAP":             8,
	"SET":             9,
	"VALUE":           10,
}
View Source 
var SessionResponseStatus_name = map[int32]string{
	0:  "OK",
	1:  "ERROR",
	2:  "NOT_LEADER",
	3:  "UNKNOWN",
	4:  "CANCELED",
	5:  "NOT_FOUND",
	6:  "ALREADY_EXISTS",
	7:  "UNAUTHORIZED",
	8:  "FORBIDDEN",
	9:  "CONFLICT",
	10: "INVALID",
	11: "UNAVAILABLE",
	12: "NOT_SUPPORTED",
	13: "TIMEOUT",
	14: "INTERNAL",
}
View Source 
var SessionResponseStatus_value = map[string]int32{
	"OK":             0,
	"ERROR":          1,
	"NOT_LEADER":     2,
	"UNKNOWN":        3,
	"CANCELED":       4,
	"NOT_FOUND":      5,
	"ALREADY_EXISTS": 6,
	"UNAUTHORIZED":   7,
	"FORBIDDEN":      8,
	"CONFLICT":       9,
	"INVALID":        10,
	"UNAVAILABLE":    11,
	"NOT_SUPPORTED":  12,
	"TIMEOUT":        13,
	"INTERNAL":       14,
}
View Source 
var SessionResponseType_name = map[int32]string{
	0: "RESPONSE",
	1: "OPEN_STREAM",
	2: "CLOSE_STREAM",
}
View Source 
var SessionResponseType_value = map[string]int32{
	"RESPONSE":     0,
	"OPEN_STREAM":  1,
	"CLOSE_STREAM": 2,
}

Functions

This section is empty.

Types

type BackupService 

type BackupService interface {
	// Backup is called to take a snapshot of the service state
	Backup(writer io.Writer) error
}

BackupService is an interface for backing up a service

type CloseSessionRequest 

type CloseSessionRequest struct {
	SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() uint64

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

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

func (*CloseSessionRequest) MarshalToSizedBuffer 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

func (m *CloseSessionRequest) Size() (n int)

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

func (m *CloseSessionRequest) Unmarshal(dAtA []byte) error

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

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

func (*CloseSessionRequest) XXX_Merge 

func (m *CloseSessionRequest) XXX_Merge(src proto.Message)

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

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

func (*CloseSessionResponse) MarshalToSizedBuffer 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

func (m *CloseSessionResponse) Size() (n int)

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

func (m *CloseSessionResponse) Unmarshal(dAtA []byte) error

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

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

func (*CloseSessionResponse) XXX_Merge 

func (m *CloseSessionResponse) XXX_Merge(src proto.Message)

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error

type Executor 

type Executor interface {
	// RegisterUnaryOperation registers a unary primitive operation
	RegisterUnaryOperation(id OperationID, callback func([]byte) ([]byte, error))

	// RegisterStreamOperation registers a new primitive operation
	RegisterStreamOperation(id OperationID, callback func([]byte, Stream))

	// GetOperation returns an operation by name
	GetOperation(id OperationID) Operation
}

Executor executes primitive operations

type Index 

type Index uint64

Index is a partition log index

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) MarshalTo 

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

func (*KeepAliveRequest) MarshalToSizedBuffer 

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

func (*KeepAliveRequest) ProtoMessage 

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) Reset 

func (m *KeepAliveRequest) Reset()

func (*KeepAliveRequest) Size 

func (m *KeepAliveRequest) Size() (n int)

func (*KeepAliveRequest) String 

func (m *KeepAliveRequest) String() string

func (*KeepAliveRequest) Unmarshal 

func (m *KeepAliveRequest) Unmarshal(dAtA []byte) error

func (*KeepAliveRequest) XXX_DiscardUnknown 

func (m *KeepAliveRequest) XXX_DiscardUnknown()

func (*KeepAliveRequest) XXX_Marshal 

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

func (*KeepAliveRequest) XXX_Merge 

func (m *KeepAliveRequest) XXX_Merge(src proto.Message)

func (*KeepAliveRequest) XXX_Size 

func (m *KeepAliveRequest) XXX_Size() int

func (*KeepAliveRequest) XXX_Unmarshal 

func (m *KeepAliveRequest) XXX_Unmarshal(b []byte) error

type KeepAliveResponse 

type KeepAliveResponse struct {
}

func (*KeepAliveResponse) Descriptor 

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

func (*KeepAliveResponse) Marshal 

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

func (*KeepAliveResponse) MarshalTo 

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

func (*KeepAliveResponse) MarshalToSizedBuffer 

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

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset 

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) Size 

func (m *KeepAliveResponse) Size() (n int)

func (*KeepAliveResponse) String 

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) Unmarshal 

func (m *KeepAliveResponse) Unmarshal(dAtA []byte) error

func (*KeepAliveResponse) XXX_DiscardUnknown 

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal 

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

func (*KeepAliveResponse) XXX_Merge 

func (m *KeepAliveResponse) XXX_Merge(src proto.Message)

func (*KeepAliveResponse) XXX_Size 

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal 

func (m *KeepAliveResponse) XXX_Unmarshal(b []byte) error

type Manager 

type Manager struct {
	// contains filtered or unexported fields
}

Manager is a Manager implementation for primitives that support sessions

func NewManager 

func NewManager(registry Registry, context PartitionContext) *Manager

NewManager returns an initialized Manager

func (*Manager) Command 

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

Command handles a service command

func (*Manager) Install 

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

Install installs a snapshot of the service

func (*Manager) Query 

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

Query handles a service query

func (*Manager) Snapshot 

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

Snapshot takes a snapshot of the service

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 OperationID 

type OperationID string

OperationID is an operation identifier

type Partition 

type Partition interface {
	// MustLeader returns whether the client can only be used on the leader
	MustLeader() bool

	// IsLeader returns whether the client is the leader
	IsLeader() bool

	// Leader returns the current leader
	Leader() string

	// Write sends a write request
	Write(ctx context.Context, input []byte, stream stream.WriteStream) error

	// Read sends a read request
	Read(ctx context.Context, input []byte, stream stream.WriteStream) error
}

Partition is the interface for a partition client

type PartitionContext 

type PartitionContext interface {
	ProtocolContext

	// PartitionID is the partition identifier
	PartitionID() PartitionID

	// Index returns the current index of the service
	Index() Index

	// Timestamp returns a deterministic, monotonically increasing timestamp
	Timestamp() time.Time
}

PartitionContext provides the current state of the partition

type PartitionID 

type PartitionID int

PartitionID is a partition identifier

type Primitive 

type Primitive interface {
	// RegisterServer registers the primitive server with the gRPC server
	RegisterServer(server *grpc.Server, protocol Protocol)

	// NewService creates a new primitive service
	NewService(scheduler Scheduler, context ServiceContext) Service
}

Primitive is a primitive type

type Protocol 

type Protocol interface {
	// Partition returns a partition
	Partition(partitionID PartitionID) Partition

	// Partitions returns the protocol partitions
	Partitions() []Partition

	// Start starts the protocol
	Start(cluster cluster.Cluster, registry Registry) error

	// Stop stops the protocol
	Stop() error
}

Protocol is the interface to be implemented by replication protocols

type ProtocolContext 

type ProtocolContext interface {
	// NodeID is the local node identifier
	NodeID() string
}

ProtocolContext provides the current state of the protocol

type Registry 

type Registry interface {
	// Register registers a primitive
	Register(primitiveType primitive.PrimitiveType, primitive Primitive)

	// GetPrimitives gets a list of primitives
	GetPrimitives() []Primitive

	// GetPrimitive gets a primitive by type
	GetPrimitive(primitiveType primitive.PrimitiveType) Primitive
}

Registry is a primitive registry

func NewRegistry 

func NewRegistry() Registry

NewRegistry creates a new primitive registry

type RestoreService 

type RestoreService interface {
	// Restore is called to restore the service state from a snapshot
	Restore(reader io.Reader) error
}

RestoreService is an interface for restoring up a service

type Scheduler 

type Scheduler interface {
	// Execute executes a function asynchronously
	Execute(f func())

	// ScheduleOnce schedules a function to be run once after the given delay
	ScheduleOnce(delay time.Duration, f func()) Timer

	// ScheduleRepeat schedules a function to run repeatedly every interval starting after the given delay
	ScheduleRepeat(delay time.Duration, interval time.Duration, f func()) Timer

	// ScheduleIndex schedules a function to run at a specific index
	ScheduleIndex(index Index, f func())
}

Scheduler provides deterministic scheduling for a state machine

type Server 

type Server struct {
	Protocol Protocol
	Type     ServiceType
}

Server is a base server for servers that support sessions

func (*Server) DoCloseService 

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

DoCloseService closes the service

func (*Server) DoCloseSession 

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

DoCloseSession closes a session

func (*Server) DoCommand 

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

DoCommand submits a command to the service

func (*Server) DoCommandStream 

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

DoCommandStream submits a streaming command to the service

func (*Server) DoCreateService 

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

DoCreateService creates the service

func (*Server) DoDeleteService 

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

DoDeleteService deletes the service

func (*Server) DoKeepAliveSession 

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

DoKeepAliveSession keeps a session alive

func (*Server) DoMetadata 

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

DoMetadata submits a metadata query to the service

func (*Server) DoOpenSession 

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

DoOpenSession opens a new session

func (*Server) DoQuery 

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

DoQuery submits a query to the service

func (*Server) DoQueryStream 

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

DoQueryStream submits a streaming query to the service

type Service 

type Service interface {
	BackupService
	RestoreService
	Executor
	Scheduler
	// contains filtered or unexported methods
}

Service is a primitive service

func NewService 

func NewService(scheduler Scheduler, context ServiceContext) Service

NewService creates a new primitive service

type ServiceCloseRequest 

type ServiceCloseRequest struct {
}

func (*ServiceCloseRequest) Descriptor 

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

func (*ServiceCloseRequest) Marshal 

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

func (*ServiceCloseRequest) MarshalTo 

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

func (*ServiceCloseRequest) MarshalToSizedBuffer 

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

func (*ServiceCloseRequest) ProtoMessage 

func (*ServiceCloseRequest) ProtoMessage()

func (*ServiceCloseRequest) Reset 

func (m *ServiceCloseRequest) Reset()

func (*ServiceCloseRequest) Size 

func (m *ServiceCloseRequest) Size() (n int)

func (*ServiceCloseRequest) String 

func (m *ServiceCloseRequest) String() string

func (*ServiceCloseRequest) Unmarshal 

func (m *ServiceCloseRequest) Unmarshal(dAtA []byte) error

func (*ServiceCloseRequest) XXX_DiscardUnknown 

func (m *ServiceCloseRequest) XXX_DiscardUnknown()

func (*ServiceCloseRequest) XXX_Marshal 

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

func (*ServiceCloseRequest) XXX_Merge 

func (m *ServiceCloseRequest) XXX_Merge(src proto.Message)

func (*ServiceCloseRequest) XXX_Size 

func (m *ServiceCloseRequest) XXX_Size() int

func (*ServiceCloseRequest) XXX_Unmarshal 

func (m *ServiceCloseRequest) XXX_Unmarshal(b []byte) error

type ServiceCloseResponse 

type ServiceCloseResponse struct {
}

func (*ServiceCloseResponse) Descriptor 

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

func (*ServiceCloseResponse) Marshal 

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

func (*ServiceCloseResponse) MarshalTo 

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

func (*ServiceCloseResponse) MarshalToSizedBuffer 

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

func (*ServiceCloseResponse) ProtoMessage 

func (*ServiceCloseResponse) ProtoMessage()

func (*ServiceCloseResponse) Reset 

func (m *ServiceCloseResponse) Reset()

func (*ServiceCloseResponse) Size 

func (m *ServiceCloseResponse) Size() (n int)

func (*ServiceCloseResponse) String 

func (m *ServiceCloseResponse) String() string

func (*ServiceCloseResponse) Unmarshal 

func (m *ServiceCloseResponse) Unmarshal(dAtA []byte) error

func (*ServiceCloseResponse) XXX_DiscardUnknown 

func (m *ServiceCloseResponse) XXX_DiscardUnknown()

func (*ServiceCloseResponse) XXX_Marshal 

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

func (*ServiceCloseResponse) XXX_Merge 

func (m *ServiceCloseResponse) XXX_Merge(src proto.Message)

func (*ServiceCloseResponse) XXX_Size 

func (m *ServiceCloseResponse) XXX_Size() int

func (*ServiceCloseResponse) XXX_Unmarshal 

func (m *ServiceCloseResponse) XXX_Unmarshal(b []byte) error

type ServiceCommandRequest 

type ServiceCommandRequest struct {
	Service *ServiceId `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*ServiceCommandRequest_Operation
	//	*ServiceCommandRequest_Create
	//	*ServiceCommandRequest_Close
	//	*ServiceCommandRequest_Delete
	Request isServiceCommandRequest_Request `protobuf_oneof:"request"`
}

func (*ServiceCommandRequest) Descriptor 

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

func (*ServiceCommandRequest) GetClose 

func (m *ServiceCommandRequest) GetClose() *ServiceCloseRequest

func (*ServiceCommandRequest) GetCreate 

func (m *ServiceCommandRequest) GetCreate() *ServiceCreateRequest

func (*ServiceCommandRequest) GetDelete 

func (m *ServiceCommandRequest) GetDelete() *ServiceDeleteRequest

func (*ServiceCommandRequest) GetOperation 

func (m *ServiceCommandRequest) GetOperation() *ServiceOperationRequest

func (*ServiceCommandRequest) GetRequest 

func (m *ServiceCommandRequest) GetRequest() isServiceCommandRequest_Request

func (*ServiceCommandRequest) GetService 

func (m *ServiceCommandRequest) GetService() *ServiceId

func (*ServiceCommandRequest) Marshal 

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

func (*ServiceCommandRequest) MarshalTo 

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

func (*ServiceCommandRequest) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest) ProtoMessage 

func (*ServiceCommandRequest) ProtoMessage()

func (*ServiceCommandRequest) Reset 

func (m *ServiceCommandRequest) Reset()

func (*ServiceCommandRequest) Size 

func (m *ServiceCommandRequest) Size() (n int)

func (*ServiceCommandRequest) String 

func (m *ServiceCommandRequest) String() string

func (*ServiceCommandRequest) Unmarshal 

func (m *ServiceCommandRequest) Unmarshal(dAtA []byte) error

func (*ServiceCommandRequest) XXX_DiscardUnknown 

func (m *ServiceCommandRequest) XXX_DiscardUnknown()

func (*ServiceCommandRequest) XXX_Marshal 

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

func (*ServiceCommandRequest) XXX_Merge 

func (m *ServiceCommandRequest) XXX_Merge(src proto.Message)

func (*ServiceCommandRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceCommandRequest) XXX_Size 

func (m *ServiceCommandRequest) XXX_Size() int

func (*ServiceCommandRequest) XXX_Unmarshal 

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

type ServiceCommandRequest_Close 

type ServiceCommandRequest_Close struct {
	Close *ServiceCloseRequest `protobuf:"bytes,4,opt,name=close,proto3,oneof" json:"close,omitempty"`
}

func (*ServiceCommandRequest_Close) MarshalTo 

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

func (*ServiceCommandRequest_Close) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Close) Size 

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

type ServiceCommandRequest_Create 

type ServiceCommandRequest_Create struct {
	Create *ServiceCreateRequest `protobuf:"bytes,3,opt,name=create,proto3,oneof" json:"create,omitempty"`
}

func (*ServiceCommandRequest_Create) MarshalTo 

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

func (*ServiceCommandRequest_Create) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Create) Size 

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

type ServiceCommandRequest_Delete 

type ServiceCommandRequest_Delete struct {
	Delete *ServiceDeleteRequest `protobuf:"bytes,5,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
}

func (*ServiceCommandRequest_Delete) MarshalTo 

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

func (*ServiceCommandRequest_Delete) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Delete) Size 

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

type ServiceCommandRequest_Operation 

type ServiceCommandRequest_Operation struct {
	Operation *ServiceOperationRequest `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}

func (*ServiceCommandRequest_Operation) MarshalTo 

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

func (*ServiceCommandRequest_Operation) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Operation) Size 

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

type ServiceCommandResponse 

type ServiceCommandResponse struct {
	// Types that are valid to be assigned to Response:
	//	*ServiceCommandResponse_Operation
	//	*ServiceCommandResponse_Create
	//	*ServiceCommandResponse_Close
	//	*ServiceCommandResponse_Delete
	Response isServiceCommandResponse_Response `protobuf_oneof:"response"`
}

func (*ServiceCommandResponse) Descriptor 

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

func (*ServiceCommandResponse) GetClose 

func (m *ServiceCommandResponse) GetClose() *ServiceCloseResponse

func (*ServiceCommandResponse) GetCreate 

func (m *ServiceCommandResponse) GetCreate() *ServiceCreateResponse

func (*ServiceCommandResponse) GetDelete 

func (m *ServiceCommandResponse) GetDelete() *ServiceDeleteResponse

func (*ServiceCommandResponse) GetOperation 

func (m *ServiceCommandResponse) GetOperation() *ServiceOperationResponse

func (*ServiceCommandResponse) GetResponse 

func (m *ServiceCommandResponse) GetResponse() isServiceCommandResponse_Response

func (*ServiceCommandResponse) Marshal 

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

func (*ServiceCommandResponse) MarshalTo 

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

func (*ServiceCommandResponse) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse) ProtoMessage 

func (*ServiceCommandResponse) ProtoMessage()

func (*ServiceCommandResponse) Reset 

func (m *ServiceCommandResponse) Reset()

func (*ServiceCommandResponse) Size 

func (m *ServiceCommandResponse) Size() (n int)

func (*ServiceCommandResponse) String 

func (m *ServiceCommandResponse) String() string

func (*ServiceCommandResponse) Unmarshal 

func (m *ServiceCommandResponse) Unmarshal(dAtA []byte) error

func (*ServiceCommandResponse) XXX_DiscardUnknown 

func (m *ServiceCommandResponse) XXX_DiscardUnknown()

func (*ServiceCommandResponse) XXX_Marshal 

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

func (*ServiceCommandResponse) XXX_Merge 

func (m *ServiceCommandResponse) XXX_Merge(src proto.Message)

func (*ServiceCommandResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceCommandResponse) XXX_Size 

func (m *ServiceCommandResponse) XXX_Size() int

func (*ServiceCommandResponse) XXX_Unmarshal 

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

type ServiceCommandResponse_Close 

type ServiceCommandResponse_Close struct {
	Close *ServiceCloseResponse `protobuf:"bytes,3,opt,name=close,proto3,oneof" json:"close,omitempty"`
}

func (*ServiceCommandResponse_Close) MarshalTo 

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

func (*ServiceCommandResponse_Close) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Close) Size 

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

type ServiceCommandResponse_Create 

type ServiceCommandResponse_Create struct {
	Create *ServiceCreateResponse `protobuf:"bytes,2,opt,name=create,proto3,oneof" json:"create,omitempty"`
}

func (*ServiceCommandResponse_Create) MarshalTo 

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

func (*ServiceCommandResponse_Create) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Create) Size 

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

type ServiceCommandResponse_Delete 

type ServiceCommandResponse_Delete struct {
	Delete *ServiceDeleteResponse `protobuf:"bytes,4,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
}

func (*ServiceCommandResponse_Delete) MarshalTo 

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

func (*ServiceCommandResponse_Delete) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Delete) Size 

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

type ServiceCommandResponse_Operation 

type ServiceCommandResponse_Operation struct {
	Operation *ServiceOperationResponse `protobuf:"bytes,1,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}

func (*ServiceCommandResponse_Operation) MarshalTo 

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

func (*ServiceCommandResponse_Operation) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Operation) Size 

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

type ServiceContext 

type ServiceContext interface {
	PartitionContext

	// ServiceID is the service identifier
	ServiceID() ServiceID

	// ServiceType returns the service type
	ServiceType() ServiceType

	// CurrentOperation returns the current operation identifier
	CurrentOperation() OperationID

	// CurrentSession returns the current session
	CurrentSession() Session

	// Session returns the session with the given identifier
	Session(id SessionID) Session

	// Sessions returns a list of open sessions
	Sessions() []Session
}

ServiceContext provides information about the context within which a service is running

type ServiceCreateRequest 

type ServiceCreateRequest struct {
}

func (*ServiceCreateRequest) Descriptor 

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

func (*ServiceCreateRequest) Marshal 

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

func (*ServiceCreateRequest) MarshalTo 

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

func (*ServiceCreateRequest) MarshalToSizedBuffer 

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

func (*ServiceCreateRequest) ProtoMessage 

func (*ServiceCreateRequest) ProtoMessage()

func (*ServiceCreateRequest) Reset 

func (m *ServiceCreateRequest) Reset()

func (*ServiceCreateRequest) Size 

func (m *ServiceCreateRequest) Size() (n int)

func (*ServiceCreateRequest) String 

func (m *ServiceCreateRequest) String() string

func (*ServiceCreateRequest) Unmarshal 

func (m *ServiceCreateRequest) Unmarshal(dAtA []byte) error

func (*ServiceCreateRequest) XXX_DiscardUnknown 

func (m *ServiceCreateRequest) XXX_DiscardUnknown()

func (*ServiceCreateRequest) XXX_Marshal 

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

func (*ServiceCreateRequest) XXX_Merge 

func (m *ServiceCreateRequest) XXX_Merge(src proto.Message)

func (*ServiceCreateRequest) XXX_Size 

func (m *ServiceCreateRequest) XXX_Size() int

func (*ServiceCreateRequest) XXX_Unmarshal 

func (m *ServiceCreateRequest) XXX_Unmarshal(b []byte) error

type ServiceCreateResponse 

type ServiceCreateResponse struct {
}

func (*ServiceCreateResponse) Descriptor 

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

func (*ServiceCreateResponse) Marshal 

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

func (*ServiceCreateResponse) MarshalTo 

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

func (*ServiceCreateResponse) MarshalToSizedBuffer 

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

func (*ServiceCreateResponse) ProtoMessage 

func (*ServiceCreateResponse) ProtoMessage()

func (*ServiceCreateResponse) Reset 

func (m *ServiceCreateResponse) Reset()

func (*ServiceCreateResponse) Size 

func (m *ServiceCreateResponse) Size() (n int)

func (*ServiceCreateResponse) String 

func (m *ServiceCreateResponse) String() string

func (*ServiceCreateResponse) Unmarshal 

func (m *ServiceCreateResponse) Unmarshal(dAtA []byte) error

func (*ServiceCreateResponse) XXX_DiscardUnknown 

func (m *ServiceCreateResponse) XXX_DiscardUnknown()

func (*ServiceCreateResponse) XXX_Marshal 

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

func (*ServiceCreateResponse) XXX_Merge 

func (m *ServiceCreateResponse) XXX_Merge(src proto.Message)

func (*ServiceCreateResponse) XXX_Size 

func (m *ServiceCreateResponse) XXX_Size() int

func (*ServiceCreateResponse) XXX_Unmarshal 

func (m *ServiceCreateResponse) XXX_Unmarshal(b []byte) error

type ServiceDeleteRequest 

type ServiceDeleteRequest struct {
}

func (*ServiceDeleteRequest) Descriptor 

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

func (*ServiceDeleteRequest) Marshal 

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

func (*ServiceDeleteRequest) MarshalTo 

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

func (*ServiceDeleteRequest) MarshalToSizedBuffer 

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

func (*ServiceDeleteRequest) ProtoMessage 

func (*ServiceDeleteRequest) ProtoMessage()

func (*ServiceDeleteRequest) Reset 

func (m *ServiceDeleteRequest) Reset()

func (*ServiceDeleteRequest) Size 

func (m *ServiceDeleteRequest) Size() (n int)

func (*ServiceDeleteRequest) String 

func (m *ServiceDeleteRequest) String() string

func (*ServiceDeleteRequest) Unmarshal 

func (m *ServiceDeleteRequest) Unmarshal(dAtA []byte) error

func (*ServiceDeleteRequest) XXX_DiscardUnknown 

func (m *ServiceDeleteRequest) XXX_DiscardUnknown()

func (*ServiceDeleteRequest) XXX_Marshal 

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

func (*ServiceDeleteRequest) XXX_Merge 

func (m *ServiceDeleteRequest) XXX_Merge(src proto.Message)

func (*ServiceDeleteRequest) XXX_Size 

func (m *ServiceDeleteRequest) XXX_Size() int

func (*ServiceDeleteRequest) XXX_Unmarshal 

func (m *ServiceDeleteRequest) XXX_Unmarshal(b []byte) error

type ServiceDeleteResponse 

type ServiceDeleteResponse struct {
}

func (*ServiceDeleteResponse) Descriptor 

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

func (*ServiceDeleteResponse) Marshal 

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

func (*ServiceDeleteResponse) MarshalTo 

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

func (*ServiceDeleteResponse) MarshalToSizedBuffer 

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

func (*ServiceDeleteResponse) ProtoMessage 

func (*ServiceDeleteResponse) ProtoMessage()

func (*ServiceDeleteResponse) Reset 

func (m *ServiceDeleteResponse) Reset()

func (*ServiceDeleteResponse) Size 

func (m *ServiceDeleteResponse) Size() (n int)

func (*ServiceDeleteResponse) String 

func (m *ServiceDeleteResponse) String() string

func (*ServiceDeleteResponse) Unmarshal 

func (m *ServiceDeleteResponse) Unmarshal(dAtA []byte) error

func (*ServiceDeleteResponse) XXX_DiscardUnknown 

func (m *ServiceDeleteResponse) XXX_DiscardUnknown()

func (*ServiceDeleteResponse) XXX_Marshal 

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

func (*ServiceDeleteResponse) XXX_Merge 

func (m *ServiceDeleteResponse) XXX_Merge(src proto.Message)

func (*ServiceDeleteResponse) XXX_Size 

func (m *ServiceDeleteResponse) XXX_Size() int

func (*ServiceDeleteResponse) XXX_Unmarshal 

func (m *ServiceDeleteResponse) XXX_Unmarshal(b []byte) error

type ServiceID 

type ServiceID ServiceId

ServiceID is a service identifier

type ServiceId 

type ServiceId struct {
	Type      ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.ServiceType" json:"type,omitempty"`
	Name      string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string      `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*ServiceId) Descriptor 

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

func (*ServiceId) GetName 

func (m *ServiceId) GetName() string

func (*ServiceId) GetNamespace 

func (m *ServiceId) GetNamespace() string

func (*ServiceId) GetType 

func (m *ServiceId) GetType() ServiceType

func (*ServiceId) Marshal 

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

func (*ServiceId) MarshalTo 

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

func (*ServiceId) MarshalToSizedBuffer 

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

func (*ServiceId) ProtoMessage 

func (*ServiceId) ProtoMessage()

func (*ServiceId) Reset 

func (m *ServiceId) Reset()

func (*ServiceId) Size 

func (m *ServiceId) Size() (n int)

func (*ServiceId) String 

func (m *ServiceId) String() string

func (*ServiceId) Unmarshal 

func (m *ServiceId) Unmarshal(dAtA []byte) error

func (*ServiceId) XXX_DiscardUnknown 

func (m *ServiceId) XXX_DiscardUnknown()

func (*ServiceId) XXX_Marshal 

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

func (*ServiceId) XXX_Merge 

func (m *ServiceId) XXX_Merge(src proto.Message)

func (*ServiceId) XXX_Size 

func (m *ServiceId) XXX_Size() int

func (*ServiceId) XXX_Unmarshal 

func (m *ServiceId) XXX_Unmarshal(b []byte) error

type ServiceMetadataRequest 

type ServiceMetadataRequest struct {
	Type      ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.ServiceType" json:"type,omitempty"`
	Namespace string      `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*ServiceMetadataRequest) Descriptor 

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

func (*ServiceMetadataRequest) GetNamespace 

func (m *ServiceMetadataRequest) GetNamespace() string

func (*ServiceMetadataRequest) GetType 

func (m *ServiceMetadataRequest) GetType() ServiceType

func (*ServiceMetadataRequest) Marshal 

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

func (*ServiceMetadataRequest) MarshalTo 

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

func (*ServiceMetadataRequest) MarshalToSizedBuffer 

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

func (*ServiceMetadataRequest) ProtoMessage 

func (*ServiceMetadataRequest) ProtoMessage()

func (*ServiceMetadataRequest) Reset 

func (m *ServiceMetadataRequest) Reset()

func (*ServiceMetadataRequest) Size 

func (m *ServiceMetadataRequest) Size() (n int)

func (*ServiceMetadataRequest) String 

func (m *ServiceMetadataRequest) String() string

func (*ServiceMetadataRequest) Unmarshal 

func (m *ServiceMetadataRequest) Unmarshal(dAtA []byte) error

func (*ServiceMetadataRequest) XXX_DiscardUnknown 

func (m *ServiceMetadataRequest) XXX_DiscardUnknown()

func (*ServiceMetadataRequest) XXX_Marshal 

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

func (*ServiceMetadataRequest) XXX_Merge 

func (m *ServiceMetadataRequest) XXX_Merge(src proto.Message)

func (*ServiceMetadataRequest) XXX_Size 

func (m *ServiceMetadataRequest) XXX_Size() int

func (*ServiceMetadataRequest) XXX_Unmarshal 

func (m *ServiceMetadataRequest) XXX_Unmarshal(b []byte) error

type ServiceMetadataResponse 

type ServiceMetadataResponse struct {
	Services []*ServiceId `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}

func (*ServiceMetadataResponse) Descriptor 

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

func (*ServiceMetadataResponse) GetServices 

func (m *ServiceMetadataResponse) GetServices() []*ServiceId

func (*ServiceMetadataResponse) Marshal 

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

func (*ServiceMetadataResponse) MarshalTo 

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

func (*ServiceMetadataResponse) MarshalToSizedBuffer 

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

func (*ServiceMetadataResponse) ProtoMessage 

func (*ServiceMetadataResponse) ProtoMessage()

func (*ServiceMetadataResponse) Reset 

func (m *ServiceMetadataResponse) Reset()

func (*ServiceMetadataResponse) Size 

func (m *ServiceMetadataResponse) Size() (n int)

func (*ServiceMetadataResponse) String 

func (m *ServiceMetadataResponse) String() string

func (*ServiceMetadataResponse) Unmarshal 

func (m *ServiceMetadataResponse) Unmarshal(dAtA []byte) error

func (*ServiceMetadataResponse) XXX_DiscardUnknown 

func (m *ServiceMetadataResponse) XXX_DiscardUnknown()

func (*ServiceMetadataResponse) XXX_Marshal 

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

func (*ServiceMetadataResponse) XXX_Merge 

func (m *ServiceMetadataResponse) XXX_Merge(src proto.Message)

func (*ServiceMetadataResponse) XXX_Size 

func (m *ServiceMetadataResponse) XXX_Size() int

func (*ServiceMetadataResponse) XXX_Unmarshal 

func (m *ServiceMetadataResponse) XXX_Unmarshal(b []byte) error

type ServiceOperationRequest 

type ServiceOperationRequest struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ServiceOperationRequest) Descriptor 

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

func (*ServiceOperationRequest) GetMethod 

func (m *ServiceOperationRequest) GetMethod() string

func (*ServiceOperationRequest) GetValue 

func (m *ServiceOperationRequest) GetValue() []byte

func (*ServiceOperationRequest) Marshal 

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

func (*ServiceOperationRequest) MarshalTo 

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

func (*ServiceOperationRequest) MarshalToSizedBuffer 

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

func (*ServiceOperationRequest) ProtoMessage 

func (*ServiceOperationRequest) ProtoMessage()

func (*ServiceOperationRequest) Reset 

func (m *ServiceOperationRequest) Reset()

func (*ServiceOperationRequest) Size 

func (m *ServiceOperationRequest) Size() (n int)

func (*ServiceOperationRequest) String 

func (m *ServiceOperationRequest) String() string

func (*ServiceOperationRequest) Unmarshal 

func (m *ServiceOperationRequest) Unmarshal(dAtA []byte) error

func (*ServiceOperationRequest) XXX_DiscardUnknown 

func (m *ServiceOperationRequest) XXX_DiscardUnknown()

func (*ServiceOperationRequest) XXX_Marshal 

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

func (*ServiceOperationRequest) XXX_Merge 

func (m *ServiceOperationRequest) XXX_Merge(src proto.Message)

func (*ServiceOperationRequest) XXX_Size 

func (m *ServiceOperationRequest) XXX_Size() int

func (*ServiceOperationRequest) XXX_Unmarshal 

func (m *ServiceOperationRequest) XXX_Unmarshal(b []byte) error

type ServiceOperationResponse 

type ServiceOperationResponse struct {
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*ServiceOperationResponse) Descriptor 

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

func (*ServiceOperationResponse) GetResult 

func (m *ServiceOperationResponse) GetResult() []byte

func (*ServiceOperationResponse) Marshal 

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

func (*ServiceOperationResponse) MarshalTo 

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

func (*ServiceOperationResponse) MarshalToSizedBuffer 

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

func (*ServiceOperationResponse) ProtoMessage 

func (*ServiceOperationResponse) ProtoMessage()

func (*ServiceOperationResponse) Reset 

func (m *ServiceOperationResponse) Reset()

func (*ServiceOperationResponse) Size 

func (m *ServiceOperationResponse) Size() (n int)

func (*ServiceOperationResponse) String 

func (m *ServiceOperationResponse) String() string

func (*ServiceOperationResponse) Unmarshal 

func (m *ServiceOperationResponse) Unmarshal(dAtA []byte) error

func (*ServiceOperationResponse) XXX_DiscardUnknown 

func (m *ServiceOperationResponse) XXX_DiscardUnknown()

func (*ServiceOperationResponse) XXX_Marshal 

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

func (*ServiceOperationResponse) XXX_Merge 

func (m *ServiceOperationResponse) XXX_Merge(src proto.Message)

func (*ServiceOperationResponse) XXX_Size 

func (m *ServiceOperationResponse) XXX_Size() int

func (*ServiceOperationResponse) XXX_Unmarshal 

func (m *ServiceOperationResponse) XXX_Unmarshal(b []byte) error

type ServiceQueryRequest 

type ServiceQueryRequest struct {
	Service *ServiceId `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*ServiceQueryRequest_Operation
	//	*ServiceQueryRequest_Metadata
	Request isServiceQueryRequest_Request `protobuf_oneof:"request"`
}

func (*ServiceQueryRequest) Descriptor 

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

func (*ServiceQueryRequest) GetMetadata 

func (m *ServiceQueryRequest) GetMetadata() *ServiceMetadataRequest

func (*ServiceQueryRequest) GetOperation 

func (m *ServiceQueryRequest) GetOperation() *ServiceOperationRequest

func (*ServiceQueryRequest) GetRequest 

func (m *ServiceQueryRequest) GetRequest() isServiceQueryRequest_Request

func (*ServiceQueryRequest) GetService 

func (m *ServiceQueryRequest) GetService() *ServiceId

func (*ServiceQueryRequest) Marshal 

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

func (*ServiceQueryRequest) MarshalTo 

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

func (*ServiceQueryRequest) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest) ProtoMessage 

func (*ServiceQueryRequest) ProtoMessage()

func (*ServiceQueryRequest) Reset 

func (m *ServiceQueryRequest) Reset()

func (*ServiceQueryRequest) Size 

func (m *ServiceQueryRequest) Size() (n int)

func (*ServiceQueryRequest) String 

func (m *ServiceQueryRequest) String() string

func (*ServiceQueryRequest) Unmarshal 

func (m *ServiceQueryRequest) Unmarshal(dAtA []byte) error

func (*ServiceQueryRequest) XXX_DiscardUnknown 

func (m *ServiceQueryRequest) XXX_DiscardUnknown()

func (*ServiceQueryRequest) XXX_Marshal 

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

func (*ServiceQueryRequest) XXX_Merge 

func (m *ServiceQueryRequest) XXX_Merge(src proto.Message)

func (*ServiceQueryRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceQueryRequest) XXX_Size 

func (m *ServiceQueryRequest) XXX_Size() int

func (*ServiceQueryRequest) XXX_Unmarshal 

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

type ServiceQueryRequest_Metadata 

type ServiceQueryRequest_Metadata struct {
	Metadata *ServiceMetadataRequest `protobuf:"bytes,3,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}

func (*ServiceQueryRequest_Metadata) MarshalTo 

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

func (*ServiceQueryRequest_Metadata) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest_Metadata) Size 

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

type ServiceQueryRequest_Operation 

type ServiceQueryRequest_Operation struct {
	Operation *ServiceOperationRequest `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}

func (*ServiceQueryRequest_Operation) MarshalTo 

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

func (*ServiceQueryRequest_Operation) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest_Operation) Size 

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

type ServiceQueryResponse 

type ServiceQueryResponse struct {
	// Types that are valid to be assigned to Response:
	//	*ServiceQueryResponse_Operation
	//	*ServiceQueryResponse_Metadata
	Response isServiceQueryResponse_Response `protobuf_oneof:"response"`
}

func (*ServiceQueryResponse) Descriptor 

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

func (*ServiceQueryResponse) GetMetadata 

func (m *ServiceQueryResponse) GetMetadata() *ServiceMetadataResponse

func (*ServiceQueryResponse) GetOperation 

func (m *ServiceQueryResponse) GetOperation() *ServiceOperationResponse

func (*ServiceQueryResponse) GetResponse 

func (m *ServiceQueryResponse) GetResponse() isServiceQueryResponse_Response

func (*ServiceQueryResponse) Marshal 

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

func (*ServiceQueryResponse) MarshalTo 

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

func (*ServiceQueryResponse) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse) ProtoMessage 

func (*ServiceQueryResponse) ProtoMessage()

func (*ServiceQueryResponse) Reset 

func (m *ServiceQueryResponse) Reset()

func (*ServiceQueryResponse) Size 

func (m *ServiceQueryResponse) Size() (n int)

func (*ServiceQueryResponse) String 

func (m *ServiceQueryResponse) String() string

func (*ServiceQueryResponse) Unmarshal 

func (m *ServiceQueryResponse) Unmarshal(dAtA []byte) error

func (*ServiceQueryResponse) XXX_DiscardUnknown 

func (m *ServiceQueryResponse) XXX_DiscardUnknown()

func (*ServiceQueryResponse) XXX_Marshal 

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

func (*ServiceQueryResponse) XXX_Merge 

func (m *ServiceQueryResponse) XXX_Merge(src proto.Message)

func (*ServiceQueryResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceQueryResponse) XXX_Size 

func (m *ServiceQueryResponse) XXX_Size() int

func (*ServiceQueryResponse) XXX_Unmarshal 

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

type ServiceQueryResponse_Metadata 

type ServiceQueryResponse_Metadata struct {
	Metadata *ServiceMetadataResponse `protobuf:"bytes,3,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}

func (*ServiceQueryResponse_Metadata) MarshalTo 

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

func (*ServiceQueryResponse_Metadata) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse_Metadata) Size 

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

type ServiceQueryResponse_Operation 

type ServiceQueryResponse_Operation struct {
	Operation *ServiceOperationResponse `protobuf:"bytes,2,opt,name=operation,proto3,oneof" json:"operation,omitempty"`
}

func (*ServiceQueryResponse_Operation) MarshalTo 

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

func (*ServiceQueryResponse_Operation) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse_Operation) Size 

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

type ServiceType 

type ServiceType int32
const (
	ServiceType_UNKNOWN_SERVICE ServiceType = 0
	ServiceType_COUNTER         ServiceType = 1
	ServiceType_ELECTION        ServiceType = 2
	ServiceType_INDEXED_MAP     ServiceType = 3
	ServiceType_LEADER_LATCH    ServiceType = 4
	ServiceType_LIST            ServiceType = 5
	ServiceType_LOCK            ServiceType = 6
	ServiceType_LOG             ServiceType = 7
	ServiceType_MAP             ServiceType = 8
	ServiceType_SET             ServiceType = 9
	ServiceType_VALUE           ServiceType = 10
)

func (ServiceType) EnumDescriptor 

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

func (ServiceType) String 

func (x ServiceType) String() string

type Session 

type Session interface {
	// ID returns the session identifier
	ID() SessionID

	// Streams returns all open streams
	Streams() []Stream

	// Stream returns a stream by ID
	Stream(id StreamID) Stream

	// StreamsOf returns all open streams for the given operation
	StreamsOf(op OperationID) []Stream
}

Session is a service session

type SessionClosedService 

type SessionClosedService interface {
	// SessionClosed is called when a session is closed for a service
	SessionClosed(Session)
}

SessionClosedService is an interface for listening to session closed events

type SessionCommandContext 

type SessionCommandContext struct {
	SessionID      uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SequenceNumber uint64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
}

func (*SessionCommandContext) Descriptor 

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

func (*SessionCommandContext) GetSequenceNumber 

func (m *SessionCommandContext) GetSequenceNumber() uint64

func (*SessionCommandContext) GetSessionID 

func (m *SessionCommandContext) GetSessionID() uint64

func (*SessionCommandContext) Marshal 

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

func (*SessionCommandContext) MarshalTo 

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

func (*SessionCommandContext) MarshalToSizedBuffer 

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

func (*SessionCommandContext) ProtoMessage 

func (*SessionCommandContext) ProtoMessage()

func (*SessionCommandContext) Reset 

func (m *SessionCommandContext) Reset()

func (*SessionCommandContext) Size 

func (m *SessionCommandContext) Size() (n int)

func (*SessionCommandContext) String 

func (m *SessionCommandContext) String() string

func (*SessionCommandContext) Unmarshal 

func (m *SessionCommandContext) Unmarshal(dAtA []byte) error

func (*SessionCommandContext) XXX_DiscardUnknown 

func (m *SessionCommandContext) XXX_DiscardUnknown()

func (*SessionCommandContext) XXX_Marshal 

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

func (*SessionCommandContext) XXX_Merge 

func (m *SessionCommandContext) XXX_Merge(src proto.Message)

func (*SessionCommandContext) XXX_Size 

func (m *SessionCommandContext) XXX_Size() int

func (*SessionCommandContext) XXX_Unmarshal 

func (m *SessionCommandContext) XXX_Unmarshal(b []byte) error

type SessionCommandRequest 

type SessionCommandRequest struct {
	Context *SessionCommandContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Command *ServiceCommandRequest `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
}

func (*SessionCommandRequest) Descriptor 

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

func (*SessionCommandRequest) GetCommand 

func (m *SessionCommandRequest) GetCommand() *ServiceCommandRequest

func (*SessionCommandRequest) GetContext 

func (m *SessionCommandRequest) GetContext() *SessionCommandContext

func (*SessionCommandRequest) Marshal 

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

func (*SessionCommandRequest) MarshalTo 

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

func (*SessionCommandRequest) MarshalToSizedBuffer 

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

func (*SessionCommandRequest) ProtoMessage 

func (*SessionCommandRequest) ProtoMessage()

func (*SessionCommandRequest) Reset 

func (m *SessionCommandRequest) Reset()

func (*SessionCommandRequest) Size 

func (m *SessionCommandRequest) Size() (n int)

func (*SessionCommandRequest) String 

func (m *SessionCommandRequest) String() string

func (*SessionCommandRequest) Unmarshal 

func (m *SessionCommandRequest) Unmarshal(dAtA []byte) error

func (*SessionCommandRequest) XXX_DiscardUnknown 

func (m *SessionCommandRequest) XXX_DiscardUnknown()

func (*SessionCommandRequest) XXX_Marshal 

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

func (*SessionCommandRequest) XXX_Merge 

func (m *SessionCommandRequest) XXX_Merge(src proto.Message)

func (*SessionCommandRequest) XXX_Size 

func (m *SessionCommandRequest) XXX_Size() int

func (*SessionCommandRequest) XXX_Unmarshal 

func (m *SessionCommandRequest) XXX_Unmarshal(b []byte) error

type SessionCommandResponse 

type SessionCommandResponse struct {
	Context  *SessionResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Response *ServiceCommandResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*SessionCommandResponse) Descriptor 

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

func (*SessionCommandResponse) GetContext 

func (m *SessionCommandResponse) GetContext() *SessionResponseContext

func (*SessionCommandResponse) GetResponse 

func (m *SessionCommandResponse) GetResponse() *ServiceCommandResponse

func (*SessionCommandResponse) Marshal 

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

func (*SessionCommandResponse) MarshalTo 

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

func (*SessionCommandResponse) MarshalToSizedBuffer 

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

func (*SessionCommandResponse) ProtoMessage 

func (*SessionCommandResponse) ProtoMessage()

func (*SessionCommandResponse) Reset 

func (m *SessionCommandResponse) Reset()

func (*SessionCommandResponse) Size 

func (m *SessionCommandResponse) Size() (n int)

func (*SessionCommandResponse) String 

func (m *SessionCommandResponse) String() string

func (*SessionCommandResponse) Unmarshal 

func (m *SessionCommandResponse) Unmarshal(dAtA []byte) error

func (*SessionCommandResponse) XXX_DiscardUnknown 

func (m *SessionCommandResponse) XXX_DiscardUnknown()

func (*SessionCommandResponse) XXX_Marshal 

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

func (*SessionCommandResponse) XXX_Merge 

func (m *SessionCommandResponse) XXX_Merge(src proto.Message)

func (*SessionCommandResponse) XXX_Size 

func (m *SessionCommandResponse) XXX_Size() int

func (*SessionCommandResponse) XXX_Unmarshal 

func (m *SessionCommandResponse) XXX_Unmarshal(b []byte) error

type SessionExpiredService 

type SessionExpiredService interface {
	// SessionExpired is called when a session is expired for a service
	SessionExpired(Session)
}

SessionExpiredService is an interface for listening to session expired events

type SessionID 

type SessionID uint64

SessionID is a session identifier

type SessionOpenService 

type SessionOpenService interface {
	// SessionOpen is called when a session is opened for a service
	SessionOpen(Session)
}

SessionOpenService is an interface for listening to session open events

type SessionOutput 

type SessionOutput struct {
	streams.Result
	Header *headers.ResponseHeader
}

SessionOutput is a result for session-supporting servers containing session header information

type SessionQueryContext 

type SessionQueryContext struct {
	SessionID          uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	LastSequenceNumber uint64 `protobuf:"varint,2,opt,name=last_sequence_number,json=lastSequenceNumber,proto3" json:"last_sequence_number,omitempty"`
	LastIndex          uint64 `protobuf:"varint,3,opt,name=last_index,json=lastIndex,proto3" json:"last_index,omitempty"`
}

func (*SessionQueryContext) Descriptor 

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

func (*SessionQueryContext) GetLastIndex 

func (m *SessionQueryContext) GetLastIndex() uint64

func (*SessionQueryContext) GetLastSequenceNumber 

func (m *SessionQueryContext) GetLastSequenceNumber() uint64

func (*SessionQueryContext) GetSessionID 

func (m *SessionQueryContext) GetSessionID() uint64

func (*SessionQueryContext) Marshal 

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

func (*SessionQueryContext) MarshalTo 

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

func (*SessionQueryContext) MarshalToSizedBuffer 

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

func (*SessionQueryContext) ProtoMessage 

func (*SessionQueryContext) ProtoMessage()

func (*SessionQueryContext) Reset 

func (m *SessionQueryContext) Reset()

func (*SessionQueryContext) Size 

func (m *SessionQueryContext) Size() (n int)

func (*SessionQueryContext) String 

func (m *SessionQueryContext) String() string

func (*SessionQueryContext) Unmarshal 

func (m *SessionQueryContext) Unmarshal(dAtA []byte) error

func (*SessionQueryContext) XXX_DiscardUnknown 

func (m *SessionQueryContext) XXX_DiscardUnknown()

func (*SessionQueryContext) XXX_Marshal 

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

func (*SessionQueryContext) XXX_Merge 

func (m *SessionQueryContext) XXX_Merge(src proto.Message)

func (*SessionQueryContext) XXX_Size 

func (m *SessionQueryContext) XXX_Size() int

func (*SessionQueryContext) XXX_Unmarshal 

func (m *SessionQueryContext) XXX_Unmarshal(b []byte) error

type SessionQueryRequest 

type SessionQueryRequest struct {
	Context *SessionQueryContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Query   *ServiceQueryRequest `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
}

func (*SessionQueryRequest) Descriptor 

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

func (*SessionQueryRequest) GetContext 

func (m *SessionQueryRequest) GetContext() *SessionQueryContext

func (*SessionQueryRequest) GetQuery 

func (m *SessionQueryRequest) GetQuery() *ServiceQueryRequest

func (*SessionQueryRequest) Marshal 

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

func (*SessionQueryRequest) MarshalTo 

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

func (*SessionQueryRequest) MarshalToSizedBuffer 

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

func (*SessionQueryRequest) ProtoMessage 

func (*SessionQueryRequest) ProtoMessage()

func (*SessionQueryRequest) Reset 

func (m *SessionQueryRequest) Reset()

func (*SessionQueryRequest) Size 

func (m *SessionQueryRequest) Size() (n int)

func (*SessionQueryRequest) String 

func (m *SessionQueryRequest) String() string

func (*SessionQueryRequest) Unmarshal 

func (m *SessionQueryRequest) Unmarshal(dAtA []byte) error

func (*SessionQueryRequest) XXX_DiscardUnknown 

func (m *SessionQueryRequest) XXX_DiscardUnknown()

func (*SessionQueryRequest) XXX_Marshal 

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

func (*SessionQueryRequest) XXX_Merge 

func (m *SessionQueryRequest) XXX_Merge(src proto.Message)

func (*SessionQueryRequest) XXX_Size 

func (m *SessionQueryRequest) XXX_Size() int

func (*SessionQueryRequest) XXX_Unmarshal 

func (m *SessionQueryRequest) XXX_Unmarshal(b []byte) error

type SessionQueryResponse 

type SessionQueryResponse struct {
	Context  *SessionResponseContext `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Response *ServiceQueryResponse   `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*SessionQueryResponse) Descriptor 

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

func (*SessionQueryResponse) GetContext 

func (m *SessionQueryResponse) GetContext() *SessionResponseContext

func (*SessionQueryResponse) GetResponse 

func (m *SessionQueryResponse) GetResponse() *ServiceQueryResponse

func (*SessionQueryResponse) Marshal 

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

func (*SessionQueryResponse) MarshalTo 

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

func (*SessionQueryResponse) MarshalToSizedBuffer 

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

func (*SessionQueryResponse) ProtoMessage 

func (*SessionQueryResponse) ProtoMessage()

func (*SessionQueryResponse) Reset 

func (m *SessionQueryResponse) Reset()

func (*SessionQueryResponse) Size 

func (m *SessionQueryResponse) Size() (n int)

func (*SessionQueryResponse) String 

func (m *SessionQueryResponse) String() string

func (*SessionQueryResponse) Unmarshal 

func (m *SessionQueryResponse) Unmarshal(dAtA []byte) error

func (*SessionQueryResponse) XXX_DiscardUnknown 

func (m *SessionQueryResponse) XXX_DiscardUnknown()

func (*SessionQueryResponse) XXX_Marshal 

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

func (*SessionQueryResponse) XXX_Merge 

func (m *SessionQueryResponse) XXX_Merge(src proto.Message)

func (*SessionQueryResponse) XXX_Size 

func (m *SessionQueryResponse) XXX_Size() int

func (*SessionQueryResponse) XXX_Unmarshal 

func (m *SessionQueryResponse) XXX_Unmarshal(b []byte) error

type SessionRequest 

type SessionRequest struct {
	// Types that are valid to be assigned to Request:
	//	*SessionRequest_OpenSession
	//	*SessionRequest_KeepAlive
	//	*SessionRequest_CloseSession
	//	*SessionRequest_Command
	//	*SessionRequest_Query
	Request isSessionRequest_Request `protobuf_oneof:"request"`
}

func (*SessionRequest) Descriptor 

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

func (*SessionRequest) GetCloseSession 

func (m *SessionRequest) GetCloseSession() *CloseSessionRequest

func (*SessionRequest) GetCommand 

func (m *SessionRequest) GetCommand() *SessionCommandRequest

func (*SessionRequest) GetKeepAlive 

func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest

func (*SessionRequest) GetOpenSession 

func (m *SessionRequest) GetOpenSession() *OpenSessionRequest

func (*SessionRequest) GetQuery 

func (m *SessionRequest) GetQuery() *SessionQueryRequest

func (*SessionRequest) GetRequest 

func (m *SessionRequest) GetRequest() isSessionRequest_Request

func (*SessionRequest) Marshal 

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

func (*SessionRequest) MarshalTo 

func (m *SessionRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

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

func (*SessionResponse) MarshalToSizedBuffer 

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

func (*SessionResponse) ProtoMessage 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) Reset 

func (m *SessionResponse) Reset()

func (*SessionResponse) Size 

func (m *SessionResponse) Size() (n int)

func (*SessionResponse) String 

func (m *SessionResponse) String() string

func (*SessionResponse) Unmarshal 

func (m *SessionResponse) Unmarshal(dAtA []byte) error

func (*SessionResponse) XXX_DiscardUnknown 

func (m *SessionResponse) XXX_DiscardUnknown()

func (*SessionResponse) XXX_Marshal 

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

func (*SessionResponse) XXX_Merge 

func (m *SessionResponse) XXX_Merge(src proto.Message)

func (*SessionResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionResponse) XXX_Size 

func (m *SessionResponse) XXX_Size() int

func (*SessionResponse) XXX_Unmarshal 

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

type SessionResponseContext 

type SessionResponseContext struct {
	StreamID uint64                `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Index    uint64                `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Sequence uint64                `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Type     SessionResponseType   `protobuf:"varint,4,opt,name=type,proto3,enum=atomix.service.SessionResponseType" json:"type,omitempty"`
	Status   SessionResponseStatus `protobuf:"varint,5,opt,name=status,proto3,enum=atomix.service.SessionResponseStatus" json:"status,omitempty"`
	Message  string                `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
}

func (*SessionResponseContext) Descriptor 

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

func (*SessionResponseContext) GetIndex 

func (m *SessionResponseContext) GetIndex() uint64

func (*SessionResponseContext) GetMessage 

func (m *SessionResponseContext) GetMessage() string

func (*SessionResponseContext) GetSequence 

func (m *SessionResponseContext) GetSequence() uint64

func (*SessionResponseContext) GetStatus 

func (m *SessionResponseContext) GetStatus() SessionResponseStatus

func (*SessionResponseContext) GetStreamID 

func (m *SessionResponseContext) GetStreamID() uint64

func (*SessionResponseContext) GetType 

func (m *SessionResponseContext) GetType() SessionResponseType

func (*SessionResponseContext) Marshal 

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

func (*SessionResponseContext) MarshalTo 

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

func (*SessionResponseContext) MarshalToSizedBuffer 

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

func (*SessionResponseContext) ProtoMessage 

func (*SessionResponseContext) ProtoMessage()

func (*SessionResponseContext) Reset 

func (m *SessionResponseContext) Reset()

func (*SessionResponseContext) Size 

func (m *SessionResponseContext) Size() (n int)

func (*SessionResponseContext) String 

func (m *SessionResponseContext) String() string

func (*SessionResponseContext) Unmarshal 

func (m *SessionResponseContext) Unmarshal(dAtA []byte) error

func (*SessionResponseContext) XXX_DiscardUnknown 

func (m *SessionResponseContext) XXX_DiscardUnknown()

func (*SessionResponseContext) XXX_Marshal 

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

func (*SessionResponseContext) XXX_Merge 

func (m *SessionResponseContext) XXX_Merge(src proto.Message)

func (*SessionResponseContext) XXX_Size 

func (m *SessionResponseContext) XXX_Size() int

func (*SessionResponseContext) XXX_Unmarshal 

func (m *SessionResponseContext) XXX_Unmarshal(b []byte) error

type SessionResponseStatus 

type SessionResponseStatus int32
const (
	SessionResponseStatus_OK             SessionResponseStatus = 0
	SessionResponseStatus_ERROR          SessionResponseStatus = 1
	SessionResponseStatus_NOT_LEADER     SessionResponseStatus = 2
	SessionResponseStatus_UNKNOWN        SessionResponseStatus = 3
	SessionResponseStatus_CANCELED       SessionResponseStatus = 4
	SessionResponseStatus_NOT_FOUND      SessionResponseStatus = 5
	SessionResponseStatus_ALREADY_EXISTS SessionResponseStatus = 6
	SessionResponseStatus_UNAUTHORIZED   SessionResponseStatus = 7
	SessionResponseStatus_FORBIDDEN      SessionResponseStatus = 8
	SessionResponseStatus_CONFLICT       SessionResponseStatus = 9
	SessionResponseStatus_INVALID        SessionResponseStatus = 10
	SessionResponseStatus_UNAVAILABLE    SessionResponseStatus = 11
	SessionResponseStatus_NOT_SUPPORTED  SessionResponseStatus = 12
	SessionResponseStatus_TIMEOUT        SessionResponseStatus = 13
	SessionResponseStatus_INTERNAL       SessionResponseStatus = 14
)

func (SessionResponseStatus) EnumDescriptor 

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

func (SessionResponseStatus) String 

func (x SessionResponseStatus) String() string

type SessionResponseType 

type SessionResponseType int32
const (
	SessionResponseType_RESPONSE     SessionResponseType = 0
	SessionResponseType_OPEN_STREAM  SessionResponseType = 1
	SessionResponseType_CLOSE_STREAM SessionResponseType = 2
)

func (SessionResponseType) EnumDescriptor 

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

func (SessionResponseType) String 

func (x SessionResponseType) String() string

type SessionResponse_CloseSession 

type SessionResponse_CloseSession struct {
	CloseSession *CloseSessionResponse `protobuf:"bytes,3,opt,name=close_session,json=closeSession,proto3,oneof" json:"close_session,omitempty"`
}

func (*SessionResponse_CloseSession) MarshalTo 

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

func (*SessionResponse_CloseSession) MarshalToSizedBuffer 

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

func (*SessionResponse_CloseSession) Size 

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

type SessionResponse_Command 

type SessionResponse_Command struct {
	Command *SessionCommandResponse `protobuf:"bytes,4,opt,name=command,proto3,oneof" json:"command,omitempty"`
}

func (*SessionResponse_Command) MarshalTo 

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

func (*SessionResponse_Command) MarshalToSizedBuffer 

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

func (*SessionResponse_Command) Size 

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

type SessionResponse_KeepAlive 

type SessionResponse_KeepAlive struct {
	KeepAlive *KeepAliveResponse `protobuf:"bytes,2,opt,name=keep_alive,json=keepAlive,proto3,oneof" json:"keep_alive,omitempty"`
}

func (*SessionResponse_KeepAlive) MarshalTo 

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

func (*SessionResponse_KeepAlive) MarshalToSizedBuffer 

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

func (*SessionResponse_KeepAlive) Size 

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

type SessionResponse_OpenSession 

type SessionResponse_OpenSession struct {
	OpenSession *OpenSessionResponse `protobuf:"bytes,1,opt,name=open_session,json=openSession,proto3,oneof" json:"open_session,omitempty"`
}

func (*SessionResponse_OpenSession) MarshalTo 

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

func (*SessionResponse_OpenSession) MarshalToSizedBuffer 

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

func (*SessionResponse_OpenSession) Size 

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

type SessionResponse_Query 

type SessionResponse_Query struct {
	Query *SessionQueryResponse `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}

func (*SessionResponse_Query) MarshalTo 

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

func (*SessionResponse_Query) MarshalToSizedBuffer 

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

func (*SessionResponse_Query) Size 

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

type SessionServer 

type SessionServer struct {
	*Server
}

SessionServer is an implementation of SessionServiceServer for session management

func (*SessionServer) CloseSession 

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

CloseSession closes a session

func (*SessionServer) KeepAlive 

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

KeepAlive keeps a session alive

func (*SessionServer) OpenSession 

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

OpenSession opens a new session

type SessionServiceSnapshot 

type SessionServiceSnapshot struct {
	ServiceId ServiceId                `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id"`
	Streams   []*SessionStreamSnapshot `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
}

Session service snapshot

func (*SessionServiceSnapshot) Descriptor 

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

func (*SessionServiceSnapshot) GetServiceId 

func (m *SessionServiceSnapshot) GetServiceId() ServiceId

func (*SessionServiceSnapshot) GetStreams 

func (m *SessionServiceSnapshot) GetStreams() []*SessionStreamSnapshot

func (*SessionServiceSnapshot) Marshal 

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

func (*SessionServiceSnapshot) MarshalTo 

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

func (*SessionServiceSnapshot) MarshalToSizedBuffer 

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

func (*SessionServiceSnapshot) ProtoMessage 

func (*SessionServiceSnapshot) ProtoMessage()

func (*SessionServiceSnapshot) Reset 

func (m *SessionServiceSnapshot) Reset()

func (*SessionServiceSnapshot) Size 

func (m *SessionServiceSnapshot) Size() (n int)

func (*SessionServiceSnapshot) String 

func (m *SessionServiceSnapshot) String() string

func (*SessionServiceSnapshot) Unmarshal 

func (m *SessionServiceSnapshot) Unmarshal(dAtA []byte) error

func (*SessionServiceSnapshot) XXX_DiscardUnknown 

func (m *SessionServiceSnapshot) XXX_DiscardUnknown()

func (*SessionServiceSnapshot) XXX_Marshal 

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

func (*SessionServiceSnapshot) XXX_Merge 

func (m *SessionServiceSnapshot) XXX_Merge(src proto.Message)

func (*SessionServiceSnapshot) XXX_Size 

func (m *SessionServiceSnapshot) XXX_Size() int

func (*SessionServiceSnapshot) XXX_Unmarshal 

func (m *SessionServiceSnapshot) XXX_Unmarshal(b []byte) error

type SessionSnapshot 

type SessionSnapshot struct {
	SessionID       uint64                    `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Timeout         time.Duration             `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout"`
	Timestamp       time.Time                 `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	CommandSequence uint64                    `protobuf:"varint,4,opt,name=command_sequence,json=commandSequence,proto3" json:"command_sequence,omitempty"`
	Services        []*SessionServiceSnapshot `protobuf:"bytes,7,rep,name=services,proto3" json:"services,omitempty"`
}

Service session

func (*SessionSnapshot) Descriptor 

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

func (*SessionSnapshot) GetCommandSequence 

func (m *SessionSnapshot) GetCommandSequence() uint64

func (*SessionSnapshot) GetServices 

func (m *SessionSnapshot) GetServices() []*SessionServiceSnapshot

func (*SessionSnapshot) GetSessionID 

func (m *SessionSnapshot) GetSessionID() uint64

func (*SessionSnapshot) GetTimeout 

func (m *SessionSnapshot) GetTimeout() time.Duration

func (*SessionSnapshot) GetTimestamp 

func (m *SessionSnapshot) GetTimestamp() time.Time

func (*SessionSnapshot) Marshal 

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

func (*SessionSnapshot) MarshalTo 

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

func (*SessionSnapshot) MarshalToSizedBuffer 

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

func (*SessionSnapshot) ProtoMessage 

func (*SessionSnapshot) ProtoMessage()

func (*SessionSnapshot) Reset 

func (m *SessionSnapshot) Reset()

func (*SessionSnapshot) Size 

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

func (*SessionSnapshot) String 

func (m *SessionSnapshot) String() string

func (*SessionSnapshot) Unmarshal 

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

func (*SessionSnapshot) XXX_DiscardUnknown 

func (m *SessionSnapshot) XXX_DiscardUnknown()

func (*SessionSnapshot) XXX_Marshal 

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

func (*SessionSnapshot) XXX_Merge 

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

func (*SessionSnapshot) XXX_Size 

func (m *SessionSnapshot) XXX_Size() int

func (*SessionSnapshot) XXX_Unmarshal 

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

type SessionStreamSnapshot 

type SessionStreamSnapshot struct {
	StreamId       uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Type           string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	SequenceNumber uint64 `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	LastCompleted  uint64 `protobuf:"varint,4,opt,name=last_completed,json=lastCompleted,proto3" json:"last_completed,omitempty"`
}

Service session stream

func (*SessionStreamSnapshot) Descriptor 

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

func (*SessionStreamSnapshot) GetLastCompleted 

func (m *SessionStreamSnapshot) GetLastCompleted() uint64

func (*SessionStreamSnapshot) GetSequenceNumber 

func (m *SessionStreamSnapshot) GetSequenceNumber() uint64

func (*SessionStreamSnapshot) GetStreamId 

func (m *SessionStreamSnapshot) GetStreamId() uint64

func (*SessionStreamSnapshot) GetType 

func (m *SessionStreamSnapshot) GetType() string

func (*SessionStreamSnapshot) Marshal 

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

func (*SessionStreamSnapshot) MarshalTo 

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

func (*SessionStreamSnapshot) MarshalToSizedBuffer 

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

func (*SessionStreamSnapshot) ProtoMessage 

func (*SessionStreamSnapshot) ProtoMessage()

func (*SessionStreamSnapshot) Reset 

func (m *SessionStreamSnapshot) Reset()

func (*SessionStreamSnapshot) Size 

func (m *SessionStreamSnapshot) Size() (n int)

func (*SessionStreamSnapshot) String 

func (m *SessionStreamSnapshot) String() string

func (*SessionStreamSnapshot) Unmarshal 

func (m *SessionStreamSnapshot) Unmarshal(dAtA []byte) error

func (*SessionStreamSnapshot) XXX_DiscardUnknown 

func (m *SessionStreamSnapshot) XXX_DiscardUnknown()

func (*SessionStreamSnapshot) XXX_Marshal 

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

func (*SessionStreamSnapshot) XXX_Merge 

func (m *SessionStreamSnapshot) XXX_Merge(src proto.Message)

func (*SessionStreamSnapshot) XXX_Size 

func (m *SessionStreamSnapshot) XXX_Size() int

func (*SessionStreamSnapshot) XXX_Unmarshal 

func (m *SessionStreamSnapshot) XXX_Unmarshal(b []byte) error

type StateMachine 

type StateMachine interface {
	// Snapshot writes the state machine snapshot to the given writer
	Snapshot(writer io.Writer) error

	// Install reads the state machine snapshot from the given reader
	Install(reader io.Reader) error

	// Command applies a command to the state machine
	Command(bytes []byte, stream streams.WriteStream)

	// Query applies a query to the state machine
	Query(bytes []byte, stream streams.WriteStream)
}

StateMachine applies commands from a protocol to a collection of state machines

type Stream 

type Stream interface {
	streams.WriteStream

	// ID returns the stream identifier
	ID() StreamID

	// OperationID returns the stream operation identifier
	OperationID() OperationID

	// Session returns the stream session
	Session() Session
}

Stream is a service stream

type StreamID 

type StreamID uint64

StreamID is a stream identifier

type StreamingOperation 

type StreamingOperation interface {
	// Execute executes the operation
	Execute(bytes []byte, stream Stream)
}

StreamingOperation is a primitive operation that returns a stream

type Timer 

type Timer interface {
	// Cancel cancels the timer, preventing it from running in the future
	Cancel()
}

Timer is a cancellable timer

type UnaryOperation 

type UnaryOperation interface {
	// Execute executes the operation
	Execute(bytes []byte) ([]byte, error)
}

UnaryOperation is a primitive operation that returns a result

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.