queued

Apr 4, 2023

Changes in this version

+ const DefaultTCPPort

+ const DefaultWSPort

+ var ErrClosed = errors.New("client is closed")

+ var ErrNilClient = errors.New("uninitialised client")

+ var ErrNilConfiguration = errors.New("illegal nil configuration data")

+ func AreEqual(c *ClientConfig, d *ClientConfig) bool

+ type Client struct

+ func NewClient(ctx context.Context, cfg *ClientConfig) (*Client, error)

+ func (c *Client) Acknowledge(ctx context.Context, id driver.ID) error

+ func (c *Client) Close() error

+ func (c *Client) Delete(ctx context.Context, name string) error

+ func (c *Client) DriverName() string

+ func (c *Client) Get(ctx context.Context, name string) (driver.ID, []byte, time.Time, error)

+ func (c *Client) Len(ctx context.Context, name string) (int, error)

+ func (c *Client) Put(ctx context.Context, name string, content []byte) error

+ func (c *Client) Refresh(ctx context.Context, id driver.ID) (time.Time, error)

+ func (c *Client) Requeue(ctx context.Context, id driver.ID) error

+ type ClientConfig struct

+ Address *address.Address

+ SSLCert []byte

+ SSLDisabled bool

+ func DefaultConfig() *ClientConfig

+ func SetDefaultConfig(c *ClientConfig) *ClientConfig

+ func (c *ClientConfig) Copy() *ClientConfig

+ func (c *ClientConfig) Hash() uint32

+ func (c *ClientConfig) URI() string

+ func (c *ClientConfig) Validate() error

+ type Option interface

+ func SSLCertAndKey(crt []byte, key []byte) Option

+ func WithDriver(d driver.Interface) Option

+ type Server struct

+ func NewServer(options ...Option) (*Server, error)