tlog

README

About

用于简化流水日志的发送和收集

Getting Started

安装依赖

go get gitee.com/gricks/fmtx/cmd/fmtx

fmtx 用于格式化代码的生成

Documentation

Index

• type Flow
• type Tlogger
  • func NewTlogger() *Tlogger
  • func (this *Tlogger) Close()
  • func (this *Tlogger) Init(addrs []string, wbuf int, wque int) error
  • func (this *Tlogger) Send(flow Flow)
  • func (this *Tlogger) SendSync(ctx context.Context, flow Flow) error

Types

type Flow

type Flow interface {
	Name() string

	// Marshal
	Marshalx() *fmtx.Buffer
	Unmarshalx([]byte) error

	// Coloration
	GetSeq() int32

	// Sql
	SQLStrs() string
	SQLCols() string
	SQLArgs() []interface{}
}

type Tlogger

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

func NewTlogger

func NewTlogger() *Tlogger

func (*Tlogger) Close

func (this *Tlogger) Close()

func (*Tlogger) Init

func (this *Tlogger) Init(addrs []string, wbuf int, wque int) error

func (*Tlogger) Send

func (this *Tlogger) Send(flow Flow)

func (*Tlogger) SendSync

func (this *Tlogger) SendSync(ctx context.Context, flow Flow) error