azureeventhub

package

v0.3.0-rc.2 Latest Latest Go to latest Published: Jul 1, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

Index ¶

func SetupEventHub(ctx context.Context, config *Config, pg pipeline.IPipelineGroup, ...) error
type Config
- func (c *Config) Validate() error
type EventConsumer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func SetupEventHub ¶

func SetupEventHub(ctx context.Context, config *Config, pg pipeline.IPipelineGroup, logger *logrus.Logger) error

Types ¶

type Config ¶

type Config struct {
	SubscriptionID                 string              `json:"subscriptionId"`
	EventHubNamespace              string              `json:"eventHubNamespace"`
	EventHubName                   string              `json:"eventHubName"`
	CheckpointStorageAccountName   string              `json:"checkpointStorageAccountName"`
	CheckpointStorageContainerName string              `json:"checkpointStorageContainerName"`
	TenantID                       string              `json:"tenantId"`
	ClientID                       config.SecretSource `json:"clientId"`
	ClientSecret                   config.SecretSource `json:"clientSecret"`
	EventConsumer                  EventConsumer
}

func (*Config) Validate ¶

func (c *Config) Validate() error

type EventConsumer ¶

type EventConsumer func(event *azeventhubs.ReceivedEventData) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL