Versions in this module Expand all Collapse all v0 v0.5.0 Jan 17, 2021 Changes in this version + var ErrBrokenPipe = errors.New("broken low-level pipe") + var ErrBufferExceeded = errors.New("session send buffer exceed") + var ErrCloseClosedSession = errors.New("close closed session") + var ErrInvalidRegisterReq = errors.New("invalid register request") + var ErrInvalidRoute = errors.New("invalid route") + var ErrMemberNotRegistered = errors.New("member is not registered") + var ErrRPC = errors.New("broken rpc") + var ErrSessionOnNotify = errors.New("current session working on notify mode") + type CompInfo struct + HandlerType string + IsRawArg bool + Name string + ReceiverType string + Scheduler string + type LocalHandler struct + func NewHandler(currentNode *Node, pipeline pipeline.Pipeline) *LocalHandler + func (h *LocalHandler) Components() []CompInfo + func (h *LocalHandler) LocalService() []string + func (h *LocalHandler) RemoteService() []string + func (h *LocalHandler) Remotes() []RemoteInfo + type Member struct + IsMaster bool + type Node struct + ServiceAddr string + func (n *Node) CloseSession(_ context.Context, req *clusterpb.CloseSessionRequest) (*clusterpb.CloseSessionResponse, error) + func (n *Node) DelMember(_ context.Context, req *clusterpb.DelMemberRequest) (*clusterpb.DelMemberResponse, error) + func (n *Node) HandleNotify(_ context.Context, req *clusterpb.NotifyMessage) (*clusterpb.MemberHandleResponse, error) + func (n *Node) HandlePush(_ context.Context, req *clusterpb.PushMessage) (*clusterpb.MemberHandleResponse, error) + func (n *Node) HandleRequest(_ context.Context, req *clusterpb.RequestMessage) (*clusterpb.MemberHandleResponse, error) + func (n *Node) HandleResponse(_ context.Context, req *clusterpb.ResponseMessage) (*clusterpb.MemberHandleResponse, error) + func (n *Node) Handler() *LocalHandler + func (n *Node) Members() []*Member + func (n *Node) NewMember(_ context.Context, req *clusterpb.NewMemberRequest) (*clusterpb.NewMemberResponse, error) + func (n *Node) SessionClosed(_ context.Context, req *clusterpb.SessionClosedRequest) (*clusterpb.SessionClosedResponse, error) + func (n *Node) Sessions() []*session.Session + func (n *Node) Shutdown() + func (n *Node) Startup() error + func (n *Node) Type() string + type Options struct + Components *component.Components + GateAddr string + IsMaster bool + Label string + MonitorAddr string + Pipeline pipeline.Pipeline + RegisterInterval time.Duration + RegistryAddr string + func NewOptions() Options + type RemoteInfo struct + Name string + type WebsocketOptions struct + CheckOrigin func(*http.Request) bool + IsWebsocket bool + ServeMux *http.ServeMux + TSLCertificate string + TSLKey string + WSPath string