client

package

v0.1.10 Latest Latest Go to latest Published: Sep 11, 2024 License: GPL-3.0 Imports: 22 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) 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) 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) error

func (*RunnerClient) GetComputedOrganizationID ¶

func (r *RunnerClient) GetComputedOrganizationID() string

func (*RunnerClient) GetDeploymentData ¶

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

func (*RunnerClient) GetPendingJobs ¶

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

func (*RunnerClient) GetPreviewData ¶

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

func (*RunnerClient) MarkJobsComplete ¶

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

func (*RunnerClient) Ping ¶

func (r *RunnerClient) Ping(firstPing bool) error

func (*RunnerClient) RefreshGitToken ¶

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

func (*RunnerClient) SendNotifications ¶

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

func (*RunnerClient) UpdateBuilds ¶

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

func (*RunnerClient) UpdateCertificates ¶

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

func (*RunnerClient) UpdateDeployments ¶

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

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

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

func (*RunnerClient) UpdatePreviews ¶

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

func (*RunnerClient) UpsertClusters ¶

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

func (*RunnerClient) UpsertJobHeartbeat ¶

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

func (*RunnerClient) UpsertVpcs ¶

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

Source Files ¶

View all Source files

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