storage

Documentation

Index

• Variables
• type CsvEngine
  • func NewCsvEngine(recordType reflect.Type) *CsvEngine
  • func (this *CsvEngine) Load(csvFile string) (error, []interface{})
  • func (this *CsvEngine) Save(csvFile string, data []interface{}) error
• type RedisPool
  • func NewRedisPool(address string, password string) *RedisPool
  • func (redisPool *RedisPool) SortedSetAdd(key string, data []byte, score uint64) error
  • func (redisPool *RedisPool) SortedSetRangeByScore(key string, min, max uint64, offset, count int) ([]string, error)
  • func (redisPool *RedisPool) SortedSetRemoveByScore(key string, min, max uint64) error
  • func (redisPool *RedisPool) SortedSetRevRangeByScore(key string, min, max uint64, offset, count int) ([]string, error)

Variables

var (
	DEFAULT_REDIS_SERVER = "localhost:6379"
)

Types

type CsvEngine

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

func NewCsvEngine

func NewCsvEngine(recordType reflect.Type) *CsvEngine

func (*CsvEngine) Load

func (this *CsvEngine) Load(csvFile string) (error, []interface{})

func (*CsvEngine) Save

func (this *CsvEngine) Save(csvFile string, data []interface{}) error

type RedisPool

type RedisPool struct {
	redis.Pool
}

func NewRedisPool

func NewRedisPool(address string, password string) *RedisPool

func (*RedisPool) SortedSetAdd

func (redisPool *RedisPool) SortedSetAdd(key string, data []byte, score uint64) error

func (*RedisPool) SortedSetRangeByScore

func (redisPool *RedisPool) SortedSetRangeByScore(key string, min, max uint64, offset, count int) ([]string, error)

min, max: inclusive

func (*RedisPool) SortedSetRemoveByScore

func (redisPool *RedisPool) SortedSetRemoveByScore(key string, min, max uint64) error

min, max: inclusive

func (*RedisPool) SortedSetRevRangeByScore

func (redisPool *RedisPool) SortedSetRevRangeByScore(key string, min, max uint64, offset, count int) ([]string, error)

min, max: inclusive