core

type ClientCodec interface {
	ClientDispatcher(transport Transport) Service
}

type ClientCodecConfig struct {
	Name       string
	Uri        *url.URL
	KeepAlives bool
	TLSConfig  *tls.Config
}

type CodecFactory interface {
	ClientCodec(cfg *ClientCodecConfig) ClientCodec

	ServerCodec(cfg *ServerCodecConfig) ServerCodec
}

type Encoding interface {
	Marshal(v interface{}) ([]byte, error)

	Unmarshal(data []byte, v interface{}) error
}

type Endpoint interface {
}

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

type Request interface {
}

type Response interface {
}

type Server interface {
	Serve(ctxt context.Context) error
}

type ServerBuilder struct {
	Name              string
	Addr              net.Addr
	Backlog           int
	Daemon            bool
	Encoding          Encoding
	Codec             ServerCodec
	CodecFactory      CodecFactory
	TLSConfig         *tls.Config
	CertFile, KeyFile string
	Transport         Transport
}

type ServerCodec interface {
	ServerDispatcher(transport Transport, service Service) Server
}

type ServerCodecConfig struct {
	Name              string
	Addr              net.Addr
	KeepAlives        bool
	TLSConfig         *tls.Config
	CertFile, KeyFile string
}

type Service interface {
	Apply(ctxt context.Context, req Request) *promise.Future
}

type ServiceBuilder interface {
	Build(service Service) Server
}

type Transport interface {
	Read() *promise.Future // []byte

	Write() *promise.Future // int

	Close(deadline time.Time) *promise.Future // nil

	LocalAddr() net.Addr

	RemoteAddr() net.Addr
}