heartbeat

package

v0.0.0-...-73e0568 Latest Latest Go to latest Published: Oct 16, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/project-flotta/flotta-device-worker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Heartbeat
- func NewHeartbeatService(dispatcherClient pb.DispatcherClient, configManager *cfg.Manager, ...) *Heartbeat
type HeartbeatData
- func NewHeartbeatData(configManager *cfg.Manager, workloadManager *workld.WorkloadManager, ...) *HeartbeatData

Constants ¶

View Source

const (
	ScopeDelta = "delta"
	ScopeFull  = "full"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Heartbeat ¶

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

func NewHeartbeatService ¶

func NewHeartbeatService(dispatcherClient pb.DispatcherClient, configManager *cfg.Manager,
	workloadManager *workld.WorkloadManager, hardware hw.Hardware, ansibleManager *ansible.Manager,
	dataMonitor *datatransfer.Monitor, osInfo *os2.OS,
	reg registration.RegistrationWrapper) *Heartbeat

func (*Heartbeat) Deregister ¶

func (s *Heartbeat) Deregister() error

func (*Heartbeat) HasStarted ¶

func (s *Heartbeat) HasStarted() bool

func (*Heartbeat) Init ¶

func (s *Heartbeat) Init(config models.DeviceConfigurationMessage) error

Init no-op due to we need to an update from the source of truth in this case(API)

func (*Heartbeat) Start ¶

func (s *Heartbeat) Start()

func (*Heartbeat) String ¶

func (s *Heartbeat) String() string

func (*Heartbeat) Update ¶

func (s *Heartbeat) Update(config models.DeviceConfigurationMessage) error

type HeartbeatData ¶

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

func NewHeartbeatData ¶

func NewHeartbeatData(configManager *cfg.Manager,
	workloadManager *workld.WorkloadManager, ansibleManager *ansible.Manager, hardware hw.Hardware, dataMonitor *datatransfer.Monitor, deviceOs *os2.OS) *HeartbeatData

func (*HeartbeatData) GetPreviousHardwareInfo ¶

func (s *HeartbeatData) GetPreviousHardwareInfo() *models.HardwareInfo

func (*HeartbeatData) RetrieveInfo ¶

func (s *HeartbeatData) RetrieveInfo() models.Heartbeat

func (*HeartbeatData) SetPreviousHardwareInfo ¶

func (s *HeartbeatData) SetPreviousHardwareInfo(previousHardwareInfo *models.HardwareInfo)

Source Files ¶

View all Source files

heartbeat.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL