event_hub

Documentation

Index

• type EventHub
  • func NewEventHub(ctx context.Context, wg *sync.WaitGroup, conf EventHubConfig) (*EventHub, error)
  • func (e EventHub) SendAlarm(events model.Events) error
• type EventHubConfig

Types

type EventHub

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

func NewEventHub

func NewEventHub(ctx context.Context, wg *sync.WaitGroup, conf EventHubConfig) (*EventHub, error)

func (EventHub) SendAlarm

func (e EventHub) SendAlarm(events model.Events) error

type EventHubConfig

type EventHubConfig struct {
	Connection   string `yaml:"connection"`
	EventHubName string `yaml:"EventHubName"`
}