workers

package
v0.0.0-...-fa920b1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2020 License: Apache-2.0 Imports: 11 Imported by: 1

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

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 NewProcessor

func NewProcessor() *Processor

NewProcessor TODO

func (*Processor) ProcessEvents

func (p *Processor) ProcessEvents(reader Reader, writer Writer)

ProcessEvents TODO

func (*Processor) Stop

func (p *Processor) Stop() error

Stop TODO

func (*Processor) Wait

func (p *Processor) Wait() error

Wait TODO

type Reader

type Reader interface {
	Fetch() <-chan ReceivedEvent
	Stop() error
}

Reader TODO

type ReceivedEvent

type ReceivedEvent struct {
	Event        *eventhubs.Event
	Err          error
	CheckPointer eph.Checkpointer
}

ReceivedEvent TODO

type Writer

type Writer interface {
	Process(event ReceivedEvent) error
}

Writer TODO

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL