client

package

Go to main page

Versions in this module

v0

v0.4.0

Oct 21, 2025

v0.3.0

Apr 25, 2024

Changes in this version

type DefaultWSConnectionFactory

+ Header http.Header

+ type WSConnError struct

+ ConnErr error

+ ResponseBody string

+ StatusCode int

+ func NewWSConnError(err error, statusCode int, respBody string) *WSConnError

+ func (e *WSConnError) Error() string

+ func (e *WSConnError) IsRetryable() bool

v0.2.2

Feb 23, 2023

v0.2.1

Sep 26, 2022

v0.2.0

Jun 27, 2022

Changes in this version

type Client

+ func (c *Client) SendCompressed(tag string, entries protocol.EntryList) error

+ func (c *Client) SendCompressedFromBytes(tag string, entries []byte) error

+ func (c *Client) SendForward(tag string, entries protocol.EntryList) error

+ func (c *Client) SendMessage(tag string, record interface{}) error

+ func (c *Client) SendMessageExt(tag string, record interface{}) error

+ func (c *Client) SendPacked(tag string, entries protocol.EntryList) error

+ func (c *Client) SendPackedFromBytes(tag string, entries []byte) error

type MessageClient

+ SendCompressed func(tag string, entries protocol.EntryList) error

+ SendCompressedFromBytes func(tag string, entries []byte) error

+ SendForward func(tag string, entries protocol.EntryList) error

+ SendMessage func(tag string, record interface{}) error

+ SendMessageExt func(tag string, record interface{}) error

+ SendPacked func(tag string, entries protocol.EntryList) error

+ SendPackedFromBytes func(tag string, entries []byte) error

v0.1.1

Feb 3, 2022

v0.1.0

Feb 3, 2022

Changes in this version

+ const AuthorizationHeader

+ const BinaryMessage

+ const DefaultConnectionTimeout

+ const TextMessage

+ type AuthInfo struct

+ Password string

+ SharedKey []byte

+ Username string

+ type Client struct

+ AuthInfo AuthInfo

+ Hostname string

+ RequireAck bool

+ Timeout time.Duration

+ func New(opts ConnectionOptions) *Client

+ func (c *Client) Connect() error

+ func (c *Client) Disconnect() error

+ func (c *Client) Handshake() error

+ func (c *Client) Reconnect() error

+ func (c *Client) Send(e protocol.ChunkEncoder) error

+ func (c *Client) SendRaw(m []byte) error

+ func (c *Client) TransportPhase() bool

+ type ConnFactory struct

+ Address string

+ Network string

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ func (f *ConnFactory) New() (net.Conn, error)

+ type ConnectionFactory interface

+ New func() (net.Conn, error)

+ type ConnectionOptions struct

+ AuthInfo AuthInfo

+ ConnectionTimeout time.Duration

+ Factory ConnectionFactory

+ RequireAck bool

+ type DefaultWSConnectionFactory struct

+ AuthInfo *IAMAuthInfo

+ TLSConfig *tls.Config

+ URL string

+ func (wcf *DefaultWSConnectionFactory) New() (ext.Conn, error)

+ func (wcf *DefaultWSConnectionFactory) NewSession(connection ws.Connection) *WSSession

+ type IAMAuthInfo struct

+ func NewIAMAuthInfo(token string) *IAMAuthInfo

+ func (ai *IAMAuthInfo) IAMToken() string

+ func (ai *IAMAuthInfo) SetIAMToken(token string)

+ type MessageClient interface

+ Connect func() error

+ Disconnect func() (err error)

+ Reconnect func() error

+ Send func(e protocol.ChunkEncoder) error

+ SendRaw func(raw []byte) error

+ type Session struct

+ Connection net.Conn

+ TransportPhase bool

+ type WSClient struct

+ ConnectionFactory WSConnectionFactory

+ ConnectionOptions ws.ConnectionOptions

+ func NewWS(opts WSConnectionOptions) *WSClient

+ func (c *WSClient) Connect() error

+ func (c *WSClient) Disconnect() (err error)

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

+ func (c *WSClient) Send(e protocol.ChunkEncoder) error

+ func (c *WSClient) SendRaw(m []byte) error

+ func (c *WSClient) Session() *WSSession

+ type WSConnectionFactory interface

+ New func() (ext.Conn, error)

+ NewSession func(ws.Connection) *WSSession

+ type WSConnectionOptions struct

+ Factory WSConnectionFactory

+ type WSSession struct

+ Connection ws.Connection

+ URL string

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