api

type ContextVariables struct {
	JobID    string `json:"jobId"`
	TaskID   string `json:"id"`
	WorkerID string `json:"workerId"`
}

type EventLogger struct {
	Service    Service
	SystemLog  logging.Logger
	SourceType string
	SourceID   string
	Prefix     string
}

type Instant = scalars.Instant

type JSONObject = scalars.JSONObject

type QueryErrorSet []*errors.QueryError

type Service interface {
	// TODO: This should not be on the interface exposed to most callers.
	Shutdown(context.Context) error
	// Execute a GraphQL operation synchronously, decoding the response data in to res.
	// Implementations should also respect CurrentContextVariables.
	Do(ctx context.Context, res any, doc string, vars map[string]any) error
	// Begin a GraphQL subscription operation. Decodes responses in to the result
	// of invoking newRes for each event response. Decoded responses are
	// delivered to to consumers via Subscription.Events().
	Subscribe(ctx context.Context, newRes func() any, doc string, vars map[string]any) Subscription
}

type Subscription interface {
	// Yields events until the subscription is stopped.  The element type is
	// specified via the original Subscribe() method call.
	Events() <-chan any
	Err() error
	Stop()
}

type ULID = scalars.ULID

type Worker struct {
	Service Service
	ID      string
	// If non-empty, only work tasks from the specified job.  Otherwise, work any
	// available task.
	JobID string
	// Called when there is no more work expected.
	OnDone func()
}

type WorkerPool struct {
	Service      Service
	Concurrency  int
	WorkerPrefix string
	JobID        string
}