Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

producer

package module

Go to main page

Versions in this module

v0

v0.3.0

Apr 30, 2021

Changes in this version

+ var ErrIllegalPartitionKey = errors.New("Invalid parition key. Length must be at least 1 and at most 256")

+ var ErrRecordSizeExceeded = errors.New("Data must be less than or equal to 1MB in size")

+ var ErrStoppedProducer = errors.New("Unable to Put record. Producer is already stopped")

+ type AggregatedRecord struct

+ ExplicitHashKeyTable []string

+ PartitionKeyTable []string

+ Records []*Record

+ XXX_unrecognized []byte

+ func (*AggregatedRecord) Descriptor() ([]byte, []int)

+ func (*AggregatedRecord) ProtoMessage()

+ func (m *AggregatedRecord) GetExplicitHashKeyTable() []string

+ func (m *AggregatedRecord) GetPartitionKeyTable() []string

+ func (m *AggregatedRecord) GetRecords() []*Record

+ func (m *AggregatedRecord) Reset()

+ func (m *AggregatedRecord) String() string

+ type Aggregator struct

+ func (a *Aggregator) Count() int

+ func (a *Aggregator) Drain() (*types.PutRecordsRequestEntry, error)

+ func (a *Aggregator) Put(data []byte, partitionKey string)

+ func (a *Aggregator) Size() int

+ type Config struct

+ AggregateBatchCount int

+ AggregateBatchSize int

+ BacklogCount int

+ BatchCount int

+ BatchSize int

+ Client Putter

+ FlushInterval time.Duration

+ Logger Logger

+ MaxConnections int

+ StreamName string

+ Verbose bool

+ type FailureRecord struct

+ Data []byte

+ PartitionKey string

+ type LogValue struct

+ Name string

+ Value interface{}

+ func (v LogValue) String() string

+ type Logger interface

+ Error func(msg string, err error, values ...LogValue)

+ Info func(msg string, values ...LogValue)

+ type Producer struct

+ func New(config *Config) *Producer

+ func (p *Producer) NotifyFailures() <-chan *FailureRecord

+ func (p *Producer) Put(data []byte, partitionKey string) error

+ func (p *Producer) Start()

+ func (p *Producer) Stop()

+ type Putter interface

+ PutRecords func(context.Context, *k.PutRecordsInput, ...func(*k.Options)) (*k.PutRecordsOutput, error)

+ type Record struct

+ Data []byte

+ ExplicitHashKeyIndex *uint64

+ PartitionKeyIndex *uint64

+ Tags []*Tag

+ XXX_unrecognized []byte

+ func (*Record) Descriptor() ([]byte, []int)

+ func (*Record) ProtoMessage()

+ func (m *Record) GetData() []byte

+ func (m *Record) GetExplicitHashKeyIndex() uint64

+ func (m *Record) GetPartitionKeyIndex() uint64

+ func (m *Record) GetTags() []*Tag

+ func (m *Record) Reset()

+ func (m *Record) String() string

+ type StdLogger struct

+ Logger *log.Logger

+ func (l *StdLogger) Error(msg string, err error, values ...LogValue)

+ func (l *StdLogger) Info(msg string, values ...LogValue)

+ type Tag struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

+ func (*Tag) Descriptor() ([]byte, []int)

+ func (*Tag) ProtoMessage()

+ func (m *Tag) GetKey() string

+ func (m *Tag) GetValue() string

+ func (m *Tag) Reset()

+ func (m *Tag) String() string

v0.2.0

Nov 21, 2018

v0.1.0

Mar 20, 2016