config

package
v0.29.0 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2023 License: MPL-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigRepo

type ConfigRepo interface {
	Exists(ownerID string, sinkID string) bool
	Add(config SinkConfig) error
	Remove(ownerID string, sinkID string) error
	Get(ownerID string, sinkID string) (SinkConfig, error)
	Edit(config SinkConfig) error
	GetAll(ownerID string) ([]SinkConfig, error)
	GetAllOwners() ([]string, error)
	DeployCollector(ctx context.Context, config SinkConfig) error
	AddActivity(ownerID string, sinkID string) error
	GetActivity(ownerID string, sinkID string) (int64, error)
}

type PrometheusState

type PrometheusState int
const (
	Unknown PrometheusState = iota
	Active
	Error
	Idle
	Warning
)

func (*PrometheusState) SetFromString

func (p *PrometheusState) SetFromString(value string) error

func (PrometheusState) String

func (p PrometheusState) String() string

func (PrometheusState) Value

func (p PrometheusState) Value() (driver.Value, error)

type SinkConfig

type SinkConfig struct {
	SinkID          string          `json:"sink_id"`
	OwnerID         string          `json:"owner_id"`
	Config          types.Metadata  `json:"config"`
	State           PrometheusState `json:"state,omitempty"`
	Msg             string          `json:"msg,omitempty"`
	LastRemoteWrite time.Time       `json:"last_remote_write,omitempty"`
}

SinkConfigParser to be compatible with new sinks config is coming from eventbus

Jump to

Keyboard shortcuts

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