mq

Documentation

Index

• Variables
• type SetArg
• type Task
• type TaskBoard
  • func NewTaskBoard(tm TaskManager) *TaskBoard
  • func (b *TaskBoard) Dispatch(ch string, t Task) error
• type TaskHeader
  • func (th *TaskHeader) SetSubject(s string)
  • func (th *TaskHeader) Subject() string
• type TaskManager
• type TaskOperator
• type TaskState
  • func ParseTaskStateFromLabel(s string) (TaskState, error)
  • func ParseTaskStateFromString(s string) (TaskState, error)
  • func (v TaskState) ConstValues() []enum.IntStringerEnum
  • func (v TaskState) Int() int
  • func (v TaskState) Label() string
  • func (v TaskState) MarshalText() ([]byte, error)
  • func (v *TaskState) Scan(src interface{}) error
  • func (v *TaskState) SetState(s TaskState)
  • func (v TaskState) State() TaskState
  • func (v TaskState) String() string
  • func (v TaskState) TypeName() string
  • func (v *TaskState) UnmarshalText(data []byte) error
  • func (v TaskState) Value() (driver.Value, error)
• type TaskUUID
  • func (tid *TaskUUID) ID() string
  • func (tid *TaskUUID) SetID(id string)
• type TaskWorker
  • func NewTaskWorker(tm TaskManager, options ...TaskWorkerOption) *TaskWorker
  • func (w *TaskWorker) Context() context.Context
  • func (w *TaskWorker) LivenessCheck() map[string]string
  • func (w *TaskWorker) Register(router *kit.Router)
  • func (w *TaskWorker) Serve(router *kit.Router) error
  • func (w *TaskWorker) SetDefault()
  • func (w TaskWorker) WithContextInjector(with contextx.WithContext) *TaskWorker
• type TaskWorkerOption
  • func WithChannel(ch string) TaskWorkerOption
  • func WithFinishFunc(fn func(ctx context.Context, t Task)) TaskWorkerOption
  • func WithWorkerCount(cnt int) TaskWorkerOption
• type WithArg

Variables

var (
	ErrPushTaskTimeout = errors.New("push task to queue timeout")
)

var InvalidTaskState = errors.New("invalid TaskState type")

var TASK_STATE__PENDING = TASK_STATE_UNKNOWN

Types

type SetArg

type SetArg interface {
	SetArg(v interface{}) error
}

type Task

type Task interface {
	Subject() string
	ID() string
	State() TaskState
	SetState(TaskState)
}

type TaskBoard

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

func NewTaskBoard

func NewTaskBoard(tm TaskManager) *TaskBoard

func (*TaskBoard) Dispatch

func (b *TaskBoard) Dispatch(ch string, t Task) error

type TaskHeader

type TaskHeader struct {
	TaskUUID
	TaskState
	// contains filtered or unexported fields
}

func (*TaskHeader) SetSubject

func (th *TaskHeader) SetSubject(s string)

func (*TaskHeader) Subject

func (th *TaskHeader) Subject() string

type TaskManager

type TaskManager interface {
	Push(ch string, t Task) error
	Pop(ch string) (Task, error)
	Remove(ch string, id string) error
	Clear(ch string) error
}

type TaskOperator

type TaskOperator interface {
	Output(ctx context.Context) (interface{}, error)
	SetArg
}

type TaskState

type TaskState uint8

const (
	TASK_STATE_UNKNOWN TaskState = iota
	TASK_STATE__SUCCEEDED
	TASK_STATE__FAILED
)

func ParseTaskStateFromLabel

func ParseTaskStateFromLabel(s string) (TaskState, error)

func ParseTaskStateFromString

func ParseTaskStateFromString(s string) (TaskState, error)

func (TaskState) ConstValues

func (v TaskState) ConstValues() []enum.IntStringerEnum

func (TaskState) Int

func (v TaskState) Int() int

func (TaskState) Label

func (v TaskState) Label() string

func (TaskState) MarshalText

func (v TaskState) MarshalText() ([]byte, error)

func (*TaskState) Scan

func (v *TaskState) Scan(src interface{}) error

func (*TaskState) SetState

func (v *TaskState) SetState(s TaskState)

func (TaskState) State

func (v TaskState) State() TaskState

func (TaskState) String

func (v TaskState) String() string

func (TaskState) TypeName

func (v TaskState) TypeName() string

func (*TaskState) UnmarshalText

func (v *TaskState) UnmarshalText(data []byte) error

func (TaskState) Value

func (v TaskState) Value() (driver.Value, error)

type TaskUUID

type TaskUUID string

func (*TaskUUID) ID

func (tid *TaskUUID) ID() string

func (*TaskUUID) SetID

func (tid *TaskUUID) SetID(id string)

type TaskWorker

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

func NewTaskWorker

func NewTaskWorker(tm TaskManager, options ...TaskWorkerOption) *TaskWorker

func (*TaskWorker) Context

func (w *TaskWorker) Context() context.Context

func (*TaskWorker) LivenessCheck

func (w *TaskWorker) LivenessCheck() map[string]string

func (*TaskWorker) Register

func (w *TaskWorker) Register(router *kit.Router)

func (*TaskWorker) Serve

func (w *TaskWorker) Serve(router *kit.Router) error

func (*TaskWorker) SetDefault

func (w *TaskWorker) SetDefault()

func (TaskWorker) WithContextInjector

func (w TaskWorker) WithContextInjector(with contextx.WithContext) *TaskWorker

type TaskWorkerOption

type TaskWorkerOption func(*taskWorkerOption)

func WithChannel

func WithChannel(ch string) TaskWorkerOption

func WithFinishFunc

func WithFinishFunc(fn func(ctx context.Context, t Task)) TaskWorkerOption

func WithWorkerCount

func WithWorkerCount(cnt int) TaskWorkerOption

type WithArg

type WithArg interface {
	Arg() interface{}
}