rule

Documentation

Index

• func UnmarshalJSON(b []byte) (influxdb.NotificationRule, error)
• type Base
  • func (b *Base) ClearPrivateData()
  • func (b Base) GetCRUDLog() influxdb.CRUDLog
  • func (b *Base) GetDescription() string
  • func (b Base) GetEndpointID() influxdb.ID
  • func (b Base) GetID() influxdb.ID
  • func (b *Base) GetLimit() *influxdb.Limit
  • func (b *Base) GetName() string
  • func (b Base) GetOrgID() influxdb.ID
  • func (b Base) GetOwnerID() influxdb.ID
  • func (b Base) GetTaskID() influxdb.ID
  • func (b *Base) MatchesTags(tags []influxdb.Tag) bool
  • func (b *Base) SetDescription(description string)
  • func (b *Base) SetID(id influxdb.ID)
  • func (b *Base) SetName(name string)
  • func (b *Base) SetOrgID(id influxdb.ID)
  • func (b *Base) SetOwnerID(id influxdb.ID)
  • func (b *Base) SetTaskID(id influxdb.ID)
• type HTTP
  • func (s *HTTP) GenerateFlux(e influxdb.NotificationEndpoint) (string, error)
  • func (s *HTTP) GenerateFluxAST(e *endpoint.HTTP) (*ast.Package, error)
  • func (s HTTP) MarshalJSON() ([]byte, error)
  • func (s HTTP) Type() string
  • func (s HTTP) Valid() error
• type PagerDuty
  • func (s *PagerDuty) GenerateFlux(e influxdb.NotificationEndpoint) (string, error)
  • func (s *PagerDuty) GenerateFluxAST(e *endpoint.PagerDuty) (*ast.Package, error)
  • func (s PagerDuty) MarshalJSON() ([]byte, error)
  • func (s PagerDuty) Type() string
  • func (s PagerDuty) Valid() error
• type Slack
  • func (s *Slack) GenerateFlux(e influxdb.NotificationEndpoint) (string, error)
  • func (s *Slack) GenerateFluxAST(e *endpoint.Slack) (*ast.Package, error)
  • func (s Slack) MarshalJSON() ([]byte, error)
  • func (s Slack) Type() string
  • func (s Slack) Valid() error

Functions

func UnmarshalJSON

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

UnmarshalJSON will convert

Types

type Base

type Base struct {
	ID          influxdb.ID `json:"id,omitempty"`
	Name        string      `json:"name"`
	Description string      `json:"description,omitempty"`
	EndpointID  influxdb.ID `json:"endpointID,omitempty"`
	OrgID       influxdb.ID `json:"orgID,omitempty"`
	OwnerID     influxdb.ID `json:"ownerID,omitempty"`
	TaskID      influxdb.ID `json:"taskID,omitempty"`
	// SleepUntil is an optional sleeptime to start a task.
	SleepUntil *time.Time             `json:"sleepUntil,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"`
	RunbookLink string                    `json:"runbookLink"`
	TagRules    []notification.TagRule    `json:"tagRules,omitempty"`
	StatusRules []notification.StatusRule `json:"statusRules,omitempty"`
	*influxdb.Limit
	influxdb.CRUDLog
}

Base is the embed struct of every notification rule.

func (*Base) ClearPrivateData

func (b *Base) ClearPrivateData()

ClearPrivateData clears the task ID from the base.

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

func (b Base) GetEndpointID() influxdb.ID

GetEndpointID gets the endpointID for a base.

func (Base) GetID

func (b Base) GetID() influxdb.ID

GetID implements influxdb.Getter interface.

func (*Base) GetLimit

func (b *Base) GetLimit() *influxdb.Limit

GetLimit returns the limit pointer.

func (*Base) GetName

func (b *Base) GetName() string

GetName implements influxdb.Getter interface.

func (Base) GetOrgID

func (b Base) GetOrgID() influxdb.ID

GetOrgID implements influxdb.Getter interface.

func (Base) GetOwnerID

func (b Base) GetOwnerID() influxdb.ID

GetOwnerID returns the owner id.

func (Base) GetTaskID

func (b Base) GetTaskID() influxdb.ID

GetTaskID gets the task ID for a base.

func (*Base) MatchesTags

func (b *Base) MatchesTags(tags []influxdb.Tag) bool

MatchesTags returns true if the Rule matches all of the tags

func (*Base) SetDescription

func (b *Base) SetDescription(description string)

SetDescription implements influxdb.Updator interface.

func (*Base) SetID

func (b *Base) SetID(id influxdb.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 influxdb.ID)

SetOrgID will set the org key.

func (*Base) SetOwnerID

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

SetOwnerID will set the owner id.

func (*Base) SetTaskID

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

SetTaskID sets the task ID for a base.

type HTTP

type HTTP struct {
	Base
}

HTTP is the notification rule config of http.

func (*HTTP) GenerateFlux

func (s *HTTP) GenerateFlux(e influxdb.NotificationEndpoint) (string, error)

GenerateFlux generates a flux script for the http notification rule.

func (*HTTP) GenerateFluxAST

func (s *HTTP) GenerateFluxAST(e *endpoint.HTTP) (*ast.Package, error)

GenerateFluxAST generates a flux AST for the http notification rule.

func (HTTP) MarshalJSON

func (s HTTP) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (HTTP) Type

func (s HTTP) Type() string

Type returns the type of the rule config.

func (HTTP) Valid

func (s HTTP) Valid() error

Valid returns where the config is valid.

type PagerDuty

type PagerDuty struct {
	Base
	MessageTemplate string `json:"messageTemplate"`
}

PagerDuty is the rule config of pagerduty notification.

func (*PagerDuty) GenerateFlux

func (s *PagerDuty) GenerateFlux(e influxdb.NotificationEndpoint) (string, error)

GenerateFlux generates a flux script for the pagerduty notification rule.

func (*PagerDuty) GenerateFluxAST

func (s *PagerDuty) GenerateFluxAST(e *endpoint.PagerDuty) (*ast.Package, error)

GenerateFluxAST generates a flux AST for the pagerduty notification rule.

func (PagerDuty) MarshalJSON

func (s PagerDuty) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (PagerDuty) Type

func (s PagerDuty) Type() string

Type returns the type of the rule config.

func (PagerDuty) Valid

func (s PagerDuty) Valid() error

Valid returns where the config is valid.

type Slack

type Slack struct {
	Base
	Channel         string `json:"channel"`
	MessageTemplate string `json:"messageTemplate"`
}

Slack is the notification rule config of slack.

func (*Slack) GenerateFlux

func (s *Slack) GenerateFlux(e influxdb.NotificationEndpoint) (string, error)

GenerateFlux generates a flux script for the slack notification rule.

func (*Slack) GenerateFluxAST

func (s *Slack) GenerateFluxAST(e *endpoint.Slack) (*ast.Package, error)

GenerateFluxAST generates a flux AST for the slack notification rule.

func (Slack) MarshalJSON

func (s Slack) MarshalJSON() ([]byte, error)

MarshalJSON implement json.Marshaler interface.

func (Slack) Type

func (s Slack) Type() string

Type returns the type of the rule config.

func (Slack) Valid

func (s Slack) Valid() error

Valid returns where the config is valid.