userd

Documentation

Index

• Constants
• func Command(getCommands CommandFactory, daemonServices []DaemonService, ...) *cobra.Command
• func Notify(c context.Context, message string)
• type CommandFactory
• type DaemonService
• type SessionClient
  • func (c *SessionClient) Close(ctx context.Context) error
• type SessionClientProvider
  • func (p *SessionClientProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (*SessionClient, error)
  • func (p *SessionClientProvider) GetAPIKey(ctx context.Context) (string, error)
  • func (p *SessionClientProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)
  • func (p *SessionClientProvider) GetInstallID(ctx context.Context) (string, error)
  • func (p *SessionClientProvider) GetSystemaAddress(ctx context.Context) (string, error)
• type WithSession

Constants

const ProcessName = "connector"

Functions

func Command

func Command(getCommands CommandFactory, daemonServices []DaemonService, sessionServices []trafficmgr.SessionService) *cobra.Command

Command returns the CLI sub-command for "connector-foreground"

func Notify

func Notify(c context.Context, message string)

Notify displays a desktop banner notification to the user

Types

type CommandFactory

type CommandFactory func() cliutil.CommandGroups

type DaemonService

type DaemonService interface {
	Name() string
	// Start should start the daemon service. It's expected that it returns and does not block. Any long-running tasks should be
	// managed as goroutines started by Start.
	Start(ctx context.Context, scout *scout.Reporter, grpcServer *grpc.Server, withSession WithSession) error
}

A DaemonService is one that runs during the entire lifecycle of the daemon. This should be used to augment the daemon with GRPC services.

type SessionClient

type SessionClient struct {
	userdaemon.SystemAClient
	systema.UserDaemonSystemAProxyClient
}

func (*SessionClient) Close

func (c *SessionClient) Close(ctx context.Context) error

type SessionClientProvider

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

func (*SessionClientProvider) BuildClient

func (p *SessionClientProvider) BuildClient(ctx context.Context, conn *grpc.ClientConn) (*SessionClient, error)

func (*SessionClientProvider) GetAPIKey

func (p *SessionClientProvider) GetAPIKey(ctx context.Context) (string, error)

func (*SessionClientProvider) GetExtraHeaders

func (p *SessionClientProvider) GetExtraHeaders(ctx context.Context) (map[string]string, error)

func (*SessionClientProvider) GetInstallID

func (p *SessionClientProvider) GetInstallID(ctx context.Context) (string, error)

func (*SessionClientProvider) GetSystemaAddress

func (p *SessionClientProvider) GetSystemaAddress(ctx context.Context) (string, error)

type WithSession

type WithSession func(c context.Context, callName string, f func(context.Context, trafficmgr.Session) error) (err error)