kafka

Oct 16, 2023

Changes in this version

type Client

+ func (c *Client) Use(middlewares ...func(pubsub.HandlerFunc) pubsub.HandlerFunc)

Feb 11, 2023

Changes in this version

+ type Channel struct

+ func (c *Channel) Close() error

+ func (c *Channel) Read(ctx context.Context, model interface{}) (<-chan interface{}, <-chan error)

+ type Client struct

+ func New(url string) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Publish(ctx context.Context, topic string, data interface{}) error

+ func (c *Client) Subscribe(ctx context.Context, topic string) (interface{}, error)