cluster

Documentation

Index

• Variables
• func CreateContainerInstance(ctx context.Context, machineType string, duration time.Duration, target string, ...) (*api.CreateContainersResponse, error)
• func InlineSsh(ctx context.Context, cluster *api.KubernetesCluster, sshAgent bool, ...) error
• func NewBareClusterCmd(hidden bool) *cobra.Command
• func NewBuildCmd() *cobra.Command
• func NewBuildkitCmd() *cobra.Command
• func NewClusterCmd(hidden bool) *cobra.Command
• func NewCreateCmd() *cobra.Command
• func NewDescribeCmd() *cobra.Command
• func NewDockerCmd() *cobra.Command
• func NewDockerCredHelperEraseCmd(hidden bool) *cobra.Command
• func NewDockerCredHelperGetCmd(hidden bool) *cobra.Command
• func NewDockerCredHelperListCmd(hidden bool) *cobra.Command
• func NewDockerCredHelperStoreCmd(hidden bool) *cobra.Command
• func NewExecScoped() *cobra.Command
• func NewExposeCmd() *cobra.Command
• func NewIngressCmd() *cobra.Command
• func NewKubeconfigCmd() *cobra.Command
• func NewKubectlCmd() *cobra.Command
• func NewListCmd() *cobra.Command
• func NewLogsCmd() *cobra.Command
• func NewMetadataCmd() *cobra.Command
• func NewProxyCmd() *cobra.Command
• func NewRunCmd() *cobra.Command
• func NewRunComposeCmd() *cobra.Command
• func NewSshCmd() *cobra.Command
• func NewTopCmd() *cobra.Command
• func NewVncCmd() *cobra.Command
• func NewVolumeCmd() *cobra.Command
• func PrintCreateClusterMsg(ctx context.Context)
• func PrintCreateContainersResult(ctx context.Context, output string, resp *api.CreateContainersResponse) error
• func SelectRunningCluster(ctx context.Context, args []string) (*api.KubernetesCluster, []string, error)
• type BuildClusterInstance
  • func NewBuildClusterInstance(ctx context.Context, platformStr string) (*BuildClusterInstance, error)
  • func NewBuildClusterInstance0(p api.BuildPlatform) *BuildClusterInstance
  • func (bp *BuildClusterInstance) NewConn(parentCtx context.Context) (net.Conn, string, error)
• type CreateContainerOpts
• type ProxyStatus
• type StatusData
• type Stream

Variables

var ErrEmptyClusterList = errors.New("no clusters")

Functions

func CreateContainerInstance

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

func InlineSsh

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

func NewBareClusterCmd

func NewBareClusterCmd(hidden bool) *cobra.Command

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

func NewBuildCmd

func NewBuildCmd() *cobra.Command

func NewBuildkitCmd

func NewBuildkitCmd() *cobra.Command

func NewClusterCmd

func NewClusterCmd(hidden bool) *cobra.Command

Used as `ns cluster`

func NewCreateCmd

func NewCreateCmd() *cobra.Command

func NewDescribeCmd

func NewDescribeCmd() *cobra.Command

func NewDockerCmd

func NewDockerCmd() *cobra.Command

func NewDockerCredHelperEraseCmd

func NewDockerCredHelperEraseCmd(hidden bool) *cobra.Command

func NewDockerCredHelperGetCmd

func NewDockerCredHelperGetCmd(hidden bool) *cobra.Command

func NewDockerCredHelperListCmd

func NewDockerCredHelperListCmd(hidden bool) *cobra.Command

func NewDockerCredHelperStoreCmd

func NewDockerCredHelperStoreCmd(hidden bool) *cobra.Command

func NewExecScoped

func NewExecScoped() *cobra.Command

func NewExposeCmd

func NewExposeCmd() *cobra.Command

func NewIngressCmd

func NewIngressCmd() *cobra.Command

func NewKubeconfigCmd

func NewKubeconfigCmd() *cobra.Command

func NewKubectlCmd

func NewKubectlCmd() *cobra.Command

func NewListCmd

func NewListCmd() *cobra.Command

func NewLogsCmd

func NewLogsCmd() *cobra.Command

func NewMetadataCmd

func NewMetadataCmd() *cobra.Command

func NewProxyCmd

func NewProxyCmd() *cobra.Command

func NewRunCmd

func NewRunCmd() *cobra.Command

func NewRunComposeCmd

func NewRunComposeCmd() *cobra.Command

func NewSshCmd

func NewSshCmd() *cobra.Command

func NewTopCmd

func NewTopCmd() *cobra.Command

func NewVncCmd

func NewVncCmd() *cobra.Command

func NewVolumeCmd

func NewVolumeCmd() *cobra.Command

func PrintCreateClusterMsg

func PrintCreateClusterMsg(ctx context.Context)

func PrintCreateContainersResult

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

func SelectRunningCluster

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

Types

type BuildClusterInstance

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

func NewBuildClusterInstance

func NewBuildClusterInstance(ctx context.Context, platformStr string) (*BuildClusterInstance, error)

func NewBuildClusterInstance0

func NewBuildClusterInstance0(p api.BuildPlatform) *BuildClusterInstance

func (*BuildClusterInstance) NewConn

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

type CreateContainerOpts

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 ProxyStatus

type ProxyStatus string

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

type StatusData

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

type Stream

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