utils

Documentation

Index

• Variables
• func ToError(val interface{}) error
• type LogWriter
  • func NewLogWriter(logger *log.Logger) *LogWriter
  • func (w *LogWriter) Close() error
  • func (w LogWriter) Lines() []string
  • func (w *LogWriter) Write(p []byte) (n int, err error)
• type PidFile
  • func NewPidFile(path string) *PidFile
  • func (p *PidFile) Acquire() error
  • func (p *PidFile) MustRelease()
  • func (p *PidFile) Release() error
• type ScheduleExpression
  • func NewSchedule(expression string) (*ScheduleExpression, error)
  • func (s ScheduleExpression) Next(t time.Time) time.Time
  • func (s ScheduleExpression) String() string
  • func (s *ScheduleExpression) UnmarshalText(text []byte) error

Variables

var (
	ErrPidFileNotFound = errors.New("pid file not found")
	ErrPidFileStale    = errors.New("pid file exists but points to a not existing process")
	ErrPidFileExists   = errors.New("pid file already exists and points to a valid process")
)

Functions

func ToError

func ToError(val interface{}) error

Types

type LogWriter

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

func NewLogWriter

func NewLogWriter(logger *log.Logger) *LogWriter

func (*LogWriter) Close

func (w *LogWriter) Close() error

func (LogWriter) Lines

func (w LogWriter) Lines() []string

func (*LogWriter) Write

func (w *LogWriter) Write(p []byte) (n int, err error)

type PidFile

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

func NewPidFile

func NewPidFile(path string) *PidFile

func (*PidFile) Acquire

func (p *PidFile) Acquire() error

func (*PidFile) MustRelease

func (p *PidFile) MustRelease()

func (*PidFile) Release

func (p *PidFile) Release() error

type ScheduleExpression

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

func NewSchedule

func NewSchedule(expression string) (*ScheduleExpression, error)

func (ScheduleExpression) Next

func (s ScheduleExpression) Next(t time.Time) time.Time

func (ScheduleExpression) String

func (s ScheduleExpression) String() string

func (*ScheduleExpression) UnmarshalText

func (s *ScheduleExpression) UnmarshalText(text []byte) error