execrpc

Apr 3, 2024

Changes in this version

+ const MessageStatusErrInitServerFailed

+ const MessageStatusInitServer

type ClientOptions

+ Config C

type ServerOptions

+ Init func(C) error

Mar 31, 2024

Changes in this version

+ const MessageStatusContinue

+ var ErrTimeoutWaitingForCall = errors.New("timed out waiting for call to complete")

+ type Call struct

+ Request Q

+ func (c *Call[Q, M, R]) Close(drop bool, r R)

+ func (c *Call[Q, M, R]) Enqueue(rr ...M)

+ func (c *Call[Q, M, R]) Receipt() <-chan R

+ func (c *Call[Q, M, R]) SendRaw(ms ...Message)

type Client

+ func (c *Client[Q, M, R]) MessagesRaw() <-chan Message

type ClientRaw

+ Messages chan Message

type Dispatcher

+ SendMessage func(...Message)

+ type Identity struct

+ ETag string

+ LastModified int64

+ Size uint32

+ func (i *Identity) SetELastModified(t int64)

+ func (i *Identity) SetESize(s uint32)

+ func (i *Identity) SetETag(s string)

+ func (i Identity) GetELastModified() int64

+ func (i Identity) GetESize() uint32

+ func (i Identity) GetETag() string

+ type LastModifiedProvider interface

+ GetELastModified func() int64

+ SetELastModified func(int64)

+ type Result struct

+ func (r Result[M, R]) Err() error

+ func (r Result[M, R]) Messages() <-chan M

+ func (r Result[M, R]) Receipt() <-chan R

type Server

+ func (s *Server[Q, M, R]) Start() error

type ServerOptions

+ DelayDelivery bool

+ GetHasher func() hash.Hash

+ Handle func(*Call[Q, M, R])

+ type SizeProvider interface

+ GetESize func() uint32

+ SetESize func(uint32)

+ type TagProvider interface

+ GetETag func() string

+ SetETag func(string)

Aug 14, 2022

Changes in this version

type ClientRawOptions

+ Dir string

Aug 12, 2022

Changes in this version

+ const MessageStatusErrDecodeFailed

+ const MessageStatusErrEncodeFailed

+ const MessageStatusOK

+ const MessageStatusSystemReservedMax

+ var ErrShutdown = errors.New("connection is shut down")

+ var ErrTimeoutWaitingForServer = errors.New("timed out waiting for server to start")

+ type Client struct

+ func StartClient(opts ClientOptions[Q, R]) (*Client[Q, R], error)

+ func (c *Client[Q, R]) Close() error

+ func (c *Client[Q, R]) Execute(r Q) (R, error)

+ type ClientOptions struct

+ Codec codecs.Codec[Q, R]

+ type ClientRaw struct

+ func StartClientRaw(opts ClientRawOptions) (*ClientRaw, error)

+ func (c *ClientRaw) Close() error

+ func (c *ClientRaw) Execute(body []byte) (Message, error)

+ type ClientRawOptions struct

+ Args []string

+ Cmd string

+ Env []string

+ OnMessage func(Message)

+ Timeout time.Duration

+ Version uint8

+ type Dispatcher interface

+ Send func(...Message) error

+ type Header struct

+ ID uint32

+ Size uint32

+ Status uint8

+ Version uint8

+ func (h *Header) Read(r io.Reader) error

+ func (h Header) Write(w io.Writer) error

+ type Message struct

+ Body []byte

+ Header Header

+ func (m *Message) Read(r io.Reader) error

+ func (m *Message) Write(w io.Writer) error

+ type Server struct

+ func NewServer(opts ServerOptions[Q, R]) (*Server[Q, R], error)

+ type ServerOptions struct

+ Call func(Dispatcher, Q) R

+ Codec codecs.Codec[R, Q]

+ type ServerRaw struct

+ func NewServerRaw(opts ServerRawOptions) (*ServerRaw, error)

+ func (s *ServerRaw) Start() error

+ func (s *ServerRaw) Wait() error

+ type ServerRawOptions struct

+ Call func(Dispatcher, Message) (Message, error)