cliutil

Documentation

Index

• Variables
• func ClientEnsureLoggedIn(ctx context.Context, apikey string, connectorClient connector.ConnectorClient) (connector.LoginResult_Code, error)
• func CommandsToRPC(cmds CommandGroups) *connector.CommandGroups
• func Disconnect(ctx context.Context, quitUserDaemon, quitRootDaemon bool) (err error)
• func EnsureLoggedIn(ctx context.Context, apikey string) (connector.LoginResult_Code, error)
• func EnsureLoggedOut(ctx context.Context) error
• func GetCloudAPIKey(ctx context.Context, description string, autoLogin bool) (string, error)
• func GetCloudLicense(ctx context.Context, outputFile, id string) (string, string, error)
• func GetCloudUserInfo(ctx context.Context, autoLogin bool, refresh bool) (*connector.UserInfo, error)
• func GetTelepresencePro(ctx context.Context) error
• func HasLoggedIn(ctx context.Context) bool
• func Logout(ctx context.Context) error
• func UserDaemonDisconnect(ctx context.Context, quitUserDaemon bool) error
• func WithConnector(ctx context.Context, fn func(context.Context, connector.ConnectorClient) error) error
• func WithManager(ctx context.Context, fn func(context.Context, manager.ManagerClient) error) error
• func WithNetwork(ctx context.Context, fn func(context.Context, daemon.DaemonClient) error) error
• func WithStartedConnector(ctx context.Context, withNotify bool, ...) error
• func WithStartedNetwork(ctx context.Context, fn func(context.Context, daemon.DaemonClient) error) error
• type CommandGroups
  • func RPCToCommands(remote *connector.CommandGroups, runner func(*cobra.Command, []string) error) (CommandGroups, error)
• type FlagGroup
• type TypeEnum
  • func TypeFromString(s string) (TypeEnum, error)
  • func (t TypeEnum) NewFlagValueFromJson(untypedDefault interface{}) (Value, error)
  • func (t TypeEnum) NewFlagValueFromPFlagString(stringDefault string) (Value, error)
  • func (t *TypeEnum) UnmarshalJSON(dat []byte) error
• type Value

Variables

var ErrNoNetwork = errors.New("telepresence network is not established")

var ErrNoTrafficManager = errors.New("telepresence traffic manager is not connected")

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

Functions

func ClientEnsureLoggedIn

func ClientEnsureLoggedIn(ctx context.Context, apikey string, connectorClient connector.ConnectorClient) (connector.LoginResult_Code, error)

ClientEnsureLoggedIn is like EnsureLoggedIn but uses an already acquired ConnectorClient.

func CommandsToRPC

func CommandsToRPC(cmds CommandGroups) *connector.CommandGroups

func Disconnect

func Disconnect(ctx context.Context, quitUserDaemon, quitRootDaemon bool) (err error)

Disconnect shuts down a session in the root daemon. When it shuts down, it will tell the connector to shut down.

func EnsureLoggedIn

func EnsureLoggedIn(ctx context.Context, apikey string) (connector.LoginResult_Code, error)

EnsureLoggedIn ensures that the user is logged in to Ambassador Cloud. An error is returned if login fails. The result code will indicate if this is a new login or if it resued an existing login. If the `apikey` argument is empty an interactive login is performed; if it is non-empty the key is used instead of performing an interactive login.

func EnsureLoggedOut

func EnsureLoggedOut(ctx context.Context) error

EnsureLoggedOut ensures that the user is logged out of Ambassador Cloud. Returns nil if not logged in.

func GetCloudAPIKey

func GetCloudAPIKey(ctx context.Context, description string, autoLogin bool) (string, error)

func GetCloudLicense

func GetCloudLicense(ctx context.Context, outputFile, id string) (string, string, error)

GetCloudLicense communicates with system a to get the jwt version of the license, puts it in a kubernetes secret, and then writes that secret to the output file for the user to apply to their cluster

func GetCloudUserInfo

func GetCloudUserInfo(ctx context.Context, autoLogin bool, refresh bool) (*connector.UserInfo, error)

func GetTelepresencePro

func GetTelepresencePro(ctx context.Context) error

GetTelepresencePro prompts the user to optionally install Telepresence Pro if it isn't installed. If the user installs it, it also asks the user to automatically update their configuration to use the new binary.

func HasLoggedIn

func HasLoggedIn(ctx context.Context) bool

HasLoggedIn returns true if either the user has an active login session or an expired login session, and returns false if either the user has never logged in or has explicitly logged out.

func Logout

func Logout(ctx context.Context) error

Logout logs out of Ambassador Cloud. Returns an error if not logged in.

func UserDaemonDisconnect

func UserDaemonDisconnect(ctx context.Context, quitUserDaemon bool) error

func WithConnector

func WithConnector(ctx context.Context, fn func(context.Context, connector.ConnectorClient) error) error

WithConnector (1) ensures that the connector is running, (2) establishes a connection to it, and (3) runs the given function with that connection.

It streams to stdout any messages that the connector wants us to display to the user (which WithConnector listens for via the UserNotifications gRPC call). WithConnector does NOT make the "Connect" gRPC call or any other gRPC call except for UserNotifications.

Nested calls to WithConnector will reuse the outer connection.

func WithManager

func WithManager(ctx context.Context, fn func(context.Context, manager.ManagerClient) error) error

func WithNetwork

func WithNetwork(ctx context.Context, fn func(context.Context, daemon.DaemonClient) error) error

WithNetwork (1) ensures that the daemon is running, (2) establishes a connection to it, and (3) runs the given function with that connection.

Nested calls to WithNetwork will reuse the outer connection.

func WithStartedConnector

func WithStartedConnector(ctx context.Context, withNotify bool, fn func(context.Context, connector.ConnectorClient) error) error

WithStartedConnector is like WithConnector, but returns ErrNoUserDaemon if the connector is not already running, rather than starting it.

func WithStartedNetwork

func WithStartedNetwork(ctx context.Context, fn func(context.Context, daemon.DaemonClient) error) error

WithStartedNetwork is like WithNetwork, but returns ErrNoNetwork if the daemon is not already running, rather than starting it.

Types

type CommandGroups

type CommandGroups map[string][]*cobra.Command

func RPCToCommands

func RPCToCommands(remote *connector.CommandGroups, runner func(*cobra.Command, []string) error) (CommandGroups, error)

type FlagGroup

type FlagGroup struct {
	Name  string
	Flags *pflag.FlagSet
}

FlagGroup represents a group of flags and the name of that group

type TypeEnum

type TypeEnum string

TypeEnum is an enum-string that identifies the datatype to use both for (1) parsing the default value of a flag, and for (2) validating and normalizing the flag value that the user passes on the CLI.

See the `flagTypes` variable in `flagtypes.go` for a listing of valid values.

func TypeFromString

func TypeFromString(s string) (TypeEnum, error)

func (TypeEnum) NewFlagValueFromJson

func (t TypeEnum) NewFlagValueFromJson(untypedDefault interface{}) (Value, error)

func (TypeEnum) NewFlagValueFromPFlagString

func (t TypeEnum) NewFlagValueFromPFlagString(stringDefault string) (Value, error)

func (*TypeEnum) UnmarshalJSON

func (t *TypeEnum) UnmarshalJSON(dat []byte) error

type Value

type Value interface {
	pflag.Value
	AsArgs(flagname string) []string
}