consul

Documentation

Index

• type Worker
  • func NewConsul(consulURL, consulToken, key string, sessionTimeout time.Duration) (*Worker, error)
  • func (w *Worker) AcquireLock() error
  • func (w *Worker) GetSnapshot() (string, error)
  • func (w *Worker) ReleaseLock() error
  • func (w *Worker) RenewSession(doneChan <-chan struct{}) error

Types

type Worker

type Worker struct {
	SessionID string
	// contains filtered or unexported fields
}

func NewConsul

func NewConsul(consulURL, consulToken, key string, sessionTimeout time.Duration) (*Worker, error)

func (*Worker) AcquireLock

func (w *Worker) AcquireLock() error

func (*Worker) GetSnapshot

func (w *Worker) GetSnapshot() (string, error)

func (*Worker) ReleaseLock

func (w *Worker) ReleaseLock() error

func (*Worker) RenewSession

func (w *Worker) RenewSession(doneChan <-chan struct{}) error