locker

Documentation

Index

• Variables
• type Locker
• type RedisLocker
  • func New(client *redis.Client, retryInterval time.Duration) *RedisLocker
  • func (m *RedisLocker) GetHostRunning(taskName string) (string, error)
  • func (m *RedisLocker) IsRunning(taskName string) (bool, error)
  • func (m *RedisLocker) NotifyRunning(taskName string) error
  • func (m *RedisLocker) NotifyStoppedRunning(taskName string) error
  • func (m *RedisLocker) RunWhenReady(ctx context.Context, taskName string, task func(context.Context)) error

Variables

var (
	ErrAlreadyRunning = errors.New("Task already running")
)

Types

type Locker

type Locker interface {
	IsRunning(taskName string) (bool, error)
	GetHostRunning(taskName string) (string, error)
	NotifyRunning(taskName string) error
	NotifyStoppedRunning(taskName string) error
	RunWhenReady(ctx context.Context, taskName string, task func(context.Context)) error
}

type RedisLocker

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

func New

func New(client *redis.Client, retryInterval time.Duration) *RedisLocker

func (*RedisLocker) GetHostRunning

func (m *RedisLocker) GetHostRunning(taskName string) (string, error)

func (*RedisLocker) IsRunning

func (m *RedisLocker) IsRunning(taskName string) (bool, error)

func (*RedisLocker) NotifyRunning

func (m *RedisLocker) NotifyRunning(taskName string) error

func (*RedisLocker) NotifyStoppedRunning

func (m *RedisLocker) NotifyStoppedRunning(taskName string) error

func (*RedisLocker) RunWhenReady

func (m *RedisLocker) RunWhenReady(ctx context.Context, taskName string, task func(context.Context)) error