fossil

Mar 2, 2023

Changes in this version

type Client

+ Open func(proto.ConnectionString, uint) error

+ type LocalClient struct

+ func (client *LocalClient) Append(topic string, data []byte) error

+ func (client *LocalClient) Close() error

+ func (client *LocalClient) Open(target proto.ConnectionString, _ uint) error

+ func (client *LocalClient) Query(q string) (database.Entries, error)

+ func (client *LocalClient) Send(message proto.Message) (proto.Message, error)

+ type RemoteClient struct

+ func (client *RemoteClient) Append(topic string, data []byte) error

+ func (client *RemoteClient) Close() error

+ func (client *RemoteClient) Open(connectionString proto.ConnectionString, size uint) error

+ func (client *RemoteClient) Query(q string) (database.Entries, error)

+ func (client *RemoteClient) Send(m proto.Message) (proto.Message, error)

Dec 8, 2022

Changes in this version

+ type Client struct

+ func NewClient(connstr string) (Client, error)

+ func NewClientPool(connstr string, size uint) (Client, error)

+ func (c *Client) Append(topic string, data []byte) error

+ func (c *Client) Close() error

+ func (c *Client) Query(q string) (database.Entries, error)

+ func (c *Client) Send(m proto.Message) (proto.Message, error)