Versions in this module Expand all Collapse all v1 v1.0.1 Jul 27, 2024 Changes in this version + type DelayTask interface + CancelDelayTask func(key string) error + Close func() error + SetDelayTask func(key string, f func(), ttl int64) error + func NewEtcdDelayTask(cli *clientv3.Client, prefix string, opts ...Option) (DelayTask, error) + type ErrMsg string + const ClosedErr + func (e ErrMsg) Error() string + type Logger interface + Error func(format string, v ...interface{}) + Info func(format string, v ...interface{}) + type NewEtcdClientFunc func() (*clientv3.Client, error) + type Option func(*etcdDelayTask) + func WithEtcdHeartbeat(newFunc NewEtcdClientFunc) Option + func WithEtcdTimeout(timeout time.Duration) Option + func WithLogger() Option + func WithLoggerWrapper(log Logger) Option + func WithReConnectCallback(f func()) Option + func WithReConnectEtcdTimeout(timeout time.Duration) Option
Go to main page