heartbeat

Documentation

Index

• Constants
• type Heartbeat
  • func NewSqsHeartbeat(client service.Sqs, queueUrl string, heartbeatInterval time.Duration, ...) (ctypes.HandleMessage[types.Message], Heartbeat)
• type HeartbeatFunc
• type SqsHeartbeat
  • func (h *SqsHeartbeat) ProcessHeartbeats(ctx context.Context)
  • func (h *SqsHeartbeat) SendHeatbeat(receiptHandle string)
  • func (h *SqsHeartbeat) Start(ctx context.Context) error
  • func (h *SqsHeartbeat) Stop(_ context.Context) error

Constants

const (
	HEARTBEAT_PID = "heartbeat"
)

Types

type Heartbeat

type Heartbeat interface {
	Start(context.Context) error
	Stop(context.Context) error
}

func NewSqsHeartbeat

func NewSqsHeartbeat(
	client service.Sqs,
	queueUrl string,
	heartbeatInterval time.Duration,
	visibilityTimeout int,
	bufferSize int,
	handler ctypes.HandleMessage[types.Message],
) (ctypes.HandleMessage[types.Message], Heartbeat)

type HeartbeatFunc

type HeartbeatFunc func(ctx context.Context, message any)

type SqsHeartbeat

type SqsHeartbeat struct {
	// contains filtered or unexported fields
}

func (*SqsHeartbeat) ProcessHeartbeats

func (h *SqsHeartbeat) ProcessHeartbeats(ctx context.Context)

func (*SqsHeartbeat) SendHeatbeat

func (h *SqsHeartbeat) SendHeatbeat(receiptHandle string)

func (*SqsHeartbeat) Start

func (h *SqsHeartbeat) Start(ctx context.Context) error

func (*SqsHeartbeat) Stop

func (h *SqsHeartbeat) Stop(_ context.Context) error