driver

Documentation

Index

• Constants
• func GetKeyPre(serviceName string) string
• func GetNodeId(serviceName string) string
• func GetStableJobStore(serviceName string) string
• func GetStableJobStoreTxKey(serviceName string) string
• func TimePre(t time.Time, preDuration time.Duration) int64
• type DriverV2
  • func NewEtcdDriver(etcdCli *clientv3.Client) DriverV2
  • func NewRedisDriver(redisClient *redis.Client) DriverV2
  • func NewRedisZSetDriver(redisClient *redis.Client) DriverV2
• type EtcdDriver
  • func (e *EtcdDriver) GetNodes(ctx context.Context) (nodes []string, err error)
  • func (e *EtcdDriver) Init(serverName string, opts ...Option)
  • func (e *EtcdDriver) NodeID() string
  • func (e *EtcdDriver) Start(ctx context.Context) (err error)
  • func (e *EtcdDriver) Stop(ctx context.Context) (err error)
• type LoggerOption
  • func NewLoggerOption(logger dlog.Logger) LoggerOption
  • func (to LoggerOption) Type() int
• type Option
• type RedisDriver
  • func (rd *RedisDriver) GetNodes(ctx context.Context) (nodes []string, err error)
  • func (rd *RedisDriver) Init(serviceName string, opts ...Option)
  • func (rd *RedisDriver) NodeID() string
  • func (rd *RedisDriver) Start(ctx context.Context) (err error)
  • func (rd *RedisDriver) Stop(ctx context.Context) (err error)
• type RedisZSetDriver
  • func (rd *RedisZSetDriver) GetNodes(ctx context.Context) (nodes []string, err error)
  • func (rd *RedisZSetDriver) Init(serviceName string, opts ...Option)
  • func (rd *RedisZSetDriver) NodeID() string
  • func (rd *RedisZSetDriver) Start(ctx context.Context) (err error)
  • func (rd *RedisZSetDriver) Stop(ctx context.Context) (err error)
• type TimeoutOption
  • func NewTimeoutOption(timeout time.Duration) TimeoutOption
  • func (to TimeoutOption) Type() int

Constants

const (
	OptionTypeTimeout = 0x600
	OptionTypeLogger  = 0x601
)

const GlobalKeyPrefix = "distributed-cron:"

GlobalKeyPrefix is a global redis key prefix

Functions

func GetKeyPre

func GetKeyPre(serviceName string) string

func GetNodeId

func GetNodeId(serviceName string) string

func GetStableJobStore

func GetStableJobStore(serviceName string) string

func GetStableJobStoreTxKey

func GetStableJobStoreTxKey(serviceName string) string

func TimePre

func TimePre(t time.Time, preDuration time.Duration) int64

Types

type DriverV2

type DriverV2 interface {
	// init driver
	Init(serviceName string, opts ...Option)
	// get nodeID
	NodeID() string
	// get nodes
	GetNodes(ctx context.Context) (nodes []string, err error)

	// register node to remote server (like etcd/redis),
	// will create a goroutine to keep the connection.
	// And then continue for other work.
	Start(ctx context.Context) (err error)

	// stop the goroutine of keep connection.
	Stop(ctx context.Context) (err error)
	// contains filtered or unexported methods
}

There is only one driver for one dcron. Tips for write a user-defined Driver by yourself.

1. Confirm that `Stop` and `Start` can be called for more times.
2. Must make `GetNodes` will return error when timeout.

func NewEtcdDriver

func NewEtcdDriver(etcdCli *clientv3.Client) DriverV2

func NewRedisDriver

func NewRedisDriver(redisClient *redis.Client) DriverV2

func NewRedisZSetDriver

func NewRedisZSetDriver(redisClient *redis.Client) DriverV2

type EtcdDriver

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

func (*EtcdDriver) GetNodes

func (e *EtcdDriver) GetNodes(ctx context.Context) (nodes []string, err error)

func (*EtcdDriver) Init

func (e *EtcdDriver) Init(serverName string, opts ...Option)

func (*EtcdDriver) NodeID

func (e *EtcdDriver) NodeID() string

func (*EtcdDriver) Start

func (e *EtcdDriver) Start(ctx context.Context) (err error)

func (*EtcdDriver) Stop

func (e *EtcdDriver) Stop(ctx context.Context) (err error)

type LoggerOption

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

func NewLoggerOption

func NewLoggerOption(logger dlog.Logger) LoggerOption

func (LoggerOption) Type

func (to LoggerOption) Type() int

type Option

type Option interface {
	Type() int
}

type RedisDriver

type RedisDriver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*RedisDriver) GetNodes

func (rd *RedisDriver) GetNodes(ctx context.Context) (nodes []string, err error)

func (*RedisDriver) Init

func (rd *RedisDriver) Init(serviceName string, opts ...Option)

func (*RedisDriver) NodeID

func (rd *RedisDriver) NodeID() string

func (*RedisDriver) Start

func (rd *RedisDriver) Start(ctx context.Context) (err error)

func (*RedisDriver) Stop

func (rd *RedisDriver) Stop(ctx context.Context) (err error)

type RedisZSetDriver

type RedisZSetDriver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*RedisZSetDriver) GetNodes

func (rd *RedisZSetDriver) GetNodes(ctx context.Context) (nodes []string, err error)

func (*RedisZSetDriver) Init

func (rd *RedisZSetDriver) Init(serviceName string, opts ...Option)

func (*RedisZSetDriver) NodeID

func (rd *RedisZSetDriver) NodeID() string

func (*RedisZSetDriver) Start

func (rd *RedisZSetDriver) Start(ctx context.Context) (err error)

func (*RedisZSetDriver) Stop

func (rd *RedisZSetDriver) Stop(ctx context.Context) (err error)

type TimeoutOption

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

func NewTimeoutOption

func NewTimeoutOption(timeout time.Duration) TimeoutOption

func (TimeoutOption) Type

func (to TimeoutOption) Type() int