eventhub

Documentation

Index

• Variables
• func NewAdminClient(ctx context.Context, config *sarama.Config) (types.AdminClientInterface, error)
• type EventHubAdminClient
  • func (c *EventHubAdminClient) Close() error
  • func (c *EventHubAdminClient) CreateTopic(ctx context.Context, topicName string, topicDetail *sarama.TopicDetail) *sarama.TopicError
  • func (c *EventHubAdminClient) DeleteTopic(ctx context.Context, topicName string) *sarama.TopicError
• type HubManagerInterface

Variables

var NewHubManagerFromConnectionStringWrapper = func(connectionString string) (HubManagerInterface, error) {
	return eventhub.NewHubManagerFromConnectionString(connectionString)
}

Azure EventHub HubManager Function Reference Variable To Facilitate Mocking In Unit Tests

Functions

func NewAdminClient

func NewAdminClient(ctx context.Context, config *sarama.Config) (types.AdminClientInterface, error)

Create A New Azure EventHub AdminClient Based On Kafka Secrets In The Specified K8S Namespace

Types

type EventHubAdminClient

type EventHubAdminClient struct {
	// contains filtered or unexported fields
}

EventHub AdminClient Definition

func (*EventHubAdminClient) Close

func (c *EventHubAdminClient) Close() error

Kafka AdminClient Close Implementation Using Azure EventHub API

func (*EventHubAdminClient) CreateTopic

func (c *EventHubAdminClient) CreateTopic(ctx context.Context, topicName string, topicDetail *sarama.TopicDetail) *sarama.TopicError

Kafka AdminClient CreateTopics Implementation Using Azure EventHub API

func (*EventHubAdminClient) DeleteTopic

func (c *EventHubAdminClient) DeleteTopic(ctx context.Context, topicName string) *sarama.TopicError

Delete A Single Topic (EventHub) Via The Azure EventHub API

type HubManagerInterface

type HubManagerInterface interface {
	Delete(ctx context.Context, name string) error
	List(ctx context.Context) ([]*eventhub.HubEntity, error)
	Put(ctx context.Context, name string, opts ...eventhub.HubManagementOption) (*eventhub.HubEntity, error)
}

Azure EventHub Client Doesn't Code To Interfaces Or Provide Mocks So We're Wrapping Our Usage Of The HubManager For Testing