p2p

Jan 29, 2022

Changes in this version

type PackageType

+ const Error

Jan 23, 2022

Changes in this version

type Client

+ func (c *Client) SetLogger(logger Logger)

type Server

+ func (s *Server) SetLogger(logger Logger)

Jan 23, 2022

Changes in this version

type Client

+ func (c *Client) SetSettings(stg *ClientSettings)

type Server

+ func (s *Server) SetSettings(stg *ServerSettings)

Jan 23, 2022

Changes in this version

+ var CipherKeyError = errors.New("cipher key error")

+ var UnexpectedPackage = errors.New("unexpected package type")

+ var UnsupportedPackage = errors.New("unsupported package type")

+ type Binary interface

+ GetBytes func() (bs []byte)

+ GetGob func(val interface{}) (err error)

+ GetJson func(val interface{}) (err error)

+ SetBytes func(bs []byte)

+ SetGob func(val interface{}) (err error)

+ SetJson func(val interface{}) (err error)

+ String func() (str string)

type Conn

+ func NewConn(conn net.Conn, limiter Limiter) (c Conn, err error)

+ func (c *Conn) ReadPackage(p *Package) (err error)

+ func (c *Conn) WritePackage(p Package) (err error)

+ type Data struct

+ Bytes []byte

+ func (d *Data) GetBytes() (bs []byte)

+ func (d *Data) GetGob(val interface{}) (err error)

+ func (d *Data) GetJson(val interface{}) (err error)

+ func (d *Data) SetBytes(bs []byte)

+ func (d *Data) SetGob(val interface{}) (err error)

+ func (d *Data) SetJson(val interface{}) (err error)

+ func (d *Data) String() (str string)

+ type Package struct

+ Type PackageType

+ type PackageType uint8

+ const Exchange

+ const Handshake

+ const Resume

+ type ResumeStatus bool

+ const ResumeImpossible

+ const ResumePossible

Jan 15, 2022

Changes in this version

+ type CipherKey []byte

+ func NewCipherKey() (key CipherKey, err error)

+ func (key CipherKey) Decode(bs []byte) (rs []byte, err error)

+ func (key CipherKey) Encode(bs []byte) (rs []byte, err error)

+ type CryptCipherKey []byte

Jan 15, 2022

Changes in this version

+ type CryptMessage []byte

+ func (cm CryptMessage) Decode(pk PrivateKey) (msg Message, err error)

type Message

+ func (msg Message) Encode(pk PublicKey) (cm CryptMessage, err error)

+ type PrivateKey struct

+ func (pk PrivateKey) Decode(bs []byte) (rs []byte, err error)

+ type PublicKey struct

+ Key rsa.PublicKey

+ func (pk PublicKey) Encode(bs []byte) (rs []byte, err error)

+ type RSA struct

+ func NewRSA() (r *RSA, err error)

+ func (r *RSA) PrivateKey() (pk PrivateKey)

+ func (r *RSA) PublicKey() (pk PublicKey)

Jan 11, 2022

Changes in this version

type Request

+ func (req *Request) GetBytes() (bs []byte)

+ func (req *Request) GetGob(val interface{}) (err error)

+ func (req *Request) GetJson(val interface{}) (err error)

+ func (req *Request) SetBytes(bs []byte)

+ func (req *Request) SetGob(val interface{}) (err error)

+ func (req *Request) SetJson(val interface{}) (err error)

+ func (req *Request) String() (str string)

type Response

+ func (res *Response) GetBytes() (bs []byte)

+ func (res *Response) GetGob(val interface{}) (err error)

+ func (res *Response) GetJson(val interface{}) (err error)

+ func (res *Response) SetBytes(bs []byte)

+ func (res *Response) SetGob(val interface{}) (err error)

+ func (res *Response) SetJson(val interface{}) (err error)

+ func (res *Response) String() (str string)

type Server

+ func (s *Server) SetHandle(topic string, handler Handler)

Jan 9, 2022

Changes in this version

type Server

+ func (s *Server) SetBytesHandle(topic string, bh BytesHandler)

+ func (s *Server) SetObjectHandle(topic string, oh ObjectHandler)

Jan 9, 2022

Changes in this version

+ var ConnectionError = errors.New("connection error")

+ var PresetConnectionError = errors.New("preset connection error")

+ func Decode(bs []byte) (val interface{}, err error)

+ func Encode(val interface{}) (bs []byte, err error)

+ func MustDecode(bs []byte) (val interface{})

+ func MustEncode(val interface{}) (bs []byte)

+ type BytesHandler func(ctx context.Context, req []byte) (res []byte, err error)

type Client

+ func (c *Client) SendBytes(topic string, req []byte) (res []byte, err error)

+ func (c *Client) SendObject(topic string, req interface{}) (res interface{}, err error)

+ type HandlerType uint

+ const BytesHandlerType

+ const ObjectHandlerType

type Message

+ Error error

+ type ObjectHandler func(ctx context.Context, req interface{}) (res interface{}, err error)

type Server

+ func (s *Server) AddBytesHandle(topic string, bh BytesHandler)

+ func (s *Server) AddObjectHandle(topic string, oh ObjectHandler)

Jan 9, 2022

Changes in this version

type Server

+ func (s *Server) SetContext(ctx context.Context)

Jan 9, 2022

Changes in this version

type Server

+ func (s *Server) Context(ctx context.Context)

Jan 8, 2022

Changes in this version

type ClientSettings

+ func (stg *ClientSettings) SetBodyLimit(limit uint)

type ServerSettings

+ func (stg *ServerSettings) SetBodyLimit(limit uint)

Jan 7, 2022

Changes in this version

+ const DefaultBodyLimit

+ const DefaultConnTimeout

+ const DefaultDelayTimeout

+ const DefaultHandleTimeout

+ const DefaultRetries

+ var UnsupportedTopic = errors.New("unsupported topic")

+ func NewStdLogger() (l *stdLogger)

+ type Client struct

+ func NewClient(tcp TCP, stg ClientSettings) (c *Client)

+ func (c *Client) Send(topic string, req []byte) (res []byte, err error)

+ type ClientSettings struct

+ func NewClientSettings() (stg ClientSettings)

+ func (stg *ClientSettings) SetConnTimeout(dur time.Duration)

+ func (stg *ClientSettings) SetLogger(l Logger)

+ func (stg *ClientSettings) SetRetry(retries uint, delay time.Duration)

+ type Conn struct

+ type Handler func(ctx context.Context, req []byte) (res []byte, err error)

+ type Limiter struct

+ type Logger interface

+ Error func(msg string)

+ Info func(msg string)

+ Warn func(msg string)

+ type Message struct

+ Content []byte

+ Topic string

+ type Metrics struct

+ type Retry struct

+ type Server struct

+ func NewServer(tcp TCP, stg ServerSettings) (s *Server)

+ func (s *Server) Close() (err error)

+ func (s *Server) Handle(topic string, handler Handler)

+ func (s *Server) Serve() (err error)

+ type ServerSettings struct

+ func NewServerSettings() (stg ServerSettings)

+ func (stg *ServerSettings) SetConnTimeout(dur time.Duration)

+ func (stg *ServerSettings) SetHandleTimeout(dur time.Duration)

+ func (stg *ServerSettings) SetLogger(l Logger)

+ type Timeout struct

Mar 9, 2021

Changes in this version

+ const DefaultRequestLimit

+ const DefaultTimeout

+ var RequestTooLarge = errors.New("request too large")

+ type Request struct

+ Body []byte

+ type Response struct

+ func (res *Response) Send(bs []byte) (err error)

+ type TCP struct

+ func NewTCP(host string, port uint) (tcp *TCP)

+ func (tcp *TCP) Close() (err error)

+ func (tcp *TCP) GetRequestLimit() (limit int)

+ func (tcp *TCP) GetTimeout() (timeout time.Duration)

+ func (tcp *TCP) Handle(handler func(req *Request, res *Response)) (err error)

+ func (tcp *TCP) Send(bytes []byte) (result []byte, err error)

+ func (tcp *TCP) SetRequestLimit(limit int)

+ func (tcp *TCP) SetTimeout(timeout time.Duration)