trafficmgr

Documentation

Index

• Variables
• func AddIntercept(sif userd.Session, c context.Context, ir *rpc.CreateInterceptRequest) *rpc.InterceptResult
• func AgentImageFromSystemA(ctx context.Context, v semver.Version) (string, error)
• func CanIntercept(sif userd.Session, c context.Context, ir *rpc.CreateInterceptRequest) (userd.InterceptInfo, *rpc.InterceptResult)
• func CheckTrafficManagerService(ctx context.Context, namespace string) error
• func DeleteSessionInfoFromUserCache(ctx context.Context) error
• func InterceptError(tp common.InterceptError, err error) *rpc.InterceptResult
• func LoadSessionInfoFromUserCache(ctx context.Context, host string) (*manager.SessionInfo, error)
• func NewSession(ctx context.Context, sr *scout.Reporter, cr *rpc.ConnectRequest, ...) (_ context.Context, _ userd.Session, cErr *connector.ConnectInfo)
• func SaveSessionInfoToUserCache(ctx context.Context, host string, session *manager.SessionInfo) error
• type SavedSession

Variables

var ErrSessionExpired = errors.New("session expired")

Functions

func AddIntercept

func AddIntercept(sif userd.Session, c context.Context, ir *rpc.CreateInterceptRequest) *rpc.InterceptResult

AddIntercept adds one intercept.

func AgentImageFromSystemA

func AgentImageFromSystemA(ctx context.Context, v semver.Version) (string, error)

AgentImageFromSystemA returns the systemA preferred agent Deprecated: not used with traffic-manager versions >= 2.6.0.

func CanIntercept

func CanIntercept(sif userd.Session, c context.Context, ir *rpc.CreateInterceptRequest) (userd.InterceptInfo, *rpc.InterceptResult)

CanIntercept checks if it is possible to create an intercept for the given request. The intercept can proceed only if the returned rpc.InterceptResult is nil. The returned runtime.Object is either nil, indicating a local intercept, or the workload for the intercept.

func CheckTrafficManagerService

func CheckTrafficManagerService(ctx context.Context, namespace string) error

func DeleteSessionInfoFromUserCache

func DeleteSessionInfoFromUserCache(ctx context.Context) error

DeleteSessionInfoFromUserCache removes SessionInfo cache if existing or returns an error. An attempt to remove a non-existing cache is a no-op and the function returns nil.

func InterceptError

func InterceptError(tp common.InterceptError, err error) *rpc.InterceptResult

func LoadSessionInfoFromUserCache

func LoadSessionInfoFromUserCache(ctx context.Context, host string) (*manager.SessionInfo, error)

LoadSessionInfoFromUserCache gets the SessionInfo from cache or returns an error if something goes wrong while loading or unmarshalling.

func NewSession

func NewSession(
	ctx context.Context,
	sr *scout.Reporter,
	cr *rpc.ConnectRequest,
	config *client.Kubeconfig,
) (_ context.Context, _ userd.Session, cErr *connector.ConnectInfo)

func SaveSessionInfoToUserCache

func SaveSessionInfoToUserCache(ctx context.Context, host string, session *manager.SessionInfo) error

SaveSessionInfoToUserCache saves the provided SessionInfo to user cache and returns an error if something goes wrong while marshalling or persisting.

Types

type SavedSession

type SavedSession struct {
	Host    string
	Session *manager.SessionInfo `json:"session"`
}