goi

Documentation

Index

• type Consumer
  • func NewConsumer(config ConsumerConfig) (*Consumer, error)
  • func (c *Consumer) Commit(topic string, offset int64) error
  • func (c *Consumer) CommitMessage(m *Message) error
  • func (c *Consumer) Connect() error
  • func (c *Consumer) Disconnect() error
  • func (c *Consumer) Read() (string, int64, []byte, error)
  • func (c *Consumer) ReadMessage() (*Message, error)
• type ConsumerConfig
• type Message
  • func NewMessage(content []byte, topic string) *Message
• type Producer
  • func NewProducer(config ProducerConfig) (*Producer, error)
  • func (p *Producer) Connect() error
  • func (p *Producer) Disconnect() error
  • func (p *Producer) Send(topic string, message []byte) error
  • func (p *Producer) SendMessage(m *Message) error
• type ProducerConfig

Types

type Consumer

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

func NewConsumer

func NewConsumer(config ConsumerConfig) (*Consumer, error)

func (*Consumer) Commit

func (c *Consumer) Commit(topic string, offset int64) error

func (*Consumer) CommitMessage

func (c *Consumer) CommitMessage(m *Message) error

func (*Consumer) Connect

func (c *Consumer) Connect() error

func (*Consumer) Disconnect

func (c *Consumer) Disconnect() error

func (*Consumer) Read

func (c *Consumer) Read() (string, int64, []byte, error)

func (*Consumer) ReadMessage

func (c *Consumer) ReadMessage() (*Message, error)

type ConsumerConfig

type ConsumerConfig struct {
	Name        *string
	GroupName   *string
	Topic       *string
	Host        *string
	Port        *int
	TcpPort     *int
	TcpFallback *bool
}

type Message

type Message struct {
	Offset  *int64
	Content []byte
	Topic   string
}

func NewMessage

func NewMessage(content []byte, topic string) *Message

type Producer

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

func NewProducer

func NewProducer(config ProducerConfig) (*Producer, error)

func (*Producer) Connect

func (p *Producer) Connect() error

func (*Producer) Disconnect

func (p *Producer) Disconnect() error

func (*Producer) Send

func (p *Producer) Send(topic string, message []byte) error

func (*Producer) SendMessage

func (p *Producer) SendMessage(m *Message) error

type ProducerConfig

type ProducerConfig struct {
	Name        *string
	Host        *string
	Port        *int
	TcpPort     *int
	TcpFallback *bool
}