Versions in this module Expand all Collapse all v0 v0.20.0 Nov 6, 2022 Changes in this version + func GetDeploymentJson(sinkId, sinkUrl, sinkUsername, sinkPassword string) (string, error) + func ReturnConfigYamlFromSink(_ context.Context, ...) (string, error) + type BasicAuthenticationExtension struct + ClientAuth ... + type Exporters struct + PrometheusRemoteWrite *PrometheusRemoteWriteExporterConfig + type Extensions struct + BasicAuth *BasicAuthenticationExtension + HealthCheckExtConfig *HealthCheckExtension + PProf *PProfExtension + ZPages *ZPagesExtension + type HealthCheckExtension struct + CollectorPipeline ... + type KafkaReceiver struct + Brokers []string + ProtocolVersion string + Topic string + type OtelConfigFile struct + Exporters Exporters + Extensions *Extensions + Processors *Processors + Receivers Receivers + Service ServiceConfig + type PProfExtension struct + Endpoint string + type Processors struct + type PrometheusRemoteWriteExporterConfig struct + Auth struct{ ... } + Endpoint string + type PrometheusState int + const Active + const Error + const Idle + const Unknown + func (p *PrometheusState) Scan(value interface{}) error + func (p PrometheusState) String() string + func (p PrometheusState) Value() (driver.Value, error) + type Receivers struct + Kafka KafkaReceiver + type ServiceConfig struct + Extensions []string + Pipelines struct{ ... } + type SinkData struct + LastRemoteWrite time.Time + Msg string + OpenTelemetry string + OwnerID string + Password string + SinkID string + State PrometheusState + Url string + User string + type ZPagesExtension struct + Endpoint string