tcp

Documentation

Index

• func Decode(r io.Reader) ([]byte, error)
• func Encode(w io.Writer, encoded []byte) error
• type ClientTransport
  • func NewClientTransport(addr string) (*ClientTransport, error)
  • func (c *ClientTransport) Close() error
  • func (c *ClientTransport) Send(request []byte) ([]byte, error)
• type ServerTransport
  • func NewServerTransport(addr string) (*ServerTransport, error)
  • func (s *ServerTransport) Close() error
  • func (s *ServerTransport) Handler(handler func([]byte) ([]byte, error))
  • func (s *ServerTransport) Listen() error

Functions

func Decode

func Decode(r io.Reader) ([]byte, error)

func Encode

func Encode(w io.Writer, encoded []byte) error

Types

type ClientTransport

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

func NewClientTransport

func NewClientTransport(addr string) (*ClientTransport, error)

func (*ClientTransport) Close

func (c *ClientTransport) Close() error

func (*ClientTransport) Send

func (c *ClientTransport) Send(request []byte) ([]byte, error)

type ServerTransport

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

func NewServerTransport

func NewServerTransport(addr string) (*ServerTransport, error)

func (*ServerTransport) Close

func (s *ServerTransport) Close() error

func (*ServerTransport) Handler

func (s *ServerTransport) Handler(handler func([]byte) ([]byte, error))

func (*ServerTransport) Listen

func (s *ServerTransport) Listen() error