check

package
v2.7.2 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func UnmarshalJSON 

func UnmarshalJSON(b []byte) (influxdb.Check, error)

UnmarshalJSON will convert

Types

type Base 

type Base struct {
	ID          platform.ID             `json:"id,omitempty"`
	Name        string                  `json:"name"`
	Description string                  `json:"description,omitempty"`
	OwnerID     platform.ID             `json:"ownerID,omitempty"`
	OrgID       platform.ID             `json:"orgID,omitempty"`
	Query       influxdb.DashboardQuery `json:"query"`

	// Care should be taken to prevent TaskID from being exposed publicly.
	TaskID platform.ID `json:"taskID,omitempty"`
	// } todo: separate these
	// NonCustomCheckBase will embed inside non-custom checks.
	// type NonCustomCheckBase struct {
	StatusMessageTemplate string                 `json:"statusMessageTemplate"`
	Cron                  string                 `json:"cron,omitempty"`
	Every                 *notification.Duration `json:"every,omitempty"`
	// Offset represents a delay before execution.
	// It gets marshalled from a string duration, i.e.: "10s" is 10 seconds
	Offset *notification.Duration `json:"offset,omitempty"`

	Tags []influxdb.Tag `json:"tags"`
	influxdb.CRUDLog
}

Base will embed inside a check.

func (*Base) ClearPrivateData 

func (b *Base) ClearPrivateData()

ClearPrivateData remove any data that we don't want to be exposed publicly.

func (Base) GetCRUDLog 

func (b Base) GetCRUDLog() influxdb.CRUDLog

GetCRUDLog implements influxdb.Getter interface.

func (*Base) GetDescription 

func (b *Base) GetDescription() string

GetDescription implements influxdb.Getter interface.

func (Base) GetID 

func (b Base) GetID() platform.ID

GetID implements influxdb.Getter interface.

func (*Base) GetName 

func (b *Base) GetName() string

GetName implements influxdb.Getter interface.

func (Base) GetOrgID 

func (b Base) GetOrgID() platform.ID

GetOrgID implements influxdb.Getter interface.

func (Base) GetOwnerID 

func (b Base) GetOwnerID() platform.ID

GetOwnerID gets the ownerID associated with a Base.

func (Base) GetTaskID 

func (b Base) GetTaskID() platform.ID

GetTaskID retrieves the task ID for a check.

func (*Base) SetDescription 

func (b *Base) SetDescription(description string)

SetDescription implements influxdb.Updator interface.

func (*Base) SetID 

func (b *Base) SetID(id platform.ID)

SetID will set the primary key.

func (*Base) SetName 

func (b *Base) SetName(name string)

SetName implements influxdb.Updator interface.

func (*Base) SetOrgID 

func (b *Base) SetOrgID(id platform.ID)

SetOrgID will set the org key.

func (*Base) SetOwnerID 

func (b *Base) SetOwnerID(id platform.ID)

SetOwnerID sets the taskID for a check.

func (*Base) SetTaskID 

func (b *Base) SetTaskID(id platform.ID)

SetTaskID sets the taskID for a check.

func (Base) Valid 

func (b Base) Valid(lang fluxlang.FluxLanguageService) error

Valid returns err if the check is invalid.

type Custom 

type Custom struct {
	ID          platform.ID             `json:"id,omitempty"`
	Name        string                  `json:"name"`
	Description string                  `json:"description,omitempty"`
	OwnerID     platform.ID             `json:"ownerID,omitempty"`
	OrgID       platform.ID             `json:"orgID,omitempty"`
	Query       influxdb.DashboardQuery `json:"query"`
	TaskID      platform.ID             `json:"taskID,omitempty"`
	CreatedAt   time.Time               `json:"createdAt"`
	UpdatedAt   time.Time               `json:"updatedAt"`
}

Custom is the custom check.

func (*Custom) ClearPrivateData 

func (c *Custom) ClearPrivateData()

ClearPrivateData remove any data that we don't want to be exposed publicly.

func (Custom) GenerateFlux 

func (c Custom) GenerateFlux(lang fluxlang.FluxLanguageService) (string, error)

GenerateFlux returns the check query text directly

func (*Custom) GetCRUDLog 

func (c *Custom) GetCRUDLog() influxdb.CRUDLog

GetCRUDLog gets crudLog

func (*Custom) GetDescription 

func (c *Custom) GetDescription() string

GetDescription is GetDescription

func (*Custom) GetID 

func (c *Custom) GetID() platform.ID

GetID is GetID

func (*Custom) GetName 

func (c *Custom) GetName() string

GetName implements influxdb.Getter interface.

func (*Custom) GetOrgID 

func (c *Custom) GetOrgID() platform.ID

GetOrgID gets the orgID associated with the Check

func (*Custom) GetOwnerID 

func (c *Custom) GetOwnerID() platform.ID

GetOwnerID gets the ownerID associated with a Check.

func (*Custom) GetTaskID 

func (c *Custom) GetTaskID() platform.ID

GetTaskID retrieves the task ID for a check.

func (Custom) MarshalJSON 

func (c Custom) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (*Custom) SetCreatedAt 

func (c *Custom) SetCreatedAt(now time.Time)

SetCreatedAt sets the creation time for a check

func (*Custom) SetDescription 

func (c *Custom) SetDescription(description string)

SetDescription is SetDescription

func (*Custom) SetID 

func (c *Custom) SetID(id platform.ID)

SetID sets the primary key for a check

func (*Custom) SetName 

func (c *Custom) SetName(name string)

SetName implements influxdb.Updator interface

func (*Custom) SetOrgID 

func (c *Custom) SetOrgID(id platform.ID)

SetOrgID is SetOrgID

func (*Custom) SetOwnerID 

func (c *Custom) SetOwnerID(id platform.ID)

SetOwnerID sets the taskID for a check.

func (*Custom) SetTaskID 

func (c *Custom) SetTaskID(id platform.ID)

SetTaskID sets the taskID for a check.

func (*Custom) SetUpdatedAt 

func (c *Custom) SetUpdatedAt(now time.Time)

SetUpdatedAt sets the update time for a check

func (Custom) Type 

func (c Custom) Type() string

Type returns the type of the check.

func (*Custom) Valid 

func (c *Custom) Valid(lang fluxlang.FluxLanguageService) error

Valid checks whether check flux is valid, returns error if invalid

type Deadman 

type Deadman struct {
	Base
	TimeSince *notification.Duration `json:"timeSince,omitempty"`
	StaleTime *notification.Duration `json:"staleTime,omitempty"`
	// If only zero values reported since time, trigger alert.
	// TODO(desa): Is this implemented in Flux?
	ReportZero bool                    `json:"reportZero"`
	Level      notification.CheckLevel `json:"level"`
}

Deadman is the deadman check.

func (Deadman) GenerateFlux 

func (c Deadman) GenerateFlux(lang fluxlang.FluxLanguageService) (string, error)

GenerateFlux returns a flux script for the Deadman provided.

func (Deadman) GenerateFluxAST 

func (c Deadman) GenerateFluxAST(lang fluxlang.FluxLanguageService) (*ast.File, error)

GenerateFluxAST returns a flux AST for the deadman provided. If there are any errors in the flux that the user provided the function will return an error for each error found when the script is parsed.

func (Deadman) MarshalJSON 

func (c Deadman) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (Deadman) Type 

func (c Deadman) Type() string

Type returns the type of the check.

type Greater 

type Greater struct {
	ThresholdConfigBase
	Value float64 `json:"value"`
}

Greater threshold type.

func (Greater) MarshalJSON 

func (td Greater) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (Greater) Type 

func (td Greater) Type() string

Type of the threshold config.

type Lesser 

type Lesser struct {
	ThresholdConfigBase
	Value float64 `json:"value"`
}

Lesser threshold type.

func (Lesser) MarshalJSON 

func (td Lesser) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (Lesser) Type 

func (td Lesser) Type() string

Type of the threshold config.

type Range 

type Range struct {
	ThresholdConfigBase
	Min    float64 `json:"min,omitempty"`
	Max    float64 `json:"max,omitempty"`
	Within bool    `json:"within"`
}

Range threshold type.

func (Range) MarshalJSON 

func (td Range) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (Range) Type 

func (td Range) Type() string

Type of the threshold config.

func (Range) Valid 

func (td Range) Valid() error

Valid overwrite the base threshold.

type Threshold 

type Threshold struct {
	Base
	Thresholds []ThresholdConfig `json:"thresholds"`
}

Threshold is the threshold check.

func (Threshold) GenerateFlux 

func (t Threshold) GenerateFlux(lang fluxlang.FluxLanguageService) (string, error)

GenerateFlux returns a flux script for the threshold provided. If there are any errors in the flux that the user provided the function will return an error for each error found when the script is parsed.

func (Threshold) GenerateFluxAST 

func (t Threshold) GenerateFluxAST(lang fluxlang.FluxLanguageService) (*ast.File, error)

GenerateFluxAST returns a flux AST for the threshold provided. If there are any errors in the flux that the user provided the function will return an error for each error found when the script is parsed.

func (Threshold) MarshalJSON 

func (t Threshold) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (Threshold) Type 

func (t Threshold) Type() string

Type returns the type of the check.

func (*Threshold) UnmarshalJSON 

func (t *Threshold) UnmarshalJSON(b []byte) error

UnmarshalJSON implement json.Unmarshaler interface.

func (Threshold) Valid 

func (t Threshold) Valid(lang fluxlang.FluxLanguageService) error

Valid returns error if something is invalid.

type ThresholdConfig 

type ThresholdConfig interface {
	MarshalJSON() ([]byte, error)
	Valid() error
	Type() string

	GetLevel() notification.CheckLevel
	// contains filtered or unexported methods
}

ThresholdConfig is the base of all threshold config.

type ThresholdConfigBase 

type ThresholdConfigBase struct {
	// If true, only alert if all values meet threshold.
	AllValues bool                    `json:"allValues"`
	Level     notification.CheckLevel `json:"level"`
}

ThresholdConfigBase is the base of all threshold config.

func (ThresholdConfigBase) GetLevel 

func (b ThresholdConfigBase) GetLevel() notification.CheckLevel

GetLevel return the check level.

func (ThresholdConfigBase) Valid 

func (b ThresholdConfigBase) Valid() error

Valid returns error if something is invalid.

Source Files

View all Source files

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.