srpc

Aug 5, 2024

Changes in this version

+ var ErrNilWriter = errors.New("writer cannot be nil")

Jul 26, 2024

Changes in this version

type ClientRPC

+ func (c *ClientRPC) WriteCallCancel() error

type MsgStreamRw

+ WriteCallCancel func() error

type ServerRPC

+ func (c *ServerRPC) WriteCallCancel() error

May 11, 2024

Changes in this version

type RawMessage

+ func (m *RawMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RawMessage) SizeVT() int

Apr 30, 2024

Changes in this version

type Packet_CallCancel

+ func (m *Packet_CallCancel) CloneOneofVT() isPacket_Body

type Packet_CallData

+ func (m *Packet_CallData) CloneOneofVT() isPacket_Body

type Packet_CallStart

+ func (m *Packet_CallStart) CloneOneofVT() isPacket_Body

Apr 22, 2024

Changes in this version

type CallData

+ func (x *CallData) MarshalProtoText() string

type CallStart

+ func (x *CallStart) MarshalProtoText() string

type Packet

+ func (x *Packet) MarshalProtoText() string

Apr 21, 2024

Changes in this version

type CallData

+ func (x *CallData) UnmarshalJSON(b []byte) error

+ func (x *CallData) UnmarshalProtoJSON(s *json.UnmarshalState)

type CallStart

+ func (x *CallStart) UnmarshalJSON(b []byte) error

+ func (x *CallStart) UnmarshalProtoJSON(s *json.UnmarshalState)

type Packet

+ func (x *Packet) UnmarshalJSON(b []byte) error

+ func (x *Packet) UnmarshalProtoJSON(s *json.UnmarshalState)

Apr 20, 2024

Changes in this version

type CallData

+ func (x *CallData) MarshalJSON() ([]byte, error)

+ func (x *CallData) MarshalProtoJSON(s *json.MarshalState)

type CallStart

+ func (x *CallStart) MarshalJSON() ([]byte, error)

+ func (x *CallStart) MarshalProtoJSON(s *json.MarshalState)

type Packet

+ func (x *Packet) MarshalJSON() ([]byte, error)

+ func (x *Packet) MarshalProtoJSON(s *json.MarshalState)

Mar 19, 2024

Changes in this version

+ type PushablePacketWriter struct — js/wasm

+ func NewPushablePacketWriter(pushable js.Value) *PushablePacketWriter

+ func (w *PushablePacketWriter) Close() error

+ func (w *PushablePacketWriter) WritePacket(pkt *Packet) error

Feb 29, 2024

Changes in this version

type PacketWriter

+ func NewPacketWriterWithClose(prw PacketWriter, close func() error) PacketWriter

Feb 29, 2024

Changes in this version

type Stream

+ func NewStreamWithClose(strm Stream, close func() error) Stream

Feb 26, 2024

Changes in this version

+ type StreamRecv interface

+ Recv func() (*T, error)

+ RecvTo func(*T) error

+ type StreamSend interface

+ Send func(*T) error

+ type StreamSendAndClose interface

+ SendAndClose func(*T) error

Feb 20, 2024

Changes in this version

+ type PacketWriter interface

+ Close func() error

+ WritePacket func(p *Packet) error

Dec 31, 2023

Changes in this version

+ type InvokerFunc func(serviceID, methodID string, strm Stream) (bool, error)

+ func (f InvokerFunc) InvokeMethod(serviceID, methodID string, strm Stream) (bool, error)

Sep 25, 2023

Changes in this version

+ type VClient struct

+ func NewVClient(c Client, le *logrus.Entry) *VClient

+ func (c *VClient) ExecCall(ctx context.Context, service, method string, in, out Message) (err error)

+ func (c *VClient) NewRawStream(ctx context.Context, msgHandler PacketDataHandler, closeHandler CloseHandler) (writer Writer, err error)

+ func (c *VClient) NewStream(ctx context.Context, service, method string, firstMsg Message) (stream Stream, err error)

+ type VMux struct

+ func NewVMux(mux Mux, le *logrus.Entry, veryVerbose bool) *VMux

+ func (v *VMux) HasService(serviceID string) (has bool)

+ func (v *VMux) HasServiceMethod(serviceID, methodID string) (has bool)

+ func (v *VMux) InvokeMethod(serviceID, methodID string, strm Stream) (done bool, err error)

+ func (v *VMux) Register(handler Handler) (err error)

Apr 4, 2023

Changes in this version

+ var ErrNoAvailableClients = errors.New("no available rpc clients")

type Client

+ NewRawStream func(ctx context.Context, msgHandler PacketDataHandler, closeHandler CloseHandler) (Writer, error)

type ClientSet

+ func (c *ClientSet) NewRawStream(ctx context.Context, msgHandler PacketDataHandler, closeHandler CloseHandler) (Writer, error)

+ type PacketDataHandler = func(data []byte) error

+ func NewPacketDataHandler(handler PacketHandler) PacketDataHandler

+ type PacketReadWriter struct

+ func (r *PacketReadWriter) Close() error

+ func (r *PacketReadWriter) ReadPump(cb PacketDataHandler, closed CloseHandler)

+ func (r *PacketReadWriter) ReadToHandler(cb PacketDataHandler) error

+ func (r *PacketReadWriter) Write(p []byte) (n int, err error)

+ func (r *PacketReadWriter) WritePacket(p *Packet) error

type PrefixClient

+ func (i *PrefixClient) NewRawStream(ctx context.Context, msgHandler PacketDataHandler, closeHandler CloseHandler) (Writer, error)

type RawMessage

+ func (m *RawMessage) Clear()

+ func (m *RawMessage) Reset()

+ type RawStreamCtor func(ctx context.Context, msgHandler PacketDataHandler, closeHandler CloseHandler) (Writer, error)

+ type RawStreamRwc struct

+ func NewRawStreamRwc(ctx context.Context, ctorFn RawStreamCtor) (*RawStreamRwc, error)

+ func (r *RawStreamRwc) Close() error

+ func (r *RawStreamRwc) Read(p []byte) (n int, err error)

+ func (r *RawStreamRwc) Write(p []byte) (int, error)

+ func (r *RawStreamRwc) WritePacket(p *Packet) error

type ServerRPC

+ func (r *ServerRPC) HandlePacketData(data []byte) error

+ type StreamRwc struct

+ func NewStreamRwc(strm Stream) *StreamRwc

+ func (s *StreamRwc) Read(p []byte) (n int, err error)

+ func (s *StreamRwc) Write(p []byte) (n int, err error)

type Writer

+ Write func(p []byte) (n int, err error)

Mar 21, 2023

Changes in this version

type CallData

+ func (m *CallData) CloneMessageVT() proto.Message

+ func (this *CallData) EqualMessageVT(thatMsg proto.Message) bool

type CallStart

+ func (m *CallStart) CloneMessageVT() proto.Message

+ func (this *CallStart) EqualMessageVT(thatMsg proto.Message) bool

type Packet

+ func (m *Packet) CloneMessageVT() proto.Message

+ func (this *Packet) EqualMessageVT(thatMsg proto.Message) bool

Feb 23, 2023

Changes in this version

+ func Listen(ctx context.Context, addr string, srv *Server, errCh <-chan error) error

type Client

+ func Dial(addr string) (Client, error)

Dec 2, 2022

Changes in this version

type ClientRPC

+ func (c *ClientRPC) WriteCancel() error

type ServerRPC

+ func (c *ServerRPC) WriteCancel() error

Dec 2, 2022

Changes in this version

+ type InvokerSlice []Invoker

+ func (s InvokerSlice) InvokeMethod(serviceID, methodID string, strm Stream) (bool, error)

+ type RawMessage struct

+ func NewRawMessage(data []byte, copy bool) *RawMessage

+ func (m *RawMessage) GetData() []byte

+ func (m *RawMessage) MarshalVT() ([]byte, error)

+ func (m *RawMessage) SetData(data []byte)

+ func (m *RawMessage) UnmarshalVT(data []byte) error

Nov 25, 2022

Changes in this version

type ClientRPC

+ func (c *ClientRPC) HandleCallCancel() error

+ func (c *ClientRPC) Wait(ctx context.Context) error

+ func (c *ClientRPC) WriteCallData(data []byte, complete bool, err error) error

+ type MsgStreamRw interface

+ ReadOne func() ([]byte, error)

+ WriteCallData func(data []byte, complete bool, err error) error

type ServerRPC

+ func (c *ServerRPC) HandleCallCancel() error

+ func (c *ServerRPC) ReadOne() ([]byte, error)

+ func (c *ServerRPC) WriteCallData(data []byte, complete bool, err error) error

Nov 11, 2022

Changes in this version

type ClientRPC

+ func (r *ClientRPC) SendCancel(writer Writer) error

type Packet

+ func NewCallCancelPacket() *Packet

+ func (x *Packet) GetCallCancel() bool

+ type Packet_CallCancel struct

+ CallCancel bool

+ func (m *Packet_CallCancel) CloneVT() isPacket_Body

+ func (m *Packet_CallCancel) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Packet_CallCancel) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Packet_CallCancel) SizeVT() (n int)

+ func (this *Packet_CallCancel) EqualVT(thatIface isPacket_Body) bool

Oct 25, 2022

Changes in this version

+ func NewYamuxConfig() *yamux.Config

Oct 25, 2022

Changes in this version

type CallData

+ func (m *CallData) CloneGenericVT() proto.Message

+ func (m *CallData) CloneVT() *CallData

type CallStart

+ func (m *CallStart) CloneGenericVT() proto.Message

+ func (m *CallStart) CloneVT() *CallStart

type Packet

+ func (m *Packet) CloneGenericVT() proto.Message

+ func (m *Packet) CloneVT() *Packet

type Packet_CallData

+ func (m *Packet_CallData) CloneVT() isPacket_Body

type Packet_CallStart

+ func (m *Packet_CallStart) CloneVT() isPacket_Body

Oct 15, 2022

Changes in this version

+ type ClientSet struct

+ func NewClientSet(clients []Client) *ClientSet

+ func (c *ClientSet) ExecCall(ctx context.Context, service, method string, in, out Message) error

+ func (c *ClientSet) NewStream(ctx context.Context, service, method string, firstMsg Message) (Stream, error)

Oct 12, 2022

Changes in this version

+ func CheckStripPrefix(id string, matchPrefixes []string) (strippedID string, matchedPrefix string)

type Client

+ ExecCall func(ctx context.Context, service, method string, in, out Message) error

+ type PrefixClient struct

+ func NewPrefixClient(client Client, serviceIDPrefixes []string) *PrefixClient

+ func (i *PrefixClient) ExecCall(ctx context.Context, service, method string, in, out Message) error

+ func (i *PrefixClient) NewStream(ctx context.Context, service, method string, firstMsg Message) (Stream, error)

Oct 12, 2022

Changes in this version

+ type PrefixInvoker struct

+ func NewPrefixInvoker(inv Invoker, serviceIDPrefixes []string) *PrefixInvoker

+ func (i *PrefixInvoker) InvokeMethod(serviceID, methodID string, strm Stream) (bool, error)

Oct 11, 2022

Changes in this version

+ func NewMuxedConnWithRwc(ctx context.Context, rwc io.ReadWriteCloser, outbound bool) (network.MuxedConn, error)

+ type RwcConn struct

+ func NewRwcConn(ctx context.Context, rwc io.ReadWriteCloser, laddr, raddr net.Addr, ...) *RwcConn

+ func (p *RwcConn) Close() error

+ func (p *RwcConn) LocalAddr() net.Addr

+ func (p *RwcConn) Read(b []byte) (n int, err error)

+ func (p *RwcConn) RemoteAddr() net.Addr

+ func (p *RwcConn) SetDeadline(t time.Time) error

+ func (p *RwcConn) SetReadDeadline(t time.Time) error

+ func (p *RwcConn) SetWriteDeadline(t time.Time) error

+ func (p *RwcConn) Write(pkt []byte) (n int, err error)

Oct 9, 2022

Changes in this version

+ type Invoker interface

+ InvokeMethod func(serviceID, methodID string, strm Stream) (bool, error)

type Mux

+ HasService func(serviceID string) bool

+ HasServiceMethod func(serviceID, methodID string) bool

type Server

+ func (s *Server) GetInvoker() Invoker

Sep 7, 2022

Changes in this version

type Packet_CallData

+ func (this *Packet_CallData) EqualVT(thatIface isPacket_Body) bool

type Packet_CallStart

+ func (this *Packet_CallStart) EqualVT(thatIface isPacket_Body) bool

Jul 10, 2022

Changes in this version

type ClientRPC

+ func (r *ClientRPC) ReadOne() ([]byte, error)

Jul 9, 2022

Changes in this version

+ func AcceptMuxedListener(ctx context.Context, lis net.Listener, srv *Server) error

Jul 9, 2022

Changes in this version

+ func NewMuxedConn(conn net.Conn, isServer bool) (network.MuxedConn, error)

type Client

+ func NewClientWithConn(conn net.Conn, isServer bool) (Client, error)

Jul 7, 2022

Changes in this version

type ClientRPC

+ func (r *ClientRPC) HandleStreamClose(closeErr error)

+ type CloseHandler = func(closeErr error)

type PacketReaderWriter

+ func (r *PacketReaderWriter) ReadToHandler(cb PacketHandler) error

type ServerRPC

+ func (r *ServerRPC) HandleStreamClose(closeErr error)

+ func (r *ServerRPC) Wait(ctx context.Context) error

Jun 25, 2022

Changes in this version

+ type MsgStream struct

+ func NewMsgStream(ctx context.Context, writer Writer, dataCh chan []byte) *MsgStream

+ func (r *MsgStream) Close() error

+ func (r *MsgStream) CloseSend() error

+ func (r *MsgStream) Context() context.Context

+ func (r *MsgStream) MsgRecv(msg Message) error

+ func (r *MsgStream) MsgSend(msg Message) error

type Server

+ func (s *Server) GetMux() Mux

Jun 24, 2022

Changes in this version

type Client

+ func NewClientWithMuxedConn(conn network.MuxedConn) Client

type OpenStreamFunc

+ func NewOpenStreamWithMuxedConn(conn network.MuxedConn) OpenStreamFunc

Jun 22, 2022

Changes in this version

type Server

+ func (s *Server) AcceptMuxedConn(ctx context.Context, mplex network.MuxedConn) error

+ func (s *Server) HandleStream(ctx context.Context, rwc io.ReadWriteCloser) error

Jun 20, 2022

Changes in this version

type CallData

+ DataIsZero bool

+ func (x *CallData) GetDataIsZero() bool

type CallStart

+ DataIsZero bool

+ func (x *CallStart) GetDataIsZero() bool

Jun 15, 2022

Changes in this version

+ var ErrCompleted = errors.New("unexpected packet after rpc was completed")

+ var ErrEmptyMethodID = errors.New("method id empty")

+ var ErrEmptyPacket = errors.New("invalid empty packet")

+ var ErrEmptyServiceID = errors.New("service id empty")

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidMessage = errors.New("invalid message")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnimplemented = errors.New("unimplemented")

+ var ErrUnrecognizedPacket = errors.New("unrecognized packet type")

+ var File_github_com_aperturerobotics_starpc_srpc_rpcproto_proto protoreflect.FileDescriptor

+ func NewPipeStream(ctx context.Context) (Stream, Stream)

+ type CallData struct

+ Complete bool

+ Data []byte

+ Error string

+ func (*CallData) Descriptor() ([]byte, []int)

+ func (*CallData) ProtoMessage()

+ func (m *CallData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CallData) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CallData) MarshalVT() (dAtA []byte, err error)

+ func (m *CallData) SizeVT() (n int)

+ func (m *CallData) UnmarshalVT(dAtA []byte) error

+ func (p *CallData) Validate() error

+ func (this *CallData) EqualVT(that *CallData) bool

+ func (x *CallData) GetComplete() bool

+ func (x *CallData) GetData() []byte

+ func (x *CallData) GetError() string

+ func (x *CallData) ProtoReflect() protoreflect.Message

+ func (x *CallData) Reset()

+ func (x *CallData) String() string

+ type CallStart struct

+ Data []byte

+ RpcMethod string

+ RpcService string

+ func (*CallStart) Descriptor() ([]byte, []int)

+ func (*CallStart) ProtoMessage()

+ func (m *CallStart) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CallStart) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CallStart) MarshalVT() (dAtA []byte, err error)

+ func (m *CallStart) SizeVT() (n int)

+ func (m *CallStart) UnmarshalVT(dAtA []byte) error

+ func (p *CallStart) Validate() error

+ func (this *CallStart) EqualVT(that *CallStart) bool

+ func (x *CallStart) GetData() []byte

+ func (x *CallStart) GetRpcMethod() string

+ func (x *CallStart) GetRpcService() string

+ func (x *CallStart) ProtoReflect() protoreflect.Message

+ func (x *CallStart) Reset()

+ func (x *CallStart) String() string

+ type CallStartResp struct

+ Error string

+ func (*CallStartResp) Descriptor() ([]byte, []int)

+ func (*CallStartResp) ProtoMessage()

+ func (m *CallStartResp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *CallStartResp) MarshalToVT(dAtA []byte) (int, error)

+ func (m *CallStartResp) MarshalVT() (dAtA []byte, err error)

+ func (m *CallStartResp) SizeVT() (n int)

+ func (m *CallStartResp) UnmarshalVT(dAtA []byte) error

+ func (p *CallStartResp) Validate() error

+ func (this *CallStartResp) EqualVT(that *CallStartResp) bool

+ func (x *CallStartResp) GetError() string

+ func (x *CallStartResp) ProtoReflect() protoreflect.Message

+ func (x *CallStartResp) Reset()

+ func (x *CallStartResp) String() string

+ type Client interface

+ Invoke func(ctx context.Context, service, method string, in, out Message) error

+ NewStream func(ctx context.Context, service, method string, firstMsg Message) (Stream, error)

+ func NewClient(openStream OpenStreamFunc) Client

+ type ClientRPC struct

+ func NewClientRPC(ctx context.Context, service, method string) *ClientRPC

+ func (r *ClientRPC) Close()

+ func (r *ClientRPC) Context() context.Context

+ func (r *ClientRPC) HandleCallData(pkt *CallData) error

+ func (r *ClientRPC) HandleCallStart(pkt *CallStart) error

+ func (r *ClientRPC) HandleCallStartResp(resp *CallStartResp) error

+ func (r *ClientRPC) HandlePacket(msg *Packet) error

+ func (r *ClientRPC) HandlePacketData(data []byte) error

+ func (r *ClientRPC) ReadAll() ([][]byte, error)

+ func (r *ClientRPC) Start(writer Writer, firstMsg []byte) error

+ type Conn interface

+ GetOpenStreamFunc func() OpenStreamFunc

+ type HTTPServer struct

+ func NewHTTPServer(mux Mux, path string) (*HTTPServer, error)

+ func (s *HTTPServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Handler interface

+ GetMethodIDs func() []string

+ GetServiceID func() string

+ InvokeMethod func(serviceID, methodID string, strm Stream) (bool, error)

+ type Message interface

+ MarshalVT func() ([]byte, error)

+ UnmarshalVT func([]byte) error

+ type Mux interface

+ InvokeMethod func(serviceID, methodID string, strm Stream) (bool, error)

+ Register func(handler Handler) error

+ func NewMux() Mux

+ type OpenStreamFunc = func(ctx context.Context, msgHandler func(pkt *Packet) error) (Writer, error)

+ func NewServerPipe(server *Server) OpenStreamFunc

+ type Packet struct

+ Body isPacket_Body

+ func NewCallDataPacket(data []byte, complete bool, err error) *Packet

+ func NewCallStartPacket(service, method string, data []byte) *Packet

+ func (*Packet) Descriptor() ([]byte, []int)

+ func (*Packet) ProtoMessage()

+ func (m *Packet) GetBody() isPacket_Body

+ func (m *Packet) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Packet) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Packet) MarshalVT() (dAtA []byte, err error)

+ func (m *Packet) SizeVT() (n int)

+ func (m *Packet) UnmarshalVT(dAtA []byte) error

+ func (p *Packet) Validate() error

+ func (this *Packet) EqualVT(that *Packet) bool

+ func (x *Packet) GetCallData() *CallData

+ func (x *Packet) GetCallStart() *CallStart

+ func (x *Packet) GetCallStartResp() *CallStartResp

+ func (x *Packet) ProtoReflect() protoreflect.Message

+ func (x *Packet) Reset()

+ func (x *Packet) String() string

+ type PacketHandler = func(pkt *Packet) error

+ type PacketReaderWriter struct

+ func NewPacketReadWriter(rw io.ReadWriteCloser, cb PacketHandler) *PacketReaderWriter

+ func (r *PacketReaderWriter) Close() error

+ func (r *PacketReaderWriter) ReadPump() error

+ func (r *PacketReaderWriter) WritePacket(p *Packet) error

+ type Packet_CallData struct

+ CallData *CallData

+ func (m *Packet_CallData) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Packet_CallData) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Packet_CallData) SizeVT() (n int)

+ type Packet_CallStart struct

+ CallStart *CallStart

+ func (m *Packet_CallStart) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Packet_CallStart) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Packet_CallStart) SizeVT() (n int)

+ type Packet_CallStartResp struct

+ CallStartResp *CallStartResp

+ func (m *Packet_CallStartResp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Packet_CallStartResp) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Packet_CallStartResp) SizeVT() (n int)

+ type RPCStream struct

+ func NewRPCStream(ctx context.Context, writer Writer, dataCh chan []byte) *RPCStream

+ func (r *RPCStream) Close() error

+ func (r *RPCStream) CloseSend() error

+ func (r *RPCStream) Context() context.Context

+ func (r *RPCStream) MsgRecv(msg Message) error

+ func (r *RPCStream) MsgSend(msg Message) error

+ type Server struct

+ func NewServer(mux Mux) *Server

+ func (s *Server) HandleConn(ctx context.Context, rwc io.ReadWriteCloser) error

+ type ServerRPC struct

+ func NewServerRPC(ctx context.Context, mux Mux) *ServerRPC

+ func (r *ServerRPC) Close()

+ func (r *ServerRPC) Context() context.Context

+ func (r *ServerRPC) HandleCallData(pkt *CallData) error

+ func (r *ServerRPC) HandleCallStart(pkt *CallStart) error

+ func (r *ServerRPC) HandleCallStartResp(resp *CallStartResp) error

+ func (r *ServerRPC) HandlePacket(msg *Packet) error

+ func (r *ServerRPC) SetWriter(w Writer)

+ type Stream interface

+ Close func() error

+ CloseSend func() error

+ Context func() context.Context

+ MsgRecv func(msg Message) error

+ MsgSend func(msg Message) error

+ type WebSocketConn struct

+ func NewWebSocketConn(ctx context.Context, conn *websocket.Conn, isServer bool) (*WebSocketConn, error)

+ func (w *WebSocketConn) AcceptStream() (io.ReadWriteCloser, error)

+ func (w *WebSocketConn) Close() error

+ func (w *WebSocketConn) GetOpenStreamFunc() OpenStreamFunc

+ func (w *WebSocketConn) GetWebSocket() *websocket.Conn

+ func (w *WebSocketConn) OpenStream(ctx context.Context, msgHandler func(pkt *Packet) error) (Writer, error)

+ type Writer interface

+ Close func() error

+ WritePacket func(p *Packet) error