pkg

package
v0.81.0 Latest Latest
Warning

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

Go to latest
Published: Jan 17, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const StdinBufferSize = 4096

Variables

This section is empty.

Functions

func CheckAvailableNewVersion

func CheckAvailableNewVersion() (bool, string, string)

func DeleteClusterById added in v0.42.1

func DeleteClusterById(clusterId string, dryRunDisabled bool)

func DeleteClusterUnDeployedInError added in v0.44.4

func DeleteClusterUnDeployedInError()

func DeleteOldClustersWithInvalidCredentials added in v0.73.0

func DeleteOldClustersWithInvalidCredentials(ageInDay int, dryRunDisabled bool)

func DeleteOrganizationByClusterId

func DeleteOrganizationByClusterId(clusterId string, dryRunDisabled bool)

func DeleteProjectById added in v0.46.4

func DeleteProjectById(projectId string, dryRunDisabled bool)

func DeployAll

func DeployAll(dryRunDisabled bool)

func DeployById

func DeployById(clusterId string, dryRunDisabled bool)

func DeployFailedClusters added in v0.48.4

func DeployFailedClusters()

func ExecLog added in v0.64.0

func ExecLog(req *LogRequest)

func ExecPortForward added in v0.77.0

func ExecPortForward(req *PortForwardRequest)

func ExecShell

func ExecShell(req *ShellRequest)

func ForceFailedDeploymentsToInternalErrorStatus added in v0.64.0

func ForceFailedDeploymentsToInternalErrorStatus()

func GetCurrentVersion

func GetCurrentVersion() string

func GetLatestOnlineVersionNumber

func GetLatestOnlineVersionNumber() (string, error)

func GetLatestOnlineVersionUrl

func GetLatestOnlineVersionUrl() (string, error)

func GetVarsByClusterId

func GetVarsByClusterId(clusterID string) []utils.Var

func LockById

func LockById(clusterId string, reason string)

func LockedClusters

func LockedClusters()

func UnockById

func UnockById(clusterId string)

func UpdateAll

func UpdateAll(dryRunDisabled bool, version string, providerKind string, parallelRun int)

func UpdateById

func UpdateById(clusterId string, dryRunDisabled bool, version string)

Types

type ListPodResponse added in v0.78.0

type ListPodResponse struct {
	Pods []PodResponse
}

func ExecListPods added in v0.78.0

func ExecListPods(req *PortForwardRequest) (*ListPodResponse, error)

type LogMessage added in v0.64.0

type LogMessage struct {
	CreatedAt Timestamp `json:"created_at"`
	Message   string    `json:"message"`
	Version   string    `json:"version"`
	PodName   string    `json:"pod_name"`
}

type LogRequest added in v0.64.0

type LogRequest struct {
	ServiceID      utils.Id
	EnvironmentID  utils.Id
	ProjectID      utils.Id
	OrganizationID utils.Id
	ClusterID      utils.Id
	RawFormat      bool
}

type PodResponse added in v0.78.0

type PodResponse struct {
	Name  string
	Ports []uint16
}

type PortForwardRequest added in v0.77.0

type PortForwardRequest struct {
	ServiceID      utils.Id `url:"service"`
	EnvironmentID  utils.Id `url:"environment"`
	ProjectID      utils.Id `url:"project"`
	OrganizationID utils.Id `url:"organization"`
	ClusterID      utils.Id `url:"cluster"`
	PodName        string   `url:"pod_name,omitempty"`
	ServiceType    string   `url:"service_type"`
	Port           uint16   `url:"port"`
	LocalPort      uint16
}

type ShellRequest

type ShellRequest struct {
	ServiceID      utils.Id `url:"service"`
	EnvironmentID  utils.Id `url:"environment"`
	ProjectID      utils.Id `url:"project"`
	OrganizationID utils.Id `url:"organization"`
	ClusterID      utils.Id `url:"cluster"`
	PodName        string   `url:"pod_name,omitempty"`
	ContainerName  string   `url:"container_name,omitempty"`
	Command        []string `url:"command"`
	TtyWidth       uint16   `url:"tty_width"`
	TtyHeight      uint16   `url:"tty_height"`
}

type Timestamp added in v0.64.0

type Timestamp struct {
	time.Time
}

func (*Timestamp) UnmarshalJSON added in v0.64.0

func (p *Timestamp) UnmarshalJSON(bytes []byte) error

UnmarshalJSON decodes an int64 timestamp into a time.Time object

type WebsocketPortForward added in v0.77.0

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

func (WebsocketPortForward) Read added in v0.77.0

func (w WebsocketPortForward) Read(p []byte) (n int, err error)

func (WebsocketPortForward) Write added in v0.77.0

func (w WebsocketPortForward) Write(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

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