Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stream

package

Go to main page

Versions in this module

v3

v3.1.0

Apr 9, 2021

v3.1.0-beta.1

Apr 7, 2021

v3.1.0-alpha.1

Apr 7, 2021

v3.1.0-alpha

Sep 5, 2019

v3.0.1

Sep 5, 2019

v3.0.0

Sep 3, 2019

Changes in this version

+ func MessageOpqaue(m *Message) interface

+ func SetMessageOpaque(m *Message, o interface{}) error

+ type Consumer interface

+ Ack func(Message) error

+ Backlog func() (int, error)

+ Config func() interface{}

+ Messages func() <-chan Message

+ Nack func(Message) error

+ type ConsumerMock struct

+ Configuration interface{}

+ ErrorsChan chan error

+ MessagesChan chan Message

+ func (c *ConsumerMock) Ack(_ Message) error

+ func (c *ConsumerMock) Close() error

+ func (c *ConsumerMock) Errors() <-chan error

+ func (c *ConsumerMock) Messages() <-chan Message

+ func (c *ConsumerMock) Nack(_ Message) error

+ func (c ConsumerMock) Backlog() (int, error)

+ func (c ConsumerMock) Config() interface{}

+ type ErrorCloser interface

+ Close func() error

+ Errors func() <-chan error

+ type Message struct

+ ConsumerTopic string

+ Key []byte

+ Offset *int64

+ ProducerTopic string

+ Tags map[string][]byte

+ Timestamp time.Time

+ Value []byte

+ func TestMessage(_ testing.TB, k, v string) Message

+ type Producer interface

+ Config func() interface{}

+ Messages func() chan<- Message

+ type ProducerMock struct

+ Configuration interface{}

+ ErrorsChan chan error

+ MessagesChan chan Message

+ func (p *ProducerMock) Close() error

+ func (p *ProducerMock) Errors() <-chan error

+ func (p *ProducerMock) Messages() chan<- Message

+ func (p ProducerMock) Config() interface{}

+ type Store interface

+ Add func(Message) error

+ Del func(Message) error

+ Flush func() error

+ Messages func() []Message

Other modules containing this package

github.com/blendle/go-streamprocessor