srvcadence

README

cadencesrv

Documentation

Index

• type Register
• type Worker
  • func NewWorker(ctx context.Context, opts ...WorkerOption) *Worker
  • func (w *Worker) Close(ctx context.Context) error
  • func (w *Worker) Listen(_ context.Context) error
  • func (w *Worker) Name() string
• type WorkerOption
  • func WithClientName(clientName string) WorkerOption
  • func WithDomain(domain string) WorkerOption
  • func WithHostPort(hostPort string) WorkerOption
  • func WithName(name string) WorkerOption
  • func WithOutboundKey(outboundKey string) WorkerOption
  • func WithRegister(register ...Register) WorkerOption
  • func WithTaskListName(taskListName string) WorkerOption

Types

type Register

type Register interface {
	Register(r worker.Registry)
}

type Worker

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

func NewWorker

func NewWorker(ctx context.Context, opts ...WorkerOption) *Worker

func (*Worker) Close

func (w *Worker) Close(ctx context.Context) error

func (*Worker) Listen

func (w *Worker) Listen(_ context.Context) error

func (*Worker) Name

func (w *Worker) Name() string

type WorkerOption

type WorkerOption func(o *workerOpts)

func WithClientName

func WithClientName(clientName string) WorkerOption

func WithDomain

func WithDomain(domain string) WorkerOption

func WithHostPort

func WithHostPort(hostPort string) WorkerOption

func WithName

func WithName(name string) WorkerOption

func WithOutboundKey

func WithOutboundKey(outboundKey string) WorkerOption

func WithRegister

func WithRegister(register ...Register) WorkerOption

func WithTaskListName

func WithTaskListName(taskListName string) WorkerOption