job

Documentation

Index

• func Dispatch(ctx context.Context, t mq.Task)
• type EventLogCleanupTask
  • func (t *EventLogCleanupTask) Arg() interface{}
  • func (t *EventLogCleanupTask) Handle(ctx context.Context) error
  • func (t *EventLogCleanupTask) Subject() string
• type EventLogTask
  • func NewEventLogTask(m *models.EventLog) *EventLogTask
  • func (t *EventLogTask) Arg() interface{}
  • func (t *EventLogTask) Handle(ctx context.Context) error
  • func (t *EventLogTask) Subject() string
• type WasmLogTask
  • func NewWasmLogTask(ctx context.Context, logLevel, logSrc, msg string) *WasmLogTask
  • func (t *WasmLogTask) Arg() interface{}
  • func (t *WasmLogTask) ID() string
  • func (t *WasmLogTask) Subject() string

Functions

func Dispatch

func Dispatch(ctx context.Context, t mq.Task)

Types

type EventLogCleanupTask

type EventLogCleanupTask struct{}

func (*EventLogCleanupTask) Arg

func (t *EventLogCleanupTask) Arg() interface{}

func (*EventLogCleanupTask) Handle

func (t *EventLogCleanupTask) Handle(ctx context.Context) error

func (*EventLogCleanupTask) Subject

func (t *EventLogCleanupTask) Subject() string

type EventLogTask

type EventLogTask struct {
	*models.EventLog
	mq.TaskState
	mq.TaskUUID
}

func NewEventLogTask

func NewEventLogTask(m *models.EventLog) *EventLogTask

func (*EventLogTask) Arg

func (t *EventLogTask) Arg() interface{}

func (*EventLogTask) Handle

func (t *EventLogTask) Handle(ctx context.Context) error

func (*EventLogTask) Subject

func (t *EventLogTask) Subject() string

type WasmLogTask

type WasmLogTask struct {
	mq.TaskState
	// contains filtered or unexported fields
}

func NewWasmLogTask

func NewWasmLogTask(ctx context.Context, logLevel, logSrc, msg string) *WasmLogTask

func (*WasmLogTask) Arg

func (t *WasmLogTask) Arg() interface{}

func (*WasmLogTask) ID

func (t *WasmLogTask) ID() string

func (*WasmLogTask) Subject

func (t *WasmLogTask) Subject() string