heartbeatmanagement

Documentation

Index

• type HeartbeatContent
• type HeartbeatSender
  • func NewHeartbeatSender[T any](chamqpChannel *chamqp.Channel, heartbeatContentGatherer HeartbeatContent[T], ...) *HeartbeatSender[T]
  • func (h *HeartbeatSender[T]) StartSending()
  • func (h *HeartbeatSender[T]) StartSendingWithParams(durable, autodelete, internal, nowait bool)

Types

type HeartbeatContent

type HeartbeatContent[T any] interface {
	GetHeartbeatContent() T
}

type HeartbeatSender

type HeartbeatSender[T any] struct {
	// contains filtered or unexported fields
}

func NewHeartbeatSender

func NewHeartbeatSender[T any](chamqpChannel *chamqp.Channel, heartbeatContentGatherer HeartbeatContent[T], exchangeName, routingKey string) *HeartbeatSender[T]

func (*HeartbeatSender[T]) StartSending

func (h *HeartbeatSender[T]) StartSending()

func (*HeartbeatSender[T]) StartSendingWithParams

func (h *HeartbeatSender[T]) StartSendingWithParams(durable, autodelete, internal, nowait bool)