task

Documentation

Index

• Constants
• type Agent
  • func (a *Agent) DockerDefaults() conf.DockerDefaults
  • func (a *Agent) Init()
  • func (Agent) MarshalDefaults(v interface{})
  • func (a *Agent) Publish(channel string, subject string, data []byte) (*constants.Task, error)
  • func (a *Agent) Register(subject string, processor constants.TaskProcessor)
  • func (a *Agent) RegisterRoutes(routes ...*courier.Route)
  • func (a *Agent) SendTask(task *constants.Task) error
  • func (a *Agent) Start(numWorker int)
  • func (a *Agent) Stop()
• type Backend
  • func NewBackend(agent *Agent) *Backend
  • func (b *Backend) Feedback(f *constants.TaskFeedback) error
• type Consumer
• type CronDescriber
• type Producer
• type Worker
  • func NewWorker(brokerType constants.BrokerType, connInfo constants.ConnectionInfo) *Worker
  • func (mq *Worker) Start(channel string, processor constants.TaskProcessor)
  • func (mq *Worker) Stop()

Constants

const (
	DefaultCentralChannel  = "service-task-manager.dev"
	DefaultCentralSubject  = "CreateOrUpdateCronTable"
	DefaultFeedbackSubject = "TaskStatusFeedback"
)

Types

type Agent

type Agent struct {
	ConnectionInfo constants.ConnectionInfo
	Channel        string
	BrokerType     constants.BrokerType `conf:"env"`

	CentralChannel string `conf:"env"`
	CentralSubject string `conf:"env"`
	// contains filtered or unexported fields
}

func (*Agent) DockerDefaults

func (a *Agent) DockerDefaults() conf.DockerDefaults

func (*Agent) Init

func (a *Agent) Init()

func (Agent) MarshalDefaults

func (Agent) MarshalDefaults(v interface{})

func (*Agent) Publish

func (a *Agent) Publish(channel string, subject string, data []byte) (*constants.Task, error)

func (*Agent) Register

func (a *Agent) Register(subject string, processor constants.TaskProcessor)

func (*Agent) RegisterRoutes

func (a *Agent) RegisterRoutes(routes ...*courier.Route)

func (*Agent) SendTask

func (a *Agent) SendTask(task *constants.Task) error

func (*Agent) Start

func (a *Agent) Start(numWorker int)

func (*Agent) Stop

func (a *Agent) Stop()

type Backend

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

func NewBackend

func NewBackend(agent *Agent) *Backend

func (*Backend) Feedback

func (b *Backend) Feedback(f *constants.TaskFeedback) error

type Consumer

type Consumer interface {
	RegisterChannel(channel string, processor constants.TaskProcessor) error
	Work()
	Stop()
}

type CronDescriber

type CronDescriber interface {
	CronSpec() string
}

type Producer

type Producer interface {
	SendTask(task *constants.Task) error
	Stop()
}

type Worker

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

func NewWorker

func NewWorker(brokerType constants.BrokerType, connInfo constants.ConnectionInfo) *Worker

func (*Worker) Start

func (mq *Worker) Start(channel string, processor constants.TaskProcessor)

func (*Worker) Stop

func (mq *Worker) Stop()