heartbeat

Oct 7, 2024

Changes in this version

+ const HeartbeatMessageType

type HeartbeatServer

+ func (h *HeartbeatServer) HandleMessage(ctx context.Context, message *ncl.Message) error

+ func (h *HeartbeatServer) ShouldProcess(ctx context.Context, message *ncl.Message) bool

type HeartbeatServerParams

+ NodeID string

Jun 24, 2024

Changes in this version

+ type Client interface

+ Close func(ctx context.Context) error

+ SendHeartbeat func(ctx context.Context, sequence uint64) error

May 23, 2024

Changes in this version

+ type Heartbeat struct

+ NodeID string

+ Sequence uint64

+ type HeartbeatClient struct

+ func NewClient(conn *nats.Conn, nodeID string, topic string) (*HeartbeatClient, error)

+ func (h *HeartbeatClient) Close(ctx context.Context) error

+ func (h *HeartbeatClient) Publish(ctx context.Context, message Heartbeat) error

+ func (h *HeartbeatClient) SendHeartbeat(ctx context.Context, sequence uint64) error

+ type HeartbeatServer struct

+ func NewServer(params HeartbeatServerParams) (*HeartbeatServer, error)

+ func (h *HeartbeatServer) CheckQueue(ctx context.Context)

+ func (h *HeartbeatServer) FilterNodeInfos(nodeInfos []*models.NodeInfo, state models.NodeConnectionState) []*models.NodeInfo

+ func (h *HeartbeatServer) Handle(ctx context.Context, message Heartbeat) error

+ func (h *HeartbeatServer) RemoveNode(nodeID string)

+ func (h *HeartbeatServer) Start(ctx context.Context) error

+ func (h *HeartbeatServer) UpdateNodeInfo(state *models.NodeState)

+ type HeartbeatServerParams struct

+ CheckFrequency time.Duration

+ Client *nats.Conn

+ Clock clock.Clock

+ NodeDisconnectedAfter time.Duration

+ Topic string

+ type TimestampedHeartbeat struct

+ Timestamp int64