eventhubs

README

Azure Event Hubs

This directory contains samples for managing and using Azure Event Hubs. The following functionality is demonstrated:

• Namespace creation in ./namespace.go
• Hub creation in ./hub.go
• Sending events in ./send_events.go
• Receiving events from a designated partition in ./receive_events.go.
• Receiving events with EventProcessorHost in ./receive_eph.go

You can run the tests in this repo by creating a .env file as described in the root README, and invoking go test -v . from this directory.

Documentation

Overview

Example (EventHubs)

ctx, cancel := context.WithTimeout(context.Background(), 300*time.Second)
// defer goes in LIFO order
defer cancel()
defer resources.Cleanup(context.Background()) // cleanup can take a long time

// create group
var err error
var groupName = config.GenerateGroupName("EventHubs")
config.SetGroupName(groupName)

_, err = resources.CreateGroup(ctx, config.GroupName())
if err != nil {
	util.LogAndPanic(err)
}
util.PrintAndLog("created group")

// create Event Hubs namespace
_, err = CreateNamespace(ctx, nsName)
if err != nil {
	util.LogAndPanic(err)
}
util.PrintAndLog("created namespace")

// create Event Hubs hub
_, err = CreateHub(ctx, nsName, hubName)
if err != nil {
	util.LogAndPanic(err)
}
util.PrintAndLog("created hub")

// send and receive messages
log.Printf("Send(ctx)\n")
Send(ctx, nsName, hubName)
log.Printf("Receive(ctx)\n")
Receive(ctx, nsName, hubName)
log.Printf("ReceiveViaEPH(ctx)\n")
ReceiveViaEPH(ctx, nsName, hubName, storageAccountName, storageContainerName)

Output:

created group
created namespace
created hub
received: test-message
received: test-message

Index

• func CreateHub(ctx context.Context, nsName string, hubName string) (eventhub.Model, error)
• func CreateNamespace(ctx context.Context, nsName string) (*eventhub.EHNamespace, error)
• func Receive(ctx context.Context, nsName, hubName string)
• func ReceiveViaEPH(ctx context.Context, ...)
• func Send(ctx context.Context, nsName, hubName string)

Examples

• Package (EventHubs)

Functions

func CreateHub

func CreateHub(ctx context.Context, nsName string, hubName string) (eventhub.Model, error)

CreateHub creates an Event Hubs hub in a namespace

func CreateNamespace

func CreateNamespace(ctx context.Context, nsName string) (*eventhub.EHNamespace, error)

CreateNamespace creates an Event Hubs namespace

func Receive

func Receive(ctx context.Context, nsName, hubName string)

func ReceiveViaEPH

func ReceiveViaEPH(ctx context.Context, nsName, hubName, storageAccountName, storageContainerName string)

ReceiveViaEPH sets up an Event Processor Host (EPH), a small framework to receive events from several partitions.

func Send

func Send(ctx context.Context, nsName, hubName string)