batch

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

type BatchClientIn interface {
	// Name returns the Job name.
	Name() string

	// Submit will submit the provided request to the job.
	Submit(ctx context.Context, data map[string]interface{}) error
}

type Ctx struct {
	Request  Request
	Response *Response
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

type Handler = handlers.Handler[Ctx]

type HandlerOption func(opts *handlerOptions)

type JobPermission string

type JobReference interface {
	// Allow requests the given permissions to the job.
	Allow(permission JobPermission, permissions ...JobPermission) *BatchClient

	// Handler will register and start the job task handler that will be called for all task submitted to this job.
	// Valid function signatures for middleware are:
	//
	//	func()
	//	func() error
	//	func(*batch.Ctx)
	//	func(*batch.Ctx) error
	//	Handler[batch.Ctx]
	Handler(handler interface{}, options ...HandlerOption)
}

type Request interface {
	JobName() string
	Data() map[string]interface{}
}

type Response struct {
	Success bool
}