privateconnector

type Authenticate func(context.Context, string) (runner.Runner, error)

type Authorize func(context.Context, Ready, Deliver) error

type ChangeArgs struct {
	Repository forge.RepoRef `json:"repository"`
	ChangeID   string        `json:"change_id"`
}

type ChangesArgs struct {
	Repository forge.RepoRef `json:"repository"`
	Cursor     string        `json:"cursor,omitempty"`
}

type CheckLogArgs struct {
	Repository forge.RepoRef `json:"repository"`
	CheckID    string        `json:"check_id"`
}

type ChecksArgs struct {
	Repository forge.RepoRef `json:"repository"`
	CommitSHA  string        `json:"commit_sha"`
}

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

type ClientConfig struct {
	Endpoint    string
	Credential  string `json:"-"`
	Target      Target
	Development bool
	CAPEM       []byte
	Client      *http.Client `json:"-"`
	Internal    bool
	Agents      *agent.NativeManager
}

type CompareArgs struct {
	Repository forge.RepoRef `json:"repository"`
	Base       string        `json:"base"`
	Head       string        `json:"head"`
}

type Completion struct {
	GrantID string `json:"grant_id"`
	Result  Result `json:"result"`
}

type Config struct {
	Authenticate  Authenticate
	TTL           time.Duration
	MaxConcurrent int
	Development   bool
	Routes        Routes
}

type Connection struct {
	Native            *agent.NativeScope    `json:"native,omitempty"`
	Protection        *ProtectionCredential `json:"protection,omitempty"`
	CheckPublishers   map[string]string     `json:"check_publishers,omitempty"`
	Kind              string                `json:"kind,omitempty"`
	AuthKind          string                `json:"auth_kind,omitempty"`
	AppID             string                `json:"app_id,omitempty"`
	InstallationID    string                `json:"installation_id,omitempty"`
	Model             string                `json:"model,omitempty"`
	Profile           string                `json:"profile,omitempty"`
	OrgID             string                `json:"org_id"`
	ID                string                `json:"id"`
	Version           int64                 `json:"version"`
	CredentialVersion int64                 `json:"credential_version"`
	Provider          string                `json:"provider"`
	Endpoint          string                `json:"endpoint"`
	Route             network.PrivateRoute  `json:"route"`
	CAPEM             []byte                `json:"ca_pem,omitempty"`
	Secret            string                `json:"-"`
}

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

type Deliver func(GrantSpec) (Result, error)

type DeliveryArgs struct {
	Repository  forge.RepoRef `json:"repository"`
	Environment string        `json:"environment"`
	RunID       string        `json:"run_id"`
}

type Elsewhere struct{ Address string }

type Executor struct {
	Agents      *agent.NativeManager
	Authorize   func(context.Context) error
	Target      Target
	Development bool
}

type Failure struct {
	RetryAfterMS int64  `json:"retry_after_ms,omitempty"`
	Code         string `json:"code"`
	Uncertain    bool   `json:"uncertain"`
}

type FileArgs struct {
	Repository forge.RepoRef `json:"repository"`
	CommitSHA  string        `json:"commit_sha"`
	Path       string        `json:"path"`
}

type FilesArgs struct {
	Repository forge.RepoRef `json:"repository"`
	CommitSHA  string        `json:"commit_sha"`
	Paths      []string      `json:"paths"`
}

type FindChangeArgs struct {
	Repository   forge.RepoRef `json:"repository"`
	OperationID  string        `json:"operation_id"`
	HeadBranch   string        `json:"head_branch"`
	TargetBranch string        `json:"target_branch"`
}

type Grant struct {
	ID            string     `json:"id"`
	RunnerVersion int64      `json:"runner_version"`
	Target        Target     `json:"target"`
	Operation     Operation  `json:"operation"`
	AuthorityID   string     `json:"authority_id"`
	Connection    Connection `json:"connection"`
	TimeoutMS     int64      `json:"timeout_ms"`

	ExpiresAt        time.Time `json:"expires_at"`
	ResultCapability string    `json:"-"`
	// contains filtered or unexported fields
}

type GrantSpec struct {
	Check          func(context.Context) error `json:"-"`
	RunnerVersion  int64
	CredentialHash string `json:"-"`
	OperationID    string
	AuthorityID    string
	Connection     Connection
}

type InventoryArgs struct {
	Namespace string `json:"namespace,omitempty"`
	Cursor    string `json:"cursor,omitempty"`
	Limit     int    `json:"limit"`
}

type Kind string

type Operation struct {
	Agent          *agent.NativeAction          `json:"agent,omitempty"`
	Delivery       *DeliveryArgs                `json:"delivery,omitempty"`
	Pipeline       *forge.PipelineRequest       `json:"pipeline,omitempty"`
	TrainGate      *forge.TrainGateRequest      `json:"train_gate,omitempty"`
	ExecutionCheck *forge.ExecutionCheckRequest `json:"execution_check,omitempty"`
	CancelQueue    *forge.QueueCancelRequest    `json:"cancel_queue,omitempty"`
	Close          *forge.CloseChangeRequest    `json:"close,omitempty"`
	Comment        *forge.CommentChangeRequest  `json:"comment,omitempty"`
	Merge          *forge.MergeRequest          `json:"merge,omitempty"`
	Commit         *ChecksArgs                  `json:"commit,omitempty"`
	Refresh        *forge.RefreshBranchRequest  `json:"refresh,omitempty"`
	Branch         *forge.UpdateBranchRequest   `json:"branch,omitempty"`
	Create         *forge.CreateChangeRequest   `json:"create,omitempty"`
	Find           *FindChangeArgs              `json:"find,omitempty"`
	Turn           *model.Turn                  `json:"turn,omitempty"`
	Source         *ChecksArgs                  `json:"source,omitempty"`
	Changes        *ChangesArgs                 `json:"changes,omitempty"`
	ID             string                       `json:"id"`
	Kind           Kind                         `json:"kind"`
	Inventory      *InventoryArgs               `json:"inventory,omitempty"`
	Repository     *RepositoryArgs              `json:"repository,omitempty"`
	Ref            *RefArgs                     `json:"ref,omitempty"`
	File           *FileArgs                    `json:"file,omitempty"`
	Files          *FilesArgs                   `json:"files,omitempty"`
	CheckLog       *CheckLogArgs                `json:"check_log,omitempty"`
	Compare        *CompareArgs                 `json:"compare,omitempty"`
	Change         *ChangeArgs                  `json:"change,omitempty"`
	Checks         *ChecksArgs                  `json:"checks,omitempty"`
}

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

type ProtectionCredential struct {
	ID                string `json:"id"`
	Version           int64  `json:"version"`
	CredentialVersion int64  `json:"credential_version"`
	Secret            string `json:"-"`
}

type Ready struct {
	runner.Runner
	CredentialHash string `json:"-"`
}

type RefArgs struct {
	Repository forge.RepoRef `json:"repository"`
	Ref        string        `json:"ref"`
}

type RepositoryArgs struct {
	Repository forge.RepoRef `json:"repository"`
}

type Result struct {
	Native            *agent.NativeState             `json:"native,omitempty"`
	Workflows         []forge.Workflow               `json:"workflows,omitempty"`
	DeploymentGates   *forge.DeploymentGates         `json:"deployment_gates,omitempty"`
	Deployment        *forge.DeploymentStatus        `json:"deployment,omitempty"`
	TrainGate         *forge.TrainGate               `json:"train_gate,omitempty"`
	ExecutionCheck    *forge.ExecutionCheck          `json:"execution_check,omitempty"`
	Queue             *forge.QueueState              `json:"queue,omitempty"`
	MergeEvidence     *forge.MergeEvidence           `json:"merge_evidence,omitempty"`
	Merge             *forge.MergeResult             `json:"merge,omitempty"`
	Commit            *forge.CommitProof             `json:"commit,omitempty"`
	Turn              *model.TurnResult              `json:"turn,omitempty"`
	Manifest          *forge.SourceManifest          `json:"manifest,omitempty"`
	Changes           *domain.Page[forge.Change]     `json:"changes,omitempty"`
	ModelCapabilities *model.Capabilities            `json:"model_capabilities,omitempty"`
	Models            []model.Model                  `json:"models,omitempty"`
	OperationID       string                         `json:"operation_id"`
	Failure           *Failure                       `json:"failure,omitempty"`
	Capabilities      *forge.Capabilities            `json:"capabilities,omitempty"`
	Inventory         *domain.Page[forge.Repository] `json:"inventory,omitempty"`
	Repository        *forge.Repository              `json:"repository,omitempty"`
	SHA               string                         `json:"sha,omitempty"`
	File              *forge.File                    `json:"file,omitempty"`
	Files             []forge.File                   `json:"files,omitempty"`
	Log               string                         `json:"log,omitempty"`
	Behind            *int                           `json:"behind,omitempty"`
	Change            *forge.Change                  `json:"change,omitempty"`
	Checks            []forge.Check                  `json:"checks,omitempty"`
	Approvals         []forge.Approval               `json:"approvals,omitempty"`
	Issues            []forge.Issue                  `json:"issues,omitempty"`
	Advisories        []forge.Advisory               `json:"advisories,omitempty"`
	Link              string                         `json:"link,omitempty"`
}

type Routes interface {
	Claim(ctx context.Context, org, route string, until time.Time) error
	Release(org, route string)
	Elsewhere(ctx context.Context, org, route string) (string, error)
}

type Target struct {
	OrgID    string `json:"org_id"`
	RunnerID string `json:"runner_id"`
}