daemon

Documentation

Index

• func WithDefaultRequest(ctx context.Context, cmd *cobra.Command) context.Context
• func WithSession(ctx context.Context, s *Session) context.Context
• func WithUserClient(ctx context.Context, ud *UserClient) context.Context
• type Request
  • func GetRequest(ctx context.Context) *Request
  • func InitRequest(cmd *cobra.Command) *Request
  • func (cr *Request) CommitFlags(cmd *cobra.Command)
• type Session
  • func GetSession(ctx context.Context) *Session
• type UserClient
  • func GetUserClient(ctx context.Context) *UserClient
  • func (ud *UserClient) DaemonPort() int

Functions

func WithDefaultRequest

func WithDefaultRequest(ctx context.Context, cmd *cobra.Command) context.Context

func WithSession

func WithSession(ctx context.Context, s *Session) context.Context

func WithUserClient

func WithUserClient(ctx context.Context, ud *UserClient) context.Context

Types

type Request

type Request struct {
	connector.ConnectRequest
	Docker bool

	// Request is created on-demand, not by InitRequest
	Implicit bool

	UserDaemonProfilingPort uint16
	RootDaemonProfilingPort uint16
	// contains filtered or unexported fields
}

func GetRequest

func GetRequest(ctx context.Context) *Request

func InitRequest

func InitRequest(cmd *cobra.Command) *Request

InitRequest adds the networking flags and Kubernetes flags to the given command and returns a Request and a FlagSet with the Kubernetes flags. The FlagSet is returned here so that a map of flags that gets modified can be extracted using FlagMap once the flag parsing has completed.

func (*Request) CommitFlags

func (cr *Request) CommitFlags(cmd *cobra.Command)

type Session

type Session struct {
	UserClient
	Info    *connector.ConnectInfo
	Started bool
}

func GetSession

func GetSession(ctx context.Context) *Session

type UserClient

type UserClient struct {
	connector.ConnectorClient
	Conn   *grpc.ClientConn
	Remote bool
}

func GetUserClient

func GetUserClient(ctx context.Context) *UserClient

func (*UserClient) DaemonPort

func (ud *UserClient) DaemonPort() int