redis

Documentation

Index

• type Redis
  • func New(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Redis
  • func (e *Redis) CheckIfNotTask(keys *goredis.ScanIterator) bool
  • func (e *Redis) Connect() bool
  • func (e *Redis) CountRedisKey(pattern string, ignoreState string) int
  • func (e *Redis) CountRedisKeyState(pattern string, state string) int
  • func (e *Redis) DelRedisKey(key string) int64
  • func (e *Redis) GetAllRedisKeys(pattern string) *goredis.ScanIterator
  • func (e *Redis) GetRedisKey(key string) string
  • func (e *Redis) GetTaskFromEvent(update *mesosproto.Event_Update) *cfg.Command
  • func (e *Redis) GetTaskFromTaskID(taskID string) *cfg.Command
  • func (e *Redis) PingRedis() error
  • func (e *Redis) SaveConfig(config cfg.Config)
  • func (e *Redis) SaveFrameworkRedis(framework *cfg.FrameworkConfig)
  • func (e *Redis) SaveTaskRedis(cmd *cfg.Command)
  • func (e *Redis) SetRedisKey(data []byte, key string)

Types

type Redis

type Redis struct {
	Client   *goredis.Client
	CTX      context.Context
	Server   string
	Password string
	DB       int
	Prefix   string
	Mesos    mesos.Mesos
}

Redis struct about the redis connection

func New

func New(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Redis

New will create a new Redis object

func (*Redis) CheckIfNotTask

func (e *Redis) CheckIfNotTask(keys *goredis.ScanIterator) bool

CheckIfNotTask check if the redis key is a mesos task

func (*Redis) Connect

func (e *Redis) Connect() bool

Connect will connect the redis DB and save the client pointer

func (*Redis) CountRedisKey

func (e *Redis) CountRedisKey(pattern string, ignoreState string) int

CountRedisKey will get back the count of the redis key

func (*Redis) CountRedisKeyState

func (e *Redis) CountRedisKeyState(pattern string, state string) int

CountRedisKeyState will get back the amount of redis keys with the spesific state.

func (*Redis) DelRedisKey

func (e *Redis) DelRedisKey(key string) int64

DelRedisKey will delete a redis key

func (*Redis) GetAllRedisKeys

func (e *Redis) GetAllRedisKeys(pattern string) *goredis.ScanIterator

GetAllRedisKeys get out all redis keys to a patter

func (*Redis) GetRedisKey

func (e *Redis) GetRedisKey(key string) string

GetRedisKey get out the data of a key

func (*Redis) GetTaskFromEvent

func (e *Redis) GetTaskFromEvent(update *mesosproto.Event_Update) *cfg.Command

GetTaskFromEvent get out the key by a mesos event

func (*Redis) GetTaskFromTaskID

func (e *Redis) GetTaskFromTaskID(taskID string) *cfg.Command

GeTaskFromTaskID get out the task by a taskID

func (*Redis) PingRedis

func (e *Redis) PingRedis() error

PingRedis to check the health of redis

func (*Redis) SaveConfig

func (e *Redis) SaveConfig(config cfg.Config)

SaveConfig store the current framework config

func (*Redis) SaveFrameworkRedis

func (e *Redis) SaveFrameworkRedis(framework *cfg.FrameworkConfig)

SaveFrameworkRedis store mesos framework in DB

func (*Redis) SaveTaskRedis

func (e *Redis) SaveTaskRedis(cmd *cfg.Command)

SaveTaskRedis store mesos task in DB

func (*Redis) SetRedisKey

func (e *Redis) SetRedisKey(data []byte, key string)

SetRedisKey store data in redis