client

package
v0.6.43 Latest Latest
Warning

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

Go to latest
Published: May 30, 2026 License: AGPL-3.0, Apache-2.0, MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CiliumServiceName = "cilium"
)

Variables

This section is empty.

Functions

func ContainersFromContainerSpecFragments

func ContainersFromContainerSpecFragments(gateName string, containerSpecFragments []*console.ContainerSpecFragment, resources *console.ContainerResourcesFragment) []corev1.Container

func IsClosed

func IsClosed(pgFragment *console.PipelineGateFragment) bool

func IsPending

func IsPending(pgFragment *console.PipelineGateFragment) bool

func JobSpecFromJobSpecFragment

func JobSpecFromJobSpecFragment(gateName string, jsFragment *console.JobSpecFragment) *batchv1.JobSpec

func JobSpecFromYaml

func JobSpecFromYaml(yamlString string) (*batchv1.JobSpec, error)

func StringMapFromInterfaceMap

func StringMapFromInterfaceMap(labels map[string]interface{}) map[string]string

func ToResourceList

func ToResourceList(resources *console.ResourceRequestFragment) corev1.ResourceList

func TolerationsFromJobSpecFragments

func TolerationsFromJobSpecFragments(fragments []*console.JobSpecFragment_Tolerations) []corev1.Toleration

TolerationsFromJobSpecFragments maps GraphQL job spec tolerations to core tolerations.

Types

type Client

type Client interface {
	GetCredentials() (url, token string)
	PingCluster(attributes console.ClusterPing) error
	Ping(vsn string) error
	RegisterRuntimeServices(svcs map[string]NamespaceVersion, deprecated []console.DeprecatedCustomResourceAttributes, serviceId *string, serviceMesh *console.ServiceMesh) error
	UpsertVirtualCluster(parentID string, attributes console.ClusterAttributes) (*console.GetClusterWithToken_Cluster, error)
	IsClusterExists(id string) (bool, error)
	GetCluster(id string) (*console.TinyClusterFragment, error)
	MyCluster() (*console.MyCluster, error)
	DetachCluster(id string) error
	GetClusterRestore(id string) (*console.ClusterRestoreFragment, error)
	UpdateClusterRestore(id string, attrs console.RestoreAttributes) (*console.ClusterRestoreFragment, error)
	SaveClusterBackup(attrs console.BackupAttributes) (*console.ClusterBackupFragment, error)
	GetClusterBackup(clusterID, namespace, name string) (*console.ClusterBackupFragment, error)
	GetServices(after *string, first *int64) (*console.PagedClusterServicesForAgent, error)
	GetService(id string) (*console.ServiceDeploymentForAgent, error)
	GetServiceDeploymentByHandle(cluster, name string) (*console.ServiceDeploymentExtended, error)
	GetServiceTarball(id string) ([]*console.GetServiceTarball_ServiceTarball, error)
	GetServiceDeploymentComponents(id string) (*console.GetServiceDeploymentComponents_ServiceDeployment, error)
	UpdateComponents(id, revisionID string, sha *string, components []*console.ComponentAttributes, errs []*console.ServiceErrorAttributes, metadata *console.ServiceMetadataAttributes) error
	UpdateServiceErrors(id string, errs []*console.ServiceErrorAttributes) error
	ParsePipelineGateCR(pgFragment *console.PipelineGateFragment, operatorNamespace string) (*v1alpha1.PipelineGate, error)
	GateExists(id string) bool
	GetClusterGate(id string) (*console.PipelineGateFragment, error)
	GetClusterGates(after *string, first *int64) (*console.PagedClusterGateIDs, error)
	UpdateGate(id string, attributes console.GateUpdateAttributes) error
	UpsertConstraints(constraints []console.PolicyConstraintAttributes) (*console.UpsertPolicyConstraints, error)
	GetNamespace(id string) (*console.ManagedNamespaceFragment, error)
	ListNamespaces(after *string, first *int64) (*console.ListClusterNamespaces_ClusterManagedNamespaces, error)
	GetStackRunBase(id string) (*v1.StackRun, error)
	GetStackRun(id string) (*console.StackRunMinimalFragment, error)
	GetStackRunApprovedAt(id string) (*console.GetStackRunApprovedAt_StackRun, error)
	AddStackRunLogs(id, logs string) error
	CompleteStackRun(id string, attributes console.StackRunAttributes) error
	UpdateStackRun(id string, attributes console.StackRunAttributes) error
	UpdateStackRunStep(id string, attributes console.RunStepAttributes) error
	ListClusterStackRuns(after *string, first *int64) (*console.ListClusterMinimalStacks_ClusterStackRuns, error)
	GetUser(email string) (*console.UserFragment, error)
	GetGroup(name string) (*console.GroupFragment, error)
	SaveUpgradeInsights(attributes []*console.UpgradeInsightAttributes, addons []*console.CloudAddonAttributes) (*console.SaveUpgradeInsights, error)
	UpsertVulnerabilityReports(vulnerabilities []*console.VulnerabilityReportAttributes) (*console.UpsertVulnerabilities, error)
	IngestClusterCost(attr console.CostIngestAttributes) (*console.IngestClusterCost, error)
	GetAgentRuntime(ctx context.Context, id string) (*console.AgentRuntimeFragment, error)
	IsAgentRuntimeExists(ctx context.Context, name, clusterID string) (bool, error)
	GetAgentRuntimeByName(ctx context.Context, name, clusterID string) (*console.AgentRuntimeFragment, error)
	UpsertAgentRuntime(ctx context.Context, attrs console.AgentRuntimeAttributes) (*console.AgentRuntimeFragment, error)
	DeleteAgentRuntime(ctx context.Context, id string) error
	ListAgentRuntime(ctx context.Context, after *string, first *int64, q *string, typeArg *console.AgentRuntimeType) (*console.ListAgentRuntimes_AgentRuntimes, error)
	ListAgentRuntimePendingRuns(ctx context.Context, id string, after *string, first *int64) (*console.ListAgentRuntimePendingRuns_AgentRuntime_PendingRuns, error)
	IsAgentRunExists(ctx context.Context, id string) (bool, error)
	GetAgentRun(ctx context.Context, id string) (*console.AgentRunFragment, error)
	GetAgentRunTodos(ctx context.Context, id string) ([]*console.AgentTodoFragment, error)
	CancelAgentRun(ctx context.Context, id string) error
	CreateAgentRun(ctx context.Context, runtimeID string, attrs console.AgentRunAttributes) (*console.AgentRunFragment, error)
	UpdateAgentRun(ctx context.Context, id string, attrs console.AgentRunStatusAttributes) (*console.AgentRunFragment, error)
	UpdateAgentRunAnalysis(ctx context.Context, runtimeID string, attrs console.AgentAnalysisAttributes) (*console.AgentRunBaseFragment, error)
	UpdateAgentRunTodos(ctx context.Context, id string, attrs []*console.AgentTodoAttributes) (*console.AgentRunBaseFragment, error)
	CreateAgentPullRequest(ctx context.Context, runID string, attrs console.AgentPullRequestAttributes) (*console.PullRequestFragment, error)
	GetSentinelRunJob(id string) (*console.SentinelRunJobFragment, error)
	ListClusterSentinelRunJobs(after *string, first *int64) (*console.ListClusterSentinelRunJobs_ClusterSentinelRunJobs, error)
	UpdateSentinelRunJobStatus(id string, attr *console.SentinelRunJobUpdateAttributes) error
	CreateAgentMessage(ctx context.Context, runID string, attrs console.AgentMessageAttributes) (*console.CreateAgentMessage_CreateAgentMessage, error)
	Me() (*console.Me_Me, error)
	GetClusterByHandle(name string) (*console.TinyClusterFragment, error)
	CreateCluster(attrs console.ClusterAttributes) (*console.CreateCluster, error)
	GetDeployToken(clusterId, clusterName *string) (string, error)
	GetUserId(email string) (string, error)
	GetGroupId(name string) (string, error)
	UpdateCluster(id string, attrs console.ClusterUpdateAttributes) error
}

func New

func New(url, token string) Client

type NamespaceVersion

type NamespaceVersion struct {
	Namespace string
	Version   string
	PartOf    string
}

Jump to

Keyboard shortcuts

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