daemonctx

func HBRecvMsgQ ¶

func HBRecvMsgQ(ctx context.Context) (hbRecvQ chan<- *hbtype.Msg)

HBRecvMsgQ function returns HBRecvMsgQ from context hb component send the hbrx decoded message from peers on this queue

func ListenAddr ¶

func ListenAddr(ctx context.Context) string

ListenAddr function returns uuid from context

func ListenRateLimiterConfig ¶

func ListenRateLimiterConfig(ctx context.Context) cluster.RateLimiterConfig

func LsnrType ¶

func LsnrType(ctx context.Context) string

LsnrType function returns listener family from context

func UUID ¶

func UUID(ctx context.Context) uuid.UUID

UUID function returns uuid from context

func WithHBRecvMsgQ ¶

func WithHBRecvMsgQ(parent context.Context, hbRecvQ chan<- *hbtype.Msg) context.Context

WithHBRecvMsgQ function returns copy of parent with HBRecvMsgQ the queue used by daemondata to retrieve hb rx decoded messages

func WithListenAddr ¶

func WithListenAddr(parent context.Context, addr string) context.Context

WithListenAddr function returns copy of parent with listener addr.

func WithListenRateLimiterConfig ¶

func WithListenRateLimiterConfig(ctx context.Context, rate rate.Limit, burst int, exp time.Duration) context.Context

WithListenRateLimiterConfig adds a rate limiter configuration to the given context with a specified rate, burst, and expires duration.

func WithLsnrType ¶

func WithLsnrType(parent context.Context, s string) context.Context

WithLsnrType function returns copy of parent with listener family.

func WithUUID ¶

func WithUUID(parent context.Context, uuid uuid.UUID) context.Context

WithUUID function returns copy of parent with uuid.