client

package

v0.1.15 Latest Latest Go to latest Published: Feb 14, 2025 License: GPL-3.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/deployment-io/deployment-runner

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Connect(options Options, organizationID string) chan struct{}
func Disconnect() error
type Options
type RunnerClient
- func Get() *RunnerClient

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrConnection = fmt.Errorf("client is not connected")

Functions ¶

func Connect ¶

func Connect(options Options, organizationID string) chan struct{}

func Disconnect ¶

func Disconnect() error

Types ¶

type Options ¶

type Options struct {
	Service string
	//OrganizationID        string
	UserID                string
	Token                 string
	ClientCertPem         string
	ClientKeyPem          string
	DockerImage           string
	Region                string
	CloudAccountID        string
	BlockTillFirstConnect bool
	RunnerMode            runner_enums.Mode
	TargetCloud           runner_enums.TargetCloud
}

type RunnerClient ¶

type RunnerClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func Get ¶

func Get() *RunnerClient

func (*RunnerClient) AddJobLogs ¶

func (r *RunnerClient) AddJobLogs(addBuildLogs []logs.AddJobLogDtoV1, organizationID string) error

func (*RunnerClient) GetComputedOrganizationID ¶

func (r *RunnerClient) GetComputedOrganizationID(organizationID string) string

func (*RunnerClient) GetDeploymentData ¶

func (r *RunnerClient) GetDeploymentData(deploymentIDs []string, organizationID string) ([]deployments.GetDeploymentDtoV1, error)

func (*RunnerClient) GetPendingJobs ¶

func (r *RunnerClient) GetPendingJobs(organizationID string) ([]jobs.PendingJobDtoV1, error)

func (*RunnerClient) GetPendingJobsForSaas ¶ added in v0.1.12

func (r *RunnerClient) GetPendingJobsForSaas(organizationID string) ([]jobs.PendingJobForSaasDtoV1, error)

func (*RunnerClient) GetPreviewData ¶

func (r *RunnerClient) GetPreviewData(previewIDs []string, organizationID string) ([]previews.GetPreviewDtoV1, error)

func (*RunnerClient) MarkJobsComplete ¶

func (r *RunnerClient) MarkJobsComplete(completingJobs []jobs.CompletingJobDtoV1, organizationID string) error

func (*RunnerClient) Ping ¶

func (r *RunnerClient) Ping(firstPing bool, organizationID string) error

func (*RunnerClient) RefreshGitToken ¶

func (r *RunnerClient) RefreshGitToken(installationID string, organizationID string) (string, error)

func (*RunnerClient) SendNotifications ¶

func (r *RunnerClient) SendNotifications(sendNotifications []notifications.SendNotificationDtoV1, organizationID string) error

func (*RunnerClient) UpdateAutomationResponses ¶ added in v0.1.14

func (r *RunnerClient) UpdateAutomationResponses(responses []automations.UpdateResponseDtoV1, organizationID string) error

func (*RunnerClient) UpdateBuilds ¶

func (r *RunnerClient) UpdateBuilds(updateBuilds []builds.UpdateBuildDtoV1, organizationID string) error

func (*RunnerClient) UpdateCertificates ¶

func (r *RunnerClient) UpdateCertificates(updateCertificates []certificates.UpdateCertificateDtoV1, organizationID string) error

func (*RunnerClient) UpdateDeployments ¶

func (r *RunnerClient) UpdateDeployments(updateDeployments []deployments.UpdateDeploymentDtoV1, organizationID string) error

func (*RunnerClient) UpdateJobOutputs ¶ added in v0.1.8

func (r *RunnerClient) UpdateJobOutputs(jobOutputs []jobs.UpdateJobOutputDtoV1, organizationID string) error

func (*RunnerClient) UpdatePreviews ¶

func (r *RunnerClient) UpdatePreviews(updatePreviews []previews.UpdatePreviewDtoV1, organizationID string) error

func (*RunnerClient) UpsertClusters ¶

func (r *RunnerClient) UpsertClusters(upsertClusters []clusters.UpsertClusterDtoV1, organizationID string) error

func (*RunnerClient) UpsertJobHeartbeat ¶

func (r *RunnerClient) UpsertJobHeartbeat(jobID string, organizationID string) (bool, error)

func (*RunnerClient) UpsertVpcs ¶

func (r *RunnerClient) UpsertVpcs(upsertVpcs []vpcs.UpsertVpcDtoV1, organizationID string) error

Source Files ¶

View all Source files

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