heartbeat

Documentation

Index

• type Database
  • func (d *Database) Open(dbConfig natsservice.MysqlConfig) error
• type DatabaseConfig
• type HeartbeatSaver
  • func NewHeartbeatSaver(config HeartbeatSaverConfig) *HeartbeatSaver
  • func (svc *HeartbeatSaver) Logger() *logrus.Entry
  • func (svc *HeartbeatSaver) Run(ctx context.Context, params ...interface{}) error
• type HeartbeatSaverConfig
• type HeartbeatSender
  • func NewHeartbeatSender(period int, randomPeriod int, meta map[string]interface{}) *HeartbeatSender
  • func (svc *HeartbeatSender) AddMeta(key string, value interface{}, send bool) error
  • func (svc *HeartbeatSender) Logger() *logrus.Entry
  • func (svc *HeartbeatSender) RemoveMeta(key string, send bool) error
  • 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) OnHeartbeatSent(heartbeatSent Sent)
  • func (svc *HeartbeatWebInterface) Run(ctx context.Context, params ...interface{}) error
• type OnHeartbeatSentCb
• type Sent
  • func NewSent(natsServiceName string, meta map[string]interface{}) (*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
	Config HeartbeatSaverConfig
	// contains filtered or unexported fields
}

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

func NewHeartbeatSaver

func NewHeartbeatSaver(config HeartbeatSaverConfig) *HeartbeatSaver

func (*HeartbeatSaver) Logger

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

func (*HeartbeatSaver) Run

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

type HeartbeatSaverConfig

type HeartbeatSaverConfig struct {
	MysqlConfig     natsservice.MysqlConfig
	OnHeartbeatSent OnHeartbeatSentCb
}

type HeartbeatSender

type HeartbeatSender struct {
	natsservice.NatsService
	Period       int
	RandomPeriod int
	Meta         map[string]interface{} // metas to send with heartbeat
	// contains filtered or unexported fields
}

func NewHeartbeatSender

func NewHeartbeatSender(period int, randomPeriod int, meta map[string]interface{}) *HeartbeatSender

func (*HeartbeatSender) AddMeta

func (svc *HeartbeatSender) AddMeta(key string, value interface{}, send bool) error

func (*HeartbeatSender) Logger

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

func (*HeartbeatSender) RemoveMeta

func (svc *HeartbeatSender) RemoveMeta(key string, send bool) error

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) OnHeartbeatSent

func (svc *HeartbeatWebInterface) OnHeartbeatSent(heartbeatSent Sent)

OnHeartbeatSent is called each time a heartbeat event is received, must return as fast as possible

func (*HeartbeatWebInterface) Run

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

type OnHeartbeatSentCb

type OnHeartbeatSentCb func(sent Sent)

OnHeartbeatSentCb is called each time a heartbit send event is received

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"`
	Os              string                 `json:"os,omitempty"`
	Arch            string                 `json:"arch,omitempty"`
	Meta            map[string]interface{} `json:"meta,omitempty"`
}

ce type : com.plugis.heartbeat.Sent

func NewSent

func NewSent(natsServiceName string, meta map[string]interface{}) (*Sent, error)

NewSent creates a new sent event