source

Documentation

Index

• type PulsarSourceHandler
  • func NewPulsarSourceHandler(baseSource source.BaseSource) *PulsarSourceHandler
  • func (p *PulsarSourceHandler) CloseSource()
  • func (p *PulsarSourceHandler) FetchData()
  • func (p *PulsarSourceHandler) InitSource()
  • func (p *PulsarSourceHandler) SourceName() string
  • func (p *PulsarSourceHandler) SourceTopic() string

Types

type PulsarSourceHandler

type PulsarSourceHandler struct {
	source.BaseSource
	// contains filtered or unexported fields
}

func NewPulsarSourceHandler

func NewPulsarSourceHandler(baseSource source.BaseSource) *PulsarSourceHandler

NewPulsarSourceHandler initializes a new Pulsar source handler

func (*PulsarSourceHandler) CloseSource

func (p *PulsarSourceHandler) CloseSource()

CloseSource closes the Pulsar source

func (*PulsarSourceHandler) FetchData

func (p *PulsarSourceHandler) FetchData()

FetchData fetches data from Pulsar

func (*PulsarSourceHandler) InitSource

func (p *PulsarSourceHandler) InitSource()

InitSource initializes the Pulsar source

func (*PulsarSourceHandler) SourceName

func (p *PulsarSourceHandler) SourceName() string

SourceName returns the name of the Pulsar source

func (*PulsarSourceHandler) SourceTopic

func (p *PulsarSourceHandler) SourceTopic() string

SourceTopic returns the topic of the Pulsar source