downtime

package module
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2022 License: MIT Imports: 13 Imported by: 0

README

downtime

Golang port of downtimed

Examples

Track system downtime

	ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
	defer cancel()

	daemon := downtime.NewDaemon(store, db, sleepDuration)

	boottime, err := downtime.SystemBootTime()
	if err != nil {
		logger.Criticalf(err.Error())
		return err
	}
	err = daemon.Init(boottime, goTimeFormat)
	if err != nil {
		logger.Criticalf("init failed: %s", err.Error())
		return err
	}

	err = daemon.Run(ctx)
	if errors.Is(err, context.Canceled) {
		return nil
	}

Track program downtime

	ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
	defer cancel()

	daemon := downtime.NewDaemon(store, db, sleepDuration)

	boottime := downtime.ProcessBootTime()
	err = daemon.Init(boottime, goTimeFormat)
	if err != nil {
		logger.Criticalf("init failed: %s", err.Error())
		return err
	}

    go func(){
        err = daemon.Run(ctx)
        if errors.Is(err, context.Canceled) {
            return nil
        } else if err != nil{
            panic(err)
        }
    }

Documentation

Index

Constants

View Source 
const (
	DefaultTimeFormat   = "%F %T"
	DefaultDataDir      = "/var/lib/downtimed/"
	DefaultDBFile       = "downtimedb"
	DefaultSleepSeconds = 15
)
View Source 
const EventSize = 16

Variables

This section is empty.

Functions

func PrintVersion 

func PrintVersion()

func ProcessBootTime 

func ProcessBootTime() time.Time

func StrftimeToGo 

func StrftimeToGo(cFormat string) (goFormat string, err error)

StrftimeToGo converts a c-style strftime format string to the format expected by time.Time.Format()

func SystemBootTime 

func SystemBootTime() (time.Time, error)

Types

type Daemon 

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

func NewDaemon 

func NewDaemon(dataStore DataStore, database EventWriter, sleep time.Duration) *Daemon

func NewDaemonWithClock 

func NewDaemonWithClock(dataStore DataStore, database EventWriter, sleep time.Duration, clk clock.Clock) *Daemon

func (Daemon) Init 

func (d Daemon) Init(bootTime time.Time, timeFormat string) error

func (Daemon) Run 

func (d Daemon) Run(ctx context.Context) error

type DataDir 

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

func NewDataDir 

func NewDataDir(dir string) (*DataDir, error)

func (DataDir) GetBoot 

func (dd DataDir) GetBoot() (time.Time, error)

func (DataDir) GetShutdown 

func (dd DataDir) GetShutdown() (time.Time, error)

func (DataDir) GetStamp 

func (dd DataDir) GetStamp() (time.Time, error)

func (DataDir) SetBoot 

func (dd DataDir) SetBoot(t time.Time) error

func (DataDir) SetShutdown 

func (dd DataDir) SetShutdown(t time.Time) error

func (DataDir) SetStamp 

func (dd DataDir) SetStamp(t time.Time) error

type DataStore 

type DataStore interface {
	SetStamp(t time.Time) error
	GetStamp() (time.Time, error)
	SetShutdown(t time.Time) error
	GetShutdown() (time.Time, error)
	SetBoot(t time.Time) error
	GetBoot() (time.Time, error)
}

type DatabaseReader 

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

func NewDatabaseReader 

func NewDatabaseReader(reader io.ReadSeeker) *DatabaseReader

func OpenDatabaseReader 

func OpenDatabaseReader(filepath string) (*DatabaseReader, error)

func (*DatabaseReader) All 

func (db *DatabaseReader) All() ([]Event, error)

func (*DatabaseReader) Close 

func (db *DatabaseReader) Close() error

func (*DatabaseReader) Next 

func (db *DatabaseReader) Next() (Event, error)

func (*DatabaseReader) Reset 

func (db *DatabaseReader) Reset() error

func (*DatabaseReader) Since 

func (db *DatabaseReader) Since(after time.Time) ([]Event, error)

type DatabaseWriter 

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

func NewDatabaseWriter 

func NewDatabaseWriter(writer io.Writer) *DatabaseWriter

func (*DatabaseWriter) Append 

func (db *DatabaseWriter) Append(event Event) error

func (*DatabaseWriter) Close 

func (db *DatabaseWriter) Close() error

type Event 

type Event struct {
	What EventType

	When UnixTimestamp
	// contains filtered or unexported fields
}

func NewEvent 

func NewEvent(what EventType, when time.Time) Event

func (Event) String 

func (e Event) String() string

type EventReader 

type EventReader interface {
	io.Closer
	Next() (Event, error)
	Since(after time.Time) ([]Event, error)
	All() ([]Event, error)
	Reset() error
}

type EventType 

type EventType uint8

ENUM( None = 0 Up = 1 Shutdown = 2 Crash = 3 ) 

const (
	// EventTypeNone is a EventType of type None.
	EventTypeNone EventType = iota
	// EventTypeUp is a EventType of type Up.
	EventTypeUp
	// EventTypeShutdown is a EventType of type Shutdown.
	EventTypeShutdown
	// EventTypeCrash is a EventType of type Crash.
	EventTypeCrash
)

func ParseEventType 

func ParseEventType(name string) (EventType, error)

ParseEventType attempts to convert a string to a EventType.

func (EventType) MarshalText 

func (x EventType) MarshalText() ([]byte, error)

MarshalText implements the text marshaller method.

func (EventType) String 

func (x EventType) String() string

String implements the Stringer interface.

func (*EventType) UnmarshalText 

func (x *EventType) UnmarshalText(text []byte) error

UnmarshalText implements the text unmarshaller method.

type EventWriter 

type EventWriter interface {
	io.Closer
	Append(event Event) error
}

type UnixTimestamp 

type UnixTimestamp int64

func (UnixTimestamp) AsTime 

func (ut UnixTimestamp) AsTime() time.Time

func (UnixTimestamp) String 

func (ut UnixTimestamp) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.