mysql

Documentation

Index

• type MysqlOperations
  • func NewMysql() *MysqlOperations
  • func (mysqlOps *MysqlOperations) CheckStatusOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (mysqlOps *MysqlOperations) ExecOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (mysqlOps *MysqlOperations) GetLagOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (mysqlOps *MysqlOperations) GetLogger() logr.Logger
  • func (mysqlOps *MysqlOperations) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)
  • func (mysqlOps *MysqlOperations) GetRoleForConsensus(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)
  • func (mysqlOps *MysqlOperations) GetRoleForReplication(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)
  • func (mysqlOps *MysqlOperations) GetRunningPort() int
  • func (mysqlOps *MysqlOperations) Init(metadata component.Properties) error
  • func (mysqlOps *MysqlOperations) InternalExec(ctx context.Context, sql string) (int64, error)
  • func (mysqlOps *MysqlOperations) InternalQuery(ctx context.Context, sql string) ([]byte, error)
  • func (mysqlOps *MysqlOperations) QueryOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
• type QueryRes

Types

type MysqlOperations

type MysqlOperations struct {
	BaseOperations
}

MysqlOperations represents MySQL output bindings.

func NewMysql

func NewMysql() *MysqlOperations

NewMysql returns a new MySQL output binding.

func (*MysqlOperations) CheckStatusOps

func (mysqlOps *MysqlOperations) CheckStatusOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*MysqlOperations) ExecOps

func (mysqlOps *MysqlOperations) ExecOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*MysqlOperations) GetLagOps

func (mysqlOps *MysqlOperations) GetLagOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*MysqlOperations) GetLogger

func (mysqlOps *MysqlOperations) GetLogger() logr.Logger

GetLogger is used for getting logger, implements BaseInternalOps interface

func (*MysqlOperations) GetRole

func (mysqlOps *MysqlOperations) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)

func (*MysqlOperations) GetRoleForConsensus

func (mysqlOps *MysqlOperations) GetRoleForConsensus(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)

func (*MysqlOperations) GetRoleForReplication

func (mysqlOps *MysqlOperations) GetRoleForReplication(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)

func (*MysqlOperations) GetRunningPort

func (mysqlOps *MysqlOperations) GetRunningPort() int

func (*MysqlOperations) Init

func (mysqlOps *MysqlOperations) Init(metadata component.Properties) error

Init initializes the MySQL binding.

func (*MysqlOperations) InternalExec

func (mysqlOps *MysqlOperations) InternalExec(ctx context.Context, sql string) (int64, error)

InternalExec is used for internal execution, implements BaseInternalOps interface

func (*MysqlOperations) InternalQuery

func (mysqlOps *MysqlOperations) InternalQuery(ctx context.Context, sql string) ([]byte, error)

InternalQuery is used for internal query, implements BaseInternalOps interface

func (*MysqlOperations) QueryOps

func (mysqlOps *MysqlOperations) QueryOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

type QueryRes

type QueryRes []map[string]interface{}