rsm

package
v0.6.8 Latest Latest
Warning

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

 Go to latest Published: May 22, 2021 License: Apache-2.0 Imports: 22 Imported by: 5

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 SessionResponseCode_name = map[int32]string{
	0:  "OK",
	1:  "ERROR",
	2:  "NOT_LEADER",
	3:  "UNKNOWN",
	4:  "CANCELED",
	5:  "NOT_FOUND",
	6:  "ALREADY_EXISTS",
	7:  "UNAUTHORIZED",
	8:  "FORBIDDEN",
	9:  "CONFLICT",
	10: "INVALID",
	11: "UNAVAILABLE",
	12: "NOT_SUPPORTED",
	13: "TIMEOUT",
	14: "INTERNAL",
}
View Source 
var SessionResponseCode_value = map[string]int32{
	"OK":             0,
	"ERROR":          1,
	"NOT_LEADER":     2,
	"UNKNOWN":        3,
	"CANCELED":       4,
	"NOT_FOUND":      5,
	"ALREADY_EXISTS": 6,
	"UNAUTHORIZED":   7,
	"FORBIDDEN":      8,
	"CONFLICT":       9,
	"INVALID":        10,
	"UNAVAILABLE":    11,
	"NOT_SUPPORTED":  12,
	"TIMEOUT":        13,
	"INTERNAL":       14,
}
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

func GetErrorFromStatus 

func GetErrorFromStatus(status SessionResponseStatus) error

GetErrorFromStatus creates a typed error from a response status

func RegisterStorageServiceServer 

func RegisterStorageServiceServer(s *grpc.Server, srv StorageServiceServer)

Types

type BackupService 

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

BackupService is an interface for backing up a service

type ClientID 

type ClientID string

ClientID is a client identifier

type CloseSessionRequest 

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

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionID 

func (m *CloseSessionRequest) GetSessionID() uint64

func (*CloseSessionRequest) Marshal 

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

func (*CloseSessionRequest) MarshalTo 

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

func (*CloseSessionRequest) MarshalToSizedBuffer 

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

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) Size 

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

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Unmarshal 

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

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

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

func (*CloseSessionRequest) XXX_Merge 

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

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

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

type CloseSessionResponse 

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) Marshal 

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

func (*CloseSessionResponse) MarshalTo 

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

func (*CloseSessionResponse) MarshalToSizedBuffer 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) Size 

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

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Unmarshal 

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

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

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

func (*CloseSessionResponse) XXX_Merge 

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

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

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

type Executor 

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

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

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

Executor executes primitive operations

type 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         []SessionStreamContext `protobuf:"bytes,3,rep,name=streams,proto3" json:"streams"`
}

func (*KeepAliveRequest) Descriptor 

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

func (*KeepAliveRequest) GetCommandSequence 

func (m *KeepAliveRequest) GetCommandSequence() uint64

func (*KeepAliveRequest) GetSessionID 

func (m *KeepAliveRequest) GetSessionID() uint64

func (*KeepAliveRequest) GetStreams 

func (m *KeepAliveRequest) GetStreams() []SessionStreamContext

func (*KeepAliveRequest) Marshal 

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

func (*KeepAliveRequest) 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(cluster cluster.Cluster, registry *Registry, context PartitionContext) *Manager

NewManager returns an initialized Manager

func (*Manager) Command 

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

Command handles a service command

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 NewServiceFunc 

type NewServiceFunc func(scheduler Scheduler, context ServiceContext) Service

NewServiceFunc is a function for creating a primitive service

type Node 

type Node struct {
	Cluster cluster.Cluster
	// contains filtered or unexported fields
}

Node is an Atomix node

func NewNode 

func NewNode(cluster cluster.Cluster, protocol Protocol) *Node

NewNode creates a new node running the given protocol

func (*Node) RegisterService 

func (n *Node) RegisterService(t string, f NewServiceFunc)

RegisterService registers a primitive service

func (*Node) Start 

func (n *Node) Start() error

Start starts the node

func (*Node) Stop 

func (n *Node) Stop() error

Stop stops the node

type OpenSessionRequest 

type OpenSessionRequest struct {
	ClientID string         `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Timeout  *time.Duration `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout,omitempty"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetClientID 

func (m *OpenSessionRequest) GetClientID() string

func (*OpenSessionRequest) GetTimeout 

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

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

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

func (*OpenSessionRequest) MarshalToSizedBuffer 

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

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

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

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

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

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

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

func (*OpenSessionRequest) XXX_Merge 

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

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

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

type OpenSessionResponse 

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

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() uint64

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

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

func (*OpenSessionResponse) MarshalToSizedBuffer 

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

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

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

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

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

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

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

func (*OpenSessionResponse) XXX_Merge 

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

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

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

type Operation 

type Operation interface{}

Operation is the base interface for primitive operations

type 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

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

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

Partition is the interface for a partition client

type PartitionContext 

type PartitionContext interface {
	// PartitionID is the partition identifier
	PartitionID() PartitionID

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

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

PartitionContext provides the current state of the partition

type PartitionID 

type PartitionID int

PartitionID is a partition identifier

type Protocol 

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

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

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

	// Stop stops the protocol
	Stop() error
}

Protocol is the interface to be implemented by replication protocols

type Registry 

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

Registry is the default primitive registry

func NewRegistry 

func NewRegistry() *Registry

NewRegistry creates a new primitive registry

func (*Registry) GetService 

func (r *Registry) GetService(primitiveType string) NewServiceFunc

func (*Registry) GetServices 

func (r *Registry) GetServices() []NewServiceFunc

func (*Registry) Register 

func (r *Registry) Register(primitiveType string, primitive NewServiceFunc)

type RestoreService 

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

RestoreService is an interface for restoring up a service

type Scheduler 

type Scheduler interface {
	// Time returns the current time
	Time() time.Time

	// Run executes a function asynchronously
	Run(f func())

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

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

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

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

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

Scheduler provides deterministic scheduling for a state machine

type Server 

type Server struct {
	Protocol Protocol
}

Server is a base server for servers that support sessions

func (*Server) Request 

func (s *Server) Request(request *StorageRequest, stream StorageService_RequestServer) error

type Service 

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

Service is a primitive service

func NewService 

func NewService(scheduler Scheduler, context ServiceContext) Service

NewService creates a new primitive service

type ServiceCloseRequest 

type ServiceCloseRequest struct {
}

func (*ServiceCloseRequest) Descriptor 

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

func (*ServiceCloseRequest) Marshal 

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

func (*ServiceCloseRequest) MarshalTo 

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

func (*ServiceCloseRequest) MarshalToSizedBuffer 

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

func (*ServiceCloseRequest) ProtoMessage 

func (*ServiceCloseRequest) ProtoMessage()

func (*ServiceCloseRequest) Reset 

func (m *ServiceCloseRequest) Reset()

func (*ServiceCloseRequest) Size 

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

func (*ServiceCloseRequest) String 

func (m *ServiceCloseRequest) String() string

func (*ServiceCloseRequest) Unmarshal 

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

func (*ServiceCloseRequest) XXX_DiscardUnknown 

func (m *ServiceCloseRequest) XXX_DiscardUnknown()

func (*ServiceCloseRequest) XXX_Marshal 

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

func (*ServiceCloseRequest) XXX_Merge 

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

func (*ServiceCloseRequest) XXX_Size 

func (m *ServiceCloseRequest) XXX_Size() int

func (*ServiceCloseRequest) XXX_Unmarshal 

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

type ServiceCloseResponse 

type ServiceCloseResponse struct {
}

func (*ServiceCloseResponse) Descriptor 

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

func (*ServiceCloseResponse) Marshal 

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

func (*ServiceCloseResponse) MarshalTo 

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

func (*ServiceCloseResponse) MarshalToSizedBuffer 

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

func (*ServiceCloseResponse) ProtoMessage 

func (*ServiceCloseResponse) ProtoMessage()

func (*ServiceCloseResponse) Reset 

func (m *ServiceCloseResponse) Reset()

func (*ServiceCloseResponse) Size 

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

func (*ServiceCloseResponse) String 

func (m *ServiceCloseResponse) String() string

func (*ServiceCloseResponse) Unmarshal 

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

func (*ServiceCloseResponse) XXX_DiscardUnknown 

func (m *ServiceCloseResponse) XXX_DiscardUnknown()

func (*ServiceCloseResponse) XXX_Marshal 

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

func (*ServiceCloseResponse) XXX_Merge 

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

func (*ServiceCloseResponse) XXX_Size 

func (m *ServiceCloseResponse) XXX_Size() int

func (*ServiceCloseResponse) XXX_Unmarshal 

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

type ServiceCommandRequest 

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

func (*ServiceCommandRequest) Descriptor 

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

func (*ServiceCommandRequest) GetClose 

func (m *ServiceCommandRequest) GetClose() *ServiceCloseRequest

func (*ServiceCommandRequest) GetCreate 

func (m *ServiceCommandRequest) GetCreate() *ServiceCreateRequest

func (*ServiceCommandRequest) GetDelete 

func (m *ServiceCommandRequest) GetDelete() *ServiceDeleteRequest

func (*ServiceCommandRequest) GetOperation 

func (m *ServiceCommandRequest) GetOperation() *ServiceOperationRequest

func (*ServiceCommandRequest) GetRequest 

func (m *ServiceCommandRequest) GetRequest() isServiceCommandRequest_Request

func (*ServiceCommandRequest) GetService 

func (m *ServiceCommandRequest) GetService() ServiceId

func (*ServiceCommandRequest) Marshal 

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

func (*ServiceCommandRequest) MarshalTo 

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

func (*ServiceCommandRequest) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest) ProtoMessage 

func (*ServiceCommandRequest) ProtoMessage()

func (*ServiceCommandRequest) Reset 

func (m *ServiceCommandRequest) Reset()

func (*ServiceCommandRequest) Size 

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

func (*ServiceCommandRequest) String 

func (m *ServiceCommandRequest) String() string

func (*ServiceCommandRequest) Unmarshal 

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

func (*ServiceCommandRequest) XXX_DiscardUnknown 

func (m *ServiceCommandRequest) XXX_DiscardUnknown()

func (*ServiceCommandRequest) XXX_Marshal 

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

func (*ServiceCommandRequest) XXX_Merge 

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

func (*ServiceCommandRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceCommandRequest) XXX_Size 

func (m *ServiceCommandRequest) XXX_Size() int

func (*ServiceCommandRequest) XXX_Unmarshal 

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

type ServiceCommandRequest_Close 

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

func (*ServiceCommandRequest_Close) MarshalTo 

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

func (*ServiceCommandRequest_Close) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Close) Size 

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

type ServiceCommandRequest_Create 

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

func (*ServiceCommandRequest_Create) MarshalTo 

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

func (*ServiceCommandRequest_Create) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Create) Size 

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

type ServiceCommandRequest_Delete 

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

func (*ServiceCommandRequest_Delete) MarshalTo 

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

func (*ServiceCommandRequest_Delete) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Delete) Size 

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

type ServiceCommandRequest_Operation 

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

func (*ServiceCommandRequest_Operation) MarshalTo 

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

func (*ServiceCommandRequest_Operation) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Operation) Size 

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

type ServiceCommandResponse 

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

func (*ServiceCommandResponse) Descriptor 

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

func (*ServiceCommandResponse) GetClose 

func (m *ServiceCommandResponse) GetClose() *ServiceCloseResponse

func (*ServiceCommandResponse) GetCreate 

func (m *ServiceCommandResponse) GetCreate() *ServiceCreateResponse

func (*ServiceCommandResponse) GetDelete 

func (m *ServiceCommandResponse) GetDelete() *ServiceDeleteResponse

func (*ServiceCommandResponse) GetOperation 

func (m *ServiceCommandResponse) GetOperation() *ServiceOperationResponse

func (*ServiceCommandResponse) GetResponse 

func (m *ServiceCommandResponse) GetResponse() isServiceCommandResponse_Response

func (*ServiceCommandResponse) Marshal 

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

func (*ServiceCommandResponse) MarshalTo 

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

func (*ServiceCommandResponse) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse) ProtoMessage 

func (*ServiceCommandResponse) ProtoMessage()

func (*ServiceCommandResponse) Reset 

func (m *ServiceCommandResponse) Reset()

func (*ServiceCommandResponse) Size 

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

func (*ServiceCommandResponse) String 

func (m *ServiceCommandResponse) String() string

func (*ServiceCommandResponse) Unmarshal 

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

func (*ServiceCommandResponse) XXX_DiscardUnknown 

func (m *ServiceCommandResponse) XXX_DiscardUnknown()

func (*ServiceCommandResponse) XXX_Marshal 

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

func (*ServiceCommandResponse) XXX_Merge 

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

func (*ServiceCommandResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceCommandResponse) XXX_Size 

func (m *ServiceCommandResponse) XXX_Size() int

func (*ServiceCommandResponse) XXX_Unmarshal 

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

type ServiceCommandResponse_Close 

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

func (*ServiceCommandResponse_Close) MarshalTo 

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

func (*ServiceCommandResponse_Close) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Close) Size 

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

type ServiceCommandResponse_Create 

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

func (*ServiceCommandResponse_Create) MarshalTo 

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

func (*ServiceCommandResponse_Create) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Create) Size 

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

type ServiceCommandResponse_Delete 

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

func (*ServiceCommandResponse_Delete) MarshalTo 

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

func (*ServiceCommandResponse_Delete) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Delete) Size 

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

type ServiceCommandResponse_Operation 

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

func (*ServiceCommandResponse_Operation) MarshalTo 

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

func (*ServiceCommandResponse_Operation) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Operation) Size 

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

type ServiceContext 

type ServiceContext interface {
	PartitionContext

	// ServiceID is the service identifier
	ServiceID() ServiceID

	// ServiceType returns the service type
	ServiceType() string

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

	// CurrentSession returns the current session
	CurrentSession() Session

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

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

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

type ServiceCreateRequest 

type ServiceCreateRequest struct {
}

func (*ServiceCreateRequest) Descriptor 

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

func (*ServiceCreateRequest) Marshal 

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

func (*ServiceCreateRequest) MarshalTo 

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

func (*ServiceCreateRequest) MarshalToSizedBuffer 

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

func (*ServiceCreateRequest) ProtoMessage 

func (*ServiceCreateRequest) ProtoMessage()

func (*ServiceCreateRequest) Reset 

func (m *ServiceCreateRequest) Reset()

func (*ServiceCreateRequest) Size 

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

func (*ServiceCreateRequest) String 

func (m *ServiceCreateRequest) String() string

func (*ServiceCreateRequest) Unmarshal 

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

func (*ServiceCreateRequest) XXX_DiscardUnknown 

func (m *ServiceCreateRequest) XXX_DiscardUnknown()

func (*ServiceCreateRequest) XXX_Marshal 

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

func (*ServiceCreateRequest) XXX_Merge 

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

func (*ServiceCreateRequest) XXX_Size 

func (m *ServiceCreateRequest) XXX_Size() int

func (*ServiceCreateRequest) XXX_Unmarshal 

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

type ServiceCreateResponse 

type ServiceCreateResponse struct {
}

func (*ServiceCreateResponse) Descriptor 

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

func (*ServiceCreateResponse) Marshal 

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

func (*ServiceCreateResponse) MarshalTo 

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

func (*ServiceCreateResponse) MarshalToSizedBuffer 

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

func (*ServiceCreateResponse) ProtoMessage 

func (*ServiceCreateResponse) ProtoMessage()

func (*ServiceCreateResponse) Reset 

func (m *ServiceCreateResponse) Reset()

func (*ServiceCreateResponse) Size 

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

func (*ServiceCreateResponse) String 

func (m *ServiceCreateResponse) String() string

func (*ServiceCreateResponse) Unmarshal 

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

func (*ServiceCreateResponse) XXX_DiscardUnknown 

func (m *ServiceCreateResponse) XXX_DiscardUnknown()

func (*ServiceCreateResponse) XXX_Marshal 

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

func (*ServiceCreateResponse) XXX_Merge 

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

func (*ServiceCreateResponse) XXX_Size 

func (m *ServiceCreateResponse) XXX_Size() int

func (*ServiceCreateResponse) XXX_Unmarshal 

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

type ServiceDeleteRequest 

type ServiceDeleteRequest struct {
}

func (*ServiceDeleteRequest) Descriptor 

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

func (*ServiceDeleteRequest) Marshal 

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

func (*ServiceDeleteRequest) MarshalTo 

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

func (*ServiceDeleteRequest) MarshalToSizedBuffer 

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

func (*ServiceDeleteRequest) ProtoMessage 

func (*ServiceDeleteRequest) ProtoMessage()

func (*ServiceDeleteRequest) Reset 

func (m *ServiceDeleteRequest) Reset()

func (*ServiceDeleteRequest) Size 

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

func (*ServiceDeleteRequest) String 

func (m *ServiceDeleteRequest) String() string

func (*ServiceDeleteRequest) Unmarshal 

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

func (*ServiceDeleteRequest) XXX_DiscardUnknown 

func (m *ServiceDeleteRequest) XXX_DiscardUnknown()

func (*ServiceDeleteRequest) XXX_Marshal 

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

func (*ServiceDeleteRequest) XXX_Merge 

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

func (*ServiceDeleteRequest) XXX_Size 

func (m *ServiceDeleteRequest) XXX_Size() int

func (*ServiceDeleteRequest) XXX_Unmarshal 

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

type ServiceDeleteResponse 

type ServiceDeleteResponse struct {
}

func (*ServiceDeleteResponse) Descriptor 

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

func (*ServiceDeleteResponse) Marshal 

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

func (*ServiceDeleteResponse) MarshalTo 

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

func (*ServiceDeleteResponse) MarshalToSizedBuffer 

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

func (*ServiceDeleteResponse) ProtoMessage 

func (*ServiceDeleteResponse) ProtoMessage()

func (*ServiceDeleteResponse) Reset 

func (m *ServiceDeleteResponse) Reset()

func (*ServiceDeleteResponse) Size 

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

func (*ServiceDeleteResponse) String 

func (m *ServiceDeleteResponse) String() string

func (*ServiceDeleteResponse) Unmarshal 

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

func (*ServiceDeleteResponse) XXX_DiscardUnknown 

func (m *ServiceDeleteResponse) XXX_DiscardUnknown()

func (*ServiceDeleteResponse) XXX_Marshal 

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

func (*ServiceDeleteResponse) XXX_Merge 

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

func (*ServiceDeleteResponse) XXX_Size 

func (m *ServiceDeleteResponse) XXX_Size() int

func (*ServiceDeleteResponse) XXX_Unmarshal 

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

type ServiceID 

type ServiceID ServiceId

ServiceID is a service identifier

type ServiceId 

type ServiceId struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ServiceId) Descriptor 

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

func (*ServiceId) GetCluster added in v0.6.2 

func (m *ServiceId) GetCluster() string

func (*ServiceId) GetName 

func (m *ServiceId) GetName() string

func (*ServiceId) GetType 

func (m *ServiceId) GetType() string

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 string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
}

func (*ServiceMetadataRequest) Descriptor 

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

func (*ServiceMetadataRequest) GetType 

func (m *ServiceMetadataRequest) GetType() string

func (*ServiceMetadataRequest) Marshal 

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

func (*ServiceMetadataRequest) MarshalTo 

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

func (*ServiceMetadataRequest) MarshalToSizedBuffer 

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

func (*ServiceMetadataRequest) ProtoMessage 

func (*ServiceMetadataRequest) ProtoMessage()

func (*ServiceMetadataRequest) Reset 

func (m *ServiceMetadataRequest) Reset()

func (*ServiceMetadataRequest) Size 

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

func (*ServiceMetadataRequest) String 

func (m *ServiceMetadataRequest) String() string

func (*ServiceMetadataRequest) Unmarshal 

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

func (*ServiceMetadataRequest) XXX_DiscardUnknown 

func (m *ServiceMetadataRequest) XXX_DiscardUnknown()

func (*ServiceMetadataRequest) XXX_Marshal 

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

func (*ServiceMetadataRequest) XXX_Merge 

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

func (*ServiceMetadataRequest) XXX_Size 

func (m *ServiceMetadataRequest) XXX_Size() int

func (*ServiceMetadataRequest) XXX_Unmarshal 

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

type ServiceMetadataResponse 

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

func (*ServiceMetadataResponse) Descriptor 

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

func (*ServiceMetadataResponse) GetServices 

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

func (*ServiceMetadataResponse) Marshal 

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

func (*ServiceMetadataResponse) MarshalTo 

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

func (*ServiceMetadataResponse) MarshalToSizedBuffer 

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

func (*ServiceMetadataResponse) ProtoMessage 

func (*ServiceMetadataResponse) ProtoMessage()

func (*ServiceMetadataResponse) Reset 

func (m *ServiceMetadataResponse) Reset()

func (*ServiceMetadataResponse) Size 

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

func (*ServiceMetadataResponse) String 

func (m *ServiceMetadataResponse) String() string

func (*ServiceMetadataResponse) Unmarshal 

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

func (*ServiceMetadataResponse) XXX_DiscardUnknown 

func (m *ServiceMetadataResponse) XXX_DiscardUnknown()

func (*ServiceMetadataResponse) XXX_Marshal 

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

func (*ServiceMetadataResponse) XXX_Merge 

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

func (*ServiceMetadataResponse) XXX_Size 

func (m *ServiceMetadataResponse) XXX_Size() int

func (*ServiceMetadataResponse) XXX_Unmarshal 

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

type ServiceOperationRequest 

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

func (*ServiceOperationRequest) Descriptor 

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

func (*ServiceOperationRequest) GetMethod 

func (m *ServiceOperationRequest) GetMethod() string

func (*ServiceOperationRequest) GetValue 

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

func (*ServiceOperationRequest) Marshal 

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

func (*ServiceOperationRequest) MarshalTo 

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

func (*ServiceOperationRequest) MarshalToSizedBuffer 

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

func (*ServiceOperationRequest) ProtoMessage 

func (*ServiceOperationRequest) ProtoMessage()

func (*ServiceOperationRequest) Reset 

func (m *ServiceOperationRequest) Reset()

func (*ServiceOperationRequest) Size 

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

func (*ServiceOperationRequest) String 

func (m *ServiceOperationRequest) String() string

func (*ServiceOperationRequest) Unmarshal 

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

func (*ServiceOperationRequest) XXX_DiscardUnknown 

func (m *ServiceOperationRequest) XXX_DiscardUnknown()

func (*ServiceOperationRequest) XXX_Marshal 

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

func (*ServiceOperationRequest) XXX_Merge 

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

func (*ServiceOperationRequest) XXX_Size 

func (m *ServiceOperationRequest) XXX_Size() int

func (*ServiceOperationRequest) XXX_Unmarshal 

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

type ServiceOperationResponse 

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

func (*ServiceOperationResponse) Descriptor 

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

func (*ServiceOperationResponse) GetResult 

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

func (*ServiceOperationResponse) Marshal 

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

func (*ServiceOperationResponse) MarshalTo 

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

func (*ServiceOperationResponse) MarshalToSizedBuffer 

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

func (*ServiceOperationResponse) ProtoMessage 

func (*ServiceOperationResponse) ProtoMessage()

func (*ServiceOperationResponse) Reset 

func (m *ServiceOperationResponse) Reset()

func (*ServiceOperationResponse) Size 

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

func (*ServiceOperationResponse) String 

func (m *ServiceOperationResponse) String() string

func (*ServiceOperationResponse) Unmarshal 

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

func (*ServiceOperationResponse) XXX_DiscardUnknown 

func (m *ServiceOperationResponse) XXX_DiscardUnknown()

func (*ServiceOperationResponse) XXX_Marshal 

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

func (*ServiceOperationResponse) XXX_Merge 

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

func (*ServiceOperationResponse) XXX_Size 

func (m *ServiceOperationResponse) XXX_Size() int

func (*ServiceOperationResponse) XXX_Unmarshal 

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

type ServiceQueryRequest 

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

func (*ServiceQueryRequest) Descriptor 

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

func (*ServiceQueryRequest) GetMetadata 

func (m *ServiceQueryRequest) GetMetadata() *ServiceMetadataRequest

func (*ServiceQueryRequest) GetOperation 

func (m *ServiceQueryRequest) GetOperation() *ServiceOperationRequest

func (*ServiceQueryRequest) GetRequest 

func (m *ServiceQueryRequest) GetRequest() isServiceQueryRequest_Request

func (*ServiceQueryRequest) GetService 

func (m *ServiceQueryRequest) GetService() *ServiceId

func (*ServiceQueryRequest) Marshal 

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

func (*ServiceQueryRequest) MarshalTo 

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

func (*ServiceQueryRequest) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest) ProtoMessage 

func (*ServiceQueryRequest) ProtoMessage()

func (*ServiceQueryRequest) Reset 

func (m *ServiceQueryRequest) Reset()

func (*ServiceQueryRequest) Size 

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

func (*ServiceQueryRequest) String 

func (m *ServiceQueryRequest) String() string

func (*ServiceQueryRequest) Unmarshal 

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

func (*ServiceQueryRequest) XXX_DiscardUnknown 

func (m *ServiceQueryRequest) XXX_DiscardUnknown()

func (*ServiceQueryRequest) XXX_Marshal 

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

func (*ServiceQueryRequest) XXX_Merge 

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

func (*ServiceQueryRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceQueryRequest) XXX_Size 

func (m *ServiceQueryRequest) XXX_Size() int

func (*ServiceQueryRequest) XXX_Unmarshal 

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

type ServiceQueryRequest_Metadata 

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

func (*ServiceQueryRequest_Metadata) MarshalTo 

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

func (*ServiceQueryRequest_Metadata) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest_Metadata) Size 

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

type ServiceQueryRequest_Operation 

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

func (*ServiceQueryRequest_Operation) MarshalTo 

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

func (*ServiceQueryRequest_Operation) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest_Operation) Size 

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

type ServiceQueryResponse 

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

func (*ServiceQueryResponse) Descriptor 

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

func (*ServiceQueryResponse) GetMetadata 

func (m *ServiceQueryResponse) GetMetadata() *ServiceMetadataResponse

func (*ServiceQueryResponse) GetOperation 

func (m *ServiceQueryResponse) GetOperation() *ServiceOperationResponse

func (*ServiceQueryResponse) GetResponse 

func (m *ServiceQueryResponse) GetResponse() isServiceQueryResponse_Response

func (*ServiceQueryResponse) Marshal 

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

func (*ServiceQueryResponse) MarshalTo 

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

func (*ServiceQueryResponse) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse) ProtoMessage 

func (*ServiceQueryResponse) ProtoMessage()

func (*ServiceQueryResponse) Reset 

func (m *ServiceQueryResponse) Reset()

func (*ServiceQueryResponse) Size 

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

func (*ServiceQueryResponse) String 

func (m *ServiceQueryResponse) String() string

func (*ServiceQueryResponse) Unmarshal 

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

func (*ServiceQueryResponse) XXX_DiscardUnknown 

func (m *ServiceQueryResponse) XXX_DiscardUnknown()

func (*ServiceQueryResponse) XXX_Marshal 

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

func (*ServiceQueryResponse) XXX_Merge 

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

func (*ServiceQueryResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceQueryResponse) XXX_Size 

func (m *ServiceQueryResponse) XXX_Size() int

func (*ServiceQueryResponse) XXX_Unmarshal 

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

type ServiceQueryResponse_Metadata 

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

func (*ServiceQueryResponse_Metadata) MarshalTo 

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

func (*ServiceQueryResponse_Metadata) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse_Metadata) Size 

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

type ServiceQueryResponse_Operation 

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

func (*ServiceQueryResponse_Operation) MarshalTo 

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

func (*ServiceQueryResponse_Operation) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse_Operation) Size 

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

type Session 

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

	// ClientID returns the client identifier
	ClientID() ClientID

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

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

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

Session is a service session

type SessionClosedService 

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

SessionClosedService is an interface for listening to session closed events

type SessionCommandContext 

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

func (*SessionCommandContext) Descriptor 

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

func (*SessionCommandContext) GetSequenceNumber 

func (m *SessionCommandContext) GetSequenceNumber() uint64

func (*SessionCommandContext) GetSessionID 

func (m *SessionCommandContext) GetSessionID() uint64

func (*SessionCommandContext) Marshal 

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

func (*SessionCommandContext) MarshalTo 

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

func (*SessionCommandContext) MarshalToSizedBuffer 

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

func (*SessionCommandContext) ProtoMessage 

func (*SessionCommandContext) ProtoMessage()

func (*SessionCommandContext) Reset 

func (m *SessionCommandContext) Reset()

func (*SessionCommandContext) Size 

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

func (*SessionCommandContext) String 

func (m *SessionCommandContext) String() string

func (*SessionCommandContext) Unmarshal 

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

func (*SessionCommandContext) XXX_DiscardUnknown 

func (m *SessionCommandContext) XXX_DiscardUnknown()

func (*SessionCommandContext) XXX_Marshal 

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

func (*SessionCommandContext) XXX_Merge 

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

func (*SessionCommandContext) XXX_Size 

func (m *SessionCommandContext) XXX_Size() int

func (*SessionCommandContext) XXX_Unmarshal 

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

type SessionCommandRequest 

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

func (*SessionCommandRequest) Descriptor 

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

func (*SessionCommandRequest) GetCommand 

func (m *SessionCommandRequest) GetCommand() ServiceCommandRequest

func (*SessionCommandRequest) GetContext 

func (m *SessionCommandRequest) GetContext() SessionCommandContext

func (*SessionCommandRequest) Marshal 

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

func (*SessionCommandRequest) MarshalTo 

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

func (*SessionCommandRequest) MarshalToSizedBuffer 

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

func (*SessionCommandRequest) ProtoMessage 

func (*SessionCommandRequest) ProtoMessage()

func (*SessionCommandRequest) Reset 

func (m *SessionCommandRequest) Reset()

func (*SessionCommandRequest) Size 

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

func (*SessionCommandRequest) String 

func (m *SessionCommandRequest) String() string

func (*SessionCommandRequest) Unmarshal 

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

func (*SessionCommandRequest) XXX_DiscardUnknown 

func (m *SessionCommandRequest) XXX_DiscardUnknown()

func (*SessionCommandRequest) XXX_Marshal 

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

func (*SessionCommandRequest) XXX_Merge 

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

func (*SessionCommandRequest) XXX_Size 

func (m *SessionCommandRequest) XXX_Size() int

func (*SessionCommandRequest) XXX_Unmarshal 

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

type SessionCommandResponse 

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

func (*SessionCommandResponse) Descriptor 

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

func (*SessionCommandResponse) GetContext 

func (m *SessionCommandResponse) GetContext() SessionResponseContext

func (*SessionCommandResponse) GetResponse 

func (m *SessionCommandResponse) GetResponse() ServiceCommandResponse

func (*SessionCommandResponse) Marshal 

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

func (*SessionCommandResponse) MarshalTo 

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

func (*SessionCommandResponse) MarshalToSizedBuffer 

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

func (*SessionCommandResponse) ProtoMessage 

func (*SessionCommandResponse) ProtoMessage()

func (*SessionCommandResponse) Reset 

func (m *SessionCommandResponse) Reset()

func (*SessionCommandResponse) Size 

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

func (*SessionCommandResponse) String 

func (m *SessionCommandResponse) String() string

func (*SessionCommandResponse) Unmarshal 

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

func (*SessionCommandResponse) XXX_DiscardUnknown 

func (m *SessionCommandResponse) XXX_DiscardUnknown()

func (*SessionCommandResponse) XXX_Marshal 

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

func (*SessionCommandResponse) XXX_Merge 

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

func (*SessionCommandResponse) XXX_Size 

func (m *SessionCommandResponse) XXX_Size() int

func (*SessionCommandResponse) XXX_Unmarshal 

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

type SessionExpiredService 

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

SessionExpiredService is an interface for listening to session expired events

type 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 SessionQueryContext 

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

func (*SessionQueryContext) Descriptor 

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

func (*SessionQueryContext) GetLastIndex 

func (m *SessionQueryContext) GetLastIndex() uint64

func (*SessionQueryContext) GetLastSequenceNumber 

func (m *SessionQueryContext) GetLastSequenceNumber() uint64

func (*SessionQueryContext) GetSessionID 

func (m *SessionQueryContext) GetSessionID() uint64

func (*SessionQueryContext) Marshal 

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

func (*SessionQueryContext) MarshalTo 

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

func (*SessionQueryContext) MarshalToSizedBuffer 

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

func (*SessionQueryContext) ProtoMessage 

func (*SessionQueryContext) ProtoMessage()

func (*SessionQueryContext) Reset 

func (m *SessionQueryContext) Reset()

func (*SessionQueryContext) Size 

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

func (*SessionQueryContext) String 

func (m *SessionQueryContext) String() string

func (*SessionQueryContext) Unmarshal 

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

func (*SessionQueryContext) XXX_DiscardUnknown 

func (m *SessionQueryContext) XXX_DiscardUnknown()

func (*SessionQueryContext) XXX_Marshal 

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

func (*SessionQueryContext) XXX_Merge 

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

func (*SessionQueryContext) XXX_Size 

func (m *SessionQueryContext) XXX_Size() int

func (*SessionQueryContext) XXX_Unmarshal 

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

type SessionQueryRequest 

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

func (*SessionQueryRequest) Descriptor 

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

func (*SessionQueryRequest) GetContext 

func (m *SessionQueryRequest) GetContext() SessionQueryContext

func (*SessionQueryRequest) GetQuery 

func (m *SessionQueryRequest) GetQuery() ServiceQueryRequest

func (*SessionQueryRequest) Marshal 

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

func (*SessionQueryRequest) MarshalTo 

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

func (*SessionQueryRequest) MarshalToSizedBuffer 

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

func (*SessionQueryRequest) ProtoMessage 

func (*SessionQueryRequest) ProtoMessage()

func (*SessionQueryRequest) Reset 

func (m *SessionQueryRequest) Reset()

func (*SessionQueryRequest) Size 

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

func (*SessionQueryRequest) String 

func (m *SessionQueryRequest) String() string

func (*SessionQueryRequest) Unmarshal 

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

func (*SessionQueryRequest) XXX_DiscardUnknown 

func (m *SessionQueryRequest) XXX_DiscardUnknown()

func (*SessionQueryRequest) XXX_Marshal 

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

func (*SessionQueryRequest) XXX_Merge 

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

func (*SessionQueryRequest) XXX_Size 

func (m *SessionQueryRequest) XXX_Size() int

func (*SessionQueryRequest) XXX_Unmarshal 

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

type SessionQueryResponse 

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

func (*SessionQueryResponse) Descriptor 

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

func (*SessionQueryResponse) GetContext 

func (m *SessionQueryResponse) GetContext() SessionResponseContext

func (*SessionQueryResponse) GetResponse 

func (m *SessionQueryResponse) GetResponse() ServiceQueryResponse

func (*SessionQueryResponse) Marshal 

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

func (*SessionQueryResponse) MarshalTo 

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

func (*SessionQueryResponse) MarshalToSizedBuffer 

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

func (*SessionQueryResponse) ProtoMessage 

func (*SessionQueryResponse) ProtoMessage()

func (*SessionQueryResponse) Reset 

func (m *SessionQueryResponse) Reset()

func (*SessionQueryResponse) Size 

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

func (*SessionQueryResponse) String 

func (m *SessionQueryResponse) String() string

func (*SessionQueryResponse) Unmarshal 

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

func (*SessionQueryResponse) XXX_DiscardUnknown 

func (m *SessionQueryResponse) XXX_DiscardUnknown()

func (*SessionQueryResponse) XXX_Marshal 

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

func (*SessionQueryResponse) XXX_Merge 

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

func (*SessionQueryResponse) XXX_Size 

func (m *SessionQueryResponse) XXX_Size() int

func (*SessionQueryResponse) XXX_Unmarshal 

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

type SessionRequest 

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

func (*SessionRequest) Descriptor 

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

func (*SessionRequest) GetCloseSession 

func (m *SessionRequest) GetCloseSession() *CloseSessionRequest

func (*SessionRequest) GetCommand 

func (m *SessionRequest) GetCommand() *SessionCommandRequest

func (*SessionRequest) GetKeepAlive 

func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest

func (*SessionRequest) GetOpenSession 

func (m *SessionRequest) GetOpenSession() *OpenSessionRequest

func (*SessionRequest) GetQuery 

func (m *SessionRequest) GetQuery() *SessionQueryRequest

func (*SessionRequest) GetRequest 

func (m *SessionRequest) GetRequest() isSessionRequest_Request

func (*SessionRequest) Marshal 

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

func (*SessionRequest) 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 {
	Type   SessionResponseType   `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.SessionResponseType" json:"type,omitempty"`
	Status SessionResponseStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
	// Types that are valid to be assigned to Response:
	//	*SessionResponse_OpenSession
	//	*SessionResponse_KeepAlive
	//	*SessionResponse_CloseSession
	//	*SessionResponse_Command
	//	*SessionResponse_Query
	Response isSessionResponse_Response `protobuf_oneof:"response"`
}

func (*SessionResponse) Descriptor 

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

func (*SessionResponse) GetCloseSession 

func (m *SessionResponse) GetCloseSession() *CloseSessionResponse

func (*SessionResponse) GetCommand 

func (m *SessionResponse) GetCommand() *SessionCommandResponse

func (*SessionResponse) GetKeepAlive 

func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse

func (*SessionResponse) GetOpenSession 

func (m *SessionResponse) GetOpenSession() *OpenSessionResponse

func (*SessionResponse) GetQuery 

func (m *SessionResponse) GetQuery() *SessionQueryResponse

func (*SessionResponse) GetResponse 

func (m *SessionResponse) GetResponse() isSessionResponse_Response

func (*SessionResponse) GetStatus 

func (m *SessionResponse) GetStatus() SessionResponseStatus

func (*SessionResponse) GetType 

func (m *SessionResponse) GetType() SessionResponseType

func (*SessionResponse) Marshal 

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

func (*SessionResponse) 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 SessionResponseCode 

type SessionResponseCode int32
const (
	SessionResponseCode_OK             SessionResponseCode = 0
	SessionResponseCode_ERROR          SessionResponseCode = 1
	SessionResponseCode_NOT_LEADER     SessionResponseCode = 2
	SessionResponseCode_UNKNOWN        SessionResponseCode = 3
	SessionResponseCode_CANCELED       SessionResponseCode = 4
	SessionResponseCode_NOT_FOUND      SessionResponseCode = 5
	SessionResponseCode_ALREADY_EXISTS SessionResponseCode = 6
	SessionResponseCode_UNAUTHORIZED   SessionResponseCode = 7
	SessionResponseCode_FORBIDDEN      SessionResponseCode = 8
	SessionResponseCode_CONFLICT       SessionResponseCode = 9
	SessionResponseCode_INVALID        SessionResponseCode = 10
	SessionResponseCode_UNAVAILABLE    SessionResponseCode = 11
	SessionResponseCode_NOT_SUPPORTED  SessionResponseCode = 12
	SessionResponseCode_TIMEOUT        SessionResponseCode = 13
	SessionResponseCode_INTERNAL       SessionResponseCode = 14
)

func (SessionResponseCode) EnumDescriptor 

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

func (SessionResponseCode) String 

func (x SessionResponseCode) String() string

type SessionResponseContext 

type SessionResponseContext struct {
	SessionID uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StreamID  uint64 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Index     uint64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Sequence  uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

func (*SessionResponseContext) Descriptor 

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

func (*SessionResponseContext) GetIndex 

func (m *SessionResponseContext) GetIndex() uint64

func (*SessionResponseContext) GetSequence 

func (m *SessionResponseContext) GetSequence() uint64

func (*SessionResponseContext) GetSessionID 

func (m *SessionResponseContext) GetSessionID() uint64

func (*SessionResponseContext) GetStreamID 

func (m *SessionResponseContext) GetStreamID() uint64

func (*SessionResponseContext) Marshal 

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

func (*SessionResponseContext) MarshalTo 

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

func (*SessionResponseContext) MarshalToSizedBuffer 

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

func (*SessionResponseContext) ProtoMessage 

func (*SessionResponseContext) ProtoMessage()

func (*SessionResponseContext) Reset 

func (m *SessionResponseContext) Reset()

func (*SessionResponseContext) Size 

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

func (*SessionResponseContext) String 

func (m *SessionResponseContext) String() string

func (*SessionResponseContext) Unmarshal 

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

func (*SessionResponseContext) XXX_DiscardUnknown 

func (m *SessionResponseContext) XXX_DiscardUnknown()

func (*SessionResponseContext) XXX_Marshal 

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

func (*SessionResponseContext) XXX_Merge 

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

func (*SessionResponseContext) XXX_Size 

func (m *SessionResponseContext) XXX_Size() int

func (*SessionResponseContext) XXX_Unmarshal 

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

type SessionResponseStatus 

type SessionResponseStatus struct {
	Code    SessionResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=atomix.service.SessionResponseCode" json:"code,omitempty"`
	Message string              `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Leader  string              `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"`
}

func (*SessionResponseStatus) Descriptor 

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

func (*SessionResponseStatus) GetCode 

func (m *SessionResponseStatus) GetCode() SessionResponseCode

func (*SessionResponseStatus) GetLeader 

func (m *SessionResponseStatus) GetLeader() string

func (*SessionResponseStatus) GetMessage 

func (m *SessionResponseStatus) GetMessage() string

func (*SessionResponseStatus) Marshal 

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

func (*SessionResponseStatus) MarshalTo 

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

func (*SessionResponseStatus) MarshalToSizedBuffer 

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

func (*SessionResponseStatus) ProtoMessage 

func (*SessionResponseStatus) ProtoMessage()

func (*SessionResponseStatus) Reset 

func (m *SessionResponseStatus) Reset()

func (*SessionResponseStatus) Size 

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

func (*SessionResponseStatus) String 

func (m *SessionResponseStatus) String() string

func (*SessionResponseStatus) Unmarshal 

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

func (*SessionResponseStatus) XXX_DiscardUnknown 

func (m *SessionResponseStatus) XXX_DiscardUnknown()

func (*SessionResponseStatus) XXX_Marshal 

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

func (*SessionResponseStatus) XXX_Merge 

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

func (*SessionResponseStatus) XXX_Size 

func (m *SessionResponseStatus) XXX_Size() int

func (*SessionResponseStatus) XXX_Unmarshal 

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

type SessionResponseType 

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

func (SessionResponseType) EnumDescriptor 

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

func (SessionResponseType) String 

func (x SessionResponseType) String() string

type SessionResponse_CloseSession 

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

func (*SessionResponse_CloseSession) MarshalTo 

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

func (*SessionResponse_CloseSession) MarshalToSizedBuffer 

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

func (*SessionResponse_CloseSession) Size 

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

type SessionResponse_Command 

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

func (*SessionResponse_Command) MarshalTo 

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

func (*SessionResponse_Command) MarshalToSizedBuffer 

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

func (*SessionResponse_Command) Size 

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

type SessionResponse_KeepAlive 

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

func (*SessionResponse_KeepAlive) MarshalTo 

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

func (*SessionResponse_KeepAlive) MarshalToSizedBuffer 

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

func (*SessionResponse_KeepAlive) Size 

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

type SessionResponse_OpenSession 

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

func (*SessionResponse_OpenSession) MarshalTo 

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

func (*SessionResponse_OpenSession) MarshalToSizedBuffer 

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

func (*SessionResponse_OpenSession) Size 

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

type SessionResponse_Query 

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

func (*SessionResponse_Query) MarshalTo 

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

func (*SessionResponse_Query) MarshalToSizedBuffer 

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

func (*SessionResponse_Query) Size 

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

type SessionServiceSnapshot 

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

Session service snapshot

func (*SessionServiceSnapshot) Descriptor 

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

func (*SessionServiceSnapshot) GetServiceId 

func (m *SessionServiceSnapshot) GetServiceId() ServiceId

func (*SessionServiceSnapshot) GetStreams 

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

func (*SessionServiceSnapshot) Marshal 

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

func (*SessionServiceSnapshot) MarshalTo 

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

func (*SessionServiceSnapshot) MarshalToSizedBuffer 

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

func (*SessionServiceSnapshot) ProtoMessage 

func (*SessionServiceSnapshot) ProtoMessage()

func (*SessionServiceSnapshot) Reset 

func (m *SessionServiceSnapshot) Reset()

func (*SessionServiceSnapshot) Size 

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

func (*SessionServiceSnapshot) String 

func (m *SessionServiceSnapshot) String() string

func (*SessionServiceSnapshot) Unmarshal 

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

func (*SessionServiceSnapshot) XXX_DiscardUnknown 

func (m *SessionServiceSnapshot) XXX_DiscardUnknown()

func (*SessionServiceSnapshot) XXX_Marshal 

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

func (*SessionServiceSnapshot) XXX_Merge 

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

func (*SessionServiceSnapshot) XXX_Size 

func (m *SessionServiceSnapshot) XXX_Size() int

func (*SessionServiceSnapshot) XXX_Unmarshal 

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

type SessionSnapshot 

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

Service session

func (*SessionSnapshot) Descriptor 

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

func (*SessionSnapshot) GetCommandSequence 

func (m *SessionSnapshot) GetCommandSequence() uint64

func (*SessionSnapshot) GetServices 

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

func (*SessionSnapshot) GetSessionID 

func (m *SessionSnapshot) GetSessionID() uint64

func (*SessionSnapshot) GetTimeout 

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

func (*SessionSnapshot) GetTimestamp 

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

func (*SessionSnapshot) Marshal 

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

func (*SessionSnapshot) 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 SessionStreamContext 

type SessionStreamContext struct {
	StreamID   uint64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ResponseID uint64 `protobuf:"varint,2,opt,name=response_id,json=responseId,proto3" json:"response_id,omitempty"`
}

func (*SessionStreamContext) Descriptor 

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

func (*SessionStreamContext) GetResponseID 

func (m *SessionStreamContext) GetResponseID() uint64

func (*SessionStreamContext) GetStreamID 

func (m *SessionStreamContext) GetStreamID() uint64

func (*SessionStreamContext) Marshal 

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

func (*SessionStreamContext) MarshalTo 

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

func (*SessionStreamContext) MarshalToSizedBuffer 

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

func (*SessionStreamContext) ProtoMessage 

func (*SessionStreamContext) ProtoMessage()

func (*SessionStreamContext) Reset 

func (m *SessionStreamContext) Reset()

func (*SessionStreamContext) Size 

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

func (*SessionStreamContext) String 

func (m *SessionStreamContext) String() string

func (*SessionStreamContext) Unmarshal 

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

func (*SessionStreamContext) XXX_DiscardUnknown 

func (m *SessionStreamContext) XXX_DiscardUnknown()

func (*SessionStreamContext) XXX_Marshal 

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

func (*SessionStreamContext) XXX_Merge 

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

func (*SessionStreamContext) XXX_Size 

func (m *SessionStreamContext) XXX_Size() int

func (*SessionStreamContext) XXX_Unmarshal 

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

type SessionStreamSnapshot 

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

Service session stream

func (*SessionStreamSnapshot) Descriptor 

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

func (*SessionStreamSnapshot) GetLastCompleted 

func (m *SessionStreamSnapshot) GetLastCompleted() uint64

func (*SessionStreamSnapshot) GetSequenceNumber 

func (m *SessionStreamSnapshot) GetSequenceNumber() uint64

func (*SessionStreamSnapshot) GetStreamId 

func (m *SessionStreamSnapshot) GetStreamId() uint64

func (*SessionStreamSnapshot) GetType 

func (m *SessionStreamSnapshot) GetType() string

func (*SessionStreamSnapshot) Marshal 

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

func (*SessionStreamSnapshot) MarshalTo 

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

func (*SessionStreamSnapshot) MarshalToSizedBuffer 

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

func (*SessionStreamSnapshot) ProtoMessage 

func (*SessionStreamSnapshot) ProtoMessage()

func (*SessionStreamSnapshot) Reset 

func (m *SessionStreamSnapshot) Reset()

func (*SessionStreamSnapshot) Size 

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

func (*SessionStreamSnapshot) String 

func (m *SessionStreamSnapshot) String() string

func (*SessionStreamSnapshot) Unmarshal 

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

func (*SessionStreamSnapshot) XXX_DiscardUnknown 

func (m *SessionStreamSnapshot) XXX_DiscardUnknown()

func (*SessionStreamSnapshot) XXX_Marshal 

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

func (*SessionStreamSnapshot) XXX_Merge 

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

func (*SessionStreamSnapshot) XXX_Size 

func (m *SessionStreamSnapshot) XXX_Size() int

func (*SessionStreamSnapshot) XXX_Unmarshal 

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

type StateMachine 

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

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

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

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

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

type StorageRequest 

type StorageRequest struct {
	PartitionID uint32          `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Request     *SessionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*StorageRequest) Descriptor 

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

func (*StorageRequest) GetPartitionID 

func (m *StorageRequest) GetPartitionID() uint32

func (*StorageRequest) GetRequest 

func (m *StorageRequest) GetRequest() *SessionRequest

func (*StorageRequest) Marshal 

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

func (*StorageRequest) MarshalTo 

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

func (*StorageRequest) MarshalToSizedBuffer 

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

func (*StorageRequest) ProtoMessage 

func (*StorageRequest) ProtoMessage()

func (*StorageRequest) Reset 

func (m *StorageRequest) Reset()

func (*StorageRequest) Size 

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

func (*StorageRequest) String 

func (m *StorageRequest) String() string

func (*StorageRequest) Unmarshal 

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

func (*StorageRequest) XXX_DiscardUnknown 

func (m *StorageRequest) XXX_DiscardUnknown()

func (*StorageRequest) XXX_Marshal 

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

func (*StorageRequest) XXX_Merge 

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

func (*StorageRequest) XXX_Size 

func (m *StorageRequest) XXX_Size() int

func (*StorageRequest) XXX_Unmarshal 

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

type StorageResponse 

type StorageResponse struct {
	PartitionID uint32           `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Response    *SessionResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
}

func (*StorageResponse) Descriptor 

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

func (*StorageResponse) GetPartitionID 

func (m *StorageResponse) GetPartitionID() uint32

func (*StorageResponse) GetResponse 

func (m *StorageResponse) GetResponse() *SessionResponse

func (*StorageResponse) Marshal 

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

func (*StorageResponse) MarshalTo 

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

func (*StorageResponse) MarshalToSizedBuffer 

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

func (*StorageResponse) ProtoMessage 

func (*StorageResponse) ProtoMessage()

func (*StorageResponse) Reset 

func (m *StorageResponse) Reset()

func (*StorageResponse) Size 

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

func (*StorageResponse) String 

func (m *StorageResponse) String() string

func (*StorageResponse) Unmarshal 

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

func (*StorageResponse) XXX_DiscardUnknown 

func (m *StorageResponse) XXX_DiscardUnknown()

func (*StorageResponse) XXX_Marshal 

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

func (*StorageResponse) XXX_Merge 

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

func (*StorageResponse) XXX_Size 

func (m *StorageResponse) XXX_Size() int

func (*StorageResponse) XXX_Unmarshal 

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

type StorageServiceClient 

type StorageServiceClient interface {
	Request(ctx context.Context, in *StorageRequest, opts ...grpc.CallOption) (StorageService_RequestClient, error)
}

StorageServiceClient is the client API for StorageService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStorageServiceClient 

func NewStorageServiceClient(cc *grpc.ClientConn) StorageServiceClient

type StorageServiceServer 

type StorageServiceServer interface {
	Request(*StorageRequest, StorageService_RequestServer) error
}

StorageServiceServer is the server API for StorageService service.

type StorageService_RequestClient 

type StorageService_RequestClient interface {
	Recv() (*StorageResponse, error)
	grpc.ClientStream
}

type StorageService_RequestServer 

type StorageService_RequestServer interface {
	Send(*StorageResponse) error
	grpc.ServerStream
}

type Stream 

type Stream interface {
	streams.WriteStream

	// ID returns the stream identifier
	ID() StreamID

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

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

Stream is a service stream

type StreamCloser 

type StreamCloser func()

StreamCloser is a function to be called when a stream is closed

type StreamID 

type StreamID uint64

StreamID is a stream identifier

type StreamingOperation 

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

StreamingOperation is a primitive operation that returns a stream

type Timer 

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

Timer is a cancellable timer

type UnaryOperation 

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

UnaryOperation is a primitive operation that returns a result

type UnimplementedStorageServiceServer 

type UnimplementedStorageServiceServer struct {
}

UnimplementedStorageServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServiceServer) Request 

func (*UnimplementedStorageServiceServer) Request(req *StorageRequest, srv StorageService_RequestServer) error

Source Files

View all Source files

Directories

Path Synopsis
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.

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.