operator

Documentation

Index

• type Holder
  • func NewHolder() *Holder
  • func (h *Holder) Get(taskName string, sqls []string) (string, *Operator)
  • func (h *Holder) Remove(taskName, key string)
  • func (h *Holder) Set(req *pb.HandleSQLsRequest) error
• type Operator
  • func (o *Operator) String() string

Types

type Holder

type Holder struct {
	// contains filtered or unexported fields
}

Holder holds SQL operators

func NewHolder

func NewHolder() *Holder

NewHolder creates a new Holder

func (*Holder) Get

func (h *Holder) Get(taskName string, sqls []string) (string, *Operator)

Get tries to get an operator by taskName and SQLs, returns key and operator

func (*Holder) Remove

func (h *Holder) Remove(taskName, key string)

Remove removes the operator with the key

func (*Holder) Set

func (h *Holder) Set(req *pb.HandleSQLsRequest) error

Set sets an operator according to request

type Operator

type Operator struct {
	Req *pb.HandleSQLsRequest
	// contains filtered or unexported fields
}

Operator contains an operation for specified binlog pos used by `sql-skip` and `sql-replace`

func (*Operator) String

func (o *Operator) String() string