forward

Nov 7, 2025

Changes in this version

type Client

+ func (c *Client) Reconnect() (err error)

Nov 2, 2025

Changes in this version

type Client

+ func (c *Client) Close() error

+ func (c *Client) Flush() error

Oct 31, 2025

Changes in this version

+ type AsciiFormatter struct

+ func NewAsciiFormatter(w io.Writer) *AsciiFormatter

+ func (a *AsciiFormatter) Write(p []byte) (n int, err error)

type ClientOptions

+ TLS bool

Mar 19, 2025

Changes in this version

type ServerOptions

+ HandleError func(err error)

+ ReadTimeout time.Duration

+ type ServerSession struct

+ func (ss *ServerSession) Buffered() int

+ func (ss *ServerSession) Close() error

+ func (ss *ServerSession) ID() uint64

+ func (ss *ServerSession) Log(str string, args ...any)

+ func (ss *ServerSession) Next(e *transport.Entry) (err error)

+ func (ss *ServerSession) Rewind()

+ func (ss *ServerSession) TimeConnected() time.Time

+ func (ss *ServerSession) TotalRead() int

+ func (ss *ServerSession) Username() string

Feb 20, 2025

Changes in this version

type ServerConn

+ func (s *ServerConn) Entries() iter.Seq2[time.Time, *msgpack.Iterator]

+ func (s *ServerConn) Tag() string

+ func (s *ServerConn) TotalRead() int

+ func (s *ServerConn) Username() string

Feb 19, 2025

Changes in this version

+ const ErrFailedAuth

+ const ErrFailedConn

+ const ErrInvalidEntry

+ const ErrInvalidHelo

+ const ErrInvalidNonce

+ const ErrInvalidPing

+ const ErrInvalidPong

+ const ErrInvalidSharedKey

+ const ErrNotSupported

+ const HELO

+ const PING

+ const PONG

+ func SharedKey(sharedKey []byte) func(clientHostname string) (sharedKey []byte, err error)

+ type AuthClient func(ctx context.Context) (Credentials, error)

+ func StaticAuthClient(cred Credentials) AuthClient

+ type AuthServer func(ctx context.Context, username string) (Credentials, error)

+ func StaticAuthServer(cred Credentials) AuthServer

+ type Client struct

+ func NewClient(addr string, opt ClientOptions) *Client

+ func (c *Client) Connect(ctx context.Context) (err error)

+ func (c *Client) Write(b []byte) (n int, err error)

+ func (c *Client) WriteBatch(tag string, size int, r io.Reader) (err error)

+ type ClientOptions struct

+ Auth AuthClient

+ Hostname string

+ type Credentials struct

+ Password string

+ SharedKey string

+ Username string

+ type Error string

+ func (err Error) Error() string

+ type Handler func(tag string, ts time.Time, iter *msgpack.Iterator, numFields int) error

+ type Server struct

+ func NewServer(opt ServerOptions) *Server

+ func (s *Server) Listen(ctx context.Context, handler Handler) (err error)

+ type ServerConn struct

+ func (s *ServerConn) Handle(ctx context.Context) (err error)

+ func (s *ServerConn) String() string

+ type ServerOptions struct

+ Address string

+ Auth AuthServer

+ Hostname string

+ PasswordAuth bool

+ Tls *tls.Config