managerutil

Documentation

Index

• func AgentsAreCompatible(agents []*rpc.AgentInfo) bool
• func GetSessionID(ctx context.Context) string
• func LoadEnv(ctx context.Context) (context.Context, error)
• func WithEnv(ctx context.Context, env *Env) context.Context
• func WithSessionID(ctx context.Context, sessionID string) context.Context
• func WithSessionInfo(ctx context.Context, si *manager.SessionInfo) context.Context
• type Env
  • func GetEnv(ctx context.Context) *Env

Functions

func AgentsAreCompatible

func AgentsAreCompatible(agents []*rpc.AgentInfo) bool

AgentsAreCompatible returns whether all the specified agents have the same product, version, and mechanisms. This might not be true for a number of reasons, such as when a deployment is restarting its Pods for an upgrade. This helper also compares Agent names as a sanity check.

func GetSessionID

func GetSessionID(ctx context.Context) string

func LoadEnv

func LoadEnv(ctx context.Context) (context.Context, error)

func WithEnv

func WithEnv(ctx context.Context, env *Env) context.Context

func WithSessionID

func WithSessionID(ctx context.Context, sessionID string) context.Context

func WithSessionInfo

func WithSessionInfo(ctx context.Context, si *manager.SessionInfo) context.Context

Types

type Env

type Env struct {
	User        string `env:"USER,default="`
	ServerHost  string `env:"SERVER_HOST,default="`
	ServerPort  string `env:"SERVER_PORT,default=8081"`
	SystemAHost string `env:"SYSTEMA_HOST,default=app.getambassador.io"`
	SystemAPort string `env:"SYSTEMA_PORT,default=443"`

	ManagerNamespace    string                     `env:"MANAGER_NAMESPACE,default="`
	ManagedNamespaces   string                     `env:"MANAGED_NAMESPACES,default="`
	AgentRegistry       string                     `env:"TELEPRESENCE_REGISTRY,default=docker.io/datawire"`
	AgentImage          string                     `env:"TELEPRESENCE_AGENT_IMAGE,default="`
	AgentPort           int32                      `env:"TELEPRESENCE_AGENT_PORT,default=9900"`
	APIPort             int32                      `env:"TELEPRESENCE_API_PORT,default="`
	MaxReceiveSize      resource.Quantity          `env:"TELEPRESENCE_MAX_RECEIVE_SIZE,default=4Mi"`
	AppProtocolStrategy k8sapi.AppProtocolStrategy `env:"TELEPRESENCE_APP_PROTO_STRATEGY,default="`

	PodCIDRStrategy string `env:"POD_CIDR_STRATEGY,default=auto"`
	PodCIDRs        string `env:"POD_CIDRS,default="`
	PodIP           string `env:"TELEPRESENCE_MANAGER_POD_IP,default="`
}

func GetEnv

func GetEnv(ctx context.Context) *Env