infoc

Documentation

Index

• type Infoc
  • func New(c *conf.Canal_Database_Infoc, logger zapcore.Core) (i *Infoc)
  • func (i *Infoc) Close()
  • func (i *Infoc) Flush()
  • func (i *Infoc) Rows(rows int64)
  • func (i *Infoc) Send(ctx context.Context, key string, v interface{}) (err error)

Types

type Infoc

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

Infoc infoc struct.

func New

func New(c *conf.Canal_Database_Infoc, logger zapcore.Core) (i *Infoc)

New new infoc2 logger.

func (*Infoc) Close

func (i *Infoc) Close()

Close close resource.

func (*Infoc) Flush

func (i *Infoc) Flush()

Flush flush reporter count.

func (*Infoc) Rows

func (i *Infoc) Rows(rows int64)

Rows the affected by binlog enent.

func (*Infoc) Send

func (i *Infoc) Send(ctx context.Context, key string, v interface{}) (err error)

Send send message.