Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidData = errors.Unwrap(fmt.Errorf("Invalid args for data processing job"))
View Source
var ErrInvalidMsg = errors.Unwrap(fmt.Errorf("Invalid args for message processing job"))
Functions ¶
This section is empty.
Types ¶
type CsvStoreJob ¶
type CsvStoreJob struct {
// contains filtered or unexported fields
}
func (*CsvStoreJob) Kind ¶
func (c *CsvStoreJob) Kind() string
type DummyManager ¶
type DummyManager struct {
// contains filtered or unexported fields
}
func (*DummyManager) Register ¶
func (f *DummyManager) Register(job Job) error
type ExpectsJob ¶
type ExpectsJob struct {
Called bool
}
func (*ExpectsJob) Kind ¶
func (e *ExpectsJob) Kind() string
type FaktoryManager ¶
type FaktoryManager struct {
// contains filtered or unexported fields
}
func (*FaktoryManager) Register ¶
func (f *FaktoryManager) Register(job Job) error
type JsonStoreJob ¶
type JsonStoreJob struct {
// contains filtered or unexported fields
}
func (*JsonStoreJob) Kind ¶
func (r *JsonStoreJob) Kind() string
type Manager ¶
type Manager interface { Register(Job) error Perform(Job, ...*Message) error Run(context.Context) error }
func NewDummyManager ¶
func NewFaktoryManager ¶
type Message ¶
type Message struct { ProcessedAt int64 `json:"processed_at" mapstructure:"processed_at" csv:"processed_at"` HappenedAt int64 `json:"happened_at" mapstructure:"happened_at" csv:"happened_at"` ID string `json:"id" csv:"id"` Kind string `json:"kind" csv:"kind"` Value interface{} `json:"value" csv:"value"` }
func NewMessageFromArg ¶
Click to show internal directories.
Click to hide internal directories.