connect

Documentation

Index

• Variables
• func CommandInitializer(cmd *cobra.Command) (err error)
• func DialDaemon(ctx context.Context, info *daemon.Info) (*grpc.ClientConn, error)
• func Disconnect(ctx context.Context)
• func DiscoverDaemon(ctx context.Context, match *regexp.Regexp, kubeContext, namespace string) (*daemon.UserClient, error)
• func EnsureSession(ctx context.Context, useLine string, required bool) (context.Context, error)
• func EnsureUserDaemon(ctx context.Context, required bool) (context.Context, error)
• func ExistingDaemon(ctx context.Context, info *daemon.Info) (*daemon.UserClient, error)
• func InitCommand(cmd *cobra.Command) (err error)
• func Quit(ctx context.Context)
• func RunConnect(cmd *cobra.Command, args []string) error
• func WithCommandInitializer(ctx context.Context, cmdInit func(cmd *cobra.Command) error) context.Context
• type ConnectError
  • func (ce *ConnectError) Code() connector.ConnectInfo_ErrType
  • func (ce *ConnectError) Unwrap() error

Variables

var (
	ErrNoUserDaemon = errors.New("telepresence user daemon is not running")
	ErrNoRootDaemon = errors.New("telepresence root daemon is not running")
)

var QuitDaemonFuncs = []func(context.Context){
	quitHostConnector, quitDockerDaemons,
}

Functions

func CommandInitializer

func CommandInitializer(cmd *cobra.Command) (err error)

func DialDaemon

func DialDaemon(ctx context.Context, info *daemon.Info) (*grpc.ClientConn, error)

DialDaemon dials the daemon appointed by the given info.

func Disconnect

func Disconnect(ctx context.Context)

Disconnect disconnects from a session in the user daemon.

func DiscoverDaemon

func DiscoverDaemon(ctx context.Context, match *regexp.Regexp, kubeContext, namespace string) (*daemon.UserClient, error)

DiscoverDaemon searches the daemon cache for an entry corresponding to the given name. A connection to that daemon is returned if such an entry is found.

func EnsureSession

func EnsureSession(ctx context.Context, useLine string, required bool) (context.Context, error)

func EnsureUserDaemon

func EnsureUserDaemon(ctx context.Context, required bool) (context.Context, error)

func ExistingDaemon

func ExistingDaemon(ctx context.Context, info *daemon.Info) (*daemon.UserClient, error)

func InitCommand

func InitCommand(cmd *cobra.Command) (err error)

func Quit

func Quit(ctx context.Context)

Quit shuts down all daemons.

func RunConnect

func RunConnect(cmd *cobra.Command, args []string) error

func WithCommandInitializer

func WithCommandInitializer(ctx context.Context, cmdInit func(cmd *cobra.Command) error) context.Context

Types

type ConnectError

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

func (*ConnectError) Code

func (ce *ConnectError) Code() connector.ConnectInfo_ErrType

func (*ConnectError) Unwrap

func (ce *ConnectError) Unwrap() error