cluster

Jan 30, 2019

Changes in this version

+ func GetUserKickTopic(uid string, svType string) string

+ type ConfigInfoRetriever struct

+ func NewConfigInfoRetriever(c *config.Config) *ConfigInfoRetriever

+ func (c *ConfigInfoRetriever) Region() string

type GRPCClient

+ func (gs *GRPCClient) SendKick(userID string, serverType string, kick *protos.KickMsg) error

+ type InfoRetriever interface

+ Region func() string

type NatsRPCClient

+ func (ns *NatsRPCClient) SendKick(userID string, serverType string, kick *protos.KickMsg) error

type RPCClient

+ SendKick func(userID string, serverType string, kick *protos.KickMsg) error

type Server

+ Hostname string

type ServiceDiscovery

+ GetServers func() []*Server

Jul 31, 2018

Changes in this version

+ func GetBindBroadcastTopic(svType string) string

+ func GetUserMessagesTopic(uid string, svType string) string

+ type Action int

+ const ADD

+ const DEL

+ type GRPCClient struct

+ func NewGRPCClient(config *config.Config, server *Server, metricsReporters []metrics.Reporter, ...) (*GRPCClient, error)

+ func (gs *GRPCClient) AddServer(sv *Server)

+ func (gs *GRPCClient) AfterInit()

+ func (gs *GRPCClient) BeforeShutdown()

+ func (gs *GRPCClient) BroadcastSessionBind(uid string) error

+ func (gs *GRPCClient) Call(ctx context.Context, rpcType protos.RPCType, route *route.Route, ...) (*protos.Response, error)

+ func (gs *GRPCClient) Init() error

+ func (gs *GRPCClient) RemoveServer(sv *Server)

+ func (gs *GRPCClient) Send(uid string, d []byte) error

+ func (gs *GRPCClient) SendPush(userID string, frontendSv *Server, push *protos.Push) error

+ func (gs *GRPCClient) Shutdown() error

+ type GRPCServer struct

+ func NewGRPCServer(config *config.Config, server *Server, metricsReporters []metrics.Reporter) (*GRPCServer, error)

+ func (gs *GRPCServer) AfterInit()

+ func (gs *GRPCServer) BeforeShutdown()

+ func (gs *GRPCServer) Init() error

+ func (gs *GRPCServer) SetPitayaServer(ps protos.PitayaServer)

+ func (gs *GRPCServer) Shutdown() error

+ type NatsRPCClient struct

+ func NewNatsRPCClient(config *config.Config, server *Server, metricsReporters []metrics.Reporter, ...) (*NatsRPCClient, error)

+ func (ns *NatsRPCClient) AfterInit()

+ func (ns *NatsRPCClient) BeforeShutdown()

+ func (ns *NatsRPCClient) BroadcastSessionBind(uid string) error

+ func (ns *NatsRPCClient) Call(ctx context.Context, rpcType protos.RPCType, route *route.Route, ...) (*protos.Response, error)

+ func (ns *NatsRPCClient) Init() error

+ func (ns *NatsRPCClient) Send(topic string, data []byte) error

+ func (ns *NatsRPCClient) SendPush(userID string, frontendSv *Server, push *protos.Push) error

+ func (ns *NatsRPCClient) Shutdown() error

+ type NatsRPCServer struct

+ func NewNatsRPCServer(config *config.Config, server *Server, metricsReporters []metrics.Reporter, ...) (*NatsRPCServer, error)

+ func (ns *NatsRPCServer) AfterInit()

+ func (ns *NatsRPCServer) BeforeShutdown()

+ func (ns *NatsRPCServer) GetBindingsChannel() chan *nats.Msg

+ func (ns *NatsRPCServer) GetUnhandledRequestsChannel() chan *protos.Request

+ func (ns *NatsRPCServer) Init() error

+ func (ns *NatsRPCServer) SetPitayaServer(ps protos.PitayaServer)

+ func (ns *NatsRPCServer) Shutdown() error

+ type RPCClient interface

+ BroadcastSessionBind func(uid string) error

+ Call func(ctx context.Context, rpcType protos.RPCType, route *route.Route, ...) (*protos.Response, error)

+ Send func(route string, data []byte) error

+ SendPush func(userID string, frontendSv *Server, push *protos.Push) error

+ type RPCServer interface

+ SetPitayaServer func(protos.PitayaServer)

+ type RemoteBindingListener interface

+ OnUserBind func(uid, fid string)

+ type SDListener interface

+ AddServer func(*Server)

+ RemoveServer func(*Server)

+ type Server struct

+ Frontend bool

+ ID string

+ Metadata map[string]string

+ Type string

+ func NewServer(id, serverType string, frontend bool, metadata ...map[string]string) *Server

+ func (s *Server) AsJSONString() string

+ type ServiceDiscovery interface

+ AddListener func(listener SDListener)

+ GetServer func(id string) (*Server, error)

+ GetServersByType func(serverType string) (map[string]*Server, error)

+ SyncServers func() error

+ func NewEtcdServiceDiscovery(config *config.Config, server *Server, cli ...*clientv3.Client) (ServiceDiscovery, error)