dsvc

Dec 21, 2024

Changes in this version

+ var Install = self.Install

+ var Name = self.Name

+ var Uninstall = self.Uninstall

+ var Using = self.Using

+ var With _Option

+ type DistServiceOptions struct

+ DecoderMsgCreator gap.IMsgCreator

+ DomainRoot string

+ FutureTimeout time.Duration

+ Meta map[string]string

+ RecvMsgHandler RecvMsgHandler

+ RefreshTTL bool

+ TTL time.Duration

+ Version string

+ type IDistService interface

+ ForwardMsg func(svc, src, dst string, seq int64, msg gap.Msg) error

+ GetFutures func() *concurrent.Futures

+ GetNodeDetails func() *NodeDetails

+ SendMsg func(dst string, msg gap.Msg) error

+ WatchMsg func(ctx context.Context, handler RecvMsgHandler) IWatcher

+ type IWatcher interface

+ Terminate func() <-chan struct{}

+ Terminated func() <-chan struct{}

+ type NodeDetails struct

+ BalanceAddr string

+ BroadcastAddr string

+ GlobalBalanceAddr string

+ GlobalBroadcastAddr string

+ LocalAddr string

+ func (d *NodeDetails) MakeBalanceAddr(service string) string

+ func (d *NodeDetails) MakeBroadcastAddr(service string) string

+ func (d *NodeDetails) MakeNodeAddr(nodeId uid.Id) (string, error)

+ type RecvMsgHandler = generic.Delegate2[string, gap.MsgPacket, error]