task

Documentation

Index

• Constants
• func CallbackWrapHandler(handler SubHandler, callback CallbackFunc) storage.ConsumerFunc
• func Services() *tService
• func WrapHandler(handler SubHandler) 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 SubHandler, ifExist bool)
• type RabbitMqTask
• type RocketMqService
• type RocketMqSpec
• type RocketMqTask
• type Service
• type SubHandler

Constants

const (
	SrvName = "TaskService"
)

Functions

func CallbackWrapHandler

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

func Services

func Services() *tService

func WrapHandler

func WrapHandler(handler SubHandler) 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]SubHandler
	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
	RoutingKeys  []string
	RoutingKey   string
	Exchange     string
	ExchangeType string
	QueueName    string
	RoutingMap   map[string]SubHandler
	ConsumerNum  int
	AutoAck      bool
}

func (*RabbitMqSpec) GetRoutingKeys

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

func (*RabbitMqSpec) Route

func (r *RabbitMqSpec) Route(routingKey string) (handler SubHandler, 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
	RoutingKey   string
	Exchange     string
	ExchangeType string
	QueueName    string
	RoutingMap   map[string]SubHandler
	ConsumerNum  int
	AutoAck      bool
}

type RocketMqTask

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

type Service

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

type SubHandler

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