runner

type Assignment struct {
	Credential Credential     `json:"-"`
	Lease      workflow.Lease `json:"lease"`
	Task       workflow.Task  `json:"task"`
}

type Credential struct {
	Token     string    `json:"-"`
	ExpiresAt time.Time `json:"expires_at"`
	Runner    Runner    `json:"runner"`
}

type FixedOperation func(context.Context, pgx.Tx, Operation) (json.RawMessage, error)

type Heartbeat struct {
	Lease  workflow.Lease `json:"lease"`
	Stop   bool           `json:"stop"`
	Reason string         `json:"reason,omitempty"`
}

type Operation struct {
	Lease        workflow.Lease
	Task         workflow.Task
	RunnerID     string
	PoolID       string
	ConnectionID string
	Input        json.RawMessage
}

type Pool struct {
	ID            string   `json:"id"`
	OrgID         string   `json:"org_id"`
	Name          string   `json:"name"`
	State         string   `json:"state"`
	RepositoryIDs []string `json:"repository_ids"`
	Version       int64    `json:"version"`
	RunnerCount   int      `json:"runner_count"`
	BusySlots     int      `json:"busy_slots"`
	Builtin       bool     `json:"builtin"`
}

type PoolFilter struct {
	Query string
	State string
}

type PoolInput struct {
	Name          string   `json:"name"`
	State         string   `json:"state"`
	RepositoryIDs []string `json:"repository_ids"`
}

type Runner struct {
	ID                  string    `json:"id"`
	OrgID               string    `json:"org_id"`
	PoolID              string    `json:"pool_id"`
	Name                string    `json:"name"`
	State               string    `json:"state"`
	Version             int64     `json:"version"`
	CredentialExpiresAt time.Time `json:"credential_expires_at"`
	PoolName            string    `json:"pool_name"`
	PoolState           string    `json:"pool_state"`
	LastSeenAt          time.Time `json:"last_seen_at"`
	EnrolledAt          time.Time `json:"enrolled_at"`
	BusySlots           int       `json:"busy_slots"`
	RouteCount          int       `json:"route_count"`
}

type Service struct {
	CompletionCheck func(context.Context, pgx.Tx, workflow.Lease, workflow.Task, workflow.Completion) error
	// contains filtered or unexported fields
}