agent

type BuildAndStartEnvStream interface {
	Recv() (*proto.BuildAndStartEnvReply, error)
}

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

type ClientBuilder interface {
	Build(config ClientConfig) ClientInterface
}

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

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

	BuildAndStartEnv(
		startEnvRequest *proto.BuildAndStartEnvRequest,
		streamHandler func(stream BuildAndStartEnvStream) error,
	) error

	InitEnv(
		initEnvRequest *proto.InitEnvRequest,
		streamHandler func(stream InitEnvStream) error,
	) error
}

type DefaultClientBuilder struct{}

type InitEnvStream interface {
	Recv() (*proto.InitEnvReply, error)
}

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