heartbeat

Documentation

Index

• type Heartbeater
• type HeartbeaterImpl
  • func New(fs ...HeartbeaterOpt) (*HeartbeaterImpl, error)
  • func (t *HeartbeaterImpl) Start() (func() error, error)
• type HeartbeaterOpt
  • func WithLogger(l *zerolog.Logger) HeartbeaterOpt
  • func WithRepository(r repository.Repository) HeartbeaterOpt
  • func WithTaskQueue(tq taskqueue.TaskQueue) HeartbeaterOpt
• type HeartbeaterOpts

Types

type Heartbeater

type Heartbeater interface {
	Start(ctx context.Context) error
}

type HeartbeaterImpl

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

func New

func New(fs ...HeartbeaterOpt) (*HeartbeaterImpl, error)

func (*HeartbeaterImpl) Start

func (t *HeartbeaterImpl) Start() (func() error, error)

type HeartbeaterOpt

type HeartbeaterOpt func(*HeartbeaterOpts)

func WithLogger

func WithLogger(l *zerolog.Logger) HeartbeaterOpt

func WithRepository

func WithRepository(r repository.Repository) HeartbeaterOpt

func WithTaskQueue

func WithTaskQueue(tq taskqueue.TaskQueue) HeartbeaterOpt

type HeartbeaterOpts

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