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
}

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.