agent

Documentation

Index

• func BuildAndStartDevEnvDefaultStreamHandler(stream BuildAndStartDevEnvStream) error
• func InitInstanceDefaultStreamHandler(stream InitInstanceStream) error
• type BuildAndStartDevEnvStream
• type Client
  • func NewClient(config ClientConfig) Client
  • func (c Client) BuildAndStartDevEnv(startDevEnvRequest *proto.BuildAndStartDevEnvRequest, ...) error
  • func (c Client) Execute(fnToExec func(agentGRPCClient proto.AgentClient) error) error
  • func (c Client) InitInstance(initInstanceRequest *proto.InitInstanceRequest, ...) 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

Functions

func BuildAndStartDevEnvDefaultStreamHandler

func BuildAndStartDevEnvDefaultStreamHandler(stream BuildAndStartDevEnvStream) error

func InitInstanceDefaultStreamHandler

func InitInstanceDefaultStreamHandler(stream InitInstanceStream) error

Types

type BuildAndStartDevEnvStream

type BuildAndStartDevEnvStream interface {
	Recv() (*proto.BuildAndStartDevEnvReply, error)
}

type Client

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

func NewClient

func NewClient(config ClientConfig) Client

func (Client) BuildAndStartDevEnv

func (c Client) BuildAndStartDevEnv(
	startDevEnvRequest *proto.BuildAndStartDevEnvRequest,
	streamHandler func(stream BuildAndStartDevEnvStream) 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

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

	BuildAndStartDevEnv(
		startDevEnvRequest *proto.BuildAndStartDevEnvRequest,
		streamHandler func(stream BuildAndStartDevEnvStream) 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)
}