redisprovisioner

Documentation

Index

• type Options
• type Provisioner
  • func New(opt *Options) (*Provisioner, error)
  • func (p *Provisioner) Check(shardID string) (string, error)
  • func (p *Provisioner) Heartbeat(shardID string) error
  • func (p *Provisioner) Release(shardID string) error
  • func (p *Provisioner) TTL() time.Duration
  • func (p *Provisioner) TryAcquire(shardID string) error

Types

type Options

type Options struct {
	TTL         time.Duration
	Lock        string
	RedisPool   *redis.Pool
	RedisPrefix string
}

type Provisioner

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

func New

func New(opt *Options) (*Provisioner, error)

func (*Provisioner) Check

func (p *Provisioner) Check(shardID string) (string, error)

func (*Provisioner) Heartbeat

func (p *Provisioner) Heartbeat(shardID string) error

func (*Provisioner) Release

func (p *Provisioner) Release(shardID string) error

func (*Provisioner) TTL

func (p *Provisioner) TTL() time.Duration

func (*Provisioner) TryAcquire

func (p *Provisioner) TryAcquire(shardID string) error