calltask

type Ending struct {
	Status  string
	Message string
	Result  json.RawMessage
	Error   json.RawMessage
}

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

type Options struct {
	Store Store
	// Retention is how long a task is kept after it is created; zero is
	// DefaultRetention.
	Retention time.Duration
	// Heartbeat is how often running calls are stamped; zero is
	// DefaultHeartbeat.
	Heartbeat time.Duration
	// PollInterval is the polling interval a client is handed; zero is
	// DefaultPollInterval.
	PollInterval time.Duration
	// Now is the clock; nil is time.Now.
	Now func() time.Time
}

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

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

type Store interface {
	// Create inserts a working task.
	Create(ctx context.Context, t Task) error
	// Get reads one task, or errTaskNotFound.
	Get(ctx context.Context, id string) (*Task, error)
	// Finish ends a working task; a task that already ended is left as it
	// is.
	Finish(ctx context.Context, id string, end Ending) error
	// RequestCancel records a request to stop a working task.
	RequestCancel(ctx context.Context, id string) error
	// Heartbeat stamps the working tasks ids name as alive, and returns the
	// ones among them a cancel was requested for.
	Heartbeat(ctx context.Context, ids []string) ([]string, error)
	// FailStale fails a working task whose heartbeat is older than before,
	// reporting whether it did.
	FailStale(ctx context.Context, id string, before time.Time, message string, rpcErr json.RawMessage) (bool, error)
	// CreateBackground inserts a working background export, or returns the
	// one already working for its caller, tool and key with created false.
	CreateBackground(ctx context.Context, t Task) (existing *Task, created bool, err error)
	// FindByKey reads the caller's latest task of tool under key, or
	// errTaskNotFound.
	FindByKey(ctx context.Context, userID, tool, key string) (*Task, error)
	// SetProgress records how far a working task has come.
	SetProgress(ctx context.Context, id string, progress json.RawMessage) error
	// EndedBackground reads the caller's background exports that ended after
	// since, newest first, at most limit.
	EndedBackground(ctx context.Context, userID string, since time.Time, limit int) ([]Task, error)
}

type Task struct {
	ID            string
	ToolName      string
	UserID        string
	Status        string
	StatusMessage string
	// Result is the tool's result in its wire form, on a completed task.
	Result json.RawMessage
	// Error is the JSON-RPC error, on a failed task.
	Error           json.RawMessage
	CreatedAt       time.Time
	UpdatedAt       time.Time
	HeartbeatAt     time.Time
	CancelRequested bool
	ExpiresAt       time.Time
	// IdempotencyKey, Background and Progress are a background export's
	// (#2212): the key its caller reads it again by, the mark that it is one,
	// and how far its walk has come.
	IdempotencyKey string
	Background     bool
	Progress       json.RawMessage
}