kafka

package

v1.0.0 Latest Latest Go to latest Published: Feb 28, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewKafka(options options.ClientOptions, logger log.LogWrapper) (*Client, error)

func (c *Client) Cleanup() error

func (c *Client) Marshal() ([]byte, error)

func (c *Client) Session(suffix string) (*Session, error)

func (c *Client) Unmarshal(data []byte) error

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

func (r *Reader) ReadEvent(ctx context.Context, ev event.Event) error

type Session struct {
	ID     string
	Suffix string
	// contains filtered or unexported fields
}

func (s *Session) Client() *Client

func (s *Session) CreateTopic(ctx context.Context, topic string, opts ...options.TopicOption) error

func (s *Session) GetReader(suffix string) *Reader

func (s *Session) GetWriter(suffix string) *Writer

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

func (w *Writer) WriteEvent(ctx context.Context, ev event.Event) error