client

Oct 29, 2017

Changes in this version

+ func WithGRPCClientConn(conn *grpc.ClientConn) optionFn

Oct 28, 2017

Changes in this version

+ func WithAddresses(addrs ...string) optionFn

+ type Client struct

+ func New(opts ...optionFn) (c *Client, err error)

+ func (c *Client) Close() error

+ func (c *Client) CreateTopic(ctx context.Context, params *sgproto.CreateTopicParams) error

+ func (c *Client) ListPartitions(ctx context.Context, topic string) ([]string, error)

+ func (c *Client) NewConsumer(topic, partition, group, name string) *Consumer

+ func (c *Client) ProduceMessage(ctx context.Context, msg *sgproto.Message) error

+ func (c *Client) ProduceMessageCh(ctx context.Context) (chan<- *sgproto.Message, <-chan error)

+ type Consumer struct

+ func (c *Consumer) Acknowledge(ctx context.Context, msg *sgproto.Message) error

+ func (c *Consumer) AcknowledgeMessages(ctx context.Context, offsets []sandflake.ID) error

+ func (c *Consumer) Commit(ctx context.Context, msg *sgproto.Message) error

+ func (c *Consumer) Consume(ctx context.Context) (chan *sgproto.Message, error)