Versions in this module Expand all Collapse all v0 v0.5.0 Apr 6, 2023 Changes in this version + var ErrBrokenPipe = errors.New("broken low-level pipe") + var ErrBufferExceed = errors.New("session send buffer exceed") + var ErrCloseClosedSession = errors.New("close closed session") + var ErrInvalidRegisterReq = errors.New("invalid register request") + var ErrSessionOnNotify = errors.New("current session working on notify mode") + type CustomerRemoteServiceRoute func(service string, session *session.Session, members []*clusterpb.MemberInfo) *clusterpb.MemberInfo + type LocalHandler struct + func NewHandler(currentNode *Node, pipeline pipeline.Pipeline) *LocalHandler + func (h *LocalHandler) LocalService() []string + func (h *LocalHandler) RemoteService() []string + type Member struct + func (m *Member) MemberInfo() *clusterpb.MemberInfo + func (m *Member) String() string + type Node struct + RpcClient *rpcClient + 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) NewMember(_ context.Context, req *clusterpb.NewMemberRequest) (*clusterpb.NewMemberResponse, error) + func (n *Node) SessionClosed(_ context.Context, req *clusterpb.SessionClosedRequest) (*clusterpb.SessionClosedResponse, error) + func (n *Node) Shutdown() + func (n *Node) Startup() error + type Options struct + AdvertiseAddr string + ClientAddr string + Components *component.Components + IsMaster bool + IsWebsocket bool + Label string + Pipeline pipeline.Pipeline + RemoteServiceRoute CustomerRemoteServiceRoute + RetryInterval time.Duration + TSLCertificate string + TSLKey string + UnregisterCallback func(Member)