rocketmq

Documentation

Index

• Constants
• func Init()
• func NewRocketMQObserver(properties map[string]interface{}) (observer.Observer, error)
• func NewRocketMQSink(properties map[string]interface{}) (sink.Sink, error)
• type RocketMQObserver
  • func (o *RocketMQObserver) Observe() error
  • func (o *RocketMQObserver) Stop()
  • func (o *RocketMQObserver) Wait()
• type RocketMQSink
  • func (s *RocketMQSink) GetStats() *sink.Stats
  • func (s *RocketMQSink) Init(name string, fields []common.Field) error
  • func (s *RocketMQSink) Write(headers []string, rows [][]interface{}, index int) error

Constants

const ROCKETMQ_OB_TYPE = "rocketmq"

const ROCKETMQ_SINK_TYPE = "rocketmq"

Functions

func Init

func Init()

func NewRocketMQObserver

func NewRocketMQObserver(properties map[string]interface{}) (observer.Observer, error)

func NewRocketMQSink

func NewRocketMQSink(properties map[string]interface{}) (sink.Sink, error)

Types

type RocketMQObserver

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

func (*RocketMQObserver) Observe

func (o *RocketMQObserver) Observe() error

func (*RocketMQObserver) Stop

func (o *RocketMQObserver) Stop()

func (*RocketMQObserver) Wait

func (o *RocketMQObserver) Wait()

type RocketMQSink

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

func (*RocketMQSink) GetStats

func (s *RocketMQSink) GetStats() *sink.Stats

func (*RocketMQSink) Init

func (s *RocketMQSink) Init(name string, fields []common.Field) error

func (*RocketMQSink) Write

func (s *RocketMQSink) Write(headers []string, rows [][]interface{}, index int) error