Documentation ¶
Index ¶
- Variables
- type SetArg
- type Task
- type TaskBoard
- type TaskHeader
- type TaskManager
- type TaskState
- 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
- type TaskWorker
- type TaskWorkerOption
- type WithArg
Constants ¶
This section is empty.
Variables ¶
View Source
var InvalidTaskState = errors.New("invalid TaskState type")
View Source
var TASK_STATE__PENDING = TASK_STATE_UNKNOWN
Functions ¶
This section is empty.
Types ¶
type TaskBoard ¶
type TaskBoard struct {
// contains filtered or unexported fields
}
func NewTaskBoard ¶
func NewTaskBoard(tm TaskManager) *TaskBoard
type TaskHeader ¶
func (*TaskHeader) SetSubject ¶
func (th *TaskHeader) SetSubject(s string)
func (*TaskHeader) Subject ¶
func (th *TaskHeader) Subject() string
type TaskManager ¶
type TaskState ¶
type TaskState uint8
func ParseTaskStateFromLabel ¶
func (TaskState) ConstValues ¶
func (v TaskState) ConstValues() []enum.IntStringerEnum
func (TaskState) MarshalText ¶
func (*TaskState) UnmarshalText ¶
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) Register ¶
func (w *TaskWorker) Register(router *kit.Router)
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
Source Files ¶
Click to show internal directories.
Click to hide internal directories.