sink

Documentation

Index

• type OracleSinkHandler
  • func NewOracleSinkHandler(baseSink sink.BaseSink, sinkOracleCfg config.OracleSinkConfig) *OracleSinkHandler
  • func (o *OracleSinkHandler) CloseSink()
  • func (o *OracleSinkHandler) InitSink()
  • func (o *OracleSinkHandler) SinkName() string
  • func (o *OracleSinkHandler) WriteData()

Types

type OracleSinkHandler

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

func NewOracleSinkHandler

func NewOracleSinkHandler(baseSink sink.BaseSink, sinkOracleCfg config.OracleSinkConfig) *OracleSinkHandler

func (*OracleSinkHandler) CloseSink

func (o *OracleSinkHandler) CloseSink()

CloseSink close Oracle connection

func (*OracleSinkHandler) InitSink

func (o *OracleSinkHandler) InitSink()

InitSink init Oracle connection

func (*OracleSinkHandler) SinkName

func (o *OracleSinkHandler) SinkName() string

SinkName return Oracle sink name

func (*OracleSinkHandler) WriteData

func (o *OracleSinkHandler) WriteData()

WriteData write data into Oracle