metrics

Documentation

Index

• func ExposeMetrics(ctx context.Context, eventChan <-chan event.SaltEvent, ...)
• type Config
• type Registry
  • func NewRegistry(config Config) Registry
  • func (r *Registry) AddObservableMinion(minion string)
  • func (r *Registry) DeleteObservableMinion(minion string)
  • func (r *Registry) IncreaseExpectedResponsesTotal(function, state string, value float64)
  • func (r *Registry) IncreaseFunctionResponsesTotal(function, state, minion string, success bool)
  • func (r *Registry) IncreaseNewJobTotal(function, state string)
  • func (r *Registry) IncreaseResponseTotal(minion string, success bool)
  • func (r *Registry) IncreaseScheduledJobReturnTotal(function, state, minion string, success bool)
  • func (r *Registry) SetFunctionStatus(minion, function, state string, success bool)
  • func (r *Registry) UpdateLastHeartbeat(minion string)

Functions

func ExposeMetrics

func ExposeMetrics(ctx context.Context, eventChan <-chan event.SaltEvent, watchChan <-chan event.WatchEvent, config Config)

Types

type Config

type Config struct {
	// HealtMinions enable/disable the health functions/states metrics
	HealthMinions bool `mapstructure:"health-minions"`

	Global struct {
		Filters struct {
			IgnoreTest bool `mapstructure:"ignore-test"`
			IgnoreMock bool `mapstructure:"ignore-mock"`
		}
	}

	SaltNewJobTotal struct {
		Enabled bool
	} `mapstructure:"salt_new_job_total"`

	SaltExpectedResponsesTotal struct {
		Enabled bool
	} `mapstructure:"salt_expected_responses_total"`

	SaltFunctionResponsesTotal struct {
		Enabled        bool
		AddMinionLabel bool `mapstructure:"add-minion-label"`
	} `mapstructure:"salt_function_responses_total"`

	SaltScheduledJobReturnTotal struct {
		Enabled        bool
		AddMinionLabel bool `mapstructure:"add-minion-label"`
	} `mapstructure:"salt_scheduled_job_return_total"`

	SaltResponsesTotal struct {
		Enabled bool
	} `mapstructure:"salt_responses_total"`

	SaltFunctionStatus struct {
		Enabled bool
		Filters struct {
			Functions []string
			States    []string
		}
	} `mapstructure:"salt_function_status"`
}

type Registry

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

func NewRegistry

func NewRegistry(config Config) Registry

func (*Registry) AddObservableMinion

func (r *Registry) AddObservableMinion(minion string)

func (*Registry) DeleteObservableMinion

func (r *Registry) DeleteObservableMinion(minion string)

func (*Registry) IncreaseExpectedResponsesTotal

func (r *Registry) IncreaseExpectedResponsesTotal(function, state string, value float64)

func (*Registry) IncreaseFunctionResponsesTotal

func (r *Registry) IncreaseFunctionResponsesTotal(function, state, minion string, success bool)

func (*Registry) IncreaseNewJobTotal

func (r *Registry) IncreaseNewJobTotal(function, state string)

func (*Registry) IncreaseResponseTotal

func (r *Registry) IncreaseResponseTotal(minion string, success bool)

func (*Registry) IncreaseScheduledJobReturnTotal

func (r *Registry) IncreaseScheduledJobReturnTotal(function, state, minion string, success bool)

func (*Registry) SetFunctionStatus

func (r *Registry) SetFunctionStatus(minion, function, state string, success bool)

func (*Registry) UpdateLastHeartbeat

func (r *Registry) UpdateLastHeartbeat(minion string)