shard

Oct 29, 2019

Changes in this version

+ var ErrUnexpectedEndOfGroupShard = fmt.Errorf("proto: unexpected end of group")

Sep 11, 2019

Changes in this version

type AddServerRole

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

type Addresses

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

type DeleteServerRole

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

type FailedToAssignRoles

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

type FinishAssignRoles

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

type FinishRegister

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

type FrontendState

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

type GetAddress

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

type GetShardToAddress

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

type RemoveServerRole

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

type ServerRole

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

type ServerState

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

type SetAddresses

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

type SetFrontendState

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

type SetServerRole

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

type SetServerState

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

type StartAssignRoles

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

type StartRegister

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

type Version

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

May 2, 2019

Changes in this version

type AddServerRole

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *AddServerRole) XXX_DiscardUnknown()

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

+ func (m *AddServerRole) XXX_Merge(src proto.Message)

+ func (m *AddServerRole) XXX_Size() int

+ func (m *AddServerRole) XXX_Unmarshal(b []byte) error

type Addresses

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Addresses) XXX_DiscardUnknown()

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

+ func (m *Addresses) XXX_Merge(src proto.Message)

+ func (m *Addresses) XXX_Size() int

+ func (m *Addresses) XXX_Unmarshal(b []byte) error

type DeleteServerRole

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *DeleteServerRole) XXX_DiscardUnknown()

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

+ func (m *DeleteServerRole) XXX_Merge(src proto.Message)

+ func (m *DeleteServerRole) XXX_Size() int

+ func (m *DeleteServerRole) XXX_Unmarshal(b []byte) error

type FailedToAssignRoles

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FailedToAssignRoles) XXX_DiscardUnknown()

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

+ func (m *FailedToAssignRoles) XXX_Merge(src proto.Message)

+ func (m *FailedToAssignRoles) XXX_Size() int

+ func (m *FailedToAssignRoles) XXX_Unmarshal(b []byte) error

type FinishAssignRoles

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FinishAssignRoles) XXX_DiscardUnknown()

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

+ func (m *FinishAssignRoles) XXX_Merge(src proto.Message)

+ func (m *FinishAssignRoles) XXX_Size() int

+ func (m *FinishAssignRoles) XXX_Unmarshal(b []byte) error

type FinishRegister

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FinishRegister) XXX_DiscardUnknown()

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

+ func (m *FinishRegister) XXX_Merge(src proto.Message)

+ func (m *FinishRegister) XXX_Size() int

+ func (m *FinishRegister) XXX_Unmarshal(b []byte) error

type FrontendState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *FrontendState) XXX_DiscardUnknown()

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

+ func (m *FrontendState) XXX_Merge(src proto.Message)

+ func (m *FrontendState) XXX_Size() int

+ func (m *FrontendState) XXX_Unmarshal(b []byte) error

type GetAddress

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *GetAddress) XXX_DiscardUnknown()

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

+ func (m *GetAddress) XXX_Merge(src proto.Message)

+ func (m *GetAddress) XXX_Size() int

+ func (m *GetAddress) XXX_Unmarshal(b []byte) error

type GetShardToAddress

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *GetShardToAddress) XXX_DiscardUnknown()

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

+ func (m *GetShardToAddress) XXX_Merge(src proto.Message)

+ func (m *GetShardToAddress) XXX_Size() int

+ func (m *GetShardToAddress) XXX_Unmarshal(b []byte) error

type RemoveServerRole

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RemoveServerRole) XXX_DiscardUnknown()

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

+ func (m *RemoveServerRole) XXX_Merge(src proto.Message)

+ func (m *RemoveServerRole) XXX_Size() int

+ func (m *RemoveServerRole) XXX_Unmarshal(b []byte) error

type ServerRole

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ServerRole) XXX_DiscardUnknown()

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

+ func (m *ServerRole) XXX_Merge(src proto.Message)

+ func (m *ServerRole) XXX_Size() int

+ func (m *ServerRole) XXX_Unmarshal(b []byte) error

type ServerState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ServerState) XXX_DiscardUnknown()

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

+ func (m *ServerState) XXX_Merge(src proto.Message)

+ func (m *ServerState) XXX_Size() int

+ func (m *ServerState) XXX_Unmarshal(b []byte) error

type SetAddresses

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SetAddresses) XXX_DiscardUnknown()

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

+ func (m *SetAddresses) XXX_Merge(src proto.Message)

+ func (m *SetAddresses) XXX_Size() int

+ func (m *SetAddresses) XXX_Unmarshal(b []byte) error

type SetFrontendState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SetFrontendState) XXX_DiscardUnknown()

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

+ func (m *SetFrontendState) XXX_Merge(src proto.Message)

+ func (m *SetFrontendState) XXX_Size() int

+ func (m *SetFrontendState) XXX_Unmarshal(b []byte) error

type SetServerRole

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SetServerRole) XXX_DiscardUnknown()

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

+ func (m *SetServerRole) XXX_Merge(src proto.Message)

+ func (m *SetServerRole) XXX_Size() int

+ func (m *SetServerRole) XXX_Unmarshal(b []byte) error

type SetServerState

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *SetServerState) XXX_DiscardUnknown()

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

+ func (m *SetServerState) XXX_Merge(src proto.Message)

+ func (m *SetServerState) XXX_Size() int

+ func (m *SetServerState) XXX_Unmarshal(b []byte) error

type StartAssignRoles

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StartAssignRoles) XXX_DiscardUnknown()

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

+ func (m *StartAssignRoles) XXX_Merge(src proto.Message)

+ func (m *StartAssignRoles) XXX_Size() int

+ func (m *StartAssignRoles) XXX_Unmarshal(b []byte) error

type StartRegister

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *StartRegister) XXX_DiscardUnknown()

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

+ func (m *StartRegister) XXX_Merge(src proto.Message)

+ func (m *StartRegister) XXX_Size() int

+ func (m *StartRegister) XXX_Unmarshal(b []byte) error

type Version

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Version) XXX_DiscardUnknown()

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

+ func (m *Version) XXX_Merge(src proto.Message)

+ func (m *Version) XXX_Size() int

+ func (m *Version) XXX_Unmarshal(b []byte) error

Jul 7, 2017

Changes in this version

+ var ErrIntOverflowShard = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthShard = fmt.Errorf("proto: negative length found during unmarshaling")

type AddServerRole

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

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

+ func (m *AddServerRole) Size() (n int)

+ func (m *AddServerRole) Unmarshal(dAtA []byte) error

type Addresses

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

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

+ func (m *Addresses) Size() (n int)

+ func (m *Addresses) Unmarshal(dAtA []byte) error

type DeleteServerRole

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

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

+ func (m *DeleteServerRole) Size() (n int)

+ func (m *DeleteServerRole) Unmarshal(dAtA []byte) error

type FailedToAssignRoles

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

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

+ func (m *FailedToAssignRoles) Size() (n int)

+ func (m *FailedToAssignRoles) Unmarshal(dAtA []byte) error

type FinishAssignRoles

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

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

+ func (m *FinishAssignRoles) Size() (n int)

+ func (m *FinishAssignRoles) Unmarshal(dAtA []byte) error

type FinishRegister

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

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

+ func (m *FinishRegister) Size() (n int)

+ func (m *FinishRegister) Unmarshal(dAtA []byte) error

type FrontendState

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

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

+ func (m *FrontendState) Size() (n int)

+ func (m *FrontendState) Unmarshal(dAtA []byte) error

type GetAddress

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

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

+ func (m *GetAddress) Size() (n int)

+ func (m *GetAddress) Unmarshal(dAtA []byte) error

type GetShardToAddress

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

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

+ func (m *GetShardToAddress) Size() (n int)

+ func (m *GetShardToAddress) Unmarshal(dAtA []byte) error

type RemoveServerRole

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

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

+ func (m *RemoveServerRole) Size() (n int)

+ func (m *RemoveServerRole) Unmarshal(dAtA []byte) error

type ServerRole

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

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

+ func (m *ServerRole) Size() (n int)

+ func (m *ServerRole) Unmarshal(dAtA []byte) error

type ServerState

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

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

+ func (m *ServerState) Size() (n int)

+ func (m *ServerState) Unmarshal(dAtA []byte) error

type SetAddresses

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

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

+ func (m *SetAddresses) Size() (n int)

+ func (m *SetAddresses) Unmarshal(dAtA []byte) error

type SetFrontendState

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

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

+ func (m *SetFrontendState) Size() (n int)

+ func (m *SetFrontendState) Unmarshal(dAtA []byte) error

type SetServerRole

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

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

+ func (m *SetServerRole) Size() (n int)

+ func (m *SetServerRole) Unmarshal(dAtA []byte) error

type SetServerState

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

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

+ func (m *SetServerState) Size() (n int)

+ func (m *SetServerState) Unmarshal(dAtA []byte) error

type StartAssignRoles

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

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

+ func (m *StartAssignRoles) Size() (n int)

+ func (m *StartAssignRoles) Unmarshal(dAtA []byte) error

type StartRegister

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

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

+ func (m *StartRegister) Size() (n int)

+ func (m *StartRegister) Unmarshal(dAtA []byte) error

type Version

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

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

+ func (m *Version) Size() (n int)

+ func (m *Version) Unmarshal(dAtA []byte) error

Feb 9, 2017

Changes in this version

type AddServerRole

+ func (m *AddServerRole) GetError() string

type Addresses

+ func (m *Addresses) GetVersion() int64

type FailedToAssignRoles

+ func (m *FailedToAssignRoles) GetNumReplicas() uint64

+ func (m *FailedToAssignRoles) GetNumShards() uint64

type FinishAssignRoles

+ func (m *FinishAssignRoles) GetError() string

type FinishRegister

+ func (m *FinishRegister) GetAddress() string

+ func (m *FinishRegister) GetError() string

type FrontendState

+ func (m *FrontendState) GetAddress() string

+ func (m *FrontendState) GetVersion() int64

type GetAddress

+ func (m *GetAddress) GetError() string

+ func (m *GetAddress) GetOk() bool

+ func (m *GetAddress) GetResult() string

+ func (m *GetAddress) GetShard() uint64

+ func (m *GetAddress) GetVersion() int64

type GetShardToAddress

+ func (m *GetShardToAddress) GetError() string

+ func (m *GetShardToAddress) GetVersion() int64

type RemoveServerRole

+ func (m *RemoveServerRole) GetError() string

type ServerRole

+ func (m *ServerRole) GetAddress() string

+ func (m *ServerRole) GetVersion() int64

type ServerState

+ func (m *ServerState) GetAddress() string

+ func (m *ServerState) GetVersion() int64

type StartRegister

+ func (m *StartRegister) GetAddress() string

type Version

+ func (m *Version) GetError() string

+ func (m *Version) GetResult() int64

Jul 7, 2016

Changes in this version

type Router

+ CloseClientConns func() error

Jun 28, 2016

Changes in this version

+ const InvalidVersion

+ var ErrCancelled = fmt.Errorf("cancelled by user")

+ type AddServerRole struct

+ Error string

+ ServerRole *ServerRole

+ func (*AddServerRole) Descriptor() ([]byte, []int)

+ func (*AddServerRole) ProtoMessage()

+ func (m *AddServerRole) GetServerRole() *ServerRole

+ func (m *AddServerRole) Reset()

+ func (m *AddServerRole) String() string

+ type Addresses struct

+ Addresses map[uint64]string

+ Version int64

+ func (*Addresses) Descriptor() ([]byte, []int)

+ func (*Addresses) ProtoMessage()

+ func (m *Addresses) GetAddresses() map[uint64]string

+ func (m *Addresses) Reset()

+ func (m *Addresses) String() string

+ type DeleteServerRole struct

+ ServerRole *ServerRole

+ func (*DeleteServerRole) Descriptor() ([]byte, []int)

+ func (*DeleteServerRole) ProtoMessage()

+ func (m *DeleteServerRole) GetServerRole() *ServerRole

+ func (m *DeleteServerRole) Reset()

+ func (m *DeleteServerRole) String() string

+ type FailedToAssignRoles struct

+ NumReplicas uint64

+ NumShards uint64

+ ServerStates map[string]*ServerState

+ func (*FailedToAssignRoles) Descriptor() ([]byte, []int)

+ func (*FailedToAssignRoles) ProtoMessage()

+ func (m *FailedToAssignRoles) GetServerStates() map[string]*ServerState

+ func (m *FailedToAssignRoles) Reset()

+ func (m *FailedToAssignRoles) String() string

+ type FinishAssignRoles struct

+ Error string

+ func (*FinishAssignRoles) Descriptor() ([]byte, []int)

+ func (*FinishAssignRoles) ProtoMessage()

+ func (m *FinishAssignRoles) Reset()

+ func (m *FinishAssignRoles) String() string

+ type FinishRegister struct

+ Address string

+ Error string

+ func (*FinishRegister) Descriptor() ([]byte, []int)

+ func (*FinishRegister) ProtoMessage()

+ func (m *FinishRegister) Reset()

+ func (m *FinishRegister) String() string

+ type Frontend interface

+ Version func(version int64) error

+ type FrontendState struct

+ Address string

+ Version int64

+ func (*FrontendState) Descriptor() ([]byte, []int)

+ func (*FrontendState) ProtoMessage()

+ func (m *FrontendState) Reset()

+ func (m *FrontendState) String() string

+ type GetAddress struct

+ Error string

+ Ok bool

+ Result string

+ Shard uint64

+ Version int64

+ func (*GetAddress) Descriptor() ([]byte, []int)

+ func (*GetAddress) ProtoMessage()

+ func (m *GetAddress) Reset()

+ func (m *GetAddress) String() string

+ type GetShardToAddress struct

+ Error string

+ Result map[uint64]string

+ Version int64

+ func (*GetShardToAddress) Descriptor() ([]byte, []int)

+ func (*GetShardToAddress) ProtoMessage()

+ func (m *GetShardToAddress) GetResult() map[uint64]string

+ func (m *GetShardToAddress) Reset()

+ func (m *GetShardToAddress) String() string

+ type RemoveServerRole struct

+ Error string

+ ServerRole *ServerRole

+ func (*RemoveServerRole) Descriptor() ([]byte, []int)

+ func (*RemoveServerRole) ProtoMessage()

+ func (m *RemoveServerRole) GetServerRole() *ServerRole

+ func (m *RemoveServerRole) Reset()

+ func (m *RemoveServerRole) String() string

+ type Router interface

+ GetAllClientConns func(version int64) ([]*grpc.ClientConn, error)

+ GetClientConn func(shard uint64, version int64) (*grpc.ClientConn, error)

+ GetShards func(version int64) (map[uint64]bool, error)

+ func NewRouter(sharder Sharder, dialer grpcutil.Dialer, localAddress string) Router

+ type Server interface

+ AddShard func(shard uint64) error

+ DeleteShard func(shard uint64) error

+ type ServerRole struct

+ Address string

+ Shards map[uint64]bool

+ Version int64

+ func (*ServerRole) Descriptor() ([]byte, []int)

+ func (*ServerRole) ProtoMessage()

+ func (m *ServerRole) GetShards() map[uint64]bool

+ func (m *ServerRole) Reset()

+ func (m *ServerRole) String() string

+ type ServerState struct

+ Address string

+ Version int64

+ func (*ServerState) Descriptor() ([]byte, []int)

+ func (*ServerState) ProtoMessage()

+ func (m *ServerState) Reset()

+ func (m *ServerState) String() string

+ type SetAddresses struct

+ Addresses *Addresses

+ func (*SetAddresses) Descriptor() ([]byte, []int)

+ func (*SetAddresses) ProtoMessage()

+ func (m *SetAddresses) GetAddresses() *Addresses

+ func (m *SetAddresses) Reset()

+ func (m *SetAddresses) String() string

+ type SetFrontendState struct

+ FrontendState *FrontendState

+ func (*SetFrontendState) Descriptor() ([]byte, []int)

+ func (*SetFrontendState) ProtoMessage()

+ func (m *SetFrontendState) GetFrontendState() *FrontendState

+ func (m *SetFrontendState) Reset()

+ func (m *SetFrontendState) String() string

+ type SetServerRole struct

+ ServerRole *ServerRole

+ func (*SetServerRole) Descriptor() ([]byte, []int)

+ func (*SetServerRole) ProtoMessage()

+ func (m *SetServerRole) GetServerRole() *ServerRole

+ func (m *SetServerRole) Reset()

+ func (m *SetServerRole) String() string

+ type SetServerState struct

+ ServerState *ServerState

+ func (*SetServerState) Descriptor() ([]byte, []int)

+ func (*SetServerState) ProtoMessage()

+ func (m *SetServerState) GetServerState() *ServerState

+ func (m *SetServerState) Reset()

+ func (m *SetServerState) String() string

+ type Sharder interface

+ AssignRoles func(address string, cancel chan bool) error

+ GetAddress func(shard uint64, version int64) (string, bool, error)

+ GetShardToAddress func(version int64) (map[uint64]string, error)

+ Register func(cancel chan bool, address string, servers []Server) error

+ RegisterFrontends func(cancel chan bool, address string, frontends []Frontend) error

+ func NewLocalSharder(addresses []string, numShards uint64) Sharder

+ func NewSharder(discoveryClient discovery.Client, numShards uint64, namespace string) Sharder

+ type StartAssignRoles struct

+ func (*StartAssignRoles) Descriptor() ([]byte, []int)

+ func (*StartAssignRoles) ProtoMessage()

+ func (m *StartAssignRoles) Reset()

+ func (m *StartAssignRoles) String() string

+ type StartRegister struct

+ Address string

+ func (*StartRegister) Descriptor() ([]byte, []int)

+ func (*StartRegister) ProtoMessage()

+ func (m *StartRegister) Reset()

+ func (m *StartRegister) String() string

+ type TestSharder interface

+ WaitForAvailability func(frontendIds []string, serverIds []string) error

+ func NewTestSharder(discoveryClient discovery.Client, numShards uint64, namespace string) TestSharder

+ type Version struct

+ Error string

+ Result int64

+ func (*Version) Descriptor() ([]byte, []int)

+ func (*Version) ProtoMessage()

+ func (m *Version) Reset()

+ func (m *Version) String() string