serv

Documentation

Index

• Constants
• Variables
• func StopStatus(status Status) bool
• func WorkStatus(status Status) bool
• type IServ
• type Serv
  • func New(conf *viper.Viper) *Serv
  • 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) Info() (result sth.Result)
  • func (serv *Serv) Message() messagebus.MessageBus
  • func (serv *Serv) OnStart(ctx context.Context) (err error)
  • func (serv *Serv) OnStop(ctx context.Context) (err error)
  • func (serv *Serv) PID() int
  • func (serv *Serv) Process() *process.Process
  • func (serv *Serv) SetStatus(newStatus Status) (oldStatus Status, err error)
  • func (serv *Serv) Status() Status
  • func (serv *Serv) Toggle(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

Constants

const (
	ServStatusChanged string = "ServStatusChanged"
)

Topics

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(context.Context) error
	OnStop(context.Context) error
}

IServ 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) 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) Info

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

Info TODO

func (*Serv) Message

func (serv *Serv) Message() messagebus.MessageBus

Message TODO

func (*Serv) OnStart

func (serv *Serv) OnStart(ctx context.Context) (err error)

OnStart TODO

func (*Serv) OnStop

func (serv *Serv) OnStop(ctx context.Context) (err error)

OnStop TODO

func (*Serv) PID

func (serv *Serv) PID() int

PID TODO

func (*Serv) Process

func (serv *Serv) Process() *process.Process

Process TODO

func (*Serv) SetStatus

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

SetStatus TODO

func (*Serv) Status

func (serv *Serv) Status() Status

Status TODO

func (*Serv) Toggle

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

Toggle TODO

type Status

type Status int

Status type

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

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