frisbee

package module

Go to main page

Versions in this module

v0

v0.1.3

Jul 28, 2021

Changes in this version

+ const DefaultBufferSize

+ const NEWSTREAM

+ const STREAMCLOSE

+ type Async struct

+ func ConnectAsync(network string, addr string, keepAlive time.Duration, logger *zerolog.Logger, ...) (*Async, error)

+ func NewAsync(c net.Conn, logger *zerolog.Logger) (conn *Async)

+ func (c *Async) Close() error

+ func (c *Async) Error() error

+ func (c *Async) Flush() error

+ func (c *Async) LocalAddr() net.Addr

+ func (c *Async) Logger() *zerolog.Logger

+ func (c *Async) NewStream(id uint64) *Stream

+ func (c *Async) Raw() net.Conn

+ func (c *Async) ReadMessage() (*Message, *[]byte, error)

+ func (c *Async) RemoteAddr() net.Addr

+ func (c *Async) SetDeadline(t time.Time) error

+ func (c *Async) SetReadDeadline(t time.Time) error

+ func (c *Async) SetWriteDeadline(t time.Time) error

+ func (c *Async) StreamChannel() <-chan *Stream

+ func (c *Async) WriteBufferSize() int

+ func (c *Async) WriteMessage(message *Message, content *[]byte) error

type Client

+ func (c *Client) Closed() bool

+ func (c *Client) Error() error

+ func (c *Client) NewStreamConn(id uint64) *Stream

+ func (c *Client) StreamChannel() <-chan *Stream

+ func (c *Client) WriteMessage(message *Message, content *[]byte) error

type Conn

+ SetDeadline func(time.Time) error

+ SetReadDeadline func(time.Time) error

+ SetWriteDeadline func(time.Time) error

type Option

+ func WithTLS(tlsConfig *tls.Config) Option

type Options

+ TLSConfig *tls.Config

+ type Stream struct

+ func (s *Stream) Close() error

+ func (s *Stream) Closed() bool

+ func (s *Stream) ID() uint64

+ func (s *Stream) Read(p []byte) (int, error)

+ func (s *Stream) ReadFrom(r io.Reader) (n int64, err error)

+ func (s *Stream) Write(p []byte) (int, error)

+ func (s *Stream) WriteTo(w io.Writer) (n int64, err error)

+ type Sync struct

+ func ConnectSync(network string, addr string, keepAlive time.Duration, logger *zerolog.Logger, ...) (*Sync, error)

+ func NewSync(c net.Conn, logger *zerolog.Logger) (conn *Sync)

+ func (c *Sync) Close() error

+ func (c *Sync) Error() error

+ func (c *Sync) LocalAddr() net.Addr

+ func (c *Sync) Logger() *zerolog.Logger

+ func (c *Sync) Raw() net.Conn

+ func (c *Sync) ReadMessage() (*Message, *[]byte, error)

+ func (c *Sync) RemoteAddr() net.Addr

+ func (c *Sync) SetDeadline(t time.Time) error

+ func (c *Sync) SetReadDeadline(t time.Time) error

+ func (c *Sync) SetWriteDeadline(t time.Time) error

+ func (c *Sync) WriteMessage(message *Message, content *[]byte) error

v0.1.2

Jun 15, 2021

Changes in this version

+ const BUFFER

+ const DEFAULT_BUFFER_SIZE

type Conn

+ func (c *Conn) ReadFrom(r io.Reader) (n int64, err error)

+ func (c *Conn) ReadMessage() (*Message, *[]byte, error)

+ func (c *Conn) WriteMessage(message *Message, content *[]byte) error

+ func (c *Conn) WriteTo(w io.Writer) (n int64, err error)

v0.1.1

Jun 3, 2021

Changes in this version

+ const RESERVED1

+ const RESERVED2

+ const RESERVED3

+ const RESERVED4

+ const RESERVED5

+ const RESERVED6

+ const RESERVED7

+ const RESERVED8

+ const RESERVED9

v0.1.0

May 31, 2021

Changes in this version

+ const ACCEPT

+ const CLOSE

+ const CLOSED

+ const CONNECTED

+ const DIAL

+ const HEARTBEAT

+ const NONE

+ const PAUSED

+ const POP

+ const PUSH

+ const READCONN

+ const SHUTDOWN

+ const WRITE

+ const WRITECONN

+ var ConnectionClosed = errors.New("connection closed")

+ var ConnectionNotInitialized = errors.New("connection not initialized")

+ var ConnectionPaused = errors.New("connection paused")

+ var DefaultLogger = zerolog.New(os.Stdout)

+ var InvalidBufferContents = errors.New("invalid buffer contents")

+ var InvalidBufferLength = errors.New("invalid buffer length")

+ var InvalidContentLength = errors.New("invalid content length")

+ type Action int

+ type Client struct

+ func NewClient(addr string, router ClientRouter, opts ...Option) *Client

+ func (c *Client) Close() error

+ func (c *Client) Connect() error

+ func (c *Client) Logger() *zerolog.Logger

+ func (c *Client) Raw() (net.Conn, error)

+ func (c *Client) Write(message *Message, content *[]byte) error

+ type ClientRouter map[uint32]ClientRouterFunc

+ type ClientRouterFunc func(incomingMessage Message, incomingContent []byte) (outgoingMessage *Message, outgoingContent []byte, action Action)

+ type Conn struct

+ func Connect(network string, addr string, keepAlive time.Duration, l *zerolog.Logger, ...) (*Conn, error)

+ func New(c net.Conn, l *zerolog.Logger, offset uint32) (conn *Conn)

+ func (c *Conn) Close() error

+ func (c *Conn) Error() error

+ func (c *Conn) Flush() error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) Logger() *zerolog.Logger

+ func (c *Conn) Offset() uint32

+ func (c *Conn) Raw() net.Conn

+ func (c *Conn) Read() (*Message, *[]byte, error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) Write(message *Message, content *[]byte) error

+ func (c *Conn) WriteBufferSize() int

+ type Message protocol.MessageV0

+ type Option func(opts *Options)

+ func WithHeartbeat(heartbeat time.Duration) Option

+ func WithKeepAlive(keepAlive time.Duration) Option

+ func WithLogger(logger *zerolog.Logger) Option

+ func WithOptions(options Options) Option

+ type Options struct

+ Heartbeat time.Duration

+ KeepAlive time.Duration

+ Logger *zerolog.Logger

+ type Server struct

+ OnClosed func(server *Server, c *Conn, err error) Action

+ OnOpened func(server *Server, c *Conn) Action

+ OnShutdown func(server *Server)

+ PreWrite func(server *Server)

+ func NewServer(addr string, router ServerRouter, opts ...Option) *Server

+ func (s *Server) Logger() *zerolog.Logger

+ func (s *Server) Shutdown() error

+ func (s *Server) Start() error

+ type ServerRouter map[uint32]ServerRouterFunc

+ type ServerRouterFunc func(c *Conn, incomingMessage Message, incomingContent []byte) (outgoingMessage *Message, outgoingContent []byte, action Action)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL