pulsar

Documentation

Index

• func NewCreatorFactory(config *config.PulsarConfig, changefeedID model.ChangeFeedID, ...) (pulsar.Client, error)
• func NewMockCreatorFactory(config *config.PulsarConfig, changefeedID model.ChangeFeedID, ...) (pulsar.Client, error)
• func NewPulsarConfig(sinkURI *url.URL, pulsarConfig *config.PulsarConfig) (*config.PulsarConfig, error)
• type FactoryCreator
• type Logger
  • func NewPulsarLogger(base *zap.Logger) *Logger
  • func (p *Logger) Debug(args ...interface{})
  • func (p *Logger) Debugf(format string, args ...interface{})
  • func (p *Logger) Error(args ...interface{})
  • func (p *Logger) Errorf(format string, args ...interface{})
  • func (p *Logger) Info(args ...interface{})
  • func (p *Logger) Infof(format string, args ...interface{})
  • func (p *Logger) SubLogger(pulsarFields log.Fields) log.Logger
  • func (p *Logger) Warn(args ...interface{})
  • func (p *Logger) Warnf(format string, args ...interface{})
  • func (p *Logger) WithError(err error) log.Entry
  • func (p *Logger) WithField(name string, value interface{}) log.Entry
  • func (p *Logger) WithFields(fields log.Fields) log.Entry

Functions

func NewCreatorFactory

func NewCreatorFactory(config *config.PulsarConfig, changefeedID model.ChangeFeedID, sinkConfig *config.SinkConfig) (pulsar.Client, error)

NewCreatorFactory returns a factory implemented based on kafka-go

func NewMockCreatorFactory

func NewMockCreatorFactory(config *config.PulsarConfig, changefeedID model.ChangeFeedID,
	sinkConfig *config.SinkConfig,
) (pulsar.Client, error)

NewMockCreatorFactory returns a factory implemented based on kafka-go

func NewPulsarConfig

func NewPulsarConfig(sinkURI *url.URL, pulsarConfig *config.PulsarConfig) (*config.PulsarConfig, error)

NewPulsarConfig new pulsar config TODO(dongmen): make this method more concise.

Types

type FactoryCreator

type FactoryCreator func(config *config.PulsarConfig, changefeedID model.ChangeFeedID, sinkConfig *config.SinkConfig) (pulsar.Client, error)

FactoryCreator defines the type of factory creator.

type Logger

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

Logger wrapper cdc logger to adapt pulsar logger

func NewPulsarLogger

func NewPulsarLogger(base *zap.Logger) *Logger

NewPulsarLogger new pulsar logger

func (*Logger) Debug

func (p *Logger) Debug(args ...interface{})

Debug debug

func (*Logger) Debugf

func (p *Logger) Debugf(format string, args ...interface{})

Debugf debugf

func (*Logger) Error

func (p *Logger) Error(args ...interface{})

Error error

func (*Logger) Errorf

func (p *Logger) Errorf(format string, args ...interface{})

Errorf errorf

func (*Logger) Info

func (p *Logger) Info(args ...interface{})

Info info

func (*Logger) Infof

func (p *Logger) Infof(format string, args ...interface{})

Infof infof

func (*Logger) SubLogger

func (p *Logger) SubLogger(pulsarFields log.Fields) log.Logger

SubLogger sub

func (*Logger) Warn

func (p *Logger) Warn(args ...interface{})

Warn warn

func (*Logger) Warnf

func (p *Logger) Warnf(format string, args ...interface{})

Warnf warnf

func (*Logger) WithError

func (p *Logger) WithError(err error) log.Entry

WithError error

func (*Logger) WithField

func (p *Logger) WithField(name string, value interface{}) log.Entry

WithField with field

func (*Logger) WithFields

func (p *Logger) WithFields(fields log.Fields) log.Entry

WithFields with fields