src

package
v1.8.3-release Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const BIFROST_VERION = "v1.6.0"
View Source
const VERSION = "v1.8.1-beta"

Variables

This section is empty.

Functions

func NewConn

func NewConn() pluginDriver.Driver

Types

type Conn

type Conn struct {
	pluginDriver.PluginDriverInterface
	Uri *string
	// contains filtered or unexported fields
}

func (*Conn) AutoCommit

func (This *Conn) AutoCommit() (LastSuccessCommitData *pluginDriver.PluginDataType, ErrData *pluginDriver.PluginDataType, e error)

合并数据,提交到es里

func (*Conn) CheckDataSkip

func (This *Conn) CheckDataSkip(data *pluginDriver.PluginDataType) bool

func (*Conn) CheckUri

func (This *Conn) CheckUri() error

func (*Conn) Close

func (This *Conn) Close() bool

func (*Conn) Commit

func (*Conn) Connect

func (This *Conn) Connect() bool

func (*Conn) GetParam

func (This *Conn) GetParam(p interface{}) (*PluginParam, error)

func (*Conn) GetUriExample

func (This *Conn) GetUriExample() string

func (*Conn) GetVersion

func (This *Conn) GetVersion() (Version string, err error)

func (*Conn) Insert

func (*Conn) Open

func (This *Conn) Open() error

func (*Conn) ReConnect

func (This *Conn) ReConnect() bool

func (*Conn) SetOption

func (This *Conn) SetOption(uri *string, param map[string]interface{})

func (*Conn) SetParam

func (This *Conn) SetParam(p interface{}) (interface{}, error)

func (*Conn) Skip

func (This *Conn) Skip(SkipData *pluginDriver.PluginDataType) error

设置跳过的位点

func (*Conn) TimeOutCommit

func (This *Conn) TimeOutCommit() (
	*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) Update

type EsServer

type EsServer struct {
	User       string
	Password   string
	Urls       []string
	Sniff      bool
	Timeout    int
	RetryCount int
}

type PluginParam

type PluginParam struct {
	EsIndexName string `json: "EsIndexName"`
	PrimaryKey  string `json: "PrimaryKey"`
	Mapping     string `json: "Mapping"`

	BifrostMustBeSuccess bool `json: "BifrostMustBeSuccess"` // bifrost server 保留,数据是否能丢
	BatchSize            int  `json: "BatchSize"`
	Data                 *TableDataStruct
	SkipBinlogData       *pluginDriver.PluginDataType // 在执行 skip 的时候 ,进行传入进来的时候需要要过滤的 位点,在每次commit之后,这个数据会被清空
	// contains filtered or unexported fields
}

type TableDataStruct

type TableDataStruct struct {
	Data       []*pluginDriver.PluginDataType
	CommitData []*pluginDriver.PluginDataType // commit 提交的数据列表,Data 每 BatchSize 数据量划分为一个最后提交的commit
}

func NewTableData

func NewTableData() *TableDataStruct

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL