hb

Documentation

Index

• type T
  • func New(_ context.Context, opts ...funcopt.O) *T
  • func (t *T) Start(ctx context.Context) error
  • func (t *T) Stop() error

Types

type T

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

func New

func New(_ context.Context, opts ...funcopt.O) *T

func (*T) Start

func (t *T) Start(ctx context.Context) error

Start startup the heartbeat components

It starts: with ctx:

• the hb controller to maintain heartbeat status and peers It is firstly started and lastly stopped
• hb drivers

with cancelable context - the dispatcher of messages to send to hb tx components - the dispatcher of read messages from hb rx components to daemon data - the goroutine responsible for hb drivers lifecycle

func (*T) Stop

func (t *T) Stop() error