cborplugin

Feb 4, 2026

Changes in this version

type Request

+ IsParametersRequest bool

+ func NewParametersRequest() *Request

type Response

+ IsParametersResponse bool

+ Params map[string]interface{}

+ func NewParametersResponse(params map[string]interface{}) *Response

+ func (r *Response) IsRegularResponse() bool

Jun 2, 2024

Changes in this version

type Request

+ Delay time.Duration

+ RequestAt time.Time

+ SURB []byte

type Response

+ Delay time.Duration

+ ID uint64

+ RequestAt time.Time

+ SURB []byte

Apr 17, 2024

Changes in this version

type Request

+ ResponseSize int

Jul 17, 2023

Changes in this version

+ type Client struct

+ func NewClient(logBackend *log.Backend, capability, endpoint string, ...) *Client

+ func (c *Client) Capability() string

+ func (c *Client) GetParameters() *map[string]interface{}

+ func (c *Client) ReadChan() chan Command

+ func (c *Client) Start(command string, args []string) error

+ func (c *Client) WriteChan() chan Command

+ type ClientPlugin interface

+ OnCommand func(interface{}) (Command, error)

+ RegisterConsumer func(*Client)

+ type Command interface

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

+ Unmarshal func(b []byte) error

+ type CommandBuilder interface

+ Build func() Command

+ type CommandIO struct

+ func NewCommandIO(log *logging.Logger) *CommandIO

+ func (c *CommandIO) Accept()

+ func (c *CommandIO) ReadChan() chan Command

+ func (c *CommandIO) Start(initiator bool, socketFile string, commandBuilder CommandBuilder)

+ func (c *CommandIO) WriteChan() chan Command

+ type Parameters map[string]string

+ type Request struct

+ HasSURB bool

+ ID uint64

+ Payload []byte

+ func (r *Request) Marshal() ([]byte, error)

+ func (r *Request) Unmarshal(b []byte) error

+ type RequestFactory struct

+ func (r *RequestFactory) Build() Command

+ type Response struct

+ Payload []byte

+ func (r *Response) Marshal() ([]byte, error)

+ func (r *Response) Unmarshal(b []byte) error

+ type ResponseFactory struct

+ func (r *ResponseFactory) Build() Command

+ type Server struct

+ func NewServer(log *logging.Logger, socketFile string, commandBuilder CommandBuilder, ...) *Server

+ func (s *Server) Accept()

+ func (s *Server) Write(cmd Command)

+ type ServerPlugin interface

+ OnCommand func(Command) (Command, error)

+ RegisterConsumer func(*Server)

+ type ServicePlugin interface

+ Capability func() string

+ GetParameters func() *Parameters

+ Halt func()

+ OnRequest func(request *Request) ([]byte, error)