tasks

Documentation

Index

• Variables
• type DbLogStoring
  • func (t *DbLogStoring) Output(ctx context.Context) (interface{}, error)
  • func (t *DbLogStoring) SetArg(v interface{}) error
• type DbLogger
• type EventLog
  • func (t *EventLog) Output(ctx context.Context) (interface{}, error)
  • func (t *EventLog) SetArg(v interface{}) error
• type EventLogCleanup
  • func (t *EventLogCleanup) Output(ctx context.Context) (interface{}, error)
  • func (t *EventLogCleanup) SetArg(v interface{}) error
• type HandleEvent
  • func (t *HandleEvent) Output(ctx context.Context) (interface{}, error)
  • func (t *HandleEvent) SetArg(v interface{}) error

Variables

var Root = kit.NewRouter()

Types

type DbLogStoring

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

func (*DbLogStoring) Output

func (t *DbLogStoring) Output(ctx context.Context) (interface{}, error)

func (*DbLogStoring) SetArg

func (t *DbLogStoring) SetArg(v interface{}) error

type DbLogger

type DbLogger interface {
	Create(sqlx.DBExecutor) error
}

type EventLog

type EventLog struct {
	*job.EventLogTask
}

func (*EventLog) Output

func (t *EventLog) Output(ctx context.Context) (interface{}, error)

func (*EventLog) SetArg

func (t *EventLog) SetArg(v interface{}) error

type EventLogCleanup

type EventLogCleanup struct {
	*job.EventLogCleanupTask
}

func (*EventLogCleanup) Output

func (t *EventLogCleanup) Output(ctx context.Context) (interface{}, error)

func (*EventLogCleanup) SetArg

func (t *EventLogCleanup) SetArg(v interface{}) error

type HandleEvent

type HandleEvent struct {
	*wasmtime.Task
}

func (*HandleEvent) Output

func (t *HandleEvent) Output(ctx context.Context) (interface{}, error)

func (*HandleEvent) SetArg

func (t *HandleEvent) SetArg(v interface{}) error