mysql

Documentation

Index

• func NewMysql(logger logger.Logger) bindings.OutputBinding
• type MysqlOperations
  • func (mysqlOps *MysqlOperations) CheckStatusOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (mysqlOps *MysqlOperations) ExecOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (mysqlOps *MysqlOperations) GetLagOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (mysqlOps *MysqlOperations) GetLogger() logger.Logger
  • func (mysqlOps *MysqlOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, ...) (string, error)
  • func (mysqlOps *MysqlOperations) GetRunningPort() int
  • func (mysqlOps *MysqlOperations) Init(metadata bindings.Metadata) error
  • func (mysqlOps *MysqlOperations) InitDelay() 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 *bindings.InvokeRequest, ...) (OpsResult, error)

Functions

func NewMysql

func NewMysql(logger logger.Logger) bindings.OutputBinding

NewMysql returns a new MySQL output binding.

Types

type MysqlOperations

type MysqlOperations struct {
	BaseOperations
	// contains filtered or unexported fields
}

MysqlOperations represents MySQL output bindings.

func (*MysqlOperations) CheckStatusOps

func (mysqlOps *MysqlOperations) CheckStatusOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

CheckStatusOps design details: https://infracreate.feishu.cn/wiki/wikcndch7lMZJneMnRqaTvhQpwb#doxcnOUyQ4Mu0KiUo232dOr5aad

func (*MysqlOperations) ExecOps

func (mysqlOps *MysqlOperations) ExecOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

func (*MysqlOperations) GetLagOps

func (mysqlOps *MysqlOperations) GetLagOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

func (*MysqlOperations) GetLogger

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

GetLogger is used for getting logger, implement BaseInternalOps interface

func (*MysqlOperations) GetRole

func (mysqlOps *MysqlOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, response *bindings.InvokeResponse) (string, error)

func (*MysqlOperations) GetRunningPort

func (mysqlOps *MysqlOperations) GetRunningPort() int

func (*MysqlOperations) Init

func (mysqlOps *MysqlOperations) Init(metadata bindings.Metadata) error

Init initializes the MySQL binding.

func (*MysqlOperations) InitDelay

func (mysqlOps *MysqlOperations) InitDelay() error

func (*MysqlOperations) InternalExec

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

InternalExec is used for internal execution, implement BaseInternalOps interface

func (*MysqlOperations) InternalQuery

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

InternalQuery is used for internal query, implement BaseInternalOps interface

func (*MysqlOperations) QueryOps

func (mysqlOps *MysqlOperations) QueryOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)