infoc

Documentation

Index

• type Config
• type Infoc
  • func New(c *Config) (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 Config

type Config struct {
	TaskID string
	// udp or tcp
	Proto string
	Addr  string
	// reporter
	ReporterAddr string
}

Config is infoc config.

type Infoc

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

Infoc infoc struct.

func New

func New(c *Config) (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.