heartbeater

package

v0.19.985 Latest Latest Go to latest Published: May 31, 2026 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(params Params) *Heartbeater

func (h *Heartbeater) Send(hb app.RunnerHeartBeat)

Send enqueues a heartbeat for batched writing to ClickHouse. The heartbeat must have ID, CreatedByID, and CreatedAt pre-populated.

type Params struct {
	fx.In

	CHDB *gorm.DB `name:"ch"`
	L    *zap.Logger
	MW   metrics.Writer
	LC   fx.Lifecycle
	Cfg  *internal.Config
}