config

Documentation

Index

• type ConfigRepo
  • func NewMemRepo(logger *zap.Logger) ConfigRepo
• type PrometheusState
  • func (p *PrometheusState) Scan(value interface{}) error
  • func (p PrometheusState) String() string
  • func (p PrometheusState) Value() (driver.Value, error)
• type SinkConfig

Types

type ConfigRepo

type ConfigRepo interface {
	Exists(sinkID string) bool
	Add(config SinkConfig) error
	Get(sinkID string) (SinkConfig, error)
	Edit(config SinkConfig) error
	GetAll() ([]SinkConfig, error)
}

func NewMemRepo

func NewMemRepo(logger *zap.Logger) ConfigRepo

type PrometheusState

type PrometheusState int

const (
	Unknown PrometheusState = iota
	Active
	Error
	Idle
)

func (*PrometheusState) Scan

func (p *PrometheusState) Scan(value interface{}) 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"`
	Url             string          `json:"remote_host"`
	User            string          `json:"username"`
	Password        string          `json:"password"`
	State           PrometheusState `json:"state,omitempty"`
	Msg             string          `json:"msg,omitempty"`
	LastRemoteWrite time.Time       `json:"last_remote_write,omitempty"`
}