mgrpc

type ConnectOption func(*connectOptions) error

type ErrorResponse struct {
	// Status is the numerical status code.
	Status int
	// Msg is a human-readable description of the error.
	Msg string
}

type GetCredsCallback func() (username, passwd string, err error)

type HTTPListenerConfig struct {
	// Accept RPC frames in POST requests.
	EnablePOST bool `yaml:"enable_post,omitempty"`
	// Allow upgrading to a WebSocket connection.
	// Note: Currently both POST and WebSocket cannot be used on the same listener.
	EnableWebSocket bool `yaml:"enable_websocket,omitempty"`
	// Cloud host base. If set, then for REST-like requests destination can be
	// specified in the Host header, and will be derived by stripping this suffix.
	CloudHost string `yaml:"cloud_host,omitempty"`
}

type Handler func(MgRPC, *frame.Frame) *frame.Frame

type ListenOption func(*ListenerConfig)

type ListenerConfig struct {
	// Address suitable for net.Listener (currently only TCP).
	Addr string `yaml:"addr"`
	// If present, connections will be wrapped in a TLS wrapper and this field
	// specifies the configuration.
	TLS *TLSConfig `yaml:"tls,omitempty"`

	// TCP listener sends RPC frames over plain TCP.
	TCP *TCPListenerConfig `yaml:"tcp,omitempty"`
	// HTTP listener uses HTTP POST requests to send RPC frames.
	// HTTP listener also supports WebSocket connections.
	HTTP *HTTPListenerConfig `yaml:"http,omitempty"`

	EnableTracing bool `yaml:"enable_tracing"`
}

type MgRPC interface {
	Call(
		ctx context.Context, dst string, cmd *frame.Command, getCreds GetCredsCallback,
	) (*frame.Response, error)
	AddHandler(method string, handler Handler)
	Disconnect(ctx context.Context) error
	IsConnected() bool
	SetCodecOptions(opts *codec.Options) error
}

type TCPListenerConfig struct {
}

type TLSConfig struct {
	// Certificate and key to be used by the server. Either a parsed Cert or file names for both
	// must be provided. It's ok to have certificate and key in the same file.
	Cert     *tls.Certificate `yaml:"-"`
	CertFile string           `yaml:"cert_file,omitempty"`
	KeyFile  string           `yaml:"key_file,omitempty"`
	// CA certificates to use to validate clients.
	// This enables requesting client certificate during handshake, which is off by default.
	// A pre-existing pool or a file to load from can be specified (but not both).
	ClientCAPool     *x509.CertPool `yaml:"-"`
	ClientCAPoolFile string         `yaml:"client_ca_pool_file,omitempty"`
}