serv

Documentation

Index

• Variables
• func StopStatus(status Status) bool
• func WorkStatus(status Status) bool
• type IServ
• type RedisServ
  • func NewRedisServ(conf *viper.Viper, client *redis.Client) *RedisServ
  • func (serv *RedisServ) Client() *redis.Client
  • func (serv *RedisServ) MetaInfo() (result sth.Result, err error)
  • func (serv *RedisServ) RedisInfo(section ...string) (utils.ParsedRedisInfo, error)
• type Serv
  • func New(conf *viper.Viper) *Serv
  • func (serv *Serv) CPUPercent() float64
  • func (serv *Serv) Conf() *viper.Viper
  • func (serv *Serv) DoWithLock(f func() (interface{}, error), rLock bool) (interface{}, error)
  • func (serv *Serv) DoWithLockOnWorkStatus(f func() (interface{}, error), rLock bool, mustWorking bool) (interface{}, error)
  • func (serv *Serv) Getpid() int
  • func (serv *Serv) MetaInfo() (result sth.Result)
  • func (serv *Serv) OnStart() error
  • func (serv *Serv) OnStop() error
  • func (serv *Serv) ProcessMemory() *process.MemoryInfoStat
  • func (serv *Serv) SetStatus(newStatus Status, lock bool) (err error)
  • func (serv *Serv) Status(lock bool) Status
  • func (serv *Serv) Switch(pauseOrResume bool) (sth.Result, error)
• type Status
  • func (s Status) MarshalJSON() ([]byte, error)
  • func (s *Status) UnmarshalJSON(b []byte) error
• type StatusConflictError
  • func (e *StatusConflictError) Error() string
• type StatusError
  • func (e *StatusError) Error() string

Variables

var StatusMap = map[string]Status{
	utils.Text(Init):      Init,
	utils.Text(Preparing): Preparing,
	utils.Text(Working):   Working,
	utils.Text(Paused):    Paused,
	utils.Text(Stopping):  Stopping,
	utils.Text(Stopped):   Stopped,
}

StatusMap TODO

Functions

func StopStatus

func StopStatus(status Status) bool

StopStatus TODO

func WorkStatus

func WorkStatus(status Status) bool

WorkStatus TODO

Types

type IServ

type IServ interface {
	OnStart() error
	OnStop() error
}

IServ TODO

type RedisServ

type RedisServ struct {
	*Serv
	// contains filtered or unexported fields
}

RedisServ TODO

func NewRedisServ

func NewRedisServ(conf *viper.Viper, client *redis.Client) *RedisServ

NewRedisServ TODO

func (*RedisServ) Client

func (serv *RedisServ) Client() *redis.Client

Client TODO

func (*RedisServ) MetaInfo

func (serv *RedisServ) MetaInfo() (result sth.Result, err error)

MetaInfo TODO

func (*RedisServ) RedisInfo

func (serv *RedisServ) RedisInfo(section ...string) (utils.ParsedRedisInfo, error)

RedisInfo TODO

type Serv

type Serv struct {
	*sync.RWMutex
	// contains filtered or unexported fields
}

Serv TODO

func New

func New(conf *viper.Viper) *Serv

New TODO

func (*Serv) CPUPercent

func (serv *Serv) CPUPercent() float64

CPUPercent TODO

func (*Serv) Conf

func (serv *Serv) Conf() *viper.Viper

Conf TODO

func (*Serv) DoWithLock

func (serv *Serv) DoWithLock(f func() (interface{}, error), rLock bool) (interface{}, error)

DoWithLock TODO

func (*Serv) DoWithLockOnWorkStatus

func (serv *Serv) DoWithLockOnWorkStatus(f func() (interface{}, error), rLock bool, mustWorking bool) (interface{}, error)

DoWithLockOnWorkStatus TODO

func (*Serv) Getpid

func (serv *Serv) Getpid() int

Getpid TODO

func (*Serv) MetaInfo

func (serv *Serv) MetaInfo() (result sth.Result)

MetaInfo TODO

func (*Serv) OnStart

func (serv *Serv) OnStart() error

OnStart TODO

func (*Serv) OnStop

func (serv *Serv) OnStop() error

OnStop TODO

func (*Serv) ProcessMemory

func (serv *Serv) ProcessMemory() *process.MemoryInfoStat

ProcessMemory TODO

func (*Serv) SetStatus

func (serv *Serv) SetStatus(newStatus Status, lock bool) (err error)

SetStatus TODO

func (*Serv) Status

func (serv *Serv) Status(lock bool) Status

Status TODO

func (*Serv) Switch

func (serv *Serv) Switch(pauseOrResume bool) (sth.Result, error)

Switch TODO

type Status

type Status int

Status type

const (
	Init      Status // init
	Preparing        // preparing
	Working          // working
	Paused           // paused
	Stopping         // stopping
	Stopped          // stopped
)

Status enum

func (Status) MarshalJSON

func (s Status) MarshalJSON() ([]byte, error)

MarshalJSON TODO

func (*Status) UnmarshalJSON

func (s *Status) UnmarshalJSON(b []byte) error

UnmarshalJSON unmashals a quoted json string to the enum value

type StatusConflictError

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

StatusConflictError TODO

func (*StatusConflictError) Error

func (e *StatusConflictError) Error() string

type StatusError

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

StatusError TODO

func (*StatusError) Error

func (e *StatusError) Error() string