Affected by GO-2022-1023 and 1 other vulnerabilities

GO-2022-1023: Brokercap Bifrost subject to authentication bypass when using HTTP basic authentication in github.com/brokercap/Bifrost

GO-2022-1067: Bifrost vulnerable to authentication check flaw that leads to authentication bypass in github.com/brokercap/Bifrost

src

package

v1.8.2-release Latest Latest Go to latest Published: Mar 25, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/brokercap/Bifrost

Links

Open Source Insights

Documentation ¶

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 (This *Conn) Commit(data *pluginDriver.PluginDataType, retry bool) (
	*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) Connect ¶

func (This *Conn) Connect() bool

func (*Conn) Del ¶

func (This *Conn) Del(data *pluginDriver.PluginDataType, retry bool) (
	*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

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 (This *Conn) Insert(data *pluginDriver.PluginDataType, retry bool) (
	*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) Open ¶

func (This *Conn) Open() error

func (*Conn) Query ¶

func (This *Conn) Query(data *pluginDriver.PluginDataType, retry bool) (
	*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, 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 ¶

func (This *Conn) Update(data *pluginDriver.PluginDataType, retry bool) (
	*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

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

Source Files ¶

View all Source files

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