jobs

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

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

type ExpectsJob struct {
	Called bool
}

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

type Job interface {
	Kind() string
	Run(ctx context.Context, args ...interface{}) error
}

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

type Manager interface {
	Register(Job) error
	Perform(Job, ...*Message) error
	Run(context.Context) error
}

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"`
}