config

type Auth struct {
	Authenticator string `json:"authenticator" yaml:"authenticator"`
}

type AuthBuilderService interface {
	GetExtensionsFromMetadata(config types.Metadata) (Extensions, string)
	DecodeAuth(config types.Metadata) (types.Metadata, error)
	EncodeAuth(config types.Metadata) (types.Metadata, error)
}

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

type BasicAuthenticationExtension struct {
	ClientAuth *ClientAuth `json:"client_auth" yaml:"client_auth"`
}

type BearerAuthExtension struct {
	BearerAuth *struct {
		Token string `json:"token" yaml:"token"`
	} `json:"client_auth" yaml:"client_auth"`
}

type ClientAuth struct {
	Username string `json:"username" yaml:"username"`
	Password string `json:"password" yaml:"password"`
}

type CollectorPipelineExtension struct {
	Enabled          string `json:"enabled" yaml:"enabled"`
	Interval         string `json:"interval" yaml:"interval"`
	FailureThreshold int32  `json:"exporter_failure_threshold" yaml:"exporter_failure_threshold"`
}

type ConfigBuilder interface {
	BuildDeploymentConfig(deployment *DeploymentRequest) (string, error)
}

type DeploymentRequest struct {
	OwnerID string
	SinkID  string
	Config  types.Metadata
	Backend string
	Status  string
}

type ExporterConfigService interface {
	GetExportersFromMetadata(config types.Metadata, authenticationExtensionName string) (Exporters, string)
}

type Exporters struct {
	PrometheusRemoteWrite *PrometheusRemoteWriteExporterConfig `json:"prometheusremotewrite,omitempty" yaml:"prometheusremotewrite,omitempty"`
	OTLPExporter          *OTLPExporterConfig                  `json:"otlphttp,omitempty" yaml:"otlphttp,omitempty"`
	LoggingExporter       *LoggingExporterConfig               `json:"logging,omitempty" yaml:"logging,omitempty"`
}

type Extensions struct {
	HealthCheckExtConfig *HealthCheckExtension `json:"health_check,omitempty" yaml:"health_check,omitempty" :"health_check_ext_config"`
	PProf                *PProfExtension       `json:"pprof,omitempty" yaml:"pprof,omitempty" :"p_prof"`
	ZPages               *ZPagesExtension      `json:"zpages,omitempty" yaml:"zpages,omitempty" :"z_pages"`
	// Exporters Authentication
	BasicAuth *BasicAuthenticationExtension `json:"basicauth/exporter,omitempty" yaml:"basicauth/exporter,omitempty" :"basic_auth"`
}

type HealthCheckExtension struct {
	Endpoint          string                      `json:"endpoint" yaml:"endpoint"`
	Path              string                      `json:"path" yaml:"path"`
	CollectorPipeline *CollectorPipelineExtension `json:"check_collector_pipeline,omitempty" yaml:"check_collector_pipeline,omitempty"`
}

type KafkaReceiver struct {
	Brokers         []string `json:"brokers" yaml:"brokers"`
	Topic           string   `json:"topic" yaml:"topic"`
	ProtocolVersion string   `json:"protocol_version" yaml:"protocol_version"`
}

type LoggingExporterConfig struct {
	Verbosity          string `json:"verbosity,omitempty" yaml:"verbosity,omitempty"`
	SamplingInitial    int    `json:"sampling_initial,omitempty" yaml:"sampling_initial,omitempty"`
	SamplingThereAfter int    `json:"sampling_thereafter,omitempty" yaml:"sampling_thereafter,omitempty"`
}

type OTLPExporterConfig struct {
	Endpoint string                 `json:"endpoint" yaml:"endpoint"`
	Headers  map[string]interface{} `json:"headers,omitempty" yaml:"headers,omitempty"`
	Auth     struct {
		Authenticator string `json:"authenticator" yaml:"authenticator"`
	}
}

type OTLPHTTPExporterBuilder struct {
}

type OtelConfigFile struct {
	Receivers  Receivers     `json:"receivers" yaml:"receivers"`
	Processors *Processors   `json:"processors,omitempty" yaml:"processors,omitempty"`
	Extensions *Extensions   `json:"extensions,omitempty" yaml:"extensions,omitempty"`
	Exporters  Exporters     `json:"exporters" yaml:"exporters"`
	Service    ServiceConfig `json:"service" yaml:"service"`
}

type PProfExtension struct {
	Endpoint string `json:"endpoint" yaml:"endpoint"`
}

type Processors struct {
}

type PrometheusExporterConfig struct {
}

type PrometheusRemoteWriteExporterConfig struct {
	Endpoint string                 `json:"endpoint" yaml:"endpoint"`
	Headers  map[string]interface{} `json:"headers,omitempty" yaml:"headers,omitempty"`
	Auth     struct {
		Authenticator string `json:"authenticator" yaml:"authenticator"`
	}
}

type PrometheusState int

type Receivers struct {
	Kafka KafkaReceiver `json:"kafka" yaml:"kafka"`
}

type ServiceConfig struct {
	Extensions []string `json:"extensions,omitempty" yaml:"extensions,omitempty"`
	Pipelines  struct {
		Metrics struct {
			Receivers  []string `json:"receivers" yaml:"receivers"`
			Processors []string `json:"processors,omitempty" yaml:"processors,omitempty"`
			Exporters  []string `json:"exporters" yaml:"exporters"`
		} `json:"metrics" yaml:"metrics"`
	} `json:"pipelines" yaml:"pipelines"`
}

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

type ZPagesExtension struct {
	Endpoint string `json:"endpoint" yaml:"endpoint"`
}