tracker

Documentation

Index

• type CurrentState
  • func (cs *CurrentState) String() string
• type Options
• type Tracker
  • func New(opts *Options) *Tracker
  • func (t *Tracker) Track(ctx context.Context)
  • func (t *Tracker) WaitClose()

Types

type CurrentState

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

func (*CurrentState) String

func (cs *CurrentState) String() string

type Options

type Options struct {
	CheckInterval time.Duration
	ClientID      string
	Cmd           string
	DbDirectory   string
	Debug         bool
	DropCreate    bool
	Env           string
	IdleTolerance time.Duration
}

type Tracker

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

func New

func New(opts *Options) *Tracker

func (*Tracker) Track

func (t *Tracker) Track(ctx context.Context)

Track starts the idle/busy tracker in a loop that runs until the context is cancelled

func (*Tracker) WaitClose

func (t *Tracker) WaitClose()

WaitClose wait for the tracker loop to finish uncommitted work