serv

Documentation

Index

• Variables
• func StopStatus(status Status) bool
• func WorkStatus(status Status) bool
• type ExtensionManager
  • func NewExtensionManager(serv IServ) *ExtensionManager
  • func (mgr *ExtensionManager) AddExtension(name string, extension IExtension) bool
  • func (mgr *ExtensionManager) Cleanup() (err error)
  • func (mgr *ExtensionManager) GetExtension(name string) IExtension
  • func (mgr *ExtensionManager) Setup() (err error)
• type IExtension
• type IServ
• type NamedExtension
  • func (ext *NamedExtension) Get() IExtension
  • func (ext *NamedExtension) ItemID() uint64
  • func (ext *NamedExtension) Name() string
• 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 (i Status) String() string
  • 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 ExtensionManager

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

ExtensionManager TODO

func NewExtensionManager

func NewExtensionManager(serv IServ) *ExtensionManager

NewExtensionManager TODO

func (*ExtensionManager) AddExtension

func (mgr *ExtensionManager) AddExtension(name string, extension IExtension) bool

AddExtension TODO

func (*ExtensionManager) Cleanup

func (mgr *ExtensionManager) Cleanup() (err error)

Cleanup TODO

func (*ExtensionManager) GetExtension

func (mgr *ExtensionManager) GetExtension(name string) IExtension

GetExtension TODO

func (*ExtensionManager) Setup

func (mgr *ExtensionManager) Setup() (err error)

Setup TODO

type IExtension

type IExtension interface {
	Setup() error
	Cleanup() error
}

IExtension TODO

type IServ

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

IServ TODO

type NamedExtension

type NamedExtension struct {
	IExtension
	// contains filtered or unexported fields
}

NamedExtension TODO

func (*NamedExtension) Get

func (ext *NamedExtension) Get() IExtension

Get TODO

func (*NamedExtension) ItemID

func (ext *NamedExtension) ItemID() uint64

ItemID TODO

func (*NamedExtension) Name

func (ext *NamedExtension) Name() string

Name 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 {
	*ExtensionManager

	*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) String

func (i Status) String() string

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