heartbeat

Documentation

Index

• type AliveUntilHeightQuery
• type CurrentHeightQuery
• type Heart
  • func New(i AliveUntilHeightQuery, j CurrentHeightQuery, k KeepAliveCall, ...) *Heart
  • func (m *Heart) Beat(ctx context.Context, locker sync.Locker) error
  • func (m *Heart) SetRetryFalloff(falloff time.Duration)
• type KeepAliveCall

Types

type AliveUntilHeightQuery

type AliveUntilHeightQuery func(context.Context) (int64, error)

type CurrentHeightQuery

type CurrentHeightQuery func(context.Context) (int64, error)

type Heart

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

func New

func New(i AliveUntilHeightQuery, j CurrentHeightQuery, k KeepAliveCall, keepAliveThreshold int64, appVersion string, locker sync.Locker) *Heart

func (*Heart) Beat

func (m *Heart) Beat(ctx context.Context, locker sync.Locker) error

func (*Heart) SetRetryFalloff

func (m *Heart) SetRetryFalloff(falloff time.Duration)

type KeepAliveCall

type KeepAliveCall func(context.Context, string) error