stream

Documentation

Index

• type Client
• type Consumer
• type Message
  • func NewMessageFromKafka(msg *sarama.ConsumerMessage, c *cluster.Consumer) *Message
  • func (m *Message) Done()
• type Producer

Types

type Client

type Client interface {
	NewConsumer() Consumer
	NewProducer() Producer
	NewConsumerAndProducer() (Consumer, Producer)
}

Client interface to be implemented by different streamclients.

type Consumer

type Consumer interface {
	Messages() <-chan *Message
	Close() error
}

Consumer interface to be implemented by different streamclients.

type Message

type Message struct {
	Value     []byte
	Key       []byte
	Topic     string
	Timestamp time.Time
	// contains filtered or unexported fields
}

Message send to or received from a stream.

func NewMessageFromKafka

func NewMessageFromKafka(msg *sarama.ConsumerMessage, c *cluster.Consumer) *Message

NewMessageFromKafka creates a new message with required Kafka metadata.

func (*Message) Done

func (m *Message) Done()

Done tells the consumer a message has been processed, and should not be send again.

type Producer

type Producer interface {
	Messages() chan<- *Message
	Close() error
	PartitionKey(func(msg *Message) []byte)
}

Producer interface to be implemented by different streamclients.