client

package
v0.8.0-alpha1 Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2023 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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)

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
	TargetNamespace     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
	TargetNamespace     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)
	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)

	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)

	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)
}

func New 

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

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) 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) (*apiv1.Image, []string, 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) ImageTag 

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

func (*DefaultClient) Info 

func (c *DefaultClient) Info(ctx context.Context) ([]apiv1.Info, 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) 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) ImageTag 

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

func (*DeferredClient) Info 

func (d *DeferredClient) Info(ctx context.Context) ([]apiv1.Info, 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 {
	Rule v1.PolicyRule
}

func (*ErrNotAuthorized) Error 

func (e *ErrNotAuthorized) Error() string

type ErrRulesNeeded 

type ErrRulesNeeded struct {
	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"`
	Details         bool   `json:"details,omitempty"`
	Prefix          string `json:"prefix,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 (c IgnoreUninstalled) ContainerReplicaList(ctx context.Context, opts *ContainerReplicaListOptions) ([]apiv1.ContainerReplica, error)

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"`
	ParseError string        `json:"parseError,omitempty"`
}

type ImageDetailsOptions 

type ImageDetailsOptions struct {
	NestedDigest string
	Profiles     []string
	DeployArgs   map[string]any
	Auth         *apiv1.RegistryAuth
}

type ImageProgress 

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

type ImagePullOptions 

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

type ImagePushOptions 

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

type LogOptions 

type LogOptions apiv1.LogOptions

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) 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) ImageTag 

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

func (*MultiClient) Info 

func (m *MultiClient) Info(ctx context.Context) ([]apiv1.Info, 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
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.