sharedstate

Documentation

Index

• type State
  • func NewState(ctx context.Context, procName string) (*State, error)
  • func (s *State) GetCloudAPIKey(ctx context.Context, desc string, autoLogin bool) (string, error)
  • func (s *State) GetCloudUserInfo(ctx context.Context, refresh, autoLogin bool) (*authdata.UserInfo, error)
  • func (s *State) GetClusterBlocking(ctx context.Context) (*userd_k8s.Cluster, error)
  • func (s *State) GetClusterNonBlocking() *userd_k8s.Cluster
  • func (s *State) GetTrafficManagerBlocking(ctx context.Context) (TrafficManager, error)
  • func (s *State) GetTrafficManagerNonBlocking() TrafficManager
  • func (s *State) MaybeSetCluster(cluster *userd_k8s.Cluster) bool
  • func (s *State) MaybeSetTrafficManager(mgr TrafficManager) bool
  • func (s *State) SetLogLevel(ctx context.Context, level string, duration time.Duration) error
• type TrafficManager

Types

type State

type State struct {
	LoginExecutor     userd_auth.LoginExecutor
	UserNotifications broadcastqueue.BroadcastQueue
	// contains filtered or unexported fields
}

func NewState

func NewState(ctx context.Context, procName string) (*State, error)

func (*State) GetCloudAPIKey

func (s *State) GetCloudAPIKey(ctx context.Context, desc string, autoLogin bool) (string, error)

func (*State) GetCloudUserInfo

func (s *State) GetCloudUserInfo(ctx context.Context, refresh, autoLogin bool) (*authdata.UserInfo, error)

func (*State) GetClusterBlocking

func (s *State) GetClusterBlocking(ctx context.Context) (*userd_k8s.Cluster, error)

func (*State) GetClusterNonBlocking

func (s *State) GetClusterNonBlocking() *userd_k8s.Cluster

func (*State) GetTrafficManagerBlocking

func (s *State) GetTrafficManagerBlocking(ctx context.Context) (TrafficManager, error)

func (*State) GetTrafficManagerNonBlocking

func (s *State) GetTrafficManagerNonBlocking() TrafficManager

func (*State) MaybeSetCluster

func (s *State) MaybeSetCluster(cluster *userd_k8s.Cluster) bool

func (*State) MaybeSetTrafficManager

func (s *State) MaybeSetTrafficManager(mgr TrafficManager) bool

func (*State) SetLogLevel

func (s *State) SetLogLevel(ctx context.Context, level string, duration time.Duration) error

type TrafficManager

type TrafficManager interface {
	// Run is the "main" method that runs in a dedicated persistent goroutine.
	Run(context.Context) error

	// GetClientBlocking returns a client object for talking to the manager.  If communication
	// is not yet established, GetClientBlocking blocks until it is (or until the Context is
	// canceled).  Error is non-nil if either there is an error establishing communication or if
	// the context is canceled.
	GetClientBlocking(ctx context.Context) (manager.ManagerClient, error)

	// GetClientNonBlocking is similar to GetClientBlocking, but if communication is not yet
	// established then it immediately returns (nil, nil) rather than blocking; this is the only
	// scenario in which both are nil.
	GetClientNonBlocking() (manager.ManagerClient, error)

	AddIntercept(context.Context, *connector.CreateInterceptRequest) (*connector.InterceptResult, error)
	RemoveIntercept(context.Context, string) error
	WorkloadInfoSnapshot(context.Context, *connector.ListRequest) *connector.WorkloadInfoSnapshot
	Uninstall(context.Context, *connector.UninstallRequest) (*connector.UninstallResult, error)
	SetStatus(context.Context, *connector.ConnectInfo)
}

A TrafficManager implementation is essentially the goroutine that handles communication with the in-cluster Traffic Manager. It includes a "Run" method which is what runs in the goroutine, and several other methods to communicate with that goroutine.