dff

Aug 26, 2025

Changes in this version

+ type Client struct

+ Name string

+ Process ProcessFunc

+ func NewClient(name string, process ProcessFunc) *Client

+ func (c *Client) Close()

+ func (c *Client) Connect() error

+ func (c *Client) Run() error

+ type ProcessFunc func(method string, inputs [][]byte) ([]byte, error)

+ type Server struct

+ InputProvider func() [][]byte

+ Method string

+ func NewServer(method string, inputProvider func() [][]byte) *Server

+ func (s *Server) Shutdown()

+ func (s *Server) Start() error

+ func (s *Server) Stop(inputShmId int, inputShmBuffer []byte, registrationListener net.Listener)