eventhub

Documentation

Index

• Constants
• func New(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, ...) providers.Provider
• func NewSource(transferID string, cfg *EventHubSource, logger log.Logger, ...) (abstract.Source, error)
• type EventHubAuth
• type EventHubSource
  • func (s *EventHubSource) GetProviderType() abstract.ProviderType
  • func (s *EventHubSource) IsAppendOnly() bool
  • func (s *EventHubSource) IsDefaultMirror() bool
  • func (s *EventHubSource) IsSource()
  • func (s *EventHubSource) Parser() map[string]interface{}
  • func (s *EventHubSource) Validate() error
  • func (s *EventHubSource) WithDefaults()
• type Provider
  • func (p *Provider) Source() (abstract.Source, error)
  • func (p *Provider) Type() abstract.ProviderType
• type Source
  • func (s *Source) Run(sink abstract.AsyncSink) error
  • func (s *Source) Stop()

Constants

const (
	EventHubAuthSAS = "SAS"
	ProviderType    = abstract.ProviderType("eventhub")
)

Functions

func New

func New(lgr log.Logger, registry metrics.Registry, cp coordinator.Coordinator, transfer *server.Transfer) providers.Provider

func NewSource

func NewSource(transferID string, cfg *EventHubSource, logger log.Logger, registry metrics.Registry) (abstract.Source, error)

Types

type EventHubAuth

type EventHubAuth struct {
	Method, KeyName string
	KeyValue        server.SecretString
}

type EventHubSource

type EventHubSource struct {
	NamespaceName     string
	HubName           string
	ConsumerGroup     string
	Topic             string
	StartingOffset    string
	StartingTimeStamp *time.Time
	Auth              *EventHubAuth
	Transformer       *server.DataTransformOptions

	ParserConfig map[string]interface{}
}

func (*EventHubSource) GetProviderType

func (s *EventHubSource) GetProviderType() abstract.ProviderType

func (*EventHubSource) IsAppendOnly

func (s *EventHubSource) IsAppendOnly() bool

func (*EventHubSource) IsDefaultMirror

func (s *EventHubSource) IsDefaultMirror() bool

func (*EventHubSource) IsSource

func (s *EventHubSource) IsSource()

func (*EventHubSource) Parser

func (s *EventHubSource) Parser() map[string]interface{}

func (*EventHubSource) Validate

func (s *EventHubSource) Validate() error

func (*EventHubSource) WithDefaults

func (s *EventHubSource) WithDefaults()

type Provider

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

func (*Provider) Source

func (p *Provider) Source() (abstract.Source, error)

func (*Provider) Type

func (p *Provider) Type() abstract.ProviderType

type Source

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

func (*Source) Run

func (s *Source) Run(sink abstract.AsyncSink) error

func (*Source) Stop

func (s *Source) Stop()