config

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

type PrometheusState int

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"`
	Opentelemetry   string          `json:"opentelemetry"`
	State           PrometheusState `json:"state,omitempty"`
	Msg             string          `json:"msg,omitempty"`
	LastRemoteWrite time.Time       `json:"last_remote_write,omitempty"`
}