batch

type BatchInput map[string]interface{}

type BatchJob struct {
	Name     string
	Inputs   map[InputId]BatchInput
	Job      func(input BatchInput) (BatchOutput, error)
	Interval time.Duration
	Version  int
}

type BatchJobResult struct {
	Successes int
	Fails     int
	Skipped   int
	Outputs   map[InputId]InputResult
}

type BatchOutput map[string]interface{}

type BatchProcessor interface {
	RunJob(job BatchJob) (BatchJobResult, error)
}

type InputId string

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