agent

Documentation

Index

• type CheckDomainReachabilityStream
• type Client
  • func NewClient(config ClientConfig) Client
  • func (c Client) CheckDomainReachability(checkDomainReachabilityRequest *proto.CheckDomainReachabilityRequest, ...) error
  • func (c Client) Execute(fnToExec func(agentGRPCClient proto.AgentClient) error) error
  • func (c Client) InitInstance(initInstanceRequest *proto.InitInstanceRequest, ...) error
  • func (c Client) InstallRuntimes(installRuntimesRequest *proto.InstallRuntimesRequest, ...) error
  • func (c Client) ReconcileServedPortsState(serveRequest *proto.ReconcileServedPortsStateRequest, ...) error
• type ClientBuilder
• type ClientConfig
  • func NewDefaultClientConfig(sshPrivateKeyBytes []byte, instancePublicIPAddress string) ClientConfig
• type ClientInterface
• type DefaultClientBuilder
  • func NewDefaultClientBuilder() DefaultClientBuilder
  • func (DefaultClientBuilder) Build(config ClientConfig) ClientInterface
• type InitInstanceStream
• type InstallRuntimesStream
• type ReconcileServedPortsStateStream

Types

type CheckDomainReachabilityStream

type CheckDomainReachabilityStream interface {
	Recv() (*proto.CheckDomainReachabilityReply, error)
}

type Client

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

func NewClient

func NewClient(config ClientConfig) Client

func (Client) CheckDomainReachability

func (c Client) CheckDomainReachability(
	checkDomainReachabilityRequest *proto.CheckDomainReachabilityRequest,
	streamHandler func(stream CheckDomainReachabilityStream) error,
) error

func (Client) Execute

func (c Client) Execute(fnToExec func(agentGRPCClient proto.AgentClient) error) error

func (Client) InitInstance

func (c Client) InitInstance(
	initInstanceRequest *proto.InitInstanceRequest,
	streamHandler func(stream InitInstanceStream) error,
) error

func (Client) InstallRuntimes

func (c Client) InstallRuntimes(
	installRuntimesRequest *proto.InstallRuntimesRequest,
	streamHandler func(stream InstallRuntimesStream) error,
) error

func (Client) ReconcileServedPortsState

func (c Client) ReconcileServedPortsState(
	serveRequest *proto.ReconcileServedPortsStateRequest,
	streamHandler func(stream ReconcileServedPortsStateStream) error,
) error

type ClientBuilder

type ClientBuilder interface {
	Build(config ClientConfig) ClientInterface
}

type ClientConfig

type ClientConfig struct {
	ServerRootUser           string
	ServerSSHPrivateKeyBytes []byte
	ServerAddr               string
	LocalAddr                string
	RemoteAddrProtocol       string
	RemoteAddr               string
}

func NewDefaultClientConfig

func NewDefaultClientConfig(
	sshPrivateKeyBytes []byte,
	instancePublicIPAddress string,
) ClientConfig

type ClientInterface

type ClientInterface interface {
	InitInstance(
		initInstanceRequest *proto.InitInstanceRequest,
		streamHandler func(stream InitInstanceStream) error,
	) error

	InstallRuntimes(
		installRuntimesRequest *proto.InstallRuntimesRequest,
		streamHandler func(stream InstallRuntimesStream) error,
	) error

	ReconcileServedPortsState(
		serveRequest *proto.ReconcileServedPortsStateRequest,
		streamHandler func(stream ReconcileServedPortsStateStream) error,
	) error

	CheckDomainReachability(
		checkDomainReachabilityRequest *proto.CheckDomainReachabilityRequest,
		streamHandler func(stream CheckDomainReachabilityStream) error,
	) error
}

type DefaultClientBuilder

type DefaultClientBuilder struct{}

func NewDefaultClientBuilder

func NewDefaultClientBuilder() DefaultClientBuilder

func (DefaultClientBuilder) Build

func (DefaultClientBuilder) Build(config ClientConfig) ClientInterface

type InitInstanceStream

type InitInstanceStream interface {
	Recv() (*proto.InitInstanceReply, error)
}

type InstallRuntimesStream

type InstallRuntimesStream interface {
	Recv() (*proto.InstallRuntimesReply, error)
}

type ReconcileServedPortsStateStream

type ReconcileServedPortsStateStream interface {
	Recv() (*proto.ReconcileServedPortsStateReply, error)
}