event_hub

Documentation

Index

• type EventHub
  • func (e *EventHub) Start(ctx context.Context, wg *sync.WaitGroup)
• type EventHubConfig
• type EventHubLight
  • func (ehl *EventHubLight) Start(ctx context.Context, wg *sync.WaitGroup)
• type IEventHub
  • func NewEventHub(svc model.IService, conf EventHubConfig) (IEventHub, error)
  • func NewEventHubLight(svc model.IService, conf EventHubConfig) (IEventHub, error)

Types

type EventHub

type EventHub struct {
	Svc model.IService
	// contains filtered or unexported fields
}

func (*EventHub) Start

func (e *EventHub) Start(ctx context.Context, wg *sync.WaitGroup)

type EventHubConfig

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

type EventHubLight

type EventHubLight struct {
	Svc model.IService
	// contains filtered or unexported fields
}

func (*EventHubLight) Start

func (ehl *EventHubLight) Start(ctx context.Context, wg *sync.WaitGroup)

type IEventHub

type IEventHub interface {
	Start(ctx context.Context, wg *sync.WaitGroup)
}

func NewEventHub

func NewEventHub(svc model.IService, conf EventHubConfig) (IEventHub, error)

func NewEventHubLight

func NewEventHubLight(svc model.IService, conf EventHubConfig) (IEventHub, error)