ring

package module

Go to main page

Versions in this module

v0

v0.7.1

Sep 1, 2022

v0.1.11

Sep 6, 2022

Changes in this version

+ var ACLModelFile = configFile("model.conf")

+ var ACLPolicyFile = configFile("policy.csv")

+ var CAFile = configFile("ca.pem")

+ var ClientCertFile = configFile("client.pem")

+ var ClientKeyFile = configFile("client-key.pem")

+ var NobodyClientCertFile = configFile("nobody-client.pem")

+ var NobodyClientKeyFile = configFile("nobody-client-key.pem")

+ var RootClientCertFile = configFile("root-client.pem")

+ var RootClientKeyFile = configFile("root-client-key.pem")

+ var ServerCertFile = configFile("server.pem")

+ var ServerKeyFile = configFile("server-key.pem")

+ func SetupTLSConfig(cfg TLSConfig) (*tls.Config, error)

+ type TLSConfig struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ Server bool

+ ServerAddress string

v0.1.10

Sep 6, 2022

Changes in this version

+ var ErrCommandNotFound = errors.New("command couldn't be handled")

+ var ErrNodeIsAlreadyOnRing = errors.New("node has already joined the ring")

+ var ErrRingShutdown = errors.New("ring is closed")

+ var ErrStartupConfiguration = errors.New("startup configuration is not correct")

+ var ErrTransportShutdown = errors.New("transport shutdown")

+ var ErrVirtualNodeCount = errors.New("virtual node count should be greater than zero")

type Config

+ Timeout time.Duration

+ type ConfigurationNode struct

+ NodeKey string

+ Tags map[string]string

+ VirtualNodes map[uint64]int

+ type ConfigurationRequest struct

+ type ConfigurationResponse struct

+ BindAddr string

+ StartupConfig *StartupConfig

+ type Message struct

+ Data *proposal

+ From ServerAddress

+ MsgType PaxosMessageType

+ type PaxosMessageType uint8

+ const AcceptMsgType

+ const PrepareMsgType

+ const PromiseMsgType

+ const ProposalMsgType

+ type Promise interface

+ Error func() error

+ Response func() interface{}

+ type RPCInfo struct

+ From ServerAddress

+ type RequestType uint8

+ const PaxosRequestType

+ const RingRequestType

+ type Server struct

+ Address ServerAddress

+ type ServerAddress string

+ type ServerID string

+ type StartupConfig struct

+ Nodes map[uint64]ConfigurationNode

+ type StreamLayer interface

+ Dial func(address ServerAddress, timeout time.Duration) (net.Conn, error)

+ type TCPStreamLayer struct

+ func (t *TCPStreamLayer) Accept() (c net.Conn, err error)

+ func (t *TCPStreamLayer) Addr() net.Addr

+ func (t *TCPStreamLayer) Close() (err error)

+ func (t *TCPStreamLayer) Dial(address ServerAddress, timeout time.Duration) (net.Conn, error)

+ type Transport struct

+ func NewTransportWithConfig(config *TransportConfig) *Transport

+ func (transport *Transport) AcceptorConsumer() <-chan rpc

+ func (transport *Transport) Close() error

+ func (transport *Transport) CloseStreams()

+ func (transport *Transport) IsShutdown() bool

+ func (transport *Transport) LocalAddr() ServerAddress

+ func (transport *Transport) RingConsumer() <-chan rpc

+ func (transport *Transport) SendConfigurationRequest(target ServerAddress, req *ConfigurationRequest, resp interface{}) error

+ func (transport *Transport) SendPaxosMessage(target ServerAddress, req *Message, resp *Message) error

+ type TransportConfig struct

+ Logger hclog.Logger

+ MaxPool int

+ Stream StreamLayer

+ Timeout time.Duration

v0.1.9

Sep 2, 2022

Changes in this version

type HashFunction

+ Hash func(key string) uint64

type MD5HashFunction

+ func (m *MD5HashFunction) Hash(name string) uint64

v0.1.8

Sep 1, 2022

v0.1.7

Sep 1, 2022

Changes in this version

type Ring

+ func (r *Ring) AddResponsibilityChangeListener(listenerId string, handler ShardResponsibilityHandler)

+ func (r *Ring) RemoveResponsibilityChangeListener(listenerId string)

+ type ShardResponsibility struct

+ func (s *ShardResponsibility) ResponsibleNode() string

+ func (s *ShardResponsibility) ResponsibleNodeTags() map[string]string

+ func (s *ShardResponsibility) Transfer(objectKey string) bool

+ type ShardResponsibilityHandler interface

+ OnChange func([]ShardResponsibility)

v0.1.6

Aug 31, 2022

v0.1.5

Aug 31, 2022

v0.1.4

Aug 31, 2022

Changes in this version

type Config

+ Tags map[string]string

v0.1.3

Aug 26, 2022

Changes in this version

type Config

+ MemberType MemberType

+ type MemberType uint8

+ const LoadBalancerMember

+ const ShardMember

type Ring

+ func (r *Ring) GetLoadBalancers() []string

v0.1.2

Aug 25, 2022

v0.1.1

Aug 23, 2022

Changes in this version

+ var ErrRealNodeNotFound = errors.New("real node not found")

type Config

+ Logger hclog.Logger

+ type Ring struct

+ func NewRing(config Config) (*Ring, error)

+ func (r *Ring) AddListener(listenerId string, handler Handler)

+ func (r *Ring) GetNode(objKey string) (interface{}, bool)

+ func (r *Ring) RemoveListener(listenerId string)

+ func (r *Ring) Shutdown() error

v0.1.0

Aug 14, 2022

Changes in this version

+ type Config struct

+ BindAddr string

+ HashFunction HashFunction

+ NodeName string

+ RPCPort int

+ SeedAddresses []string

+ VirtualNodeCount int

+ func (c Config) RPCAddr() (string, error)

+ type ConsistentHashRouter struct

+ func NewConsistentHashRouter(hashFunction HashFunction) (*ConsistentHashRouter, error)

+ func (c *ConsistentHashRouter) Get(key string) (interface{}, bool)

+ func (c *ConsistentHashRouter) GetVirtualNodes(key string) ([]virtualNode, bool)

+ func (c *ConsistentHashRouter) Join(nodeKey string, vNodeCount int) error

+ func (c *ConsistentHashRouter) Leave(nodeKey string) error

+ type Handler interface

+ Join func(nodeKey string, vNodeCount int) error

+ Leave func(nodeKey string) error

+ type HandlerWrapper struct

+ func NewHandlerWrapper() *HandlerWrapper

+ func (h *HandlerWrapper) Join(rpcAddr string, vNodeCount int) error

+ func (h *HandlerWrapper) Leave(rpcAddr string) error

+ type HashFunction interface

+ type MD5HashFunction struct

+ type Member struct

+ func NewMember(config Config) (*Member, error)

+ func (m *Member) AddListener(listenerId string, handler Handler)

+ func (m *Member) RemoveListener(listenerId string)

+ func (m *Member) Shutdown() error

+ type Membership struct

+ func NewMemberShip(handler Handler, config MembershipConfig) (*Membership, error)

+ func (m *Membership) Leave() error

+ func (m *Membership) Members() []serf.Member

+ type MembershipConfig struct

+ BindAddr string

+ NodeName string

+ SeedAddresses []string

+ Tags map[string]string

+ type ParentNode struct

+ func (p *ParentNode) GetKey() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL