proxy.golang.org : github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs : v0.1.1

Shows how to start consuming events in partitions in an Event Hub using the ConsumerClient. If you have an Azure Storage account you can use the Processor type instead, which will handle distributing partitions between multiple consumers and storing progress using checkpoints. See example_consuming_with_checkpoints_test.go for an example. Shows how to use the Processor type, using a ConsumerClient and CheckpointStore. The Processor type acts as a load balancer, ensuring that partitions are divided up evenly amongst active Processor instances. It also allows storing (and restoring) checkpoints of progress. NOTE: If you want to manually allocate partitions or to have more control over the process you can use the ConsumerClient. See example_consuming_events_test.go for an example. Shows how to migrate from the older `github.com/Azure/azure-event-hubs-go` checkpointer to to the format used by this package, `github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs/checkpoints/BlobStore` NOTE: This example is not safe to run while either the old or new checkpoint store is in-use as it doesn't respect locking or ownership. Shows how to send events to an Event Hub partition using the ProducerClient and EventDataBatch.

Registry - Documentation - Download - JSON
purl: pkg:golang/github.com/%21azure/azure-sdk-for-go/sdk/messaging/[email protected]
Published: over 2 years ago
Indexed: over 2 years ago