shard

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