rpc

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

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

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

type IncomingMessage struct {
	Body []byte
}

type MessageSender interface {
	Send(msg *transport.Message) error
}

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

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

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

type RawConnection interface {
	Next() (*transport.Message, error)
	Send(msg *transport.Message) error
	Close() error
}

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

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

type RequestBody struct {
	Name []string        `json:"name"`
	Type string          `json:"type"`
	Args json.RawMessage `json:"args"`
}

type RequestHandler interface {
	// HandleRequest should respond to the provided request using the response
	// writer. Implementations must eventually call Stream.CloseWithError.
	// HandleRequest may block as it is executed in a goroutine.
	HandleRequest(ctx context.Context, s Stream, req *Request)
}

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

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

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

type ResponseStream interface {
	WriteMessage(body []byte, bodyType transport.MessageBodyType) error
	Channel() <-chan ResponseWithError
	Ctx() context.Context
}

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

type ResponseWithError struct {
	// Value is only set if Err is nil.
	Value *Response

	// If Err is not nil then it may be of ErrRemoteEnd, RemoteError or a
	// different error.
	Err error
}

type Stream interface {
	// WriteMessage sends a message over the underlying stream.
	WriteMessage(body []byte, bodyType transport.MessageBodyType) error

	// CloseWithError terminates the underlying stream. Error is sent to the
	// other party. Error can be nil.
	CloseWithError(err error) error

	// IncomingMessages gives the caller access to incoming messages. Returns an
	// error if this isn't a duplex stream.
	IncomingMessages() (<-chan IncomingMessage, error)
}