client

package

v1.0.7 Latest Latest Go to latest Published: May 15, 2025 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	// contains filtered or unexported fields
}

Client is a struct that holds the connection to the server

func NewClient(address, port string, tlsCfg *config.ClientTLSConfig) (*Client, error)

NewClient creates a new client It accepts an optional tlsCfg to enable mTLS. If tlsCfg is nil, it defaults to an insecure connection.

func (c *Client) BulkRetrieve(topic string, startOffset int64, limit int32) (*pb.BulkRetrieveResponse, error)

BulkRetrieve retrieves a batch of messages from the server.

func (c *Client) Close()

Close closes the connection to the server

func (c *Client) Consume(topic string, offset int64) ([]byte, int64, error)

Consume retrieves a message from the server

func (c *Client) ConsumeEarliest(topic string) ([]byte, int64, error)

func (c *Client) ConsumeLatest(topic string) ([]byte, int64, error)

func (c *Client) CreateTopic(topic string) error

CreateTopic creates a new topic on the server

func (c *Client) DeleteUntilOffset(topic string, offset int64) error

DeleteUntilOffset deletes all messages in a topic until a certain offset

func (c *Client) Produce(topic string, message []byte) error

Produce sends a message to the server

func (c *Client) StreamConsume(topic string, startOffset int64, function func([]byte, int64) error) error

func (c *Client) StreamProduce(topic string, function func() ([]byte, error)) error

StreamProduce sends a stream of messages to the server