service

package
v0.2.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ServiceType_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "COUNTER",
	2:  "ELECTION",
	3:  "INDEXED_MAP",
	4:  "LEADER_LATCH",
	5:  "LIST",
	6:  "LOCK",
	7:  "LOG",
	8:  "MAP",
	9:  "SET",
	10: "VALUE",
}
View Source 
var ServiceType_value = map[string]int32{
	"UNKNOWN":      0,
	"COUNTER":      1,
	"ELECTION":     2,
	"INDEXED_MAP":  3,
	"LEADER_LATCH": 4,
	"LIST":         5,
	"LOCK":         6,
	"LOG":          7,
	"MAP":          8,
	"SET":          9,
	"VALUE":        10,
}
View Source 
var SessionResponseType_name = map[int32]string{
	0: "RESPONSE",
	1: "OPEN_STREAM",
	2: "CLOSE_STREAM",
}
View Source 
var SessionResponseType_value = map[string]int32{
	"RESPONSE":     0,
	"OPEN_STREAM":  1,
	"CLOSE_STREAM": 2,
}

Functions

This section is empty.

Types

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

type Context interface {
	// Node is the local node identifier
	Node() string

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

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

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

type Executor 

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

	// RegisterStreamOperation registers a new primitive operation
	RegisterStreamOperation(name string, callback func([]byte, stream.WriteStream))

	// GetOperation returns an operation by name
	GetOperation(name string) Operation
}

Executor executes primitive operations

type KeepAliveRequest 

type KeepAliveRequest struct {
	SessionID       uint64            `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	CommandSequence uint64            `protobuf:"varint,2,opt,name=command_sequence,json=commandSequence,proto3" json:"command_sequence,omitempty"`
	Streams         map[uint64]uint64 `` /* 157-byte string literal not displayed */
}

func (*KeepAliveRequest) Descriptor 

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

func (*KeepAliveRequest) GetCommandSequence 

func (m *KeepAliveRequest) GetCommandSequence() uint64

func (*KeepAliveRequest) GetSessionID 

func (m *KeepAliveRequest) GetSessionID() uint64

func (*KeepAliveRequest) GetStreams 

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

func (*KeepAliveRequest) Marshal 

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

func (*KeepAliveRequest) MarshalTo 

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

func (*KeepAliveRequest) MarshalToSizedBuffer 

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

func (*KeepAliveRequest) ProtoMessage 

func (*KeepAliveRequest) ProtoMessage()

func (*KeepAliveRequest) Reset 

func (m *KeepAliveRequest) Reset()

func (*KeepAliveRequest) Size 

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

func (*KeepAliveRequest) String 

func (m *KeepAliveRequest) String() string

func (*KeepAliveRequest) Unmarshal 

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

func (*KeepAliveRequest) XXX_DiscardUnknown 

func (m *KeepAliveRequest) XXX_DiscardUnknown()

func (*KeepAliveRequest) XXX_Marshal 

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

func (*KeepAliveRequest) XXX_Merge 

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

func (*KeepAliveRequest) XXX_Size 

func (m *KeepAliveRequest) XXX_Size() int

func (*KeepAliveRequest) XXX_Unmarshal 

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

type KeepAliveResponse 

type KeepAliveResponse struct {
}

func (*KeepAliveResponse) Descriptor 

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

func (*KeepAliveResponse) Marshal 

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

func (*KeepAliveResponse) MarshalTo 

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

func (*KeepAliveResponse) MarshalToSizedBuffer 

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

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset 

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) Size 

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

func (*KeepAliveResponse) String 

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) Unmarshal 

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

func (*KeepAliveResponse) XXX_DiscardUnknown 

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal 

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

func (*KeepAliveResponse) XXX_Merge 

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

func (*KeepAliveResponse) XXX_Size 

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal 

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

type ManagedService 

type ManagedService struct {
	Executor  Executor
	Context   Context
	Scheduler Scheduler
	// contains filtered or unexported fields
}

ManagedService is a service that is managed by the service manager

func NewManagedService 

func NewManagedService(serviceType ServiceType, scheduler Scheduler, context Context) *ManagedService

NewManagedService creates a new primitive service

func (*ManagedService) Session 

func (s *ManagedService) Session() *Session

Session returns the current session

func (*ManagedService) SessionOf 

func (s *ManagedService) SessionOf(id uint64) *Session

SessionOf returns the session with the given identifier

func (*ManagedService) Sessions 

func (s *ManagedService) Sessions() []*Session

Sessions returns a list of open sessions

func (*ManagedService) Type 

func (s *ManagedService) Type() ServiceType

Type returns the service type

type Manager 

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

Manager is a Manager implementation for primitives that support sessions

func NewManager 

func NewManager(registry Registry, context Context) *Manager

NewManager returns an initialized Manager

func (*Manager) Command 

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

Command handles a service command

func (*Manager) Install 

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

Install installs a snapshot of the service

func (*Manager) Query 

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

Query handles a service query

func (*Manager) Snapshot 

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

Snapshot takes a snapshot of the service

type OpenSessionRequest 

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

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetTimeout 

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

func (*OpenSessionRequest) Marshal 

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

func (*OpenSessionRequest) MarshalTo 

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

func (*OpenSessionRequest) MarshalToSizedBuffer 

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

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) Size 

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

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Unmarshal 

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

func (*OpenSessionRequest) XXX_DiscardUnknown 

func (m *OpenSessionRequest) XXX_DiscardUnknown()

func (*OpenSessionRequest) XXX_Marshal 

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

func (*OpenSessionRequest) XXX_Merge 

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

func (*OpenSessionRequest) XXX_Size 

func (m *OpenSessionRequest) XXX_Size() int

func (*OpenSessionRequest) XXX_Unmarshal 

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

type OpenSessionResponse 

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

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSessionID 

func (m *OpenSessionResponse) GetSessionID() uint64

func (*OpenSessionResponse) Marshal 

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

func (*OpenSessionResponse) MarshalTo 

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

func (*OpenSessionResponse) MarshalToSizedBuffer 

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

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) Size 

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

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Unmarshal 

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

func (*OpenSessionResponse) XXX_DiscardUnknown 

func (m *OpenSessionResponse) XXX_DiscardUnknown()

func (*OpenSessionResponse) XXX_Marshal 

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

func (*OpenSessionResponse) XXX_Merge 

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

func (*OpenSessionResponse) XXX_Size 

func (m *OpenSessionResponse) XXX_Size() int

func (*OpenSessionResponse) XXX_Unmarshal 

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

type Operation 

type Operation interface{}

Operation is the base interface for primitive operations

type Registry 

type Registry interface {
	// GetType returns a service type by name
	GetType(serviceType ServiceType) func(scheduler Scheduler, context Context) Service
}

Registry is a service registry

type Scheduler 

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

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

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

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

Scheduler provides deterministic scheduling for a state machine

type Service 

type Service interface {

	// Backup is called to take a snapshot of the service state
	Backup(writer io.Writer) error

	// Resotre is called to restore the service state from a snapshot
	Restore(reader io.Reader) error
	// contains filtered or unexported methods
}

Service is a primitive service

type ServiceCloseRequest 

type ServiceCloseRequest struct {
}

func (*ServiceCloseRequest) Descriptor 

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

func (*ServiceCloseRequest) Marshal 

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

func (*ServiceCloseRequest) MarshalTo 

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

func (*ServiceCloseRequest) MarshalToSizedBuffer 

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

func (*ServiceCloseRequest) ProtoMessage 

func (*ServiceCloseRequest) ProtoMessage()

func (*ServiceCloseRequest) Reset 

func (m *ServiceCloseRequest) Reset()

func (*ServiceCloseRequest) Size 

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

func (*ServiceCloseRequest) String 

func (m *ServiceCloseRequest) String() string

func (*ServiceCloseRequest) Unmarshal 

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

func (*ServiceCloseRequest) XXX_DiscardUnknown 

func (m *ServiceCloseRequest) XXX_DiscardUnknown()

func (*ServiceCloseRequest) XXX_Marshal 

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

func (*ServiceCloseRequest) XXX_Merge 

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

func (*ServiceCloseRequest) XXX_Size 

func (m *ServiceCloseRequest) XXX_Size() int

func (*ServiceCloseRequest) XXX_Unmarshal 

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

type ServiceCloseResponse 

type ServiceCloseResponse struct {
}

func (*ServiceCloseResponse) Descriptor 

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

func (*ServiceCloseResponse) Marshal 

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

func (*ServiceCloseResponse) MarshalTo 

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

func (*ServiceCloseResponse) MarshalToSizedBuffer 

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

func (*ServiceCloseResponse) ProtoMessage 

func (*ServiceCloseResponse) ProtoMessage()

func (*ServiceCloseResponse) Reset 

func (m *ServiceCloseResponse) Reset()

func (*ServiceCloseResponse) Size 

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

func (*ServiceCloseResponse) String 

func (m *ServiceCloseResponse) String() string

func (*ServiceCloseResponse) Unmarshal 

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

func (*ServiceCloseResponse) XXX_DiscardUnknown 

func (m *ServiceCloseResponse) XXX_DiscardUnknown()

func (*ServiceCloseResponse) XXX_Marshal 

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

func (*ServiceCloseResponse) XXX_Merge 

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

func (*ServiceCloseResponse) XXX_Size 

func (m *ServiceCloseResponse) XXX_Size() int

func (*ServiceCloseResponse) XXX_Unmarshal 

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

type ServiceCommandRequest 

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

func (*ServiceCommandRequest) Descriptor 

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

func (*ServiceCommandRequest) GetClose 

func (m *ServiceCommandRequest) GetClose() *ServiceCloseRequest

func (*ServiceCommandRequest) GetCreate 

func (m *ServiceCommandRequest) GetCreate() *ServiceCreateRequest

func (*ServiceCommandRequest) GetDelete 

func (m *ServiceCommandRequest) GetDelete() *ServiceDeleteRequest

func (*ServiceCommandRequest) GetOperation 

func (m *ServiceCommandRequest) GetOperation() *ServiceOperationRequest

func (*ServiceCommandRequest) GetRequest 

func (m *ServiceCommandRequest) GetRequest() isServiceCommandRequest_Request

func (*ServiceCommandRequest) GetService 

func (m *ServiceCommandRequest) GetService() *ServiceId

func (*ServiceCommandRequest) Marshal 

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

func (*ServiceCommandRequest) MarshalTo 

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

func (*ServiceCommandRequest) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest) ProtoMessage 

func (*ServiceCommandRequest) ProtoMessage()

func (*ServiceCommandRequest) Reset 

func (m *ServiceCommandRequest) Reset()

func (*ServiceCommandRequest) Size 

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

func (*ServiceCommandRequest) String 

func (m *ServiceCommandRequest) String() string

func (*ServiceCommandRequest) Unmarshal 

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

func (*ServiceCommandRequest) XXX_DiscardUnknown 

func (m *ServiceCommandRequest) XXX_DiscardUnknown()

func (*ServiceCommandRequest) XXX_Marshal 

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

func (*ServiceCommandRequest) XXX_Merge 

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

func (*ServiceCommandRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceCommandRequest) XXX_Size 

func (m *ServiceCommandRequest) XXX_Size() int

func (*ServiceCommandRequest) XXX_Unmarshal 

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

type ServiceCommandRequest_Close 

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

func (*ServiceCommandRequest_Close) MarshalTo 

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

func (*ServiceCommandRequest_Close) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Close) Size 

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

type ServiceCommandRequest_Create 

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

func (*ServiceCommandRequest_Create) MarshalTo 

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

func (*ServiceCommandRequest_Create) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Create) Size 

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

type ServiceCommandRequest_Delete 

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

func (*ServiceCommandRequest_Delete) MarshalTo 

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

func (*ServiceCommandRequest_Delete) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Delete) Size 

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

type ServiceCommandRequest_Operation 

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

func (*ServiceCommandRequest_Operation) MarshalTo 

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

func (*ServiceCommandRequest_Operation) MarshalToSizedBuffer 

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

func (*ServiceCommandRequest_Operation) Size 

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

type ServiceCommandResponse 

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

func (*ServiceCommandResponse) Descriptor 

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

func (*ServiceCommandResponse) GetClose 

func (m *ServiceCommandResponse) GetClose() *ServiceCloseResponse

func (*ServiceCommandResponse) GetCreate 

func (m *ServiceCommandResponse) GetCreate() *ServiceCreateResponse

func (*ServiceCommandResponse) GetDelete 

func (m *ServiceCommandResponse) GetDelete() *ServiceDeleteResponse

func (*ServiceCommandResponse) GetOperation 

func (m *ServiceCommandResponse) GetOperation() *ServiceOperationResponse

func (*ServiceCommandResponse) GetResponse 

func (m *ServiceCommandResponse) GetResponse() isServiceCommandResponse_Response

func (*ServiceCommandResponse) Marshal 

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

func (*ServiceCommandResponse) MarshalTo 

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

func (*ServiceCommandResponse) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse) ProtoMessage 

func (*ServiceCommandResponse) ProtoMessage()

func (*ServiceCommandResponse) Reset 

func (m *ServiceCommandResponse) Reset()

func (*ServiceCommandResponse) Size 

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

func (*ServiceCommandResponse) String 

func (m *ServiceCommandResponse) String() string

func (*ServiceCommandResponse) Unmarshal 

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

func (*ServiceCommandResponse) XXX_DiscardUnknown 

func (m *ServiceCommandResponse) XXX_DiscardUnknown()

func (*ServiceCommandResponse) XXX_Marshal 

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

func (*ServiceCommandResponse) XXX_Merge 

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

func (*ServiceCommandResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceCommandResponse) XXX_Size 

func (m *ServiceCommandResponse) XXX_Size() int

func (*ServiceCommandResponse) XXX_Unmarshal 

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

type ServiceCommandResponse_Close 

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

func (*ServiceCommandResponse_Close) MarshalTo 

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

func (*ServiceCommandResponse_Close) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Close) Size 

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

type ServiceCommandResponse_Create 

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

func (*ServiceCommandResponse_Create) MarshalTo 

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

func (*ServiceCommandResponse_Create) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Create) Size 

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

type ServiceCommandResponse_Delete 

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

func (*ServiceCommandResponse_Delete) MarshalTo 

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

func (*ServiceCommandResponse_Delete) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Delete) Size 

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

type ServiceCommandResponse_Operation 

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

func (*ServiceCommandResponse_Operation) MarshalTo 

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

func (*ServiceCommandResponse_Operation) MarshalToSizedBuffer 

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

func (*ServiceCommandResponse_Operation) Size 

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

type 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 struct {
	Type      ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=atomix.service.ServiceType" json:"type,omitempty"`
	Name      string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string      `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*ServiceId) Descriptor 

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

func (*ServiceId) GetName 

func (m *ServiceId) GetName() string

func (*ServiceId) GetNamespace 

func (m *ServiceId) GetNamespace() string

func (*ServiceId) GetType 

func (m *ServiceId) GetType() ServiceType

func (*ServiceId) Marshal 

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

func (*ServiceId) MarshalTo 

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

func (*ServiceId) MarshalToSizedBuffer 

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

func (*ServiceId) ProtoMessage 

func (*ServiceId) ProtoMessage()

func (*ServiceId) Reset 

func (m *ServiceId) Reset()

func (*ServiceId) Size 

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

func (*ServiceId) String 

func (m *ServiceId) String() string

func (*ServiceId) Unmarshal 

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

func (*ServiceId) XXX_DiscardUnknown 

func (m *ServiceId) XXX_DiscardUnknown()

func (*ServiceId) XXX_Marshal 

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

func (*ServiceId) XXX_Merge 

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

func (*ServiceId) XXX_Size 

func (m *ServiceId) XXX_Size() int

func (*ServiceId) XXX_Unmarshal 

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

type ServiceMetadataRequest 

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

func (*ServiceMetadataRequest) Descriptor 

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

func (*ServiceMetadataRequest) GetNamespace 

func (m *ServiceMetadataRequest) GetNamespace() string

func (*ServiceMetadataRequest) GetType 

func (m *ServiceMetadataRequest) GetType() ServiceType

func (*ServiceMetadataRequest) Marshal 

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

func (*ServiceMetadataRequest) MarshalTo 

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

func (*ServiceMetadataRequest) MarshalToSizedBuffer 

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

func (*ServiceMetadataRequest) ProtoMessage 

func (*ServiceMetadataRequest) ProtoMessage()

func (*ServiceMetadataRequest) Reset 

func (m *ServiceMetadataRequest) Reset()

func (*ServiceMetadataRequest) Size 

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

func (*ServiceMetadataRequest) String 

func (m *ServiceMetadataRequest) String() string

func (*ServiceMetadataRequest) Unmarshal 

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

func (*ServiceMetadataRequest) XXX_DiscardUnknown 

func (m *ServiceMetadataRequest) XXX_DiscardUnknown()

func (*ServiceMetadataRequest) XXX_Marshal 

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

func (*ServiceMetadataRequest) XXX_Merge 

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

func (*ServiceMetadataRequest) XXX_Size 

func (m *ServiceMetadataRequest) XXX_Size() int

func (*ServiceMetadataRequest) XXX_Unmarshal 

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

type ServiceMetadataResponse 

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

func (*ServiceMetadataResponse) Descriptor 

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

func (*ServiceMetadataResponse) GetServices 

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

func (*ServiceMetadataResponse) Marshal 

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

func (*ServiceMetadataResponse) MarshalTo 

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

func (*ServiceMetadataResponse) MarshalToSizedBuffer 

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

func (*ServiceMetadataResponse) ProtoMessage 

func (*ServiceMetadataResponse) ProtoMessage()

func (*ServiceMetadataResponse) Reset 

func (m *ServiceMetadataResponse) Reset()

func (*ServiceMetadataResponse) Size 

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

func (*ServiceMetadataResponse) String 

func (m *ServiceMetadataResponse) String() string

func (*ServiceMetadataResponse) Unmarshal 

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

func (*ServiceMetadataResponse) XXX_DiscardUnknown 

func (m *ServiceMetadataResponse) XXX_DiscardUnknown()

func (*ServiceMetadataResponse) XXX_Marshal 

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

func (*ServiceMetadataResponse) XXX_Merge 

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

func (*ServiceMetadataResponse) XXX_Size 

func (m *ServiceMetadataResponse) XXX_Size() int

func (*ServiceMetadataResponse) XXX_Unmarshal 

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

type ServiceOperationRequest 

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

func (*ServiceOperationRequest) Descriptor 

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

func (*ServiceOperationRequest) GetMethod 

func (m *ServiceOperationRequest) GetMethod() string

func (*ServiceOperationRequest) GetValue 

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

func (*ServiceOperationRequest) Marshal 

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

func (*ServiceOperationRequest) MarshalTo 

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

func (*ServiceOperationRequest) MarshalToSizedBuffer 

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

func (*ServiceOperationRequest) ProtoMessage 

func (*ServiceOperationRequest) ProtoMessage()

func (*ServiceOperationRequest) Reset 

func (m *ServiceOperationRequest) Reset()

func (*ServiceOperationRequest) Size 

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

func (*ServiceOperationRequest) String 

func (m *ServiceOperationRequest) String() string

func (*ServiceOperationRequest) Unmarshal 

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

func (*ServiceOperationRequest) XXX_DiscardUnknown 

func (m *ServiceOperationRequest) XXX_DiscardUnknown()

func (*ServiceOperationRequest) XXX_Marshal 

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

func (*ServiceOperationRequest) XXX_Merge 

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

func (*ServiceOperationRequest) XXX_Size 

func (m *ServiceOperationRequest) XXX_Size() int

func (*ServiceOperationRequest) XXX_Unmarshal 

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

type ServiceOperationResponse 

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

func (*ServiceOperationResponse) Descriptor 

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

func (*ServiceOperationResponse) GetResult 

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

func (*ServiceOperationResponse) Marshal 

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

func (*ServiceOperationResponse) MarshalTo 

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

func (*ServiceOperationResponse) MarshalToSizedBuffer 

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

func (*ServiceOperationResponse) ProtoMessage 

func (*ServiceOperationResponse) ProtoMessage()

func (*ServiceOperationResponse) Reset 

func (m *ServiceOperationResponse) Reset()

func (*ServiceOperationResponse) Size 

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

func (*ServiceOperationResponse) String 

func (m *ServiceOperationResponse) String() string

func (*ServiceOperationResponse) Unmarshal 

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

func (*ServiceOperationResponse) XXX_DiscardUnknown 

func (m *ServiceOperationResponse) XXX_DiscardUnknown()

func (*ServiceOperationResponse) XXX_Marshal 

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

func (*ServiceOperationResponse) XXX_Merge 

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

func (*ServiceOperationResponse) XXX_Size 

func (m *ServiceOperationResponse) XXX_Size() int

func (*ServiceOperationResponse) XXX_Unmarshal 

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

type ServiceQueryRequest 

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

func (*ServiceQueryRequest) Descriptor 

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

func (*ServiceQueryRequest) GetMetadata 

func (m *ServiceQueryRequest) GetMetadata() *ServiceMetadataRequest

func (*ServiceQueryRequest) GetOperation 

func (m *ServiceQueryRequest) GetOperation() *ServiceOperationRequest

func (*ServiceQueryRequest) GetRequest 

func (m *ServiceQueryRequest) GetRequest() isServiceQueryRequest_Request

func (*ServiceQueryRequest) GetService 

func (m *ServiceQueryRequest) GetService() *ServiceId

func (*ServiceQueryRequest) Marshal 

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

func (*ServiceQueryRequest) MarshalTo 

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

func (*ServiceQueryRequest) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest) ProtoMessage 

func (*ServiceQueryRequest) ProtoMessage()

func (*ServiceQueryRequest) Reset 

func (m *ServiceQueryRequest) Reset()

func (*ServiceQueryRequest) Size 

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

func (*ServiceQueryRequest) String 

func (m *ServiceQueryRequest) String() string

func (*ServiceQueryRequest) Unmarshal 

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

func (*ServiceQueryRequest) XXX_DiscardUnknown 

func (m *ServiceQueryRequest) XXX_DiscardUnknown()

func (*ServiceQueryRequest) XXX_Marshal 

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

func (*ServiceQueryRequest) XXX_Merge 

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

func (*ServiceQueryRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceQueryRequest) XXX_Size 

func (m *ServiceQueryRequest) XXX_Size() int

func (*ServiceQueryRequest) XXX_Unmarshal 

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

type ServiceQueryRequest_Metadata 

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

func (*ServiceQueryRequest_Metadata) MarshalTo 

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

func (*ServiceQueryRequest_Metadata) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest_Metadata) Size 

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

type ServiceQueryRequest_Operation 

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

func (*ServiceQueryRequest_Operation) MarshalTo 

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

func (*ServiceQueryRequest_Operation) MarshalToSizedBuffer 

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

func (*ServiceQueryRequest_Operation) Size 

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

type ServiceQueryResponse 

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

func (*ServiceQueryResponse) Descriptor 

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

func (*ServiceQueryResponse) GetMetadata 

func (m *ServiceQueryResponse) GetMetadata() *ServiceMetadataResponse

func (*ServiceQueryResponse) GetOperation 

func (m *ServiceQueryResponse) GetOperation() *ServiceOperationResponse

func (*ServiceQueryResponse) GetResponse 

func (m *ServiceQueryResponse) GetResponse() isServiceQueryResponse_Response

func (*ServiceQueryResponse) Marshal 

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

func (*ServiceQueryResponse) MarshalTo 

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

func (*ServiceQueryResponse) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse) ProtoMessage 

func (*ServiceQueryResponse) ProtoMessage()

func (*ServiceQueryResponse) Reset 

func (m *ServiceQueryResponse) Reset()

func (*ServiceQueryResponse) Size 

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

func (*ServiceQueryResponse) String 

func (m *ServiceQueryResponse) String() string

func (*ServiceQueryResponse) Unmarshal 

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

func (*ServiceQueryResponse) XXX_DiscardUnknown 

func (m *ServiceQueryResponse) XXX_DiscardUnknown()

func (*ServiceQueryResponse) XXX_Marshal 

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

func (*ServiceQueryResponse) XXX_Merge 

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

func (*ServiceQueryResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ServiceQueryResponse) XXX_Size 

func (m *ServiceQueryResponse) XXX_Size() int

func (*ServiceQueryResponse) XXX_Unmarshal 

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

type ServiceQueryResponse_Metadata 

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

func (*ServiceQueryResponse_Metadata) MarshalTo 

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

func (*ServiceQueryResponse_Metadata) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse_Metadata) Size 

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

type ServiceQueryResponse_Operation 

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

func (*ServiceQueryResponse_Operation) MarshalTo 

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

func (*ServiceQueryResponse_Operation) MarshalToSizedBuffer 

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

func (*ServiceQueryResponse_Operation) Size 

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

type ServiceType 

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

func (ServiceType) EnumDescriptor 

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

func (ServiceType) String 

func (x ServiceType) String() string

type Session 

type Session struct {
	ID          uint64
	Timeout     time.Duration
	LastUpdated time.Time
	// contains filtered or unexported fields
}

Session manages the ordering of request and response streams for a single client

func (*Session) Stream 

func (s *Session) Stream(id uint64) streams.WriteStream

Stream returns the given stream

func (*Session) StreamID 

func (s *Session) StreamID() uint64

StreamID returns the ID of the current stream

func (*Session) Streams 

func (s *Session) Streams() []streams.WriteStream

Streams returns a slice of all open streams of any type owned by the session

func (*Session) StreamsOf 

func (s *Session) StreamsOf(op string) []streams.WriteStream

StreamsOf returns a slice of all open streams for the given named operation owned by the session

type SessionClosed 

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

SessionClosed is an interface for listening to session closed events

type SessionCommandContext 

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

func (*SessionCommandContext) Descriptor 

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

func (*SessionCommandContext) GetSequenceNumber 

func (m *SessionCommandContext) GetSequenceNumber() uint64

func (*SessionCommandContext) GetSessionID 

func (m *SessionCommandContext) GetSessionID() uint64

func (*SessionCommandContext) Marshal 

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

func (*SessionCommandContext) MarshalTo 

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

func (*SessionCommandContext) MarshalToSizedBuffer 

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

func (*SessionCommandContext) ProtoMessage 

func (*SessionCommandContext) ProtoMessage()

func (*SessionCommandContext) Reset 

func (m *SessionCommandContext) Reset()

func (*SessionCommandContext) Size 

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

func (*SessionCommandContext) String 

func (m *SessionCommandContext) String() string

func (*SessionCommandContext) Unmarshal 

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

func (*SessionCommandContext) XXX_DiscardUnknown 

func (m *SessionCommandContext) XXX_DiscardUnknown()

func (*SessionCommandContext) XXX_Marshal 

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

func (*SessionCommandContext) XXX_Merge 

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

func (*SessionCommandContext) XXX_Size 

func (m *SessionCommandContext) XXX_Size() int

func (*SessionCommandContext) XXX_Unmarshal 

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

type SessionCommandRequest 

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

func (*SessionCommandRequest) Descriptor 

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

func (*SessionCommandRequest) GetCommand 

func (m *SessionCommandRequest) GetCommand() *ServiceCommandRequest

func (*SessionCommandRequest) GetContext 

func (m *SessionCommandRequest) GetContext() *SessionCommandContext

func (*SessionCommandRequest) Marshal 

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

func (*SessionCommandRequest) MarshalTo 

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

func (*SessionCommandRequest) MarshalToSizedBuffer 

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

func (*SessionCommandRequest) ProtoMessage 

func (*SessionCommandRequest) ProtoMessage()

func (*SessionCommandRequest) Reset 

func (m *SessionCommandRequest) Reset()

func (*SessionCommandRequest) Size 

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

func (*SessionCommandRequest) String 

func (m *SessionCommandRequest) String() string

func (*SessionCommandRequest) Unmarshal 

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

func (*SessionCommandRequest) XXX_DiscardUnknown 

func (m *SessionCommandRequest) XXX_DiscardUnknown()

func (*SessionCommandRequest) XXX_Marshal 

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

func (*SessionCommandRequest) XXX_Merge 

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

func (*SessionCommandRequest) XXX_Size 

func (m *SessionCommandRequest) XXX_Size() int

func (*SessionCommandRequest) XXX_Unmarshal 

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

type SessionCommandResponse 

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

func (*SessionCommandResponse) Descriptor 

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

func (*SessionCommandResponse) GetContext 

func (m *SessionCommandResponse) GetContext() *SessionResponseContext

func (*SessionCommandResponse) GetResponse 

func (m *SessionCommandResponse) GetResponse() *ServiceCommandResponse

func (*SessionCommandResponse) Marshal 

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

func (*SessionCommandResponse) MarshalTo 

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

func (*SessionCommandResponse) MarshalToSizedBuffer 

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

func (*SessionCommandResponse) ProtoMessage 

func (*SessionCommandResponse) ProtoMessage()

func (*SessionCommandResponse) Reset 

func (m *SessionCommandResponse) Reset()

func (*SessionCommandResponse) Size 

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

func (*SessionCommandResponse) String 

func (m *SessionCommandResponse) String() string

func (*SessionCommandResponse) Unmarshal 

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

func (*SessionCommandResponse) XXX_DiscardUnknown 

func (m *SessionCommandResponse) XXX_DiscardUnknown()

func (*SessionCommandResponse) XXX_Marshal 

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

func (*SessionCommandResponse) XXX_Merge 

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

func (*SessionCommandResponse) XXX_Size 

func (m *SessionCommandResponse) XXX_Size() int

func (*SessionCommandResponse) XXX_Unmarshal 

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

type SessionExpired 

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

SessionExpired is an interface for listening to session expired events

type SessionOpen 

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

SessionOpen 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,omitempty"`
	Query   *ServiceQueryRequest `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
}

func (*SessionQueryRequest) Descriptor 

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

func (*SessionQueryRequest) GetContext 

func (m *SessionQueryRequest) GetContext() *SessionQueryContext

func (*SessionQueryRequest) GetQuery 

func (m *SessionQueryRequest) GetQuery() *ServiceQueryRequest

func (*SessionQueryRequest) Marshal 

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

func (*SessionQueryRequest) MarshalTo 

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

func (*SessionQueryRequest) MarshalToSizedBuffer 

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

func (*SessionQueryRequest) ProtoMessage 

func (*SessionQueryRequest) ProtoMessage()

func (*SessionQueryRequest) Reset 

func (m *SessionQueryRequest) Reset()

func (*SessionQueryRequest) Size 

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

func (*SessionQueryRequest) String 

func (m *SessionQueryRequest) String() string

func (*SessionQueryRequest) Unmarshal 

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

func (*SessionQueryRequest) XXX_DiscardUnknown 

func (m *SessionQueryRequest) XXX_DiscardUnknown()

func (*SessionQueryRequest) XXX_Marshal 

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

func (*SessionQueryRequest) XXX_Merge 

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

func (*SessionQueryRequest) XXX_Size 

func (m *SessionQueryRequest) XXX_Size() int

func (*SessionQueryRequest) XXX_Unmarshal 

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

type SessionQueryResponse 

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

func (*SessionQueryResponse) Descriptor 

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

func (*SessionQueryResponse) GetContext 

func (m *SessionQueryResponse) GetContext() *SessionResponseContext

func (*SessionQueryResponse) GetResponse 

func (m *SessionQueryResponse) GetResponse() *ServiceQueryResponse

func (*SessionQueryResponse) Marshal 

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

func (*SessionQueryResponse) MarshalTo 

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

func (*SessionQueryResponse) MarshalToSizedBuffer 

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

func (*SessionQueryResponse) ProtoMessage 

func (*SessionQueryResponse) ProtoMessage()

func (*SessionQueryResponse) Reset 

func (m *SessionQueryResponse) Reset()

func (*SessionQueryResponse) Size 

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

func (*SessionQueryResponse) String 

func (m *SessionQueryResponse) String() string

func (*SessionQueryResponse) Unmarshal 

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

func (*SessionQueryResponse) XXX_DiscardUnknown 

func (m *SessionQueryResponse) XXX_DiscardUnknown()

func (*SessionQueryResponse) XXX_Marshal 

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

func (*SessionQueryResponse) XXX_Merge 

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

func (*SessionQueryResponse) XXX_Size 

func (m *SessionQueryResponse) XXX_Size() int

func (*SessionQueryResponse) XXX_Unmarshal 

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

type SessionRequest 

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

func (*SessionRequest) Descriptor 

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

func (*SessionRequest) GetCloseSession 

func (m *SessionRequest) GetCloseSession() *CloseSessionRequest

func (*SessionRequest) GetCommand 

func (m *SessionRequest) GetCommand() *SessionCommandRequest

func (*SessionRequest) GetKeepAlive 

func (m *SessionRequest) GetKeepAlive() *KeepAliveRequest

func (*SessionRequest) GetOpenSession 

func (m *SessionRequest) GetOpenSession() *OpenSessionRequest

func (*SessionRequest) GetQuery 

func (m *SessionRequest) GetQuery() *SessionQueryRequest

func (*SessionRequest) GetRequest 

func (m *SessionRequest) GetRequest() isSessionRequest_Request

func (*SessionRequest) Marshal 

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

func (*SessionRequest) MarshalTo 

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

func (*SessionRequest) MarshalToSizedBuffer 

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

func (*SessionRequest) ProtoMessage 

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) Reset 

func (m *SessionRequest) Reset()

func (*SessionRequest) Size 

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

func (*SessionRequest) String 

func (m *SessionRequest) String() string

func (*SessionRequest) Unmarshal 

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

func (*SessionRequest) XXX_DiscardUnknown 

func (m *SessionRequest) XXX_DiscardUnknown()

func (*SessionRequest) XXX_Marshal 

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

func (*SessionRequest) XXX_Merge 

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

func (*SessionRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionRequest) XXX_Size 

func (m *SessionRequest) XXX_Size() int

func (*SessionRequest) XXX_Unmarshal 

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

type SessionRequest_CloseSession 

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

func (*SessionRequest_CloseSession) MarshalTo 

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

func (*SessionRequest_CloseSession) MarshalToSizedBuffer 

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

func (*SessionRequest_CloseSession) Size 

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

type SessionRequest_Command 

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

func (*SessionRequest_Command) MarshalTo 

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

func (*SessionRequest_Command) MarshalToSizedBuffer 

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

func (*SessionRequest_Command) Size 

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

type SessionRequest_KeepAlive 

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

func (*SessionRequest_KeepAlive) MarshalTo 

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

func (*SessionRequest_KeepAlive) MarshalToSizedBuffer 

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

func (*SessionRequest_KeepAlive) Size 

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

type SessionRequest_OpenSession 

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

func (*SessionRequest_OpenSession) MarshalTo 

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

func (*SessionRequest_OpenSession) MarshalToSizedBuffer 

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

func (*SessionRequest_OpenSession) Size 

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

type SessionRequest_Query 

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

func (*SessionRequest_Query) MarshalTo 

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

func (*SessionRequest_Query) MarshalToSizedBuffer 

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

func (*SessionRequest_Query) Size 

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

type SessionResponse 

type SessionResponse struct {
	// Types that are valid to be assigned to Response:
	//	*SessionResponse_OpenSession
	//	*SessionResponse_KeepAlive
	//	*SessionResponse_CloseSession
	//	*SessionResponse_Command
	//	*SessionResponse_Query
	Response isSessionResponse_Response `protobuf_oneof:"response"`
}

func (*SessionResponse) Descriptor 

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

func (*SessionResponse) GetCloseSession 

func (m *SessionResponse) GetCloseSession() *CloseSessionResponse

func (*SessionResponse) GetCommand 

func (m *SessionResponse) GetCommand() *SessionCommandResponse

func (*SessionResponse) GetKeepAlive 

func (m *SessionResponse) GetKeepAlive() *KeepAliveResponse

func (*SessionResponse) GetOpenSession 

func (m *SessionResponse) GetOpenSession() *OpenSessionResponse

func (*SessionResponse) GetQuery 

func (m *SessionResponse) GetQuery() *SessionQueryResponse

func (*SessionResponse) GetResponse 

func (m *SessionResponse) GetResponse() isSessionResponse_Response

func (*SessionResponse) Marshal 

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

func (*SessionResponse) MarshalTo 

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

func (*SessionResponse) MarshalToSizedBuffer 

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

func (*SessionResponse) ProtoMessage 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) Reset 

func (m *SessionResponse) Reset()

func (*SessionResponse) Size 

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

func (*SessionResponse) String 

func (m *SessionResponse) String() string

func (*SessionResponse) Unmarshal 

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

func (*SessionResponse) XXX_DiscardUnknown 

func (m *SessionResponse) XXX_DiscardUnknown()

func (*SessionResponse) XXX_Marshal 

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

func (*SessionResponse) XXX_Merge 

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

func (*SessionResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionResponse) XXX_Size 

func (m *SessionResponse) XXX_Size() int

func (*SessionResponse) XXX_Unmarshal 

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

type SessionResponseContext 

type SessionResponseContext struct {
	StreamID uint64              `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Index    uint64              `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Sequence uint64              `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Type     SessionResponseType `protobuf:"varint,4,opt,name=type,proto3,enum=atomix.service.SessionResponseType" json:"type,omitempty"`
}

func (*SessionResponseContext) Descriptor 

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

func (*SessionResponseContext) GetIndex 

func (m *SessionResponseContext) GetIndex() uint64

func (*SessionResponseContext) GetSequence 

func (m *SessionResponseContext) GetSequence() uint64

func (*SessionResponseContext) GetStreamID 

func (m *SessionResponseContext) GetStreamID() uint64

func (*SessionResponseContext) GetType 

func (m *SessionResponseContext) GetType() SessionResponseType

func (*SessionResponseContext) Marshal 

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

func (*SessionResponseContext) MarshalTo 

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

func (*SessionResponseContext) MarshalToSizedBuffer 

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

func (*SessionResponseContext) ProtoMessage 

func (*SessionResponseContext) ProtoMessage()

func (*SessionResponseContext) Reset 

func (m *SessionResponseContext) Reset()

func (*SessionResponseContext) Size 

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

func (*SessionResponseContext) String 

func (m *SessionResponseContext) String() string

func (*SessionResponseContext) Unmarshal 

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

func (*SessionResponseContext) XXX_DiscardUnknown 

func (m *SessionResponseContext) XXX_DiscardUnknown()

func (*SessionResponseContext) XXX_Marshal 

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

func (*SessionResponseContext) XXX_Merge 

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

func (*SessionResponseContext) XXX_Size 

func (m *SessionResponseContext) XXX_Size() int

func (*SessionResponseContext) XXX_Unmarshal 

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

type SessionResponseType 

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

func (SessionResponseType) EnumDescriptor 

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

func (SessionResponseType) String 

func (x SessionResponseType) String() string

type SessionResponse_CloseSession 

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

func (*SessionResponse_CloseSession) MarshalTo 

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

func (*SessionResponse_CloseSession) MarshalToSizedBuffer 

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

func (*SessionResponse_CloseSession) Size 

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

type SessionResponse_Command 

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

func (*SessionResponse_Command) MarshalTo 

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

func (*SessionResponse_Command) MarshalToSizedBuffer 

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

func (*SessionResponse_Command) Size 

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

type SessionResponse_KeepAlive 

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

func (*SessionResponse_KeepAlive) MarshalTo 

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

func (*SessionResponse_KeepAlive) MarshalToSizedBuffer 

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

func (*SessionResponse_KeepAlive) Size 

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

type SessionResponse_OpenSession 

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

func (*SessionResponse_OpenSession) MarshalTo 

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

func (*SessionResponse_OpenSession) MarshalToSizedBuffer 

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

func (*SessionResponse_OpenSession) Size 

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

type SessionResponse_Query 

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

func (*SessionResponse_Query) MarshalTo 

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

func (*SessionResponse_Query) MarshalToSizedBuffer 

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

func (*SessionResponse_Query) Size 

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

type SessionSnapshot 

type SessionSnapshot struct {
	SessionID       uint64                   `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Timeout         time.Duration            `protobuf:"bytes,2,opt,name=timeout,proto3,stdduration" json:"timeout"`
	Timestamp       time.Time                `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"`
	CommandSequence uint64                   `protobuf:"varint,4,opt,name=command_sequence,json=commandSequence,proto3" json:"command_sequence,omitempty"`
	LastApplied     uint64                   `protobuf:"varint,5,opt,name=last_applied,json=lastApplied,proto3" json:"last_applied,omitempty"`
	Streams         []*SessionStreamSnapshot `protobuf:"bytes,6,rep,name=streams,proto3" json:"streams,omitempty"`
	Services        []string                 `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) GetLastApplied 

func (m *SessionSnapshot) GetLastApplied() uint64

func (*SessionSnapshot) GetServices 

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

func (*SessionSnapshot) GetSessionID 

func (m *SessionSnapshot) GetSessionID() uint64

func (*SessionSnapshot) GetStreams 

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

func (*SessionSnapshot) GetTimeout 

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

func (*SessionSnapshot) GetTimestamp 

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

func (*SessionSnapshot) Marshal 

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

func (*SessionSnapshot) MarshalTo 

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

func (*SessionSnapshot) MarshalToSizedBuffer 

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

func (*SessionSnapshot) ProtoMessage 

func (*SessionSnapshot) ProtoMessage()

func (*SessionSnapshot) Reset 

func (m *SessionSnapshot) Reset()

func (*SessionSnapshot) Size 

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

func (*SessionSnapshot) String 

func (m *SessionSnapshot) String() string

func (*SessionSnapshot) Unmarshal 

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

func (*SessionSnapshot) XXX_DiscardUnknown 

func (m *SessionSnapshot) XXX_DiscardUnknown()

func (*SessionSnapshot) XXX_Marshal 

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

func (*SessionSnapshot) XXX_Merge 

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

func (*SessionSnapshot) XXX_Size 

func (m *SessionSnapshot) XXX_Size() int

func (*SessionSnapshot) XXX_Unmarshal 

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

type SessionStreamSnapshot 

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

Service session stream

func (*SessionStreamSnapshot) Descriptor 

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

func (*SessionStreamSnapshot) GetLastCompleted 

func (m *SessionStreamSnapshot) GetLastCompleted() uint64

func (*SessionStreamSnapshot) GetSequenceNumber 

func (m *SessionStreamSnapshot) GetSequenceNumber() uint64

func (*SessionStreamSnapshot) GetStreamId 

func (m *SessionStreamSnapshot) GetStreamId() uint64

func (*SessionStreamSnapshot) GetType 

func (m *SessionStreamSnapshot) GetType() string

func (*SessionStreamSnapshot) Marshal 

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

func (*SessionStreamSnapshot) MarshalTo 

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

func (*SessionStreamSnapshot) MarshalToSizedBuffer 

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

func (*SessionStreamSnapshot) ProtoMessage 

func (*SessionStreamSnapshot) ProtoMessage()

func (*SessionStreamSnapshot) Reset 

func (m *SessionStreamSnapshot) Reset()

func (*SessionStreamSnapshot) Size 

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

func (*SessionStreamSnapshot) String 

func (m *SessionStreamSnapshot) String() string

func (*SessionStreamSnapshot) Unmarshal 

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

func (*SessionStreamSnapshot) XXX_DiscardUnknown 

func (m *SessionStreamSnapshot) XXX_DiscardUnknown()

func (*SessionStreamSnapshot) XXX_Marshal 

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

func (*SessionStreamSnapshot) XXX_Merge 

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

func (*SessionStreamSnapshot) XXX_Size 

func (m *SessionStreamSnapshot) XXX_Size() int

func (*SessionStreamSnapshot) XXX_Unmarshal 

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

type SessionizedServiceSnapshot 

type SessionizedServiceSnapshot struct {
	Index     uint64             `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Timestamp uint64             `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Sessions  []*SessionSnapshot `protobuf:"bytes,3,rep,name=sessions,proto3" json:"sessions,omitempty"`
}

Sessionized service snapshot

func (*SessionizedServiceSnapshot) Descriptor 

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

func (*SessionizedServiceSnapshot) GetIndex 

func (m *SessionizedServiceSnapshot) GetIndex() uint64

func (*SessionizedServiceSnapshot) GetSessions 

func (m *SessionizedServiceSnapshot) GetSessions() []*SessionSnapshot

func (*SessionizedServiceSnapshot) GetTimestamp 

func (m *SessionizedServiceSnapshot) GetTimestamp() uint64

func (*SessionizedServiceSnapshot) Marshal 

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

func (*SessionizedServiceSnapshot) MarshalTo 

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

func (*SessionizedServiceSnapshot) MarshalToSizedBuffer 

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

func (*SessionizedServiceSnapshot) ProtoMessage 

func (*SessionizedServiceSnapshot) ProtoMessage()

func (*SessionizedServiceSnapshot) Reset 

func (m *SessionizedServiceSnapshot) Reset()

func (*SessionizedServiceSnapshot) Size 

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

func (*SessionizedServiceSnapshot) String 

func (m *SessionizedServiceSnapshot) String() string

func (*SessionizedServiceSnapshot) Unmarshal 

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

func (*SessionizedServiceSnapshot) XXX_DiscardUnknown 

func (m *SessionizedServiceSnapshot) XXX_DiscardUnknown()

func (*SessionizedServiceSnapshot) XXX_Marshal 

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

func (*SessionizedServiceSnapshot) XXX_Merge 

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

func (*SessionizedServiceSnapshot) XXX_Size 

func (m *SessionizedServiceSnapshot) XXX_Size() int

func (*SessionizedServiceSnapshot) XXX_Unmarshal 

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

type StreamingOperation 

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

StreamingOperation is a primitive operation that returns a stream

type Timer 

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

Timer is a cancellable timer

type UnaryOperation 

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

UnaryOperation is a primitive operation that returns a result

Source Files

View all Source files

Jump to

Keyboard shortcuts

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