heartbeat

Documentation

Index

• type Database
  • func (d *Database) Open(dbConfig natsservice.MysqlConfig) error
• type DatabaseConfig
• type HeartbeatSaver
  • func NewHeartbeatSaver(mysqlConfig natsservice.MysqlConfig) *HeartbeatSaver
  • func (svc *HeartbeatSaver) Logger() *logrus.Entry
  • func (svc *HeartbeatSaver) Run(ctx context.Context, params ...interface{}) error
• type HeartbeatSender
  • func NewHeartbeatSender(period int, randomPeriod int) *HeartbeatSender
  • func (svc *HeartbeatSender) Logger() *logrus.Entry
  • func (svc *HeartbeatSender) Run(ctx context.Context, params ...interface{}) error
  • func (svc *HeartbeatSender) SendHeartbeatEvent(ctx context.Context) error
• type HeartbeatWebInterface
  • func NewHeartbeatWebInterface(mysqlConfig natsservice.MysqlConfig) *HeartbeatWebInterface
  • func (svc *HeartbeatWebInterface) Run(ctx context.Context, params ...interface{}) error
• type Sent
  • func NewSent(natsServiceName string) (*Sent, error)

Types

type Database

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

func (*Database) Open

func (d *Database) Open(dbConfig natsservice.MysqlConfig) error

type DatabaseConfig

type DatabaseConfig struct {
	DBHost string `ini:"dbhost,omitempty"`
	DBname string `ini:"dbname,omitempty"`
	DBuser string `ini:"dbuser,omitempty"`
	DBpass string `ini:"dbpass,omitempty"`
	DBPort int    `ini:"dbport,omitempty"`
}

type HeartbeatSaver

type HeartbeatSaver struct {
	natsservice.NatsService
	// contains filtered or unexported fields
}

HeartbeatSaver listens to com.plugis.heartbeat.Sent events and saves events in a database

func NewHeartbeatSaver

func NewHeartbeatSaver(mysqlConfig natsservice.MysqlConfig) *HeartbeatSaver

func (*HeartbeatSaver) Logger

func (svc *HeartbeatSaver) Logger() *logrus.Entry

func (*HeartbeatSaver) Run

func (svc *HeartbeatSaver) Run(ctx context.Context, params ...interface{}) error

type HeartbeatSender

type HeartbeatSender struct {
	natsservice.NatsService
	Period       int
	RandomPeriod int
	// contains filtered or unexported fields
}

func NewHeartbeatSender

func NewHeartbeatSender(period int, randomPeriod int) *HeartbeatSender

func (*HeartbeatSender) Logger

func (svc *HeartbeatSender) Logger() *logrus.Entry

func (*HeartbeatSender) Run

func (svc *HeartbeatSender) Run(ctx context.Context, params ...interface{}) error

func (*HeartbeatSender) SendHeartbeatEvent

func (svc *HeartbeatSender) SendHeartbeatEvent(ctx context.Context) error

type HeartbeatWebInterface

type HeartbeatWebInterface struct {
	natsservice.NatsService
	// contains filtered or unexported fields
}

HeartbeatWebInterface exposes com.plugis.heartbeat.Sent events that are saved in the database

func NewHeartbeatWebInterface

func NewHeartbeatWebInterface(mysqlConfig natsservice.MysqlConfig) *HeartbeatWebInterface

func (*HeartbeatWebInterface) Run

func (svc *HeartbeatWebInterface) Run(ctx context.Context, params ...interface{}) error

type Sent

type Sent struct {
	Hostname        string    `json:"hostname"`
	Mac             string    `json:"mac"`
	InternalIP      string    `json:"ip"`
	Started         time.Time `json:"started,omitempty"`
	Uptime          uint64    `json:"uptime,omitempty"`
	NatsServiceName string    `json:"nats-service,omitempty"`
}

ce type : com.plugis.heartbeat.Sent

func NewSent

func NewSent(natsServiceName string) (*Sent, error)

NewSent creates a new sent event