sink

Documentation

Index

• type PulsarSinkHandler
  • func NewPulsarSinkHandler(baseSink sink.BaseSink, sinkPulsarCfg config.PulsarSinkConfig) *PulsarSinkHandler
  • func (p *PulsarSinkHandler) CloseSink()
  • func (p *PulsarSinkHandler) InitSink()
  • func (p *PulsarSinkHandler) SinkName() string
  • func (p *PulsarSinkHandler) WriteData()

Types

type PulsarSinkHandler

type PulsarSinkHandler struct {
	sink.BaseSink
	// contains filtered or unexported fields
}

func NewPulsarSinkHandler

func NewPulsarSinkHandler(baseSink sink.BaseSink, sinkPulsarCfg config.PulsarSinkConfig) *PulsarSinkHandler

NewPulsarSinkHandler creates a new Pulsar sink handler

func (*PulsarSinkHandler) CloseSink

func (p *PulsarSinkHandler) CloseSink()

CloseSink closes the Pulsar sink

func (*PulsarSinkHandler) InitSink

func (p *PulsarSinkHandler) InitSink()

InitSink initializes the Pulsar sink

func (*PulsarSinkHandler) SinkName

func (p *PulsarSinkHandler) SinkName() string

SinkName returns the name of the Pulsar sink

func (*PulsarSinkHandler) WriteData

func (p *PulsarSinkHandler) WriteData()

WriteData writes data to Pulsar