connector

Documentation

Index

• Variables
• func IsErrRecordNotFound(err error) bool
• func IsMongoErrClientDisconnected(err error) bool
• func IsMongoErrEmptySlice(err error) bool
• func IsMongoErrInvalidIndexValue(err error) bool
• func IsMongoErrNilCursor(err error) bool
• func IsMongoErrNilDocument(err error) bool
• func IsMongoErrNilValue(err error) bool
• func IsMongoErrNoDocuments(err error) bool
• func IsMongoErrWrongClient(err error) bool
• func IsNil(err error) bool
• type TracingHook
  • func NewTracingHook(opt redisOpt) *TracingHook
  • func (hook TracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (hook TracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (hook TracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (hook TracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
  • func (hook TracingHook) StartSpanFromContext(ctx context.Context, cmd redis.Cmder, cmdList []redis.Cmder) context.Context

Variables

var Conf *configMap

var Mongo = new(mongoConnector)

Mongo : Global Database Connector

var Mysql = new(mysqleConnector)

Mysql : Global Database Connector

var Redis = new(redisConnector)

Redis : Global Redis Connector

Functions

func IsErrRecordNotFound

func IsErrRecordNotFound(err error) bool

IsErrRecordNotFound gorm 查询是否为空判断

func IsMongoErrClientDisconnected

func IsMongoErrClientDisconnected(err error) bool

IsMongoErrClientDisconnected : ...

func IsMongoErrEmptySlice

func IsMongoErrEmptySlice(err error) bool

IsMongoErrEmptySlice : ...

func IsMongoErrInvalidIndexValue

func IsMongoErrInvalidIndexValue(err error) bool

IsMongoErrInvalidIndexValue : ...

func IsMongoErrNilCursor

func IsMongoErrNilCursor(err error) bool

IsMongoErrNilCursor : ...

func IsMongoErrNilDocument

func IsMongoErrNilDocument(err error) bool

IsMongoErrNilDocument document 为空

func IsMongoErrNilValue

func IsMongoErrNilValue(err error) bool

IsMongoErrNilValue 值为空

func IsMongoErrNoDocuments

func IsMongoErrNoDocuments(err error) bool

IsMongoErrNoDocuments : ...

func IsMongoErrWrongClient

func IsMongoErrWrongClient(err error) bool

IsMongoErrWrongClient : ...

func IsNil

func IsNil(err error) bool

IsNil Nil reply returned by Redis when key does not exist.

Types

type TracingHook

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

func NewTracingHook

func NewTracingHook(opt redisOpt) *TracingHook

func (TracingHook) AfterProcess

func (hook TracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

AfterProcess 执行后

func (TracingHook) AfterProcessPipeline

func (hook TracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

AfterProcessPipeline 后处理管道

func (TracingHook) BeforeProcess

func (hook TracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

BeforeProcess 执行前

func (TracingHook) BeforeProcessPipeline

func (hook TracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

BeforeProcessPipeline 流水线前

func (TracingHook) StartSpanFromContext

func (hook TracingHook) StartSpanFromContext(ctx context.Context, cmd redis.Cmder, cmdList []redis.Cmder) context.Context