task

Documentation

Index

• Constants
• func CallbackWrapHandler(handler SubTask, callback CallbackFunc) storage.ConsumerFunc
• func Services() *tService
• func WrapHandler(handler SubTask) storage.ConsumerFunc
• type CallbackFunc
• type Handler
• type MemoryService
• type MemorySpec
• type MemoryTask
• type NsqService
• type NsqSpec
• type NsqTask
• type RabbitMqService
• type RabbitMqSpec
  • func (r *RabbitMqSpec) GetRoutingKeys() []string
  • func (r *RabbitMqSpec) Route(routingKey string) (handler SubTask, ifExist bool)
• type RabbitMqTask
• type RocketMqService
• type RocketMqSpec
  • func (r *RocketMqSpec) Route(routingKey string) (handler SubTask, ifExist bool)
• type RocketMqTask
• type Service
• type SubTask
• type TasksService

Constants

const (
	DefaultQueue = "default"
)

const (
	SrvName = "TaskService"
)

Functions

func CallbackWrapHandler

func CallbackWrapHandler(handler SubTask, callback CallbackFunc) storage.ConsumerFunc

func Services

func Services() *tService

func WrapHandler

func WrapHandler(handler SubTask) storage.ConsumerFunc

Types

type CallbackFunc

type CallbackFunc func(context.Context, interface{}) error

CallbackFunc 消费结果统一回调

type Handler

type Handler interface {
	Handle(ctx context.Context, msg storage.Messager) error
}

Handler 任务MQ路由的回调接口/**/

type MemoryService

type MemoryService interface {
	Service
	AddTasks(task ...MemoryTask) MemoryService
}

type MemorySpec

type MemorySpec struct {
	TaskName   string
	RoutingKey string
}

type MemoryTask

type MemoryTask interface {
	GetSpec() *MemorySpec
	Handler
}

type NsqService

type NsqService interface {
	Service
	AddTasks(task ...NsqTask) NsqService
}

type NsqSpec

type NsqSpec struct {
	TaskName     string
	RoutingKey   string
	Exchange     string
	ExchangeType string
	QueueName    string
	RoutingMap   map[string]SubTask
	ConsumerNum  int
	CTag         string
}

type NsqTask

type NsqTask interface {
	GetSpec(ctx context.Context) *NsqSpec
	Handler
}

type RabbitMqService

type RabbitMqService interface {
	Service
	AddTasks(task ...RabbitMqTask) RabbitMqService
}

type RabbitMqSpec

type RabbitMqSpec struct {
	TaskName     string
	Vhost        string
	RoutingKeys  []string
	RoutingKey   string
	Exchange     string
	ExchangeType string
	QueueName    string
	SubTasks     []SubTask
	ConsumerNum  int
	CoroutineNum int
	Prefetch     int
	AutoAck      bool
}

func (*RabbitMqSpec) GetRoutingKeys

func (r *RabbitMqSpec) GetRoutingKeys() []string

func (*RabbitMqSpec) Route

func (r *RabbitMqSpec) Route(routingKey string) (handler SubTask, ifExist bool)

type RabbitMqTask

type RabbitMqTask interface {
	GetSpec(ctx context.Context) *RabbitMqSpec
	Handler
}

type RocketMqService

type RocketMqService interface {
	Service
	AddTasks(task ...RocketMqTask) RocketMqService
}

type RocketMqSpec

type RocketMqSpec struct {
	TaskName          string
	GroupName         string
	TopicName         string
	SubTasks          []SubTask
	ConsumerNum       int
	MaxReconsumeTimes int32
	AutoCommit        bool
}

func (*RocketMqSpec) Route

func (r *RocketMqSpec) Route(routingKey string) (handler SubTask, ifExist bool)

type RocketMqTask

type RocketMqTask interface {
	GetSpec(ctx context.Context) *RocketMqSpec
	Handler
}

type Service

type Service interface {
	String() string
	Start(ctx context.Context)
}

type SubTask

type SubTask interface {
	RoutingKey() string
	Handle(ctx context.Context, msg storage.Messager) (interface{}, error)
}

type TasksService

type TasksService interface {
	Service
	AddServices(services ...Service) TasksService
}