cluster

package
v0.0.350 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2024 License: Apache-2.0 Imports: 116 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrEmptyClusterList = errors.New("no instances")

Functions

func CreateContainerInstance added in v0.0.291

func CreateContainerInstance(ctx context.Context, machineType string, duration time.Duration, target string, devmode bool, opts CreateContainerOpts) (*api.CreateContainersResponse, error)

func InlineSsh added in v0.0.291

func InlineSsh(ctx context.Context, cluster *api.KubernetesCluster, sshAgent bool, args []string) error

func NewBareClusterCmd added in v0.0.204

func NewBareClusterCmd(use string, hidden bool) *cobra.Command

Used by `nsc` (and as the basis to `ns cluster`)

func NewBuildCmd added in v0.0.178

func NewBuildCmd() *cobra.Command

func NewBuildkitCmd added in v0.0.204

func NewBuildkitCmd() *cobra.Command

func NewClusterCmd

func NewClusterCmd(hidden bool) *cobra.Command

Used as `ns cluster`

func NewCreateCmd added in v0.0.203

func NewCreateCmd() *cobra.Command

func NewDescribeCmd added in v0.0.230

func NewDescribeCmd() *cobra.Command

func NewDestroyCmd added in v0.0.350

func NewDestroyCmd() *cobra.Command

func NewDockerCmd added in v0.0.222

func NewDockerCmd() *cobra.Command

func NewDockerCredHelperEraseCmd added in v0.0.212

func NewDockerCredHelperEraseCmd(hidden bool) *cobra.Command

func NewDockerCredHelperGetCmd added in v0.0.212

func NewDockerCredHelperGetCmd(hidden bool) *cobra.Command

func NewDockerCredHelperListCmd added in v0.0.212

func NewDockerCredHelperListCmd(hidden bool) *cobra.Command

func NewDockerCredHelperStoreCmd added in v0.0.212

func NewDockerCredHelperStoreCmd(hidden bool) *cobra.Command

func NewExecScoped added in v0.0.231

func NewExecScoped() *cobra.Command

func NewExposeCmd added in v0.0.203

func NewExposeCmd() *cobra.Command

func NewIngressCmd added in v0.0.271

func NewIngressCmd() *cobra.Command

func NewKubeconfigCmd added in v0.0.209

func NewKubeconfigCmd() *cobra.Command

func NewKubectlCmd added in v0.0.161

func NewKubectlCmd() *cobra.Command

func NewListCmd added in v0.0.203

func NewListCmd() *cobra.Command

func NewLogsCmd added in v0.0.203

func NewLogsCmd() *cobra.Command

func NewMetadataCmd added in v0.0.203

func NewMetadataCmd() *cobra.Command

func NewProxyCmd added in v0.0.185

func NewProxyCmd() *cobra.Command

func NewRunCmd added in v0.0.203

func NewRunCmd() *cobra.Command

func NewRunComposeCmd added in v0.0.203

func NewRunComposeCmd() *cobra.Command

func NewSshCmd added in v0.0.203

func NewSshCmd() *cobra.Command

func NewTopCmd added in v0.0.289

func NewTopCmd() *cobra.Command

func NewVncCmd added in v0.0.329

func NewVncCmd() *cobra.Command

func NewVolumeCmd added in v0.0.299

func NewVolumeCmd() *cobra.Command

func PrintCreateClusterMsg added in v0.0.291

func PrintCreateClusterMsg(ctx context.Context)

func PrintCreateContainersResult added in v0.0.291

func PrintCreateContainersResult(ctx context.Context, output string, resp *api.CreateContainersResponse) error

func SelectRunningCluster added in v0.0.291

func SelectRunningCluster(ctx context.Context, args []string) (*api.KubernetesCluster, []string, error)

Types

type BuildCluster added in v0.0.341

type BuildCluster interface {
	NewConn(ctx context.Context) (net.Conn, string, error)
	GetPlatform() string
	RunBuildProxy(ctx context.Context, socketPath, controlSocketPath string, useGrpcProxy, annotateBuild bool, workersInfo *controlapi.ListWorkersResponse) (*buildProxy, error)
}

func NewBuildCluster added in v0.0.341

func NewBuildCluster(ctx context.Context, platformStr, buildkitSockPath string) (BuildCluster, error)

type CreateContainerOpts added in v0.0.291

type CreateContainerOpts struct {
	Name                 string
	Image                string
	Args                 []string
	Env                  map[string]string
	Flags                []string
	ExportedPorts        []exportContainerPort
	Features             []string
	Labels               map[string]string
	InternalExtra        string
	EnableDocker         bool
	ForwardNscState      bool
	ExposeNscBins        bool
	Network              string
	Experimental         any
	InstanceExperimental any
}

type LocalBuilderInstance added in v0.0.341

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

func NewLocalBuilderInstance added in v0.0.341

func NewLocalBuilderInstance(buildkitSockPath string) (*LocalBuilderInstance, error)

func (*LocalBuilderInstance) GetPlatform added in v0.0.341

func (l *LocalBuilderInstance) GetPlatform() string

func (*LocalBuilderInstance) NewConn added in v0.0.341

func (l *LocalBuilderInstance) NewConn(parentCtx context.Context) (net.Conn, string, error)

func (*LocalBuilderInstance) RunBuildProxy added in v0.0.341

func (l *LocalBuilderInstance) RunBuildProxy(ctx context.Context, socketPath, controlSocketPath string, useGrpcProxy, annotateBuild bool, workersInfo *controlapi.ListWorkersResponse) (*buildProxy, error)

type ProxyStatus added in v0.0.303

type ProxyStatus string
const (
	ProxyStatus_Starting ProxyStatus = "Starting"
	ProxyStatus_Running  ProxyStatus = "Running"
	ProxyStatus_Failing  ProxyStatus = "Failing"
)

type RemoteBuildClusterInstance added in v0.0.341

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

func NewRemoteBuildClusterInstance0 added in v0.0.341

func NewRemoteBuildClusterInstance0(p api.BuildPlatform) *RemoteBuildClusterInstance

func (*RemoteBuildClusterInstance) GetPlatform added in v0.0.341

func (bp *RemoteBuildClusterInstance) GetPlatform() string

func (*RemoteBuildClusterInstance) NewConn added in v0.0.341

func (bp *RemoteBuildClusterInstance) NewConn(parentCtx context.Context) (net.Conn, string, error)

func (*RemoteBuildClusterInstance) RunBuildProxy added in v0.0.341

func (bp *RemoteBuildClusterInstance) RunBuildProxy(ctx context.Context, socketPath, controlSocketPath string, useGrpcProxy, annotateBuild bool, workersInfo *controlapi.ListWorkersResponse) (*buildProxy, error)

type StatusData added in v0.0.318

type StatusData struct {
	Platform       string
	Status         ProxyStatus
	LastError      string
	LogPath        string
	LastInstanceID string
	LastUpdate     time.Time
	Requests       int
}

type Stream added in v0.0.281

type Stream interface {
	SendMsg(m interface{}) error
	RecvMsg(m interface{}) error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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