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

pulsavro

package module

Go to main page

Versions in this module

v1

v1.1.1

Aug 19, 2020

v0

v0.1.1

Aug 19, 2020

Changes in this version

+ type AvroConsumer struct

+ Consumer pulsar.Consumer

+ func (ac *AvroConsumer) Close()

+ func (ac *AvroConsumer) DecodeAvroMessage(msg pulsar.Message) (interface{}, error)

+ func (ac *AvroConsumer) GetSchemaByTopic(topic string) (*goavro.Codec, error)

v0.1.0

Aug 19, 2020

Changes in this version

+ func DecodeAvroFromBytes(schema string, payload []byte) (interface{}, error)

+ func EncodeAvroToBytes(schema string, datum interface{}) ([]byte, error)

type AvroProducer

+ func (ap *AvroProducer) EncodeAvroMessage(value interface{}) ([]byte, error)

v0.0.1

Aug 18, 2020

Changes in this version

+ func NewAvroConsumer(client pulsar.Client, consumerOptions pulsar.ConsumerOptions, ...) (*avroConsumer, error)

+ type AvroProducer struct

+ func NewAvroProducer(client pulsar.Client, producerOptions pulsar.ProducerOptions, ...) (*AvroProducer, error)

+ func (ap *AvroProducer) Close()

+ func (ap *AvroProducer) CreateMessage(value interface{}) ([]byte, error)

+ func (ap *AvroProducer) Send(message *pulsar.ProducerMessage) (pulsar.MessageID, error)

+ type CachedSchemaRegistryClient struct

+ SchemaRegistryClient *SchemaRegistryClient

+ func NewCachedSchemaRegistryClient(connect []string) *CachedSchemaRegistryClient

+ func NewCachedSchemaRegistryClientWithRetries(connect []string, retries int) *CachedSchemaRegistryClient

+ func (client *CachedSchemaRegistryClient) CreateSchemaByTopic(topic string, schema string) error

+ func (client *CachedSchemaRegistryClient) GetSchemaCodecByTopic(topic string) (*goavro.Codec, error)

+ type SchemaRegistryClient struct

+ SchemaRegistryConnect []string

+ func NewSchemaRegistryClient(connect []string) *SchemaRegistryClient

+ func NewSchemaRegistryClientWithRetries(connect []string, retries int) *SchemaRegistryClient

+ func (client *SchemaRegistryClient) CreateSchemaByTopic(topic string, schema string) error

+ func (client *SchemaRegistryClient) GetSchemaCodecByTopic(topic string) (*goavro.Codec, error)

+ type SchemaRegistryClientInterface interface

+ CreateSchemaByTopic func(string, string) error

+ GetSchemaCodecByTopic func(string) (*goavro.Codec, error)