Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventHubMultiPartitionReader ¶
type EventHubMultiPartitionReader struct {
// contains filtered or unexported fields
}
EventHubMultiPartitionReader TODO
func NewEventHubMultiPartitionReader ¶
func NewEventHubMultiPartitionReader(options EventHubMultiPartitionReaderOptions) (*EventHubMultiPartitionReader, error)
NewEventHubMultiPartitionReader TODO
func (*EventHubMultiPartitionReader) Fetch ¶
func (h *EventHubMultiPartitionReader) Fetch() <-chan ReceivedEvent
Fetch TODO
func (*EventHubMultiPartitionReader) Stop ¶
func (h *EventHubMultiPartitionReader) Stop() error
Stop TODO
type EventHubMultiPartitionReaderOptions ¶
type EventHubMultiPartitionReaderOptions struct { SubscriptionID string EnvironmentName string ResourceGroup string StorageAccountName string StorageContainerName string NsName string EventHubName string NumOfHosts int }
EventHubMultiPartitionReaderOptions TODO
type InfluxDBEventWriter ¶
type InfluxDBEventWriter struct {
// contains filtered or unexported fields
}
InfluxDBEventWriter TODO
func NewInfluxDBEventWriter ¶
func NewInfluxDBEventWriter(influxDBURL string, templateSource string) (*InfluxDBEventWriter, error)
NewInfluxDBEventWriter TODO
func (*InfluxDBEventWriter) Process ¶
func (c *InfluxDBEventWriter) Process(event ReceivedEvent) error
Process TODO
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor TODO
func (*Processor) ProcessEvents ¶
ProcessEvents TODO
type ReceivedEvent ¶
type ReceivedEvent struct { Event *eventhubs.Event Err error CheckPointer eph.Checkpointer }
ReceivedEvent TODO
Click to show internal directories.
Click to hide internal directories.