worker

Documentation

Index

• type ConnectionConfig
• type Worker
  • func NewWorker(cfg *config.WorkerConfig) (*Worker, error)
  • func (w *Worker) Name() string
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error

Types

type ConnectionConfig

type ConnectionConfig struct {
	Endpoint string `json:"endpoint"`
	Group    string `json:"group"`
}

type Worker

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

func NewWorker

func NewWorker(cfg *config.WorkerConfig) (*Worker, error)

func (*Worker) Name

func (w *Worker) Name() string

func (*Worker) Start

func (w *Worker) Start() error

func (*Worker) Stop

func (w *Worker) Stop() error