ping

Documentation

Index

• type PingManager
  • func (x *PingManager) Close()
  • func (x *PingManager) DataPolicyDeleted(id int16)
  • func (x *PingManager) RemoveMetric(containerId int32, id int64)
  • func (x *PingManager) RunContainer(container models.Container[models.PingContainer])
  • func (x *PingManager) SetMetric(metric models.Metric[models.PingMetric])
  • func (x *PingManager) Start()
  • func (x *PingManager) StopContainer(id int32)

Types

type PingManager

type PingManager struct {
	// Log is the logger.
	Log *logger.Logger
	// PG is the postgres client.
	PG *pg.PG
	// Influxdb is the influxdn client.
	Influxdb *influxdb.Client
	// Redis is the Redis client.
	Redis *redis.Client
	// AmqpConn is the amqp connection.
	AmqpConn *amqp.Conn
	// ServiceNumber is the number of the service that
	// is running the PingManager
	ServiceNumber int
	// TotalServices is the number of services that
	// are running PingMnagers
	TotalServices int
	// contains filtered or unexported fields
}

func (*PingManager) Close

func (x *PingManager) Close()

func (*PingManager) DataPolicyDeleted

func (x *PingManager) DataPolicyDeleted(id int16)

DataPolicyDeleted removes all metrics that are related to the data policy.

func (*PingManager) RemoveMetric

func (x *PingManager) RemoveMetric(containerId int32, id int64)

RemoveMetric removes a metric from a container. Does not panic if the container or the metric not found.

func (*PingManager) RunContainer

func (x *PingManager) RunContainer(container models.Container[models.PingContainer])

func (*PingManager) SetMetric

func (x *PingManager) SetMetric(metric models.Metric[models.PingMetric])

SetMetric updates/creates a metric from a container. Does not panic if container not found.

func (*PingManager) Start

func (x *PingManager) Start()

func (*PingManager) StopContainer

func (x *PingManager) StopContainer(id int32)

stopContainer stops a container. Safe to call multiple times.