redis

package
v0.0.0-...-948e253 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 25, 2021 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// RefreshTypeDel redis 操作类型为删除key
	RefreshTypeDel = 0
	// RefreshTypeUpdate redis 操作类型为更新key
	RefreshTypeUpdate = 1
	// RedisKeyTypeList 存储到redis 为list 类型, 目前暂不支持
	RedisKeyTypeList = "list"
	// RedisKeyTypeString 存储到redis 为string 类型
	RedisKeyTypeString = "string"
	// RedisKeyTypeSet 存储到redis 为 set 类型
	RedisKeyTypeSet = "set"
	// RedisKeyTypeZset 存储到redis 为 zset 类型
	RedisKeyTypeZset = "zset"
	// RedisKeyTypeHash 存储到redis 为 hash 类型
	RedisKeyTypeHash = "hash"
)
View Source
var (
	// OnlyGzip 只进行gzip压缩
	OnlyGzip = 1
	// GzipBase64 先gzip压缩,压缩后base64编码
	GzipBase64 = 2
	// Snappy 只snappy压缩
	Snappy = 3
	// SnappyBase64 先snappy压缩,压缩后base64编码
	SnappyBase64 = 4
)

Functions

func FusionProcessing

func FusionProcessing(redisData []utility.ConsumerDataStruct) error

FusionProcessing 处理数据,写入redis

func GetPos

func GetPos(sid int) (string, int)

GetPos 获取redis 持久化的位置

func SavePos

func SavePos(sid int, binlogFile string, binlogPos uint32, timestamp uint32) error

SavePos save mysql binlog position

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL