redisoper

package
v0.0.0-...-b6245c8 Latest Latest
Warning

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

Go to latest
Published: Nov 27, 2018 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const ConnectTimeout = 5000
View Source
const IdleTimeout = 300000
View Source
const LPUSH_KEY = "origin_file"
View Source
const MaxActive = 5000
View Source
const MaxIdle = 100
View Source
const ReadTimeout = 0
View Source
const WriteTimeout = 0

Variables

This section is empty.

Functions

This section is empty.

Types

type EncItem

type EncItem struct {
	Profilename string `json:"profilename"`
	Id          string `json:"id"`
	Url         string `json:"url"`
	Timestamp   string `json:"timestamp"`
}

type RedisOper

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

func NewRedisOper

func NewRedisOper(hostname string, port int, password string) *RedisOper

func (*RedisOper) GetEncodeStat

func (self *RedisOper) GetEncodeStat(Id string) (info *common.EncodeStatInfo, err error)

func (*RedisOper) IsEncodedDone

func (self *RedisOper) IsEncodedDone(key string) bool

func (*RedisOper) Notify

func (self *RedisOper) Notify(filename string) error

func (*RedisOper) SetEncodeNotify

func (self *RedisOper) SetEncodeNotify(encNotify common.EncodeNotification)

func (*RedisOper) Start

func (self *RedisOper) Start() error

func (*RedisOper) UpdateEncodeStat

func (self *RedisOper) UpdateEncodeStat(info *common.EncodeStatInfo) error

Jump to

Keyboard shortcuts

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