heartfelt

Mar 18, 2022

Changes in this version

type Event

+ Extra interface{}

Mar 13, 2022

Changes in this version

+ type DynamicTimeoutHeartHub interface

+ DisposableHeartbeatWithTimeout func(key string, timeout time.Duration) error

+ HeartbeatWithTimeout func(key string, timeout time.Duration) error

+ func NewDynamicTimeoutHeartHub(options ...heartHubOption) DynamicTimeoutHeartHub

Mar 13, 2022

Changes in this version

+ const EventRemoveKey

+ var ErrDynamicNotSupported error = errors.New("heartbeat: this HeartHub has been closed")

+ var ErrNoDefaultTimeout error = errors.New("heartbeat: this HeartHub has been closed")

+ func WithDefaultTimeoutOption(timeout time.Duration) heartHubOption

+ type DynamicTimeoutHearthub interface

+ DisposableHeartbeatWithTimeout func(key string, timeout time.Duration) error

+ HeartbeatWithTimeout func(key string, timeout time.Duration) error

+ func NewDynamicTimeoutHearthub(options ...heartHubOption) DynamicTimeoutHearthub

type Event

+ Timeout time.Duration

+ TimeoutTime time.Time

type HeartHub

+ func NewFixedTimeoutHeartHub(timeout time.Duration, options ...heartHubOption) HeartHub

+ DisposableHeartbeat func(key string) error

Mar 8, 2022

Changes in this version

+ const EventHeartBeat

+ const EventTimeout

+ var ErrHubClosed error = errors.New("heartbeat: this HeartHub has been closed")

+ func WithDegreeOfParallelismOption(degree int) heartHubOption

+ func WithEventBufferSizeOption(bufferSize int) heartHubOption

+ func WithHeartbeatBufferSizeOption(bufferSize int) heartHubOption

+ func WithLoggerOption(logger Logger) heartHubOption

+ func WithSubscribeEventNamesOption(eventNames ...string) heartHubOption

+ func WithTimeoutOption(timeout time.Duration) heartHubOption

+ func WithVerboseInfoOption() heartHubOption

+ type Event struct

+ BeatTime time.Time

+ Disposable bool

+ EventName string

+ EventTime time.Time

+ HeartKey string

+ JoinTime time.Time

+ type HeartHub struct

+ func NewHeartHub(options ...heartHubOption) *HeartHub

+ func (hub *HeartHub) Close()

+ func (hub *HeartHub) GetEventChannel() <-chan *Event

+ func (hub *HeartHub) Heartbeat(key string, disposable bool) error

+ func (hub *HeartHub) Remove(key string) error

+ type Logger interface

+ Error func(v ...interface{})

+ Info func(v ...interface{})