client

package
v0.9.0-rc2 Latest Latest
Warning

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

Go to latest
Published: Oct 18, 2023 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	PrefixErrRulesNeeded  = "rules needed: "
	PrefixErrRulesMissing = "rules missing: "
)

Functions

func BuildClientID

func BuildClientID(image, file string) string

func FindImage

func FindImage(ctx context.Context, c Client, name string) (*apiv1.Image, string, error)

FindImage finds an image if exists and returns whether it was found by tag

func ToApp

func ToApp(namespace, image string, opts *AppRunOptions) *apiv1.App

func ToAppUpdate

func ToAppUpdate(ctx context.Context, c Client, name string, opts *AppUpdateOptions) (*apiv1.App, error)

func TranslateNotAllowed

func TranslateNotAllowed(err error) error

Types

type AcornImageBuildOptions

type AcornImageBuildOptions struct {
	BuilderName string
	Credentials CredentialLookup
	Cwd         string
	Platforms   []v1.Platform
	Args        map[string]any
	Profiles    []string
	Streams     *streams.Output
}

type AppRunOptions

type AppRunOptions struct {
	Name                string
	Region              string
	Annotations         []v1.ScopedLabel
	Labels              []v1.ScopedLabel
	PublishMode         v1.PublishMode
	Volumes             []v1.VolumeBinding
	Secrets             []v1.SecretBinding
	Links               []v1.ServiceBinding
	Publish             []v1.PortBinding
	Env                 []v1.NameValue
	Profiles            []string
	DeployArgs          map[string]any
	Stop                *bool
	Permissions         []v1.Permissions
	AutoUpgrade         *bool
	NotifyUpgrade       *bool
	AutoUpgradeInterval string
	Memory              v1.MemoryMap
	ComputeClasses      v1.ComputeClassMap
}

func (AppRunOptions) ToUpdate

func (a AppRunOptions) ToUpdate() AppUpdateOptions

type AppUpdateOptions

type AppUpdateOptions struct {
	Annotations         []v1.ScopedLabel
	Labels              []v1.ScopedLabel
	PublishMode         v1.PublishMode
	Volumes             []v1.VolumeBinding
	Secrets             []v1.SecretBinding
	Links               []v1.ServiceBinding
	Publish             []v1.PortBinding
	Env                 []v1.NameValue
	Profiles            []string
	Permissions         []v1.Permissions
	DeployArgs          map[string]any
	Stop                *bool
	Image               string
	Replace             bool // Replace is used to indicate whether the update should be a patch (replace=false: only change specified fields) or a full update (replace=true: reset unspecified fields to defaults)
	AutoUpgrade         *bool
	NotifyUpgrade       *bool
	AutoUpgradeInterval string
	Memory              v1.MemoryMap
	ComputeClasses      v1.ComputeClassMap
	Region              string
	DevSessionClient    *v1.DevSessionInstanceClient
}

func (AppUpdateOptions) ToRun

func (a AppUpdateOptions) ToRun() AppRunOptions

type Client

type Client interface {
	AppList(ctx context.Context) ([]apiv1.App, error)
	AppDelete(ctx context.Context, name string) (*apiv1.App, error)
	AppGet(ctx context.Context, name string) (*apiv1.App, error)
	AppStop(ctx context.Context, name string) error
	AppStart(ctx context.Context, name string) error
	AppRun(ctx context.Context, image string, opts *AppRunOptions) (*apiv1.App, error)
	AppUpdate(ctx context.Context, name string, opts *AppUpdateOptions) (*apiv1.App, error)
	AppLog(ctx context.Context, name string, opts *LogOptions) (<-chan apiv1.LogMessage, error)
	AppInfo(ctx context.Context, name string) (string, error)
	AppConfirmUpgrade(ctx context.Context, name string) error
	AppPullImage(ctx context.Context, name string) error
	AppIgnoreDeleteCleanup(ctx context.Context, name string) error

	DevSessionRenew(ctx context.Context, name string, client v1.DevSessionInstanceClient) error
	DevSessionRelease(ctx context.Context, name string) error

	CredentialCreate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)
	CredentialList(ctx context.Context) ([]apiv1.Credential, error)
	CredentialGet(ctx context.Context, serverAddress string) (*apiv1.Credential, error)
	CredentialUpdate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)
	CredentialDelete(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

	SecretCreate(ctx context.Context, name, secretType string, data map[string][]byte) (*apiv1.Secret, error)
	SecretList(ctx context.Context) ([]apiv1.Secret, error)
	SecretGet(ctx context.Context, name string) (*apiv1.Secret, error)
	SecretReveal(ctx context.Context, name string) (*apiv1.Secret, error)
	SecretUpdate(ctx context.Context, name string, data map[string][]byte) (*apiv1.Secret, error)
	SecretDelete(ctx context.Context, name string) (*apiv1.Secret, error)

	ContainerReplicaList(ctx context.Context, opts *ContainerReplicaListOptions) ([]apiv1.ContainerReplica, error)
	ContainerReplicaGet(ctx context.Context, name string) (*apiv1.ContainerReplica, error)
	ContainerReplicaDelete(ctx context.Context, name string) (*apiv1.ContainerReplica, error)
	ContainerReplicaExec(ctx context.Context, name string, args []string, tty bool, opts *ContainerReplicaExecOptions) (*term.ExecIO, error)
	ContainerReplicaPortForward(ctx context.Context, name string, port int) (PortForwardDialer, error)

	JobList(ctx context.Context, opts *JobListOptions) ([]apiv1.Job, error)
	JobGet(ctx context.Context, name string) (*apiv1.Job, error)
	JobRestart(ctx context.Context, name string) error

	VolumeList(ctx context.Context) ([]apiv1.Volume, error)
	VolumeGet(ctx context.Context, name string) (*apiv1.Volume, error)
	VolumeDelete(ctx context.Context, name string) (*apiv1.Volume, error)

	ImageList(ctx context.Context) ([]apiv1.Image, error)
	ImageGet(ctx context.Context, name string) (*apiv1.Image, error)
	ImageDelete(ctx context.Context, name string, opts *ImageDeleteOptions) (*apiv1.Image, []string, error) // returns the modified/deleted image and a list of deleted tags
	ImagePush(ctx context.Context, tagName string, opts *ImagePushOptions) (<-chan ImageProgress, error)
	ImagePull(ctx context.Context, name string, opts *ImagePullOptions) (<-chan ImageProgress, error)
	ImageTag(ctx context.Context, image, tag string) error
	ImageDetails(ctx context.Context, imageName string, opts *ImageDetailsOptions) (*ImageDetails, error)

	ImageSign(ctx context.Context, image string, payload []byte, signatureB64 string, opts *ImageSignOptions) (*apiv1.ImageSignature, error)
	ImageVerify(ctx context.Context, image string, opts *ImageVerifyOptions) (*apiv1.ImageSignature, error)

	AcornImageBuildGet(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)
	AcornImageBuildList(ctx context.Context) ([]apiv1.AcornImageBuild, error)
	AcornImageBuildDelete(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)
	AcornImageBuild(ctx context.Context, file string, opts *AcornImageBuildOptions) (*v1.AppImage, error)

	ProjectGet(ctx context.Context, name string) (*apiv1.Project, error)
	ProjectList(ctx context.Context) ([]apiv1.Project, error)
	ProjectCreate(ctx context.Context, name, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)
	ProjectUpdate(ctx context.Context, project *apiv1.Project, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)
	ProjectDelete(ctx context.Context, name string) (*apiv1.Project, error)

	VolumeClassList(ctx context.Context) ([]apiv1.VolumeClass, error)
	VolumeClassGet(ctx context.Context, name string) (*apiv1.VolumeClass, error)

	Info(ctx context.Context) ([]apiv1.Info, error)

	ComputeClassList(ctx context.Context) ([]apiv1.ComputeClass, error)
	ComputeClassGet(ctx context.Context, name string) (*apiv1.ComputeClass, error)

	RegionList(ctx context.Context) ([]apiv1.Region, error)
	RegionGet(ctx context.Context, name string) (*apiv1.Region, error)

	EventStream(ctx context.Context, opts *EventStreamOptions) (<-chan apiv1.Event, error)

	GetProject() string
	GetNamespace() string
	GetClient() (kclient.WithWatch, error)

	KubeProxyAddress(ctx context.Context, opts *KubeProxyAddressOptions) (string, error)
	KubeConfig(ctx context.Context, opts *KubeProxyAddressOptions) ([]byte, error)
}

func New

func New(restConfig *rest.Config, project, namespace string) (Client, error)

type ContainerLogsWriter added in v0.9.0

type ContainerLogsWriter interface {
	Container(timeStamp metav1.Time, containerName, line string)
}

type ContainerReplicaExecOptions

type ContainerReplicaExecOptions struct {
	DebugImage string `json:"debugImage,omitempty"`
}

type ContainerReplicaListOptions

type ContainerReplicaListOptions struct {
	App string `json:"app,omitempty"`
}

type CredentialLookup

type CredentialLookup func(ctx context.Context, serverAddress string) (*apiv1.RegistryAuth, bool, error)

type DefaultClient

type DefaultClient struct {
	Project    string
	Namespace  string
	Client     kclient.WithWatch
	RESTConfig *rest.Config
	RESTClient *rest.RESTClient
	Dialer     *k8schannel.Dialer
}

func (*DefaultClient) AcornImageBuild

func (c *DefaultClient) AcornImageBuild(ctx context.Context, file string, opts *AcornImageBuildOptions) (*v1.AppImage, error)

func (*DefaultClient) AcornImageBuildDelete

func (c *DefaultClient) AcornImageBuildDelete(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (*DefaultClient) AcornImageBuildGet

func (c *DefaultClient) AcornImageBuildGet(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (*DefaultClient) AcornImageBuildList

func (c *DefaultClient) AcornImageBuildList(ctx context.Context) ([]apiv1.AcornImageBuild, error)

func (*DefaultClient) AppConfirmUpgrade

func (c *DefaultClient) AppConfirmUpgrade(ctx context.Context, name string) error

func (*DefaultClient) AppDelete

func (c *DefaultClient) AppDelete(ctx context.Context, name string) (*apiv1.App, error)

func (*DefaultClient) AppGet

func (c *DefaultClient) AppGet(ctx context.Context, name string) (*apiv1.App, error)

func (*DefaultClient) AppIgnoreDeleteCleanup

func (c *DefaultClient) AppIgnoreDeleteCleanup(ctx context.Context, name string) error

func (*DefaultClient) AppInfo

func (c *DefaultClient) AppInfo(ctx context.Context, name string) (string, error)

func (*DefaultClient) AppList

func (c *DefaultClient) AppList(ctx context.Context) ([]apiv1.App, error)

func (*DefaultClient) AppLog

func (c *DefaultClient) AppLog(ctx context.Context, name string, opts *LogOptions) (<-chan apiv1.LogMessage, error)

func (*DefaultClient) AppPullImage

func (c *DefaultClient) AppPullImage(ctx context.Context, name string) error

func (*DefaultClient) AppRun

func (c *DefaultClient) AppRun(ctx context.Context, image string, opts *AppRunOptions) (*apiv1.App, error)

func (*DefaultClient) AppStart

func (c *DefaultClient) AppStart(ctx context.Context, name string) (err error)

func (*DefaultClient) AppStop

func (c *DefaultClient) AppStop(ctx context.Context, name string) (err error)

func (*DefaultClient) AppUpdate

func (c *DefaultClient) AppUpdate(ctx context.Context, name string, opts *AppUpdateOptions) (result *apiv1.App, err error)

func (*DefaultClient) ComputeClassGet

func (c *DefaultClient) ComputeClassGet(ctx context.Context, name string) (*apiv1.ComputeClass, error)

func (*DefaultClient) ComputeClassList

func (c *DefaultClient) ComputeClassList(ctx context.Context) ([]apiv1.ComputeClass, error)

func (*DefaultClient) ContainerReplicaDelete

func (c *DefaultClient) ContainerReplicaDelete(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (*DefaultClient) ContainerReplicaExec

func (c *DefaultClient) ContainerReplicaExec(ctx context.Context, containerName string, args []string, tty bool, opts *ContainerReplicaExecOptions) (*term.ExecIO, error)

func (*DefaultClient) ContainerReplicaGet

func (c *DefaultClient) ContainerReplicaGet(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (*DefaultClient) ContainerReplicaList

func (c *DefaultClient) ContainerReplicaList(ctx context.Context, opts *ContainerReplicaListOptions) ([]apiv1.ContainerReplica, error)

func (*DefaultClient) ContainerReplicaPortForward

func (c *DefaultClient) ContainerReplicaPortForward(ctx context.Context, containerName string, port int) (PortForwardDialer, error)

func (*DefaultClient) CredentialCreate

func (c *DefaultClient) CredentialCreate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*DefaultClient) CredentialDelete

func (c *DefaultClient) CredentialDelete(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (*DefaultClient) CredentialGet

func (c *DefaultClient) CredentialGet(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (*DefaultClient) CredentialList

func (c *DefaultClient) CredentialList(ctx context.Context) ([]apiv1.Credential, error)

func (*DefaultClient) CredentialUpdate

func (c *DefaultClient) CredentialUpdate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*DefaultClient) DevSessionRelease

func (c *DefaultClient) DevSessionRelease(ctx context.Context, name string) error

func (*DefaultClient) DevSessionRenew

func (c *DefaultClient) DevSessionRenew(ctx context.Context, name string, client v1.DevSessionInstanceClient) error

func (*DefaultClient) EventStream

func (c *DefaultClient) EventStream(ctx context.Context, opts *EventStreamOptions) (<-chan apiv1.Event, error)

func (*DefaultClient) GetClient

func (c *DefaultClient) GetClient() (kclient.WithWatch, error)

func (*DefaultClient) GetNamespace

func (c *DefaultClient) GetNamespace() string

func (*DefaultClient) GetProject

func (c *DefaultClient) GetProject() string

func (*DefaultClient) ImageDelete

func (c *DefaultClient) ImageDelete(ctx context.Context, imageName string, opts *ImageDeleteOptions) (imgResult *apiv1.Image, _ []string, err error)

ImageDelete handles two use cases: remove a tag from an image or delete an image entirely. Both may go hand in hand when deleting the last remaining tag.

func (*DefaultClient) ImageDetails

func (c *DefaultClient) ImageDetails(ctx context.Context, imageName string, opts *ImageDetailsOptions) (*ImageDetails, error)

func (*DefaultClient) ImageGet

func (c *DefaultClient) ImageGet(ctx context.Context, imageName string) (*apiv1.Image, error)

func (*DefaultClient) ImageList

func (c *DefaultClient) ImageList(ctx context.Context) ([]apiv1.Image, error)

func (*DefaultClient) ImagePull

func (c *DefaultClient) ImagePull(ctx context.Context, imageName string, opts *ImagePullOptions) (<-chan ImageProgress, error)

func (*DefaultClient) ImagePush

func (c *DefaultClient) ImagePush(ctx context.Context, imageName string, opts *ImagePushOptions) (<-chan ImageProgress, error)

func (*DefaultClient) ImageSign

func (c *DefaultClient) ImageSign(ctx context.Context, image string, payload []byte, signatureB64 string, opts *ImageSignOptions) (*apiv1.ImageSignature, error)

func (*DefaultClient) ImageTag

func (c *DefaultClient) ImageTag(ctx context.Context, imageName, tag string) error

func (*DefaultClient) ImageVerify

func (c *DefaultClient) ImageVerify(ctx context.Context, image string, opts *ImageVerifyOptions) (*apiv1.ImageSignature, error)

func (*DefaultClient) Info

func (c *DefaultClient) Info(ctx context.Context) ([]apiv1.Info, error)

func (*DefaultClient) JobGet

func (c *DefaultClient) JobGet(ctx context.Context, name string) (*apiv1.Job, error)

func (*DefaultClient) JobList

func (c *DefaultClient) JobList(ctx context.Context, opts *JobListOptions) ([]apiv1.Job, error)

func (*DefaultClient) JobRestart

func (c *DefaultClient) JobRestart(ctx context.Context, name string) error

func (*DefaultClient) KubeConfig

func (c *DefaultClient) KubeConfig(ctx context.Context, opts *KubeProxyAddressOptions) ([]byte, error)

func (*DefaultClient) KubeProxyAddress

func (c *DefaultClient) KubeProxyAddress(ctx context.Context, opts *KubeProxyAddressOptions) (string, error)

func (*DefaultClient) ProjectCreate

func (c *DefaultClient) ProjectCreate(ctx context.Context, name, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*DefaultClient) ProjectDelete

func (c *DefaultClient) ProjectDelete(ctx context.Context, name string) (*apiv1.Project, error)

func (*DefaultClient) ProjectGet

func (c *DefaultClient) ProjectGet(ctx context.Context, name string) (*apiv1.Project, error)

func (*DefaultClient) ProjectList

func (c *DefaultClient) ProjectList(ctx context.Context) ([]apiv1.Project, error)

func (*DefaultClient) ProjectUpdate

func (c *DefaultClient) ProjectUpdate(ctx context.Context, project *apiv1.Project, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*DefaultClient) RegionGet

func (c *DefaultClient) RegionGet(ctx context.Context, name string) (*apiv1.Region, error)

func (*DefaultClient) RegionList

func (c *DefaultClient) RegionList(ctx context.Context) ([]apiv1.Region, error)

func (*DefaultClient) SecretCreate

func (c *DefaultClient) SecretCreate(ctx context.Context, name, secretType string, data map[string][]byte) (*apiv1.Secret, error)

func (*DefaultClient) SecretDelete

func (c *DefaultClient) SecretDelete(ctx context.Context, serverAddress string) (*apiv1.Secret, error)

func (*DefaultClient) SecretGet

func (c *DefaultClient) SecretGet(ctx context.Context, name string) (*apiv1.Secret, error)

func (*DefaultClient) SecretList

func (c *DefaultClient) SecretList(ctx context.Context) ([]apiv1.Secret, error)

func (*DefaultClient) SecretReveal

func (c *DefaultClient) SecretReveal(ctx context.Context, name string) (*apiv1.Secret, error)

func (*DefaultClient) SecretUpdate

func (c *DefaultClient) SecretUpdate(ctx context.Context, name string, data map[string][]byte) (*apiv1.Secret, error)

func (*DefaultClient) VolumeClassGet

func (c *DefaultClient) VolumeClassGet(ctx context.Context, name string) (*apiv1.VolumeClass, error)

func (*DefaultClient) VolumeClassList

func (c *DefaultClient) VolumeClassList(ctx context.Context) ([]apiv1.VolumeClass, error)

func (*DefaultClient) VolumeDelete

func (c *DefaultClient) VolumeDelete(ctx context.Context, name string) (*apiv1.Volume, error)

func (*DefaultClient) VolumeGet

func (c *DefaultClient) VolumeGet(ctx context.Context, name string) (*apiv1.Volume, error)

func (*DefaultClient) VolumeList

func (c *DefaultClient) VolumeList(ctx context.Context) (result []apiv1.Volume, _ error)

type DeferredClient

type DeferredClient struct {
	Project   string
	Namespace string
	New       func() (Client, error)
	Client    Client
	// contains filtered or unexported fields
}

func (*DeferredClient) AcornImageBuild

func (d *DeferredClient) AcornImageBuild(ctx context.Context, file string, opts *AcornImageBuildOptions) (*v1.AppImage, error)

func (*DeferredClient) AcornImageBuildDelete

func (d *DeferredClient) AcornImageBuildDelete(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (*DeferredClient) AcornImageBuildGet

func (d *DeferredClient) AcornImageBuildGet(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (*DeferredClient) AcornImageBuildList

func (d *DeferredClient) AcornImageBuildList(ctx context.Context) ([]apiv1.AcornImageBuild, error)

func (*DeferredClient) AppConfirmUpgrade

func (d *DeferredClient) AppConfirmUpgrade(ctx context.Context, name string) error

func (*DeferredClient) AppDelete

func (d *DeferredClient) AppDelete(ctx context.Context, name string) (*apiv1.App, error)

func (*DeferredClient) AppGet

func (d *DeferredClient) AppGet(ctx context.Context, name string) (*apiv1.App, error)

func (*DeferredClient) AppIgnoreDeleteCleanup

func (d *DeferredClient) AppIgnoreDeleteCleanup(ctx context.Context, name string) error

func (*DeferredClient) AppInfo

func (d *DeferredClient) AppInfo(ctx context.Context, name string) (string, error)

func (*DeferredClient) AppList

func (d *DeferredClient) AppList(ctx context.Context) ([]apiv1.App, error)

func (*DeferredClient) AppLog

func (d *DeferredClient) AppLog(ctx context.Context, name string, opts *LogOptions) (<-chan apiv1.LogMessage, error)

func (*DeferredClient) AppPullImage

func (d *DeferredClient) AppPullImage(ctx context.Context, name string) error

func (*DeferredClient) AppRun

func (d *DeferredClient) AppRun(ctx context.Context, image string, opts *AppRunOptions) (*apiv1.App, error)

func (*DeferredClient) AppStart

func (d *DeferredClient) AppStart(ctx context.Context, name string) error

func (*DeferredClient) AppStop

func (d *DeferredClient) AppStop(ctx context.Context, name string) error

func (*DeferredClient) AppUpdate

func (d *DeferredClient) AppUpdate(ctx context.Context, name string, opts *AppUpdateOptions) (*apiv1.App, error)

func (*DeferredClient) ComputeClassGet

func (d *DeferredClient) ComputeClassGet(ctx context.Context, name string) (*apiv1.ComputeClass, error)

func (*DeferredClient) ComputeClassList

func (d *DeferredClient) ComputeClassList(ctx context.Context) ([]apiv1.ComputeClass, error)

func (*DeferredClient) ContainerReplicaDelete

func (d *DeferredClient) ContainerReplicaDelete(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (*DeferredClient) ContainerReplicaExec

func (d *DeferredClient) ContainerReplicaExec(ctx context.Context, name string, args []string, tty bool, opts *ContainerReplicaExecOptions) (*term.ExecIO, error)

func (*DeferredClient) ContainerReplicaGet

func (d *DeferredClient) ContainerReplicaGet(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (*DeferredClient) ContainerReplicaList

func (d *DeferredClient) ContainerReplicaList(ctx context.Context, opts *ContainerReplicaListOptions) ([]apiv1.ContainerReplica, error)

func (*DeferredClient) ContainerReplicaPortForward

func (d *DeferredClient) ContainerReplicaPortForward(ctx context.Context, containerName string, port int) (PortForwardDialer, error)

func (*DeferredClient) CredentialCreate

func (d *DeferredClient) CredentialCreate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*DeferredClient) CredentialDelete

func (d *DeferredClient) CredentialDelete(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (*DeferredClient) CredentialGet

func (d *DeferredClient) CredentialGet(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (*DeferredClient) CredentialList

func (d *DeferredClient) CredentialList(ctx context.Context) ([]apiv1.Credential, error)

func (*DeferredClient) CredentialUpdate

func (d *DeferredClient) CredentialUpdate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*DeferredClient) DevSessionRelease

func (d *DeferredClient) DevSessionRelease(ctx context.Context, name string) error

func (*DeferredClient) DevSessionRenew

func (d *DeferredClient) DevSessionRenew(ctx context.Context, name string, client v1.DevSessionInstanceClient) error

func (*DeferredClient) EventStream

func (d *DeferredClient) EventStream(ctx context.Context, opts *EventStreamOptions) (<-chan apiv1.Event, error)

func (*DeferredClient) GetClient

func (d *DeferredClient) GetClient() (client.WithWatch, error)

func (*DeferredClient) GetNamespace

func (d *DeferredClient) GetNamespace() string

func (*DeferredClient) GetProject

func (d *DeferredClient) GetProject() string

func (*DeferredClient) ImageDelete

func (d *DeferredClient) ImageDelete(ctx context.Context, name string, opts *ImageDeleteOptions) (*apiv1.Image, []string, error)

func (*DeferredClient) ImageDetails

func (d *DeferredClient) ImageDetails(ctx context.Context, imageName string, opts *ImageDetailsOptions) (*ImageDetails, error)

func (*DeferredClient) ImageGet

func (d *DeferredClient) ImageGet(ctx context.Context, name string) (*apiv1.Image, error)

func (*DeferredClient) ImageList

func (d *DeferredClient) ImageList(ctx context.Context) ([]apiv1.Image, error)

func (*DeferredClient) ImagePull

func (d *DeferredClient) ImagePull(ctx context.Context, name string, opts *ImagePullOptions) (<-chan ImageProgress, error)

func (*DeferredClient) ImagePush

func (d *DeferredClient) ImagePush(ctx context.Context, tagName string, opts *ImagePushOptions) (<-chan ImageProgress, error)

func (*DeferredClient) ImageSign

func (d *DeferredClient) ImageSign(ctx context.Context, image string, payload []byte, signatureB64 string, opts *ImageSignOptions) (*apiv1.ImageSignature, error)

func (*DeferredClient) ImageTag

func (d *DeferredClient) ImageTag(ctx context.Context, image, tag string) error

func (*DeferredClient) ImageVerify

func (d *DeferredClient) ImageVerify(ctx context.Context, image string, opts *ImageVerifyOptions) (*apiv1.ImageSignature, error)

func (*DeferredClient) Info

func (d *DeferredClient) Info(ctx context.Context) ([]apiv1.Info, error)

func (*DeferredClient) JobGet

func (d *DeferredClient) JobGet(ctx context.Context, name string) (*apiv1.Job, error)

func (*DeferredClient) JobList

func (d *DeferredClient) JobList(ctx context.Context, opts *JobListOptions) ([]apiv1.Job, error)

func (*DeferredClient) JobRestart

func (d *DeferredClient) JobRestart(ctx context.Context, name string) error

func (*DeferredClient) KubeConfig

func (d *DeferredClient) KubeConfig(ctx context.Context, opts *KubeProxyAddressOptions) ([]byte, error)

func (*DeferredClient) KubeProxyAddress

func (d *DeferredClient) KubeProxyAddress(ctx context.Context, opts *KubeProxyAddressOptions) (string, error)

func (*DeferredClient) ProjectCreate

func (d *DeferredClient) ProjectCreate(ctx context.Context, name, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*DeferredClient) ProjectDelete

func (d *DeferredClient) ProjectDelete(ctx context.Context, name string) (*apiv1.Project, error)

func (*DeferredClient) ProjectGet

func (d *DeferredClient) ProjectGet(ctx context.Context, name string) (*apiv1.Project, error)

func (*DeferredClient) ProjectList

func (d *DeferredClient) ProjectList(ctx context.Context) ([]apiv1.Project, error)

func (*DeferredClient) ProjectUpdate

func (d *DeferredClient) ProjectUpdate(ctx context.Context, project *apiv1.Project, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*DeferredClient) RegionGet

func (d *DeferredClient) RegionGet(ctx context.Context, name string) (*apiv1.Region, error)

func (*DeferredClient) RegionList

func (d *DeferredClient) RegionList(ctx context.Context) ([]apiv1.Region, error)

func (*DeferredClient) SecretCreate

func (d *DeferredClient) SecretCreate(ctx context.Context, name, secretType string, data map[string][]byte) (*apiv1.Secret, error)

func (*DeferredClient) SecretDelete

func (d *DeferredClient) SecretDelete(ctx context.Context, name string) (*apiv1.Secret, error)

func (*DeferredClient) SecretGet

func (d *DeferredClient) SecretGet(ctx context.Context, name string) (*apiv1.Secret, error)

func (*DeferredClient) SecretList

func (d *DeferredClient) SecretList(ctx context.Context) ([]apiv1.Secret, error)

func (*DeferredClient) SecretReveal

func (d *DeferredClient) SecretReveal(ctx context.Context, name string) (*apiv1.Secret, error)

func (*DeferredClient) SecretUpdate

func (d *DeferredClient) SecretUpdate(ctx context.Context, name string, data map[string][]byte) (*apiv1.Secret, error)

func (*DeferredClient) VolumeClassGet

func (d *DeferredClient) VolumeClassGet(ctx context.Context, name string) (*apiv1.VolumeClass, error)

func (*DeferredClient) VolumeClassList

func (d *DeferredClient) VolumeClassList(ctx context.Context) ([]apiv1.VolumeClass, error)

func (*DeferredClient) VolumeDelete

func (d *DeferredClient) VolumeDelete(ctx context.Context, name string) (*apiv1.Volume, error)

func (*DeferredClient) VolumeGet

func (d *DeferredClient) VolumeGet(ctx context.Context, name string) (*apiv1.Volume, error)

func (*DeferredClient) VolumeList

func (d *DeferredClient) VolumeList(ctx context.Context) ([]apiv1.Volume, error)

type ErrNotAuthorized

type ErrNotAuthorized struct {
	Permissions []v1.Permissions
}

func (*ErrNotAuthorized) Error

func (e *ErrNotAuthorized) Error() string

type ErrRulesNeeded

type ErrRulesNeeded struct {
	Missing     []v1.Permissions
	Permissions []v1.Permissions
}

func (*ErrRulesNeeded) Error

func (e *ErrRulesNeeded) Error() string

type EventStreamOptions

type EventStreamOptions struct {
	Tail            int    `json:"tail,omitempty"`
	Follow          bool   `json:"follow,omitempty"`
	Prefix          string `json:"prefix,omitempty"`
	Since           string `json:"since,omitempty"`
	Until           string `json:"until,omitempty"`
	ResourceVersion string `json:"resourceVersion,omitempty"`
}

func (EventStreamOptions) ListOptions

func (o EventStreamOptions) ListOptions() *kclient.ListOptions

type Factory

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

func NewClientFactory

func NewClientFactory(restConfig *rest.Config) (*Factory, error)

func (*Factory) Namespace

func (f *Factory) Namespace(project, namespace string) Client

type IgnoreUninstalled

type IgnoreUninstalled struct {
	Client Client
}

func (IgnoreUninstalled) AcornImageBuild

func (c IgnoreUninstalled) AcornImageBuild(ctx context.Context, file string, opts *AcornImageBuildOptions) (*v1.AppImage, error)

func (IgnoreUninstalled) AcornImageBuildDelete

func (c IgnoreUninstalled) AcornImageBuildDelete(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (IgnoreUninstalled) AcornImageBuildGet

func (c IgnoreUninstalled) AcornImageBuildGet(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (IgnoreUninstalled) AcornImageBuildList

func (c IgnoreUninstalled) AcornImageBuildList(ctx context.Context) ([]apiv1.AcornImageBuild, error)

func (IgnoreUninstalled) AppConfirmUpgrade

func (c IgnoreUninstalled) AppConfirmUpgrade(ctx context.Context, name string) error

func (IgnoreUninstalled) AppDelete

func (c IgnoreUninstalled) AppDelete(ctx context.Context, name string) (*apiv1.App, error)

func (IgnoreUninstalled) AppGet

func (c IgnoreUninstalled) AppGet(ctx context.Context, name string) (*apiv1.App, error)

func (IgnoreUninstalled) AppList

func (c IgnoreUninstalled) AppList(ctx context.Context) ([]apiv1.App, error)

func (*IgnoreUninstalled) AppLog

func (c *IgnoreUninstalled) AppLog(ctx context.Context, name string, opts *LogOptions) (<-chan apiv1.LogMessage, error)

func (IgnoreUninstalled) AppPullImage

func (c IgnoreUninstalled) AppPullImage(ctx context.Context, name string) error

func (IgnoreUninstalled) AppRun

func (c IgnoreUninstalled) AppRun(ctx context.Context, image string, opts *AppRunOptions) (*apiv1.App, error)

func (*IgnoreUninstalled) AppSkipDeleteCleanup

func (c *IgnoreUninstalled) AppSkipDeleteCleanup(ctx context.Context, name string) error

func (IgnoreUninstalled) AppStart

func (c IgnoreUninstalled) AppStart(ctx context.Context, name string) error

func (IgnoreUninstalled) AppStop

func (c IgnoreUninstalled) AppStop(ctx context.Context, name string) error

func (IgnoreUninstalled) AppUpdate

func (c IgnoreUninstalled) AppUpdate(ctx context.Context, name string, opts *AppUpdateOptions) (*apiv1.App, error)

func (IgnoreUninstalled) ContainerReplicaDelete

func (c IgnoreUninstalled) ContainerReplicaDelete(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (IgnoreUninstalled) ContainerReplicaExec

func (c IgnoreUninstalled) ContainerReplicaExec(ctx context.Context, name string, args []string, tty bool, opts *ContainerReplicaExecOptions) (*term.ExecIO, error)

func (IgnoreUninstalled) ContainerReplicaGet

func (c IgnoreUninstalled) ContainerReplicaGet(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (IgnoreUninstalled) ContainerReplicaList

func (IgnoreUninstalled) ContainerReplicaPortForward

func (c IgnoreUninstalled) ContainerReplicaPortForward(ctx context.Context, name string, port int) (PortForwardDialer, error)

func (IgnoreUninstalled) CredentialCreate

func (c IgnoreUninstalled) CredentialCreate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (IgnoreUninstalled) CredentialDelete

func (c IgnoreUninstalled) CredentialDelete(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (IgnoreUninstalled) CredentialGet

func (c IgnoreUninstalled) CredentialGet(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (IgnoreUninstalled) CredentialList

func (c IgnoreUninstalled) CredentialList(ctx context.Context) ([]apiv1.Credential, error)

func (IgnoreUninstalled) CredentialUpdate

func (c IgnoreUninstalled) CredentialUpdate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*IgnoreUninstalled) DevSessionRelease

func (c *IgnoreUninstalled) DevSessionRelease(ctx context.Context, name string) error

func (*IgnoreUninstalled) DevSessionRenew

func (c *IgnoreUninstalled) DevSessionRenew(ctx context.Context, name string, client v1.DevSessionInstanceClient) error

func (IgnoreUninstalled) GetClient

func (c IgnoreUninstalled) GetClient() (kclient.WithWatch, error)

func (IgnoreUninstalled) GetNamespace

func (c IgnoreUninstalled) GetNamespace() string

func (IgnoreUninstalled) GetProject

func (c IgnoreUninstalled) GetProject() string

func (IgnoreUninstalled) ImageDelete

func (c IgnoreUninstalled) ImageDelete(ctx context.Context, name string, opts *ImageDeleteOptions) (*apiv1.Image, []string, error)

func (IgnoreUninstalled) ImageDetails

func (c IgnoreUninstalled) ImageDetails(ctx context.Context, imageName string, opts *ImageDetailsOptions) (*ImageDetails, error)

func (IgnoreUninstalled) ImageGet

func (c IgnoreUninstalled) ImageGet(ctx context.Context, name string) (*apiv1.Image, error)

func (IgnoreUninstalled) ImageList

func (c IgnoreUninstalled) ImageList(ctx context.Context) ([]apiv1.Image, error)

func (IgnoreUninstalled) ImagePull

func (c IgnoreUninstalled) ImagePull(ctx context.Context, name string, opts *ImagePullOptions) (<-chan ImageProgress, error)

func (IgnoreUninstalled) ImagePush

func (c IgnoreUninstalled) ImagePush(ctx context.Context, tagName string, opts *ImagePushOptions) (<-chan ImageProgress, error)

func (IgnoreUninstalled) ImageTag

func (c IgnoreUninstalled) ImageTag(ctx context.Context, image, tag string) error

func (IgnoreUninstalled) Info

func (c IgnoreUninstalled) Info(ctx context.Context) ([]apiv1.Info, error)

func (*IgnoreUninstalled) ProjectCreate

func (c *IgnoreUninstalled) ProjectCreate(ctx context.Context, name, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*IgnoreUninstalled) ProjectDelete

func (c *IgnoreUninstalled) ProjectDelete(ctx context.Context, name string) (*apiv1.Project, error)

func (*IgnoreUninstalled) ProjectGet

func (c *IgnoreUninstalled) ProjectGet(ctx context.Context, name string) (*apiv1.Project, error)

func (*IgnoreUninstalled) ProjectList

func (c *IgnoreUninstalled) ProjectList(ctx context.Context) ([]apiv1.Project, error)

func (*IgnoreUninstalled) ProjectUpdate

func (c *IgnoreUninstalled) ProjectUpdate(ctx context.Context, project *apiv1.Project, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (IgnoreUninstalled) SecretCreate

func (c IgnoreUninstalled) SecretCreate(ctx context.Context, name, secretType string, data map[string][]byte) (*apiv1.Secret, error)

func (IgnoreUninstalled) SecretDelete

func (c IgnoreUninstalled) SecretDelete(ctx context.Context, name string) (*apiv1.Secret, error)

func (IgnoreUninstalled) SecretGet

func (c IgnoreUninstalled) SecretGet(ctx context.Context, name string) (*apiv1.Secret, error)

func (IgnoreUninstalled) SecretList

func (c IgnoreUninstalled) SecretList(ctx context.Context) ([]apiv1.Secret, error)

func (IgnoreUninstalled) SecretReveal

func (c IgnoreUninstalled) SecretReveal(ctx context.Context, name string) (*apiv1.Secret, error)

func (IgnoreUninstalled) SecretUpdate

func (c IgnoreUninstalled) SecretUpdate(ctx context.Context, name string, data map[string][]byte) (*apiv1.Secret, error)

func (IgnoreUninstalled) VolumeClassGet

func (c IgnoreUninstalled) VolumeClassGet(ctx context.Context, name string) (*apiv1.VolumeClass, error)

func (IgnoreUninstalled) VolumeClassList

func (c IgnoreUninstalled) VolumeClassList(ctx context.Context) ([]apiv1.VolumeClass, error)

func (IgnoreUninstalled) VolumeDelete

func (c IgnoreUninstalled) VolumeDelete(ctx context.Context, name string) (*apiv1.Volume, error)

func (IgnoreUninstalled) VolumeGet

func (c IgnoreUninstalled) VolumeGet(ctx context.Context, name string) (*apiv1.Volume, error)

func (IgnoreUninstalled) VolumeList

func (c IgnoreUninstalled) VolumeList(ctx context.Context) ([]apiv1.Volume, error)

type ImageDeleteOptions

type ImageDeleteOptions struct {
	Force bool `json:"force,omitempty"`
}

type ImageDetails

type ImageDetails struct {
	AppImage        v1.AppImage         `json:"appImage,omitempty"`
	AppSpec         *v1.AppSpec         `json:"appSpec,omitempty"`
	Params          *v1.ParamSpec       `json:"params,omitempty"`
	ImageName       string              `json:"imageName,omitempty"`
	SignatureDigest string              `json:"signatureDigest,omitempty"`
	Readme          string              `json:"readme,omitempty"`
	ParseError      string              `json:"parseError,omitempty"`
	Permissions     []v1.Permissions    `json:"permissions,omitempty"`
	NestedImages    []apiv1.NestedImage `json:"nestedImages,omitempty"`
}

type ImageDetailsOptions

type ImageDetailsOptions struct {
	NestedDigest  string
	Profiles      []string
	DeployArgs    map[string]any
	Auth          *apiv1.RegistryAuth
	IncludeNested bool
	// NoDefaultRegistry - if true, indicates that no default container registry should be assumed when getting image details
	NoDefaultRegistry bool
}

type ImageProgress

type ImageProgress struct {
	Total       int64  `json:"total,omitempty"`
	Complete    int64  `json:"complete,omitempty"`
	Error       string `json:"error,omitempty"`
	CurrentTask string `json:"currentTask,omitempty"`
}

type ImagePullOptions

type ImagePullOptions struct {
	Auth *apiv1.RegistryAuth `json:"auth,omitempty"`
}

type ImagePushOptions

type ImagePushOptions struct {
	Auth *apiv1.RegistryAuth `json:"auth,omitempty"`
}

type ImageSignOptions

type ImageSignOptions struct {
	PublicKey string              `json:"publicKeys,omitempty"`
	Auth      *apiv1.RegistryAuth `json:"auth,omitempty"`
}

type ImageVerifyOptions

type ImageVerifyOptions struct {
	PublicKey    string              `json:"publicKeys,omitempty"`
	Annotations  map[string]string   `json:"annotations,omitempty"`
	Auth         *apiv1.RegistryAuth `json:"auth,omitempty"`
	NoVerifyName bool                `json:"noVerifyName,omitempty"`
}

type JobListOptions

type JobListOptions struct {
	App string `json:"app,omitempty"`
}

type KubeProxyAddressOptions

type KubeProxyAddressOptions struct {
	Region string `json:"region,omitempty"`
}

type LogOptions

type LogOptions struct {
	apiv1.LogOptions

	Logger ContainerLogsWriter
}

type MultiClient

type MultiClient struct {
	Factory ProjectClientFactory
	// contains filtered or unexported fields
}

func NewMultiClient

func NewMultiClient(project, namespace string, factory ProjectClientFactory) *MultiClient

func (*MultiClient) AcornImageBuild

func (m *MultiClient) AcornImageBuild(ctx context.Context, file string, opts *AcornImageBuildOptions) (result *v1.AppImage, err error)

func (*MultiClient) AcornImageBuildDelete

func (m *MultiClient) AcornImageBuildDelete(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (*MultiClient) AcornImageBuildGet

func (m *MultiClient) AcornImageBuildGet(ctx context.Context, name string) (*apiv1.AcornImageBuild, error)

func (*MultiClient) AcornImageBuildList

func (m *MultiClient) AcornImageBuildList(ctx context.Context) ([]apiv1.AcornImageBuild, error)

func (*MultiClient) AppConfirmUpgrade

func (m *MultiClient) AppConfirmUpgrade(ctx context.Context, name string) error

func (*MultiClient) AppDelete

func (m *MultiClient) AppDelete(ctx context.Context, name string) (*apiv1.App, error)

func (*MultiClient) AppGet

func (m *MultiClient) AppGet(ctx context.Context, name string) (*apiv1.App, error)

func (*MultiClient) AppIgnoreDeleteCleanup

func (m *MultiClient) AppIgnoreDeleteCleanup(ctx context.Context, name string) error

func (*MultiClient) AppInfo

func (m *MultiClient) AppInfo(ctx context.Context, name string) (string, error)

func (*MultiClient) AppList

func (m *MultiClient) AppList(ctx context.Context) ([]apiv1.App, error)

func (*MultiClient) AppLog

func (m *MultiClient) AppLog(ctx context.Context, name string, opts *LogOptions) (<-chan apiv1.LogMessage, error)

func (*MultiClient) AppPullImage

func (m *MultiClient) AppPullImage(ctx context.Context, name string) error

func (*MultiClient) AppRun

func (m *MultiClient) AppRun(ctx context.Context, image string, opts *AppRunOptions) (*apiv1.App, error)

func (*MultiClient) AppStart

func (m *MultiClient) AppStart(ctx context.Context, name string) error

func (*MultiClient) AppStop

func (m *MultiClient) AppStop(ctx context.Context, name string) error

func (*MultiClient) AppUpdate

func (m *MultiClient) AppUpdate(ctx context.Context, name string, opts *AppUpdateOptions) (*apiv1.App, error)

func (*MultiClient) ComputeClassGet

func (m *MultiClient) ComputeClassGet(ctx context.Context, name string) (*apiv1.ComputeClass, error)

func (*MultiClient) ComputeClassList

func (m *MultiClient) ComputeClassList(ctx context.Context) ([]apiv1.ComputeClass, error)

func (*MultiClient) ContainerReplicaDelete

func (m *MultiClient) ContainerReplicaDelete(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (*MultiClient) ContainerReplicaExec

func (m *MultiClient) ContainerReplicaExec(ctx context.Context, name string, args []string, tty bool, opts *ContainerReplicaExecOptions) (exec *term.ExecIO, err error)

func (*MultiClient) ContainerReplicaGet

func (m *MultiClient) ContainerReplicaGet(ctx context.Context, name string) (*apiv1.ContainerReplica, error)

func (*MultiClient) ContainerReplicaList

func (m *MultiClient) ContainerReplicaList(ctx context.Context, opts *ContainerReplicaListOptions) ([]apiv1.ContainerReplica, error)

func (*MultiClient) ContainerReplicaPortForward

func (m *MultiClient) ContainerReplicaPortForward(ctx context.Context, name string, port int) (dialer PortForwardDialer, err error)

func (*MultiClient) CredentialCreate

func (m *MultiClient) CredentialCreate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*MultiClient) CredentialDelete

func (m *MultiClient) CredentialDelete(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (*MultiClient) CredentialGet

func (m *MultiClient) CredentialGet(ctx context.Context, serverAddress string) (*apiv1.Credential, error)

func (*MultiClient) CredentialList

func (m *MultiClient) CredentialList(ctx context.Context) ([]apiv1.Credential, error)

func (*MultiClient) CredentialUpdate

func (m *MultiClient) CredentialUpdate(ctx context.Context, serverAddress, username, password string, skipChecks bool) (*apiv1.Credential, error)

func (*MultiClient) DevSessionRelease

func (m *MultiClient) DevSessionRelease(ctx context.Context, name string) error

func (*MultiClient) DevSessionRenew

func (m *MultiClient) DevSessionRenew(ctx context.Context, name string, client v1.DevSessionInstanceClient) error

func (*MultiClient) EventStream

func (m *MultiClient) EventStream(ctx context.Context, opts *EventStreamOptions) (<-chan apiv1.Event, error)

func (*MultiClient) GetClient

func (m *MultiClient) GetClient() (kclient.WithWatch, error)

func (*MultiClient) GetNamespace

func (m *MultiClient) GetNamespace() string

func (*MultiClient) GetProject

func (m *MultiClient) GetProject() string

func (*MultiClient) ImageDelete

func (m *MultiClient) ImageDelete(ctx context.Context, name string, opts *ImageDeleteOptions) (*apiv1.Image, []string, error)

func (*MultiClient) ImageDetails

func (m *MultiClient) ImageDetails(ctx context.Context, imageName string, opts *ImageDetailsOptions) (result *ImageDetails, err error)

func (*MultiClient) ImageGet

func (m *MultiClient) ImageGet(ctx context.Context, name string) (*apiv1.Image, error)

func (*MultiClient) ImageList

func (m *MultiClient) ImageList(ctx context.Context) ([]apiv1.Image, error)

func (*MultiClient) ImagePull

func (m *MultiClient) ImagePull(ctx context.Context, name string, opts *ImagePullOptions) (result <-chan ImageProgress, err error)

func (*MultiClient) ImagePush

func (m *MultiClient) ImagePush(ctx context.Context, tagName string, opts *ImagePushOptions) (result <-chan ImageProgress, err error)

func (*MultiClient) ImageSign

func (m *MultiClient) ImageSign(ctx context.Context, image string, payload []byte, signatureB64 string, opts *ImageSignOptions) (*apiv1.ImageSignature, error)

func (*MultiClient) ImageTag

func (m *MultiClient) ImageTag(ctx context.Context, image, tag string) error

func (*MultiClient) ImageVerify

func (m *MultiClient) ImageVerify(ctx context.Context, image string, opts *ImageVerifyOptions) (*apiv1.ImageSignature, error)

func (*MultiClient) Info

func (m *MultiClient) Info(ctx context.Context) ([]apiv1.Info, error)

func (*MultiClient) JobGet

func (m *MultiClient) JobGet(ctx context.Context, name string) (*apiv1.Job, error)

func (*MultiClient) JobList

func (m *MultiClient) JobList(ctx context.Context, opts *JobListOptions) ([]apiv1.Job, error)

func (*MultiClient) JobRestart

func (m *MultiClient) JobRestart(ctx context.Context, name string) error

func (*MultiClient) KubeConfig

func (m *MultiClient) KubeConfig(ctx context.Context, opts *KubeProxyAddressOptions) ([]byte, error)

func (*MultiClient) KubeProxyAddress

func (m *MultiClient) KubeProxyAddress(ctx context.Context, opts *KubeProxyAddressOptions) (string, error)

func (*MultiClient) ProjectCreate

func (m *MultiClient) ProjectCreate(ctx context.Context, name, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*MultiClient) ProjectDelete

func (m *MultiClient) ProjectDelete(ctx context.Context, name string) (*apiv1.Project, error)

func (*MultiClient) ProjectGet

func (m *MultiClient) ProjectGet(ctx context.Context, name string) (*apiv1.Project, error)

func (*MultiClient) ProjectList

func (m *MultiClient) ProjectList(ctx context.Context) ([]apiv1.Project, error)

func (*MultiClient) ProjectUpdate

func (m *MultiClient) ProjectUpdate(ctx context.Context, project *apiv1.Project, defaultRegion string, supportedRegions []string) (*apiv1.Project, error)

func (*MultiClient) RegionGet

func (m *MultiClient) RegionGet(ctx context.Context, name string) (*apiv1.Region, error)

func (*MultiClient) RegionList

func (m *MultiClient) RegionList(ctx context.Context) ([]apiv1.Region, error)

func (*MultiClient) SecretCreate

func (m *MultiClient) SecretCreate(ctx context.Context, name, secretType string, data map[string][]byte) (*apiv1.Secret, error)

func (*MultiClient) SecretDelete

func (m *MultiClient) SecretDelete(ctx context.Context, name string) (*apiv1.Secret, error)

func (*MultiClient) SecretGet

func (m *MultiClient) SecretGet(ctx context.Context, name string) (*apiv1.Secret, error)

func (*MultiClient) SecretList

func (m *MultiClient) SecretList(ctx context.Context) ([]apiv1.Secret, error)

func (*MultiClient) SecretReveal

func (m *MultiClient) SecretReveal(ctx context.Context, name string) (*apiv1.Secret, error)

func (*MultiClient) SecretUpdate

func (m *MultiClient) SecretUpdate(ctx context.Context, name string, data map[string][]byte) (*apiv1.Secret, error)

func (*MultiClient) VolumeClassGet

func (m *MultiClient) VolumeClassGet(ctx context.Context, name string) (*apiv1.VolumeClass, error)

func (*MultiClient) VolumeClassList

func (m *MultiClient) VolumeClassList(ctx context.Context) ([]apiv1.VolumeClass, error)

func (*MultiClient) VolumeDelete

func (m *MultiClient) VolumeDelete(ctx context.Context, name string) (*apiv1.Volume, error)

func (*MultiClient) VolumeGet

func (m *MultiClient) VolumeGet(ctx context.Context, name string) (*apiv1.Volume, error)

func (*MultiClient) VolumeList

func (m *MultiClient) VolumeList(ctx context.Context) ([]apiv1.Volume, error)

type ObjectPointer

type ObjectPointer[T any] interface {
	kclient.Object
	*T
}

type PortForwardDialer

type PortForwardDialer func(ctx context.Context) (net.Conn, error)

type ProjectClientFactory

type ProjectClientFactory interface {
	ForProject(ctx context.Context, project string) (Client, error)
	List(ctx context.Context) ([]Client, error)
	DefaultProject() string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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