wire

type ComposedConn struct {
	*bufio.Reader
	io.Writer
	io.Closer
	Recyclable
}

type Context interface {
	Account() *pb.Account
	ReadMarshal(v Unmarshaller) (byte, error)
	WriteMarshal(tag byte, v Marshaller) error

	// Forwards any data between the 2 contexts
	BridgeTo(other Context) error

	// Returns a writer that will send traffic as framed messages
	Writer() io.WriteCloser

	// Returns a reader that recieves traffic as framed messages
	Reader() io.Reader

	// Returns the total number of messages and bytes, respectively, that the
	// context has transmitted.
	Accounting() (int64, int64)

	// Close the context and cleanup any resources. Does not close
	// any IOs though.
	Close() error
}

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

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

type MarshalBytes []byte

type Marshaller interface {
	Size() int
	MarshalTo(b []byte) (int, error)
}

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

type RPCContext interface {
	Context
	ReadRequest(v Unmarshaller) error
	WriteResponse(v Marshaller) error
}

type RPCHandler interface {
	HandleRPC(ctx context.Context, wctx RPCContext) error
}

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

type ReadAdapter struct {
	FR *FramingReader
	// contains filtered or unexported fields
}

type ReadMarshaler interface {
	ReadMarshal(Unmarshaller) (byte, int, error)
}

type Recyclable interface {
	Recycle()
}

type ULID struct {
	ulid.ULID
}

type Unmarshaller interface {
	Unmarshal([]byte) error
}

type WriteAdapter struct {
	FW *FramingWriter
}

type WriteMarshaler interface {
	WriteMarshal(byte, Marshaller) (int, error)
}