worker

Documentation

Index

• type Worker
  • func New(zkClient *zookeeper.ZookeeperClient, id string) *Worker
  • func (w *Worker) Run() error
  • func (w *Worker) Stop()

Types

type Worker

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

func New

func New(zkClient *zookeeper.ZookeeperClient, id string) *Worker

func (*Worker) Run

func (w *Worker) Run() error

Run creates ephemeral node in zk for the worker and invokes control

func (*Worker) Stop

func (w *Worker) Stop()

Stop to gracefully shut down the worker