redisLog

Documentation

Index

• type RedisDbLogSender
  • func NewRedisDbLogSender() *RedisDbLogSender
  • func (d *RedisDbLogSender) GetHeaderBytes(head dbUtils.SendHead) ([]byte, error)
  • func (d *RedisDbLogSender) GetOldFirstFilePath() (string, error)
  • func (d *RedisDbLogSender) Send(bytes []byte) error
  • func (d *RedisDbLogSender) StartSendFile()
• type RedisLogContent
• type RedisLogHelper
  • func NewRedisLogHelper() *RedisLogHelper
  • func (d *RedisLogHelper) CheckNewFile(fl *os.File) bool
  • func (d *RedisLogHelper) GetLatestFileIndex() int
  • func (d *RedisLogHelper) GetOldFirstFilePath() (string, error)
  • func (d *RedisLogHelper) WriteLog(logContent RedisLogContent) error
• type RedisLogType

Types

type RedisDbLogSender

type RedisDbLogSender struct {
	MaxIndex int
	// contains filtered or unexported fields
}

func NewRedisDbLogSender

func NewRedisDbLogSender() *RedisDbLogSender

func (*RedisDbLogSender) GetHeaderBytes

func (d *RedisDbLogSender) GetHeaderBytes(head dbUtils.SendHead) ([]byte, error)

func (*RedisDbLogSender) GetOldFirstFilePath

func (d *RedisDbLogSender) GetOldFirstFilePath() (string, error)

func (*RedisDbLogSender) Send

func (d *RedisDbLogSender) Send(bytes []byte) error

func (*RedisDbLogSender) StartSendFile

func (d *RedisDbLogSender) StartSendFile()

type RedisLogContent

type RedisLogContent struct {
	LogType           RedisLogType
	RedisKey          string
	Content           interface{}
	SecondsOfDuration float64
	Count             int64
}

type RedisLogHelper

type RedisLogHelper struct {
	FileLock        sync.Mutex
	FileNameTemp    string
	FileName        string
	FileIndex       int
	MaxFileSize     int64
	MaxWriteSeconds float64
}

func NewRedisLogHelper

func NewRedisLogHelper() *RedisLogHelper

func (*RedisLogHelper) CheckNewFile

func (d *RedisLogHelper) CheckNewFile(fl *os.File) bool

func (*RedisLogHelper) GetLatestFileIndex

func (d *RedisLogHelper) GetLatestFileIndex() int

func (*RedisLogHelper) GetOldFirstFilePath

func (d *RedisLogHelper) GetOldFirstFilePath() (string, error)

func (*RedisLogHelper) WriteLog

func (d *RedisLogHelper) WriteLog(logContent RedisLogContent) error

type RedisLogType

type RedisLogType int

const (
	Add    RedisLogType = 0
	Del    RedisLogType = 1
	Incr   RedisLogType = 2
	Expire RedisLogType = 3
	LPush  RedisLogType = 4
	LSet   RedisLogType = 5
	LRem   RedisLogType = 6
)