common

Documentation

Index

• func CheckIdProcessed(conn redis.Conn, hash_key string, key string) (string, error)
• func FilePutContent(outfile string, content string) error
• func GetCtx(file string) (*sj.Json, error)
• func GetHourStrFromId(id string) (string, error)
• func GetSubStr(str, pre, post string) string
• func GzCompress(raw string) string
• func NewPool(server string, password string, idle int, timeoutSec int) *redis.Pool
• func ReadFile(path string) (string, error)
• func SetIdProcessed(conn redis.Conn, hash_key string, key string, val string) (int, error)
• func WriteFile(path string, content string) error
• func ZlibCompress(raw string) string
• func ZlibDeCompress(line []byte) (string, error)
• type RedisPoolManager

Functions

func CheckIdProcessed

func CheckIdProcessed(conn redis.Conn, hash_key string, key string) (string, error)

func FilePutContent

func FilePutContent(outfile string, content string) error

func GetCtx

func GetCtx(file string) (*sj.Json, error)

func GetHourStrFromId

func GetHourStrFromId(id string) (string, error)

get 2016-02-26-12 from http://hostname:80/access/info.2016-02-26-12-05.gz

func GetSubStr

func GetSubStr(str, pre, post string) string

func GzCompress

func GzCompress(raw string) string

func NewPool

func NewPool(server string, password string, idle int, timeoutSec int) *redis.Pool

func ReadFile

func ReadFile(path string) (string, error)

func SetIdProcessed

func SetIdProcessed(conn redis.Conn, hash_key string, key string, val string) (int, error)

func WriteFile

func WriteFile(path string, content string) error

func ZlibCompress

func ZlibCompress(raw string) string

func ZlibDeCompress

func ZlibDeCompress(line []byte) (string, error)

Types

type RedisPoolManager

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