a8rcloud

Documentation

Index

• Constants
• func KeyDescAgent(spec *manager.InterceptSpec) string
• func WithSystemAPool[T Closeable](ctx context.Context, poolName string, provider ClientProvider[T]) context.Context
• type ClientProvider
  • func GetSystemAPoolProvider[T Closeable](ctx context.Context, poolName string) ClientProvider[T]
• type Closeable
• type HeaderProvider
• type SessionClient
• type SystemAPool
  • func GetSystemAPool[T Closeable](ctx context.Context, poolName string) (SystemAPool[T], error)

Constants

const (
	KeyDescWorkstation    = "telepresence:workstation"
	KeyDescTrafficManager = "telepresence:traffic-manager"

	// Not quite a real API key description, but the bogus name that we catalog the key under
	// when the user explicitly uses --apikey to pass us a key to use in order to create the
	// other keys.
	KeyDescRoot = ""
)

API key descriptions to use when requesting API keys from Ambassador Cloud.

const (
	ApiKeyHeader           = "X-Ambassador-Api-Key"
	InstallIDHeader        = "X-Ambassador-Install-ID"
	TrafficManagerIDHeader = "X-Telepresence-ManagerID"
)

const (
	TrafficManagerConnName        = "traffic-manager"
	UnauthdTrafficManagerConnName = "traffic-manager-unauth"
	UserdConnName                 = "userd"
)

Functions

func KeyDescAgent

func KeyDescAgent(spec *manager.InterceptSpec) string

func WithSystemAPool

func WithSystemAPool[T Closeable](ctx context.Context, poolName string, provider ClientProvider[T]) context.Context

Types

type ClientProvider

type ClientProvider[T Closeable] interface {
	HeaderProvider
	GetCloudConfig(ctx context.Context) (*manager.AmbassadorCloudConfig, error)
	BuildClient(ctx context.Context, conn *grpc.ClientConn) (T, error)
}

func GetSystemAPoolProvider

func GetSystemAPoolProvider[T Closeable](ctx context.Context, poolName string) ClientProvider[T]

type Closeable

type Closeable interface {
	Close(ctx context.Context) error
}

type HeaderProvider

type HeaderProvider interface {
	GetAPIKey(ctx context.Context) (string, error)
	GetInstallID(ctx context.Context) (string, error)
	GetExtraHeaders(ctx context.Context) (map[string]string, error)
}

type SessionClient

type SessionClient interface {
	userdaemon.SystemAClient
	systema.SystemACRUDClient
	systema.UserDaemonSystemAProxyClient
	Closeable
}

type SystemAPool

type SystemAPool[T Closeable] interface {
	Get(ctx context.Context) (T, error)
	Done(ctx context.Context) error
}

func GetSystemAPool

func GetSystemAPool[T Closeable](ctx context.Context, poolName string) (SystemAPool[T], error)