api

package

Go to main page

Versions in this module

v0

v0.6.2

Mar 6, 2024

v0.6.1

Nov 15, 2023

v0.6.0

Sep 18, 2023

Changes in this version

type API

+ func (api *API) AttachToTaskRun(stream proto.Gofer_AttachToTaskRunServer) error

+ func (api *API) RunExtensionInstaller(stream proto.Gofer_RunExtensionInstallerServer) error

+ func (api *API) RunPipelineConfigurator(stream proto.Gofer_RunPipelineConfiguratorServer) error

v0.5.0

Apr 17, 2023

Changes in this version

+ const ExtensionContainerIDFmt

+ var ErrExtensionNotFound = errors.New("api: extension is not found")

+ var ErrNoValidConfiguration = errors.New("api: there was no valid, live pipeline configuration found")

type API

+ func (api *API) CreatePipelineExtensionSubscription(ctx context.Context, request *proto.CreatePipelineExtensionSubscriptionRequest) (*proto.CreatePipelineExtensionSubscriptionResponse, error)

+ func (api *API) DeletePipelineConfig(ctx context.Context, request *proto.DeletePipelineConfigRequest) (*proto.DeletePipelineConfigResponse, error)

+ func (api *API) DeletePipelineExtensionSubscription(ctx context.Context, request *proto.DeletePipelineExtensionSubscriptionRequest) (*proto.DeletePipelineExtensionSubscriptionResponse, error)

+ func (api *API) DeployPipeline(ctx context.Context, request *proto.DeployPipelineRequest) (*proto.DeployPipelineResponse, error)

+ func (api *API) DisableExtension(ctx context.Context, request *proto.DisableExtensionRequest) (*proto.DisableExtensionResponse, error)

+ func (api *API) DisablePipelineExtensionSubscription(ctx context.Context, ...) (*proto.DisablePipelineExtensionSubscriptionResponse, error)

+ func (api *API) EnableExtension(ctx context.Context, request *proto.EnableExtensionRequest) (*proto.EnableExtensionResponse, error)

+ func (api *API) EnablePipelineExtensionSubscription(ctx context.Context, request *proto.EnablePipelineExtensionSubscriptionRequest) (*proto.EnablePipelineExtensionSubscriptionResponse, error)

+ func (api *API) GetDeployment(ctx context.Context, request *proto.GetDeploymentRequest) (*proto.GetDeploymentResponse, error)

+ func (api *API) GetExtension(ctx context.Context, request *proto.GetExtensionRequest) (*proto.GetExtensionResponse, error)

+ func (api *API) GetExtensionInstallInstructions(ctx context.Context, request *proto.GetExtensionInstallInstructionsRequest) (*proto.GetExtensionInstallInstructionsResponse, error)

+ func (api *API) GetPipelineConfig(ctx context.Context, request *proto.GetPipelineConfigRequest) (*proto.GetPipelineConfigResponse, error)

+ func (api *API) GetPipelineExtensionSubscription(ctx context.Context, request *proto.GetPipelineExtensionSubscriptionRequest) (*proto.GetPipelineExtensionSubscriptionResponse, error)

+ func (api *API) InstallExtension(ctx context.Context, request *proto.InstallExtensionRequest) (*proto.InstallExtensionResponse, error)

+ func (api *API) ListDeployments(ctx context.Context, request *proto.ListDeploymentsRequest) (*proto.ListDeploymentsResponse, error)

+ func (api *API) ListExtensions(ctx context.Context, request *proto.ListExtensionsRequest) (*proto.ListExtensionsResponse, error)

+ func (api *API) ListPipelineConfigs(ctx context.Context, request *proto.ListPipelineConfigsRequest) (*proto.ListPipelineConfigsResponse, error)

+ func (api *API) ListPipelineExtensionSubscriptions(ctx context.Context, request *proto.ListPipelineExtensionSubscriptionsRequest) (*proto.ListPipelineExtensionSubscriptionsResponse, error)

+ func (api *API) RegisterPipelineConfig(ctx context.Context, request *proto.RegisterPipelineConfigRequest) (*proto.RegisterPipelineConfigResponse, error)

+ func (api *API) UninstallExtension(ctx context.Context, request *proto.UninstallExtensionRequest) (*proto.UninstallExtensionResponse, error)

type RunStateMachine

+ Config *models.PipelineConfig

v0.4.1

Nov 10, 2022

v0.4.0

Nov 10, 2022

v0.3.1

Oct 26, 2022

v0.3.0

Oct 13, 2022

Changes in this version

+ const GlobalSecretKeyFmt

+ const InstallerContainerIDFmt

+ const PipelineSecretKeyFmt

+ const TaskContainerIDFmt

+ const TaskRunFilePath

+ const TriggerContainerIDFmt

type API

+ func (api *API) CreatePipeline(ctx context.Context, request *proto.CreatePipelineRequest) (*proto.CreatePipelineResponse, error)

+ func (api *API) DeleteGlobalSecret(ctx context.Context, request *proto.DeleteGlobalSecretRequest) (*proto.DeleteGlobalSecretResponse, error)

+ func (api *API) DeletePipeline(ctx context.Context, request *proto.DeletePipelineRequest) (*proto.DeletePipelineResponse, error)

+ func (api *API) DeletePipelineSecret(ctx context.Context, request *proto.DeletePipelineSecretRequest) (*proto.DeletePipelineSecretResponse, error)

+ func (api *API) DisableCommonTask(ctx context.Context, request *proto.DisableCommonTaskRequest) (*proto.DisableCommonTaskResponse, error)

+ func (api *API) DisableToken(ctx context.Context, request *proto.DisableTokenRequest) (*proto.DisableTokenResponse, error)

+ func (api *API) DisableTrigger(ctx context.Context, request *proto.DisableTriggerRequest) (*proto.DisableTriggerResponse, error)

+ func (api *API) EnableCommonTask(ctx context.Context, request *proto.EnableCommonTaskRequest) (*proto.EnableCommonTaskResponse, error)

+ func (api *API) EnableToken(ctx context.Context, request *proto.EnableTokenRequest) (*proto.EnableTokenResponse, error)

+ func (api *API) EnableTrigger(ctx context.Context, request *proto.EnableTriggerRequest) (*proto.EnableTriggerResponse, error)

+ func (api *API) GetCommonTask(ctx context.Context, request *proto.GetCommonTaskRequest) (*proto.GetCommonTaskResponse, error)

+ func (api *API) GetCommonTaskInstallInstructions(ctx context.Context, request *proto.GetCommonTaskInstallInstructionsRequest) (*proto.GetCommonTaskInstallInstructionsResponse, error)

+ func (api *API) GetGlobalSecret(ctx context.Context, request *proto.GetGlobalSecretRequest) (*proto.GetGlobalSecretResponse, error)

+ func (api *API) GetPipelineSecret(ctx context.Context, request *proto.GetPipelineSecretRequest) (*proto.GetPipelineSecretResponse, error)

+ func (api *API) GetTriggerInstallInstructions(ctx context.Context, request *proto.GetTriggerInstallInstructionsRequest) (*proto.GetTriggerInstallInstructionsResponse, error)

+ func (api *API) InstallCommonTask(ctx context.Context, request *proto.InstallCommonTaskRequest) (*proto.InstallCommonTaskResponse, error)

+ func (api *API) InstallTrigger(ctx context.Context, request *proto.InstallTriggerRequest) (*proto.InstallTriggerResponse, error)

+ func (api *API) ListCommonTasks(ctx context.Context, request *proto.ListCommonTasksRequest) (*proto.ListCommonTasksResponse, error)

+ func (api *API) ListGlobalSecrets(ctx context.Context, request *proto.ListGlobalSecretsRequest) (*proto.ListGlobalSecretsResponse, error)

+ func (api *API) ListPipelineObjects(ctx context.Context, request *proto.ListPipelineObjectsRequest) (*proto.ListPipelineObjectsResponse, error)

+ func (api *API) ListPipelineSecrets(ctx context.Context, request *proto.ListPipelineSecretsRequest) (*proto.ListPipelineSecretsResponse, error)

+ func (api *API) ListRunObjects(ctx context.Context, request *proto.ListRunObjectsRequest) (*proto.ListRunObjectsResponse, error)

+ func (api *API) ListTokens(ctx context.Context, request *proto.ListTokensRequest) (*proto.ListTokensResponse, error)

+ func (api *API) PutGlobalSecret(ctx context.Context, request *proto.PutGlobalSecretRequest) (*proto.PutGlobalSecretResponse, error)

+ func (api *API) PutPipelineSecret(ctx context.Context, request *proto.PutPipelineSecretRequest) (*proto.PutPipelineSecretResponse, error)

+ func (api *API) UninstallCommonTask(ctx context.Context, request *proto.UninstallCommonTaskRequest) (*proto.UninstallCommonTaskResponse, error)

+ func (api *API) UninstallTrigger(ctx context.Context, request *proto.UninstallTriggerRequest) (*proto.UninstallTriggerResponse, error)

+ func (api *API) UpdatePipeline(ctx context.Context, request *proto.UpdatePipelineRequest) (*proto.UpdatePipelineResponse, error)

+ type InterpolationKind string

+ const InterpolationKindGlobalSecret

+ const InterpolationKindPipelineObject

+ const InterpolationKindPipelineSecret

+ const InterpolationKindRunObject

+ const InterpolationKindUnknown

+ type RunStateMachine struct

+ API *API

+ Pipeline *models.Pipeline

+ Run *models.Run

+ StopRuns *atomic.Bool

+ TaskRuns syncmap.Syncmap[string, models.TaskRun]

v0.2.0-beta

Apr 25, 2022

retracted

v0.2.0-alpha

Oct 4, 2022

v0.1.0

Feb 22, 2022

retracted

Changes in this version

+ func StartExternalEventsService(config *config.API, api *API)

type API

+ func (api *API) GetEvent(ctx context.Context, request *proto.GetEventRequest) (*proto.GetEventResponse, error)

+ func (api *API) ListEvents(request *proto.ListEventsRequest, stream proto.Gofer_ListEventsServer) error

v0.1.0-alpha

Sep 27, 2022

v0.0.3

Jan 28, 2022

retracted

Changes in this version

+ const SecretKeyFmt

+ var ErrPipelineConfigNotValid = errors.New("api: pipeline configuration is invalid")

type API

+ func (api *API) DeleteSecret(ctx context.Context, request *proto.DeleteSecretRequest) (*proto.DeleteSecretResponse, error)

+ func (api *API) GetSecret(ctx context.Context, request *proto.GetSecretRequest) (*proto.GetSecretResponse, error)

+ func (api *API) PutSecret(ctx context.Context, request *proto.PutSecretRequest) (*proto.PutSecretResponse, error)

v0.0.2

Jan 7, 2022

retracted

v0.0.1

Jan 5, 2022

retracted

Changes in this version

+ const GOFEREOF

+ const ObjectPipelineKeyFmt

+ const ObjectRunKeyFmt

+ const TASKCONTAINERIDFORMAT

+ const TRIGGERCONTAINERIDFORMAT

+ var ErrPipelineAbandoned = errors.New("api: pipeline is in state 'abandoned'")

+ var ErrPipelineActive = errors.New("api: pipeline is in state 'active'")

+ var ErrPipelineNotActive = errors.New("api: pipeline is not in state 'active'")

+ var ErrPipelineRunsInProgress = errors.New("api: pipeline has runs which are still in progress")

+ var ErrTriggerConfigNotValid = errors.New("api: trigger configuration is invalid")

+ var ErrTriggerNotFound = errors.New("api: trigger is not found")

+ func StartEventsService(config *config.API, api *API)

+ type API struct

+ func NewAPI(config *config.API, storage storage.Engine, scheduler scheduler.Engine, ...) (*API, error)

+ func (api *API) AbandonPipeline(ctx context.Context, request *proto.AbandonPipelineRequest) (*proto.AbandonPipelineResponse, error)

+ func (api *API) AddRegistryAuth(ctx context.Context, request *proto.AddRegistryAuthRequest) (*proto.AddRegistryAuthResponse, error)

+ func (api *API) BatchGetRuns(ctx context.Context, request *proto.BatchGetRunsRequest) (*proto.BatchGetRunsResponse, error)

+ func (api *API) BatchGetTriggerEvents(ctx context.Context, request *proto.BatchGetTriggerEventsRequest) (*proto.BatchGetTriggerEventsResponse, error)

+ func (api *API) BootstrapToken(ctx context.Context, request *proto.BootstrapTokenRequest) (*proto.BootstrapTokenResponse, error)

+ func (api *API) CancelAllRuns(ctx context.Context, request *proto.CancelAllRunsRequest) (*proto.CancelAllRunsResponse, error)

+ func (api *API) CancelRun(ctx context.Context, request *proto.CancelRunRequest) (*proto.CancelRunResponse, error)

+ func (api *API) CancelTaskRun(ctx context.Context, request *proto.CancelTaskRunRequest) (*proto.CancelTaskRunResponse, error)

+ func (api *API) CreateNamespace(ctx context.Context, request *proto.CreateNamespaceRequest) (*proto.CreateNamespaceResponse, error)

+ func (api *API) CreatePipelineByURL(ctx context.Context, request *proto.CreatePipelineByURLRequest) (*proto.CreatePipelineByURLResponse, error)

+ func (api *API) CreatePipelineRaw(ctx context.Context, request *proto.CreatePipelineRawRequest) (*proto.CreatePipelineRawResponse, error)

+ func (api *API) CreateToken(ctx context.Context, request *proto.CreateTokenRequest) (*proto.CreateTokenResponse, error)

+ func (api *API) DeleteNamespace(ctx context.Context, request *proto.DeleteNamespaceRequest) (*proto.DeleteNamespaceResponse, error)

+ func (api *API) DeletePipelineObject(ctx context.Context, request *proto.DeletePipelineObjectRequest) (*proto.DeletePipelineObjectResponse, error)

+ func (api *API) DeleteRunObject(ctx context.Context, request *proto.DeleteRunObjectRequest) (*proto.DeleteRunObjectResponse, error)

+ func (api *API) DeleteTaskRunLogs(ctx context.Context, request *proto.DeleteTaskRunLogsRequest) (*proto.DeleteTaskRunLogsResponse, error)

+ func (api *API) DeleteToken(ctx context.Context, request *proto.DeleteTokenRequest) (*proto.DeleteTokenResponse, error)

+ func (api *API) DisablePipeline(ctx context.Context, request *proto.DisablePipelineRequest) (*proto.DisablePipelineResponse, error)

+ func (api *API) EnablePipeline(ctx context.Context, request *proto.EnablePipelineRequest) (*proto.EnablePipelineResponse, error)

+ func (api *API) GetNamespace(ctx context.Context, request *proto.GetNamespaceRequest) (*proto.GetNamespaceResponse, error)

+ func (api *API) GetPipeline(ctx context.Context, request *proto.GetPipelineRequest) (*proto.GetPipelineResponse, error)

+ func (api *API) GetPipelineObject(ctx context.Context, request *proto.GetPipelineObjectRequest) (*proto.GetPipelineObjectResponse, error)

+ func (api *API) GetRun(ctx context.Context, request *proto.GetRunRequest) (*proto.GetRunResponse, error)

+ func (api *API) GetRunObject(ctx context.Context, request *proto.GetRunObjectRequest) (*proto.GetRunObjectResponse, error)

+ func (api *API) GetSystemInfo(context context.Context, request *proto.GetSystemInfoRequest) (*proto.GetSystemInfoResponse, error)

+ func (api *API) GetTaskRun(ctx context.Context, request *proto.GetTaskRunRequest) (*proto.GetTaskRunResponse, error)

+ func (api *API) GetTaskRunLogs(request *proto.GetTaskRunLogsRequest, stream proto.Gofer_GetTaskRunLogsServer) error

+ func (api *API) GetToken(ctx context.Context, request *proto.GetTokenRequest) (*proto.GetTokenResponse, error)

+ func (api *API) GetTrigger(ctx context.Context, request *proto.GetTriggerRequest) (*proto.GetTriggerResponse, error)

+ func (api *API) GetTriggerEvent(ctx context.Context, request *proto.GetTriggerEventRequest) (*proto.GetTriggerEventResponse, error)

+ func (api *API) ListNamespaces(ctx context.Context, request *proto.ListNamespacesRequest) (*proto.ListNamespacesResponse, error)

+ func (api *API) ListPipelines(ctx context.Context, request *proto.ListPipelinesRequest) (*proto.ListPipelinesResponse, error)

+ func (api *API) ListRegistryAuths(ctx context.Context, request *proto.ListRegistryAuthsRequest) (*proto.ListRegistryAuthsResponse, error)

+ func (api *API) ListRuns(ctx context.Context, request *proto.ListRunsRequest) (*proto.ListRunsResponse, error)

+ func (api *API) ListTaskRuns(ctx context.Context, request *proto.ListTaskRunsRequest) (*proto.ListTaskRunsResponse, error)

+ func (api *API) ListTriggerEvents(ctx context.Context, request *proto.ListTriggerEventsRequest) (*proto.ListTriggerEventsResponse, error)

+ func (api *API) ListTriggers(ctx context.Context, request *proto.ListTriggersRequest) (*proto.ListTriggersResponse, error)

+ func (api *API) PutPipelineObject(ctx context.Context, request *proto.PutPipelineObjectRequest) (*proto.PutPipelineObjectResponse, error)

+ func (api *API) PutRunObject(ctx context.Context, request *proto.PutRunObjectRequest) (*proto.PutRunObjectResponse, error)

+ func (api *API) RemoveRegistryAuth(ctx context.Context, request *proto.RemoveRegistryAuthRequest) (*proto.RemoveRegistryAuthResponse, error)

+ func (api *API) RepairOrphan(ctx context.Context, request *proto.RepairOrphanRequest) (*proto.RepairOrphanResponse, error)

+ func (api *API) RetryRun(ctx context.Context, request *proto.RetryRunRequest) (*proto.RetryRunResponse, error)

+ func (api *API) StartAPIService()

+ func (api *API) StartRun(ctx context.Context, request *proto.StartRunRequest) (*proto.StartRunResponse, error)

+ func (api *API) ToggleEventIngress(ctx context.Context, request *proto.ToggleEventIngressRequest) (*proto.ToggleEventIngressResponse, error)

+ func (api *API) UpdateNamespace(ctx context.Context, request *proto.UpdateNamespaceRequest) (*proto.UpdateNamespaceResponse, error)

+ func (api *API) UpdatePipelineByURL(ctx context.Context, request *proto.UpdatePipelineByURLRequest) (*proto.UpdatePipelineByURLResponse, error)

+ func (api *API) UpdatePipelineRaw(ctx context.Context, request *proto.UpdatePipelineRawRequest) (*proto.UpdatePipelineRawResponse, error)

+ type CancelContext struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL