src

Documentation

Index

• Constants
• func AddCount(dbname, schameName, tableName string, event eventType, rowsCount int, ...)
• func ClearCountContent(c *CountContent)
• func GetDbList() (data []string)
• func GetSchameList(dbname string) (data []string)
• func GetSchameTableList(dbname string, schema string) (data []string)
• func NewConn() driver.Driver
• type Conn
  • func (This *Conn) CheckUri() error
  • func (This *Conn) Close() bool
  • func (This *Conn) Commit(data *driver.PluginDataType, retry bool) (LastSuccessCommitData *driver.PluginDataType, ErrData *driver.PluginDataType, ...)
  • func (This *Conn) Del(data *driver.PluginDataType, retry bool) (*driver.PluginDataType, *driver.PluginDataType, error)
  • func (This *Conn) GetParam(p interface{}) (*PluginParam, error)
  • func (This *Conn) GetUriExample() string
  • func (This *Conn) Insert(data *driver.PluginDataType, retry bool) (*driver.PluginDataType, *driver.PluginDataType, error)
  • func (This *Conn) Open() error
  • func (This *Conn) Query(data *driver.PluginDataType, retry bool) (*driver.PluginDataType, *driver.PluginDataType, error)
  • func (This *Conn) SetOption(uri *string, param map[string]interface{})
  • func (This *Conn) SetParam(p interface{}) (interface{}, error)
  • func (This *Conn) Update(data *driver.PluginDataType, retry bool) (*driver.PluginDataType, *driver.PluginDataType, error)
• type CountContent
  • func GetFlow(flowType string, dbname, schameName, tableName string) (data []CountContent, err error)
  • func GetFlowByDbName(flowType string, dbname string) (data []CountContent, err error)
  • func GetFlowBySchema(flowType string, dbname, schameName string) (data []CountContent, err error)
  • func NewCountContent() *CountContent
• type CountContentArr
• type CountFlow
  • func NewFlow() *CountFlow
• type DoSlice
• type PluginParam
• type PluginTableCountController
  • func (c *PluginTableCountController) GetFlow()
  • func (c *PluginTableCountController) GetSchemaList()
  • func (c *PluginTableCountController) GetSchemaTableList()
  • func (c *PluginTableCountController) Index()

Constants

const (
	INSERT eventType = 1
	UPDATE eventType = 2
	DELETE eventType = 3
	DDL    eventType = 4
	COMMIT eventType = 5
)

const BIFROST_VERION = "v1.6.0"

const VERSION = "v1.6.0"

Functions

func AddCount

func AddCount(dbname, schameName, tableName string, event eventType, rowsCount int, eventCount bool)

func ClearCountContent

func ClearCountContent(c *CountContent)

func GetDbList

func GetDbList() (data []string)

func GetSchameList

func GetSchameList(dbname string) (data []string)

func GetSchameTableList

func GetSchameTableList(dbname string, schema string) (data []string)

func NewConn

func NewConn() driver.Driver

Types

type Conn

type Conn struct {
	driver.PluginDriverInterface
	// contains filtered or unexported fields
}

func (*Conn) CheckUri

func (This *Conn) CheckUri() error

func (*Conn) Close

func (This *Conn) Close() bool

func (*Conn) Commit

func (This *Conn) Commit(data *driver.PluginDataType, retry bool) (LastSuccessCommitData *driver.PluginDataType, ErrData *driver.PluginDataType, err error)

func (*Conn) Del

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

func (*Conn) GetParam

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

func (*Conn) GetUriExample

func (This *Conn) GetUriExample() string

func (*Conn) Insert

func (This *Conn) Insert(data *driver.PluginDataType, retry bool) (*driver.PluginDataType, *driver.PluginDataType, error)

func (*Conn) Open

func (This *Conn) Open() error

func (*Conn) Query

func (This *Conn) Query(data *driver.PluginDataType, retry bool) (*driver.PluginDataType, *driver.PluginDataType, error)

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) Update

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

type CountContent

type CountContent struct {
	Time        int64
	InsertCount uint64
	UpdateCount uint64
	DeleteCount uint64
	InsertRows  uint64
	UpdateRows  uint64
	DeleteRows  uint64
	DDLCount    uint64
	CommitCount uint64
}

func GetFlow

func GetFlow(flowType string, dbname, schameName, tableName string) (data []CountContent, err error)

func GetFlowByDbName

func GetFlowByDbName(flowType string, dbname string) (data []CountContent, err error)

func GetFlowBySchema

func GetFlowBySchema(flowType string, dbname, schameName string) (data []CountContent, err error)

func NewCountContent

func NewCountContent() *CountContent

type CountContentArr

type CountContentArr struct {
	Count   uint8
	Data    []CountContent
	Content *CountContent
}

type CountFlow

type CountFlow struct {
	TenMinute *CountContentArr
	Hour      *CountContentArr
	EightHour *CountContentArr
	Day       *CountContentArr
	Content   *CountContent
}

func NewFlow

func NewFlow() *CountFlow

type DoSlice

type DoSlice struct {
	DoTenMinuteSlice bool
	DoHourSlice      bool
	DoEightHourSlice bool
	DoDaySlice       bool
	DoClear          bool
}

type PluginParam

type PluginParam struct {
	DbName string
}

type PluginTableCountController

type PluginTableCountController struct {
	controller.CommonController
}

func (*PluginTableCountController) GetFlow

func (c *PluginTableCountController) GetFlow()

func (*PluginTableCountController) GetSchemaList

func (c *PluginTableCountController) GetSchemaList()

func (*PluginTableCountController) GetSchemaTableList

func (c *PluginTableCountController) GetSchemaTableList()

func (*PluginTableCountController) Index

func (c *PluginTableCountController) Index()