initialize

Documentation

Index

• Variables
• type RedisHook
  • func (rh RedisHook) AfterProcess(_ context.Context, cmd redis.Cmder) error
  • func (rh RedisHook) AfterProcessPipeline(_ context.Context, cmds []redis.Cmder) error
  • func (rh RedisHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (rh RedisHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Variables

var (
	Config        *_config
	Cache         util.Cache
	Db            *gorm.DB
	Nats          *nats.Conn
	Scheduler     *gocron.Scheduler
	RequestLogger *zap.Logger
	ErrorLogger   *zap.Logger
	PanicLogger   *zap.Logger
)

var Rdb, LockRdb *redis.Client

Types

type RedisHook

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

func (RedisHook) AfterProcess

func (rh RedisHook) AfterProcess(_ context.Context, cmd redis.Cmder) error

func (RedisHook) AfterProcessPipeline

func (rh RedisHook) AfterProcessPipeline(_ context.Context, cmds []redis.Cmder) error

func (RedisHook) BeforeProcess

func (rh RedisHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (RedisHook) BeforeProcessPipeline

func (rh RedisHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)