trafficmgr

Documentation

Index

• Variables
• func CheckTrafficManagerService(ctx context.Context, namespace string) error
• func DeleteSessionInfoFromUserCache(ctx context.Context, daemonID *daemon.Identifier) error
• func InterceptError(tp common.InterceptError, err error) *rpc.InterceptResult
• func LoadSessionInfoFromUserCache(ctx context.Context, daemonID *daemon.Identifier) (*manager.SessionInfo, error)
• func NewSession(ctx context.Context, cr *rpc.ConnectRequest, config *client.Kubeconfig) (rc context.Context, _ userd.Session, info *connector.ConnectInfo)
• func SaveSessionInfoToUserCache(ctx context.Context, daemonID *daemon.Identifier, session *manager.SessionInfo) error
• type SavedSession

Variables

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

Functions

func CheckTrafficManagerService

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

func DeleteSessionInfoFromUserCache

func DeleteSessionInfoFromUserCache(ctx context.Context, daemonID *daemon.Identifier) 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, daemonID *daemon.Identifier) (*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,
	cr *rpc.ConnectRequest,
	config *client.Kubeconfig,
) (rc context.Context, _ userd.Session, info *connector.ConnectInfo)

func SaveSessionInfoToUserCache

func SaveSessionInfoToUserCache(ctx context.Context, daemonID *daemon.Identifier, 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 {
	KubeContext string               `json:"kubeContext"`
	Namespace   string               `json:"namespace"`
	Session     *manager.SessionInfo `json:"session"`
}