Documentation ¶
Index ¶
- func DefaultMapper(event couchbase.Event) []document.ESActionDocument
- type Connector
- type ConnectorBuilder
- func (c *ConnectorBuilder) Build() (Connector, error)
- func (c *ConnectorBuilder) SetLogger(logrus *logrus.Logger) *ConnectorBuilder
- func (c *ConnectorBuilder) SetMapper(mapper Mapper) *ConnectorBuilder
- func (c *ConnectorBuilder) SetSinkResponseHandler(sinkResponseHandler dcpElasticsearch.SinkResponseHandler) *ConnectorBuilder
- type DcpEventHandler
- func (h *DcpEventHandler) AfterRebalanceEnd()
- func (h *DcpEventHandler) AfterRebalanceStart()
- func (h *DcpEventHandler) AfterStreamStart()
- func (h *DcpEventHandler) AfterStreamStop()
- func (h *DcpEventHandler) BeforeRebalanceEnd()
- func (h *DcpEventHandler) BeforeRebalanceStart()
- func (h *DcpEventHandler) BeforeStreamStart()
- func (h *DcpEventHandler) BeforeStreamStop()
- type Mapper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultMapper ¶
func DefaultMapper(event couchbase.Event) []document.ESActionDocument
Types ¶
type Connector ¶
type Connector interface { Start() Close() GetDcpClient() dcpCouchbase.Client }
type ConnectorBuilder ¶
type ConnectorBuilder struct {
// contains filtered or unexported fields
}
func NewConnectorBuilder ¶
func NewConnectorBuilder(config any) *ConnectorBuilder
func (*ConnectorBuilder) Build ¶
func (c *ConnectorBuilder) Build() (Connector, error)
func (*ConnectorBuilder) SetLogger ¶
func (c *ConnectorBuilder) SetLogger(logrus *logrus.Logger) *ConnectorBuilder
func (*ConnectorBuilder) SetMapper ¶
func (c *ConnectorBuilder) SetMapper(mapper Mapper) *ConnectorBuilder
func (*ConnectorBuilder) SetSinkResponseHandler ¶ added in v1.1.28
func (c *ConnectorBuilder) SetSinkResponseHandler(sinkResponseHandler dcpElasticsearch.SinkResponseHandler) *ConnectorBuilder
type DcpEventHandler ¶ added in v0.0.40
type DcpEventHandler struct {
// contains filtered or unexported fields
}
func (*DcpEventHandler) AfterRebalanceEnd ¶ added in v0.0.40
func (h *DcpEventHandler) AfterRebalanceEnd()
func (*DcpEventHandler) AfterRebalanceStart ¶ added in v0.0.40
func (h *DcpEventHandler) AfterRebalanceStart()
func (*DcpEventHandler) AfterStreamStart ¶ added in v0.0.40
func (h *DcpEventHandler) AfterStreamStart()
func (*DcpEventHandler) AfterStreamStop ¶ added in v0.0.40
func (h *DcpEventHandler) AfterStreamStop()
func (*DcpEventHandler) BeforeRebalanceEnd ¶ added in v0.0.40
func (h *DcpEventHandler) BeforeRebalanceEnd()
func (*DcpEventHandler) BeforeRebalanceStart ¶ added in v0.0.40
func (h *DcpEventHandler) BeforeRebalanceStart()
func (*DcpEventHandler) BeforeStreamStart ¶ added in v0.0.40
func (h *DcpEventHandler) BeforeStreamStart()
func (*DcpEventHandler) BeforeStreamStop ¶ added in v0.0.40
func (h *DcpEventHandler) BeforeStreamStop()
Click to show internal directories.
Click to hide internal directories.