eventhub

Documentation

Index

• func Run()
• type Event
  • func UnmarshallEvent(eventJObj []byte) (error, Event)
• type HubEventUnpacker
  • func (h *HubEventUnpacker) InitConfig(f *forwarder.ForwarderConfiguration)
  • func (h HubEventUnpacker) Process(eventJObj []byte, partitionID string, eventID int64, rateLimiter *rate.Limiter) error

Functions

func Run

func Run()

Types

type Event

type Event struct {
	Records []struct {
		Properties struct {
			Log string `json:"log"`
		} `json:"properties"`
	} `json:"records"`
}

func UnmarshallEvent

func UnmarshallEvent(eventJObj []byte) (error, Event)

type HubEventUnpacker

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

func (*HubEventUnpacker) InitConfig

func (h *HubEventUnpacker) InitConfig(f *forwarder.ForwarderConfiguration)

func (HubEventUnpacker) Process

func (h HubEventUnpacker) Process(eventJObj []byte, partitionID string, eventID int64, rateLimiter *rate.Limiter) error