watch

Documentation

Index

• Constants
• type TaskWorkerWatch
  • func NewTaskWorkerWatch(etcdClient *clientv3.Client, svc service.Service) (*TaskWorkerWatch, error)
  • func (t *TaskWorkerWatch) Close()
  • func (t *TaskWorkerWatch) Watch()

Constants

const SUBSCRIBE = "worker"

Types

type TaskWorkerWatch

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

func NewTaskWorkerWatch

func NewTaskWorkerWatch(etcdClient *clientv3.Client, svc service.Service) (*TaskWorkerWatch, error)

func (*TaskWorkerWatch) Close

func (t *TaskWorkerWatch) Close()

func (*TaskWorkerWatch) Watch

func (t *TaskWorkerWatch) Watch()