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 (*ServiceCommandRequest) GetCreate

func (*ServiceCommandRequest) GetDelete

func (*ServiceCommandRequest) GetOperation

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 (*ServiceCommandResponse) GetCreate

func (*ServiceCommandResponse) GetDelete

func (*ServiceCommandResponse) GetOperation

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 (*ServiceQueryResponse) GetOperation

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 (*SessionCommandRequest) GetContext

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 (*SessionCommandResponse) GetResponse

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 (*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 (*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 (*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

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