runner

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 25, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsSupportedArch 

func IsSupportedArch(arch params.OSArch) bool

func IsSupportedOSType 

func IsSupportedOSType(osType params.OSType) bool

Types

type EnterprisePoolManager 

type EnterprisePoolManager interface {
	CreateEnterprisePoolManager(ctx context.Context, enterprise params.Enterprise, providers map[string]common.Provider, store dbCommon.Store) (common.PoolManager, error)
	UpdateEnterprisePoolManager(ctx context.Context, enterprise params.Enterprise) (common.PoolManager, error)
	GetEnterprisePoolManager(enterprise params.Enterprise) (common.PoolManager, error)
	DeleteEnterprisePoolManager(enterprise params.Enterprise) error
	GetEnterprisePoolManagers() (map[string]common.PoolManager, error)
}

type HookTargetType 

type HookTargetType string
const (
	RepoHook         HookTargetType = "repository"
	OrganizationHook HookTargetType = "organization"
	EnterpriseHook   HookTargetType = "business"
)

type OrgPoolManager 

type OrgPoolManager interface {
	CreateOrgPoolManager(ctx context.Context, org params.Organization, providers map[string]common.Provider, store dbCommon.Store) (common.PoolManager, error)
	UpdateOrgPoolManager(ctx context.Context, org params.Organization) (common.PoolManager, error)
	GetOrgPoolManager(org params.Organization) (common.PoolManager, error)
	DeleteOrgPoolManager(org params.Organization) error
	GetOrgPoolManagers() (map[string]common.PoolManager, error)
}

type PoolManagerController 

type PoolManagerController interface {
	RepoPoolManager
	OrgPoolManager
	EnterprisePoolManager
}

type RepoPoolManager 

type RepoPoolManager interface {
	CreateRepoPoolManager(ctx context.Context, repo params.Repository, providers map[string]common.Provider, store dbCommon.Store) (common.PoolManager, error)
	UpdateRepoPoolManager(ctx context.Context, repo params.Repository) (common.PoolManager, error)
	GetRepoPoolManager(repo params.Repository) (common.PoolManager, error)
	DeleteRepoPoolManager(repo params.Repository) error
	GetRepoPoolManagers() (map[string]common.PoolManager, error)
}

type Runner 

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

func NewRunner 

func NewRunner(ctx context.Context, cfg config.Config, db dbCommon.Store) (*Runner, error)

func (*Runner) AddInstanceStatusMessage 

func (r *Runner) AddInstanceStatusMessage(ctx context.Context, param params.InstanceUpdateMessage) error

func (*Runner) CreateEnterprise 

func (r *Runner) CreateEnterprise(ctx context.Context, param params.CreateEnterpriseParams) (enterprise params.Enterprise, err error)

func (*Runner) CreateEnterprisePool 

func (r *Runner) CreateEnterprisePool(ctx context.Context, enterpriseID string, param params.CreatePoolParams) (params.Pool, error)

func (*Runner) CreateOrgPool 

func (r *Runner) CreateOrgPool(ctx context.Context, orgID string, param params.CreatePoolParams) (params.Pool, error)

func (*Runner) CreateOrganization 

func (r *Runner) CreateOrganization(ctx context.Context, param params.CreateOrgParams) (org params.Organization, err error)

func (*Runner) CreateRepoPool 

func (r *Runner) CreateRepoPool(ctx context.Context, repoID string, param params.CreatePoolParams) (params.Pool, error)

func (*Runner) CreateRepository 

func (r *Runner) CreateRepository(ctx context.Context, param params.CreateRepoParams) (repo params.Repository, err error)

func (*Runner) DeleteEnterprise 

func (r *Runner) DeleteEnterprise(ctx context.Context, enterpriseID string) error

func (*Runner) DeleteEnterprisePool 

func (r *Runner) DeleteEnterprisePool(ctx context.Context, enterpriseID, poolID string) error

func (*Runner) DeleteOrgPool 

func (r *Runner) DeleteOrgPool(ctx context.Context, orgID, poolID string) error

func (*Runner) DeleteOrganization 

func (r *Runner) DeleteOrganization(ctx context.Context, orgID string) error

func (*Runner) DeletePoolByID 

func (r *Runner) DeletePoolByID(ctx context.Context, poolID string) error

func (*Runner) DeleteRepoPool 

func (r *Runner) DeleteRepoPool(ctx context.Context, repoID, poolID string) error

func (*Runner) DeleteRepository 

func (r *Runner) DeleteRepository(ctx context.Context, repoID string) error

func (*Runner) DispatchWorkflowJob 

func (r *Runner) DispatchWorkflowJob(hookTargetType, signature string, jobData []byte) error

func (*Runner) ForceDeleteRunner 

func (r *Runner) ForceDeleteRunner(ctx context.Context, instanceName string) error

func (*Runner) GetControllerInfo 

func (r *Runner) GetControllerInfo(ctx context.Context) (params.ControllerInfo, error)

GetControllerInfo returns the controller id and the hostname. This data might be used in metrics and logging.

func (*Runner) GetEnterpriseByID 

func (r *Runner) GetEnterpriseByID(ctx context.Context, enterpriseID string) (params.Enterprise, error)

func (*Runner) GetEnterprisePoolByID 

func (r *Runner) GetEnterprisePoolByID(ctx context.Context, enterpriseID, poolID string) (params.Pool, error)

func (*Runner) GetInstance 

func (r *Runner) GetInstance(ctx context.Context, instanceName string) (params.Instance, error)

func (*Runner) GetInstanceGithubRegistrationToken 

func (r *Runner) GetInstanceGithubRegistrationToken(ctx context.Context) (string, error)

func (*Runner) GetOrgPoolByID 

func (r *Runner) GetOrgPoolByID(ctx context.Context, orgID, poolID string) (params.Pool, error)

func (*Runner) GetOrganizationByID 

func (r *Runner) GetOrganizationByID(ctx context.Context, orgID string) (params.Organization, error)

func (*Runner) GetPoolByID 

func (r *Runner) GetPoolByID(ctx context.Context, poolID string) (params.Pool, error)

func (*Runner) GetRepoPoolByID 

func (r *Runner) GetRepoPoolByID(ctx context.Context, repoID, poolID string) (params.Pool, error)

func (*Runner) GetRepositoryByID 

func (r *Runner) GetRepositoryByID(ctx context.Context, repoID string) (params.Repository, error)

func (*Runner) ListAllInstances 

func (r *Runner) ListAllInstances(ctx context.Context) ([]params.Instance, error)

func (*Runner) ListAllJobs added in v0.1.2 

func (r *Runner) ListAllJobs(ctx context.Context) ([]params.Job, error)

func (*Runner) ListAllPools 

func (r *Runner) ListAllPools(ctx context.Context) ([]params.Pool, error)

func (*Runner) ListCredentials 

func (r *Runner) ListCredentials(ctx context.Context) ([]params.GithubCredentials, error)

func (*Runner) ListEnterpriseInstances 

func (r *Runner) ListEnterpriseInstances(ctx context.Context, enterpriseID string) ([]params.Instance, error)

func (*Runner) ListEnterprisePools 

func (r *Runner) ListEnterprisePools(ctx context.Context, enterpriseID string) ([]params.Pool, error)

func (*Runner) ListEnterprises 

func (r *Runner) ListEnterprises(ctx context.Context) ([]params.Enterprise, error)

func (*Runner) ListOrgInstances 

func (r *Runner) ListOrgInstances(ctx context.Context, orgID string) ([]params.Instance, error)

func (*Runner) ListOrgPools 

func (r *Runner) ListOrgPools(ctx context.Context, orgID string) ([]params.Pool, error)

func (*Runner) ListOrganizations 

func (r *Runner) ListOrganizations(ctx context.Context) ([]params.Organization, error)

func (*Runner) ListPoolInstances 

func (r *Runner) ListPoolInstances(ctx context.Context, poolID string) ([]params.Instance, error)

func (*Runner) ListProviders 

func (r *Runner) ListProviders(ctx context.Context) ([]params.Provider, error)

func (*Runner) ListRepoInstances 

func (r *Runner) ListRepoInstances(ctx context.Context, repoID string) ([]params.Instance, error)

func (*Runner) ListRepoPools 

func (r *Runner) ListRepoPools(ctx context.Context, repoID string) ([]params.Pool, error)

func (*Runner) ListRepositories 

func (r *Runner) ListRepositories(ctx context.Context) ([]params.Repository, error)

func (*Runner) Start 

func (r *Runner) Start() error

func (*Runner) Stop 

func (r *Runner) Stop() error

func (*Runner) UpdateEnterprise 

func (r *Runner) UpdateEnterprise(ctx context.Context, enterpriseID string, param params.UpdateEntityParams) (params.Enterprise, error)

func (*Runner) UpdateEnterprisePool 

func (r *Runner) UpdateEnterprisePool(ctx context.Context, enterpriseID, poolID string, param params.UpdatePoolParams) (params.Pool, error)

func (*Runner) UpdateOrgPool 

func (r *Runner) UpdateOrgPool(ctx context.Context, orgID, poolID string, param params.UpdatePoolParams) (params.Pool, error)

func (*Runner) UpdateOrganization 

func (r *Runner) UpdateOrganization(ctx context.Context, orgID string, param params.UpdateEntityParams) (params.Organization, error)

func (*Runner) UpdatePoolByID 

func (r *Runner) UpdatePoolByID(ctx context.Context, poolID string, param params.UpdatePoolParams) (params.Pool, error)

func (*Runner) UpdateRepoPool 

func (r *Runner) UpdateRepoPool(ctx context.Context, repoID, poolID string, param params.UpdatePoolParams) (params.Pool, error)

func (*Runner) UpdateRepository 

func (r *Runner) UpdateRepository(ctx context.Context, repoID string, param params.UpdateEntityParams) (params.Repository, error)

func (*Runner) Wait 

func (r *Runner) Wait() error

Source Files

View all Source files

Directories

Path Synopsis
mocks
external
lxd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.