agent

type CheckDomainReachabilityStream interface {
	Recv() (*proto.CheckDomainReachabilityReply, 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

	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 struct{}

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

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

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