driver

package
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	OptionTypeTimeout = 0x600
	OptionTypeLogger  = 0x601
)
View Source
const GlobalKeyPrefix = "distributed-cron:"

GlobalKeyPrefix is global redis key preifx

Variables

This section is empty.

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)
	Start(ctx context.Context) (err error)
	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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL