go_interval

README

go-interval

Go Job Interval With Distributed Lock

Redis as distributed lock

Documentation

Index

• type GoInterval
  • func (t *GoInterval) Run(ctx context.Context) error
• type Locker
  • func (s *Locker) Lock(ctx context.Context, key string) (success bool, err error)
  • func (s *Locker) Unlock(ctx context.Context, key string) error

Types

type GoInterval

type GoInterval struct {
	Name     string
	Arg      func()
	Interval time.Duration

	RedisConnector *redis.Client
	// contains filtered or unexported fields
}

func (*GoInterval) Run

func (t *GoInterval) Run(ctx context.Context) error

type Locker

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

func (*Locker) Lock

func (s *Locker) Lock(ctx context.Context, key string) (success bool, err error)

func (*Locker) Unlock

func (s *Locker) Unlock(ctx context.Context, key string) error