muxrpc

type CallError struct {
	Name    string `json:"name"`
	Message string `json:"message"`
	Stack   string `json:"stack"`
}

type CallType string

type Endpoint interface {
	// The different call types:
	Async(ctx context.Context, tipe interface{}, method Method, args ...interface{}) (interface{}, error)
	Source(ctx context.Context, tipe interface{}, method Method, args ...interface{}) (luigi.Source, error)
	Sink(ctx context.Context, method Method, args ...interface{}) (luigi.Sink, error)
	Duplex(ctx context.Context, tipe interface{}, method Method, args ...interface{}) (luigi.Source, luigi.Sink, error)

	// Do allows general calls
	Do(ctx context.Context, req *Request) error

	// Terminate wraps up the RPC session
	Terminate() error

	// Remote returns the network address of the remote
	Remote() net.Addr
}

type Handler interface {
	HandleCall(ctx context.Context, req *Request, edp Endpoint)
	HandleConnect(ctx context.Context, edp Endpoint)
}

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

type HandlerWrapper func(Handler) Handler

type Method []string

type NamedHandler struct {
	Method  Method
	Handler Handler
}

type Packer interface {
	luigi.Source
	luigi.Sink
}

type Request struct {
	// Stream allows sending and receiving packets
	Stream Stream `json:"-"`

	// Method is the name of the called function
	Method Method `json:"name"`
	// Args contains the call arguments
	RawArgs json.RawMessage `json:"args"`
	// Type is the type of the call, i.e. async, sink, source or duplex
	Type CallType `json:"type"`
	// contains filtered or unexported fields
}

type Server interface {
	Remote() net.Addr
	Serve(context.Context) error
}

type Stream interface {
	luigi.Source
	luigi.Sink
	luigi.ErrorCloser

	// WithType tells the stream in what type JSON data should be unmarshalled into
	WithType(tipe interface{})

	// WithReq tells the stream what request number should be used for sent messages
	WithReq(req int32)
}