batch

type BatchHintsResult struct {
	// A list of known values of completedDir used by existing watchers.
	CompletedDirs []string
}

type BatchResult struct {
	WorkflowID string
	RunID      string
}

type BatchStatusResult struct {
	Running    bool
	Status     *string
	WorkflowID *string
	RunID      *string
}

type Client struct {
	SubmitEndpoint goa.Endpoint
	StatusEndpoint goa.Endpoint
	HintsEndpoint  goa.Endpoint
}

type Endpoints struct {
	Submit goa.Endpoint
	Status goa.Endpoint
	Hints  goa.Endpoint
}

type Service interface {
	// Submit a new batch
	Submit(context.Context, *SubmitPayload) (res *BatchResult, err error)
	// Retrieve status of current batch operation.
	Status(context.Context) (res *BatchStatusResult, err error)
	// Retrieve form hints
	Hints(context.Context) (res *BatchHintsResult, err error)
}

type SubmitPayload struct {
	Path                string
	Pipeline            *string
	ProcessingConfig    *string
	CompletedDir        *string
	RetentionPeriod     *string
	RejectDuplicates    bool
	ExcludeHiddenFiles  bool
	TransferType        *string
	ProcessNameMetadata bool
	Depth               int
}