server

type AgentTokenAuthenticationOptions struct {
	Enabled                bool
	AgentNamespace         string
	AgentServiceAccount    string
	AuthenticationAudience string
	KubernetesClient       kubernetes.Interface
}

type Backend interface {
	Send(p *client.Packet) error
	Recv() (*client.Packet, error)
	Context() context.Context
	GetAgentID() string
	GetAgentIdentifiers() header.Identifiers
}

type BackendManager interface {
	// Backend returns a single backend.
	// WARNING: the context passed to the function should be a session-scoped
	// context instead of a request-scoped context, as the backend manager will
	// pick a backend for every tunnel session and each tunnel session may
	// contains multiple requests.
	Backend(ctx context.Context) (Backend, error)
	BackendStorage
	ReadinessManager
}

type BackendStorage interface {
	// AddBackend adds a backend.
	AddBackend(identifier string, idType header.IdentifierType, backend Backend)
	// RemoveBackend removes a backend.
	RemoveBackend(identifier string, idType header.IdentifierType, backend Backend)
	// NumBackends returns the number of backends.
	NumBackends() int
}

type DefaultBackendManager struct {
	*DefaultBackendStorage
}

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

type DefaultRouteBackendManager struct {
	*DefaultBackendStorage
}

type DestHostBackendManager struct {
	*DefaultBackendStorage
}

type ErrNotFound struct{}

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

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

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

type ProxyClientConnection struct {
	Mode string
	HTTP io.ReadWriter

	CloseHTTP func() error
	// contains filtered or unexported fields
}

type ProxyServer struct {
	// BackendManagers contains a list of BackendManagers
	BackendManagers []BackendManager

	// Readiness reports if the proxy server is ready, i.e., if the proxy
	// server has connections to proxy agents (backends). Note that the
	// proxy server does not check the healthiness of the connections,
	// though the proxy agents do, so this readiness check might report
	// ready but there is no healthy connection.
	Readiness ReadinessManager

	PendingDial *PendingDialManager

	// agent authentication
	AgentAuthenticationOptions *AgentTokenAuthenticationOptions
	// contains filtered or unexported fields
}

type ProxyStrategy string

type ReadinessManager interface {
	// Ready returns if the proxy server is ready. If not, also return an
	// error message.
	Ready() (bool, string)
}

type Tunnel struct {
	Server *ProxyServer
}