source

Documentation

Index

• type RocketMQSourceHandler
  • func NewRocketMQSource(baseSource source.BaseSource) *RocketMQSourceHandler
  • func (r *RocketMQSourceHandler) CloseSource()
  • func (r *RocketMQSourceHandler) FetchData()
  • func (r *RocketMQSourceHandler) InitSource()
  • func (r *RocketMQSourceHandler) SourceName() string
  • func (r *RocketMQSourceHandler) SourceTopic() string

Types

type RocketMQSourceHandler

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

func NewRocketMQSource

func NewRocketMQSource(baseSource source.BaseSource) *RocketMQSourceHandler

NewRocketMQSource initializes a new RocketMQ source handler

func (*RocketMQSourceHandler) CloseSource

func (r *RocketMQSourceHandler) CloseSource()

CloseSource closes the RocketMQ source

func (*RocketMQSourceHandler) FetchData

func (r *RocketMQSourceHandler) FetchData()

FetchData fetches data from RocketMQ

func (*RocketMQSourceHandler) InitSource

func (r *RocketMQSourceHandler) InitSource()

InitSource initializes the RocketMQ source

func (*RocketMQSourceHandler) SourceName

func (r *RocketMQSourceHandler) SourceName() string

SourceName returns the name of the RocketMQ source

func (*RocketMQSourceHandler) SourceTopic

func (r *RocketMQSourceHandler) SourceTopic() string

SourceTopic returns the topic of the RocketMQ