managerutil

Documentation

Index

• func AgentImageFromSystemA(ctx context.Context) (string, error)
• func AgentsAreCompatible(agents []*rpc.AgentInfo) bool
• func GetAgentImage(ctx context.Context) string
• func GetExtendedAgentImage(ctx context.Context) (string, error)
• func GetSessionID(ctx context.Context) string
• func LoadEnv(ctx context.Context) (context.Context, error)
• func WithAgentImageRetriever(ctx context.Context, onChange func(context.Context, string) error) context.Context
• 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
  • func (e *Env) GeneratorConfig(qualifiedAgentImage string) (*agentmap.GeneratorConfig, error)
  • func (e *Env) GetAlsoProxySubnets() ([]*manager.IPNet, error)
  • func (e *Env) GetManagedNamespaces() []string
  • func (e *Env) GetNeverProxySubnets() ([]*manager.IPNet, error)
  • func (e *Env) QualifiedAgentImage() string
• type SystemaCRUDClient
• type UnauthdConnProvider
  • func (p *UnauthdConnProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (SystemaCRUDClient, error)
  • func (p *UnauthdConnProvider) GetAPIKey(ctx context.Context) (string, error)
  • func (p *UnauthdConnProvider) GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)
  • func (p *UnauthdConnProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)
  • func (p *UnauthdConnProvider) GetInstallID(ctx context.Context) (string, error)

Functions

func AgentImageFromSystemA

func AgentImageFromSystemA(ctx context.Context) (string, error)

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 GetAgentImage

func GetAgentImage(ctx context.Context) string

GetAgentImage returns the fully qualified name of the traffic-agent image, i.e. "docker.io/tel2:2.7.4"

func GetExtendedAgentImage

func GetExtendedAgentImage(ctx context.Context) (string, error)

GetExtendedAgentImage returns the fully qualified name of the extended traffic-agent image, e.g. "docker.io/datawire/ambassador-telepresence-agent:1.12.8", or error indicating that the image name doesn't match.

func GetSessionID

func GetSessionID(ctx context.Context) string

func LoadEnv

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

func WithAgentImageRetriever

func WithAgentImageRetriever(ctx context.Context, onChange func(context.Context, string) error) context.Context

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 {
	LogLevel       string `env:"LOG_LEVEL,default=info"`
	User           string `env:"USER,default="`
	ServerHost     string `env:"SERVER_HOST,default="`
	ServerPort     string `env:"SERVER_PORT,default=8081"`
	PrometheusPort string `env:"PROMETHEUS_PORT,default=0"`
	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"`
	AgentResources      string                     `env:"AGENT_RESOURCES,default="`
	AgentInitResources  string                     `env:"AGENT_INIT_RESOURCES,default="`
	APIPort             int32                      `env:"TELEPRESENCE_API_PORT,default="`
	TracingPort         int32                      `env:"TELEPRESENCE_GRPC_TRACE_PORT,default="`
	MaxReceiveSize      resource.Quantity          `env:"TELEPRESENCE_MAX_RECEIVE_SIZE,default=4Mi"`
	AppProtocolStrategy k8sapi.AppProtocolStrategy `env:"TELEPRESENCE_APP_PROTO_STRATEGY,default="`
	AgentInjectPolicy   agentconfig.InjectPolicy   `env:"AGENT_INJECT_POLICY,default="`

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

	DNSServiceName       string `env:"DNS_SERVICE_NAME,default=coredns"`
	DNSServiceNamespace  string `env:"DNS_SERVICE_NAMESPACE,default=kube-system"`
	DNSServiceIP         string `env:"DNS_SERVICE_IP,default="`
	DNSAlsoProxySubnets  string `env:"ALSO_PROXY_SUBNETS,default="`
	DNSNeverProxySubnets string `env:"NEVER_PROXY_SUBNETS,default="`
}

func GetEnv

func GetEnv(ctx context.Context) *Env

func (*Env) GeneratorConfig

func (e *Env) GeneratorConfig(qualifiedAgentImage string) (*agentmap.GeneratorConfig, error)

func (*Env) GetAlsoProxySubnets

func (e *Env) GetAlsoProxySubnets() ([]*manager.IPNet, error)

func (*Env) GetManagedNamespaces

func (e *Env) GetManagedNamespaces() []string

func (*Env) GetNeverProxySubnets

func (e *Env) GetNeverProxySubnets() ([]*manager.IPNet, error)

func (*Env) QualifiedAgentImage

func (e *Env) QualifiedAgentImage() string

type SystemaCRUDClient

type SystemaCRUDClient interface {
	systemarpc.SystemACRUDClient
	a8rcloud.Closeable
}

type UnauthdConnProvider

type UnauthdConnProvider struct {
	Config *manager.AmbassadorCloudConfig
}

func (*UnauthdConnProvider) BuildClient

func (p *UnauthdConnProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (SystemaCRUDClient, error)

func (*UnauthdConnProvider) GetAPIKey

func (p *UnauthdConnProvider) GetAPIKey(ctx context.Context) (string, error)

func (*UnauthdConnProvider) GetCloudConfig

func (p *UnauthdConnProvider) GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)

func (*UnauthdConnProvider) GetExtraHeaders

func (p *UnauthdConnProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)

func (*UnauthdConnProvider) GetInstallID

func (p *UnauthdConnProvider) GetInstallID(ctx context.Context) (string, error)