usp_azure_event_hub

Documentation

Index

• type EventHubAdapter
  • func NewEventHubAdapter(conf EventHubConfig) (*EventHubAdapter, chan struct{}, error)
  • func (a *EventHubAdapter) Close() error
• type EventHubConfig
  • func (c *EventHubConfig) Validate() error

Types

type EventHubAdapter

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

func NewEventHubAdapter

func NewEventHubAdapter(conf EventHubConfig) (*EventHubAdapter, chan struct{}, error)

func (*EventHubAdapter) Close

func (a *EventHubAdapter) Close() error

type EventHubConfig

type EventHubConfig struct {
	ClientOptions    uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	ConnectionString string                  `json:"connection_string" yaml:"connection_string"`
}

func (*EventHubConfig) Validate

func (c *EventHubConfig) Validate() error