Documentation ¶
Index ¶
- Constants
- func GetMachineID() string
- func SetupFlags(flags *pflag.FlagSet)
- func WithPublisher(p publisher) option
- type AppConfig
- func (c *AppConfig) AnalyticsFrontendKey() string
- func (c *AppConfig) AnalyticsServerKey() string
- func (c *AppConfig) ApplicationExporter() (*TelemetryExporterOption, error)
- func (c *AppConfig) DataStorePipelineTestConnectionEnabled() bool
- func (c *AppConfig) DemoEnabled() []string
- func (c *AppConfig) DemoEndpoints() map[string]string
- func (c *AppConfig) ExperimentalFeatures() []string
- func (c *AppConfig) Exporter() (*TelemetryExporterOption, error)
- func (c *AppConfig) InternalTelemetryEnabled() bool
- func (c *AppConfig) InternalTelemetryOtelCollectorAddress() string
- func (c *AppConfig) NATSEndpoint() string
- func (c *AppConfig) OtlpServerEnabled() bool
- func (c *AppConfig) PostgresConnString() string
- func (c *AppConfig) ServerPathPrefix() string
- func (c *AppConfig) ServerPort() int
- func (c *AppConfig) Set(key string, value any)
- func (c *AppConfig) TestPipelineTraceFetchingEnabled() bool
- func (c *AppConfig) TestPipelineTriggerExecutionEnabled() bool
- func (c *AppConfig) Validate() error
- func (c *AppConfig) Watch(updateFn func(c *AppConfig))
- type Config
- type ExporterConfig
- type OTELCollectorConfig
- type Option
- type Repository
- func (r *Repository) Count(ctx context.Context, query string) (int, error)
- func (r *Repository) Create(ctx context.Context, updated Config) (Config, error)
- func (r *Repository) Current(ctx context.Context) Config
- func (r *Repository) Get(ctx context.Context, i id.ID) (Config, error)
- func (r *Repository) List(ctx context.Context, take, skip int, query, sortBy, sortDirection string) ([]Config, error)
- func (r *Repository) Provision(ctx context.Context, updated Config) error
- func (r *Repository) SetID(cfg Config, id id.ID) Config
- func (*Repository) SortingFields() []string
- func (r *Repository) Update(ctx context.Context, updated Config) (Config, error)
- type TelemetryExporterOption
Constants ¶
View Source
const ( ResourceID = "/app/config/update" ResourceName = "Config" ResourceNamePlural = "Configs" )
Variables ¶
This section is empty.
Functions ¶
func GetMachineID ¶
func GetMachineID() string
func SetupFlags ¶
func WithPublisher ¶
func WithPublisher(p publisher) option
Types ¶
type AppConfig ¶
type AppConfig struct {
// contains filtered or unexported fields
}
func (*AppConfig) AnalyticsFrontendKey ¶
func (*AppConfig) AnalyticsServerKey ¶
func (*AppConfig) ApplicationExporter ¶
func (c *AppConfig) ApplicationExporter() (*TelemetryExporterOption, error)
func (*AppConfig) DataStorePipelineTestConnectionEnabled ¶
func (*AppConfig) DemoEnabled ¶
func (*AppConfig) DemoEndpoints ¶
func (*AppConfig) ExperimentalFeatures ¶
func (*AppConfig) Exporter ¶
func (c *AppConfig) Exporter() (*TelemetryExporterOption, error)
func (*AppConfig) InternalTelemetryEnabled ¶
func (*AppConfig) InternalTelemetryOtelCollectorAddress ¶
func (*AppConfig) NATSEndpoint ¶ added in v0.14.5
func (*AppConfig) OtlpServerEnabled ¶
func (*AppConfig) PostgresConnString ¶
func (*AppConfig) ServerPathPrefix ¶
func (*AppConfig) ServerPort ¶
func (*AppConfig) TestPipelineTraceFetchingEnabled ¶
func (*AppConfig) TestPipelineTriggerExecutionEnabled ¶
type Config ¶
type Config struct { ID id.ID `json:"id"` Name string `json:"name"` AnalyticsEnabled bool `json:"analyticsEnabled"` }
func (Config) IsAnalyticsEnabled ¶
type ExporterConfig ¶
type ExporterConfig struct { Type string `yaml:",omitempty" mapstructure:"type"` CollectorConfiguration OTELCollectorConfig `yaml:"collector,omitempty" mapstructure:"collector"` }
type OTELCollectorConfig ¶
type OTELCollectorConfig struct {
Endpoint string `yaml:",omitempty" mapstructure:"endpoint"`
}
type Option ¶
type Option func(*AppConfig)
func WithFlagSet ¶
func WithLogger ¶
func WithLogger(l logger) Option
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
func NewRepository ¶
func NewRepository(db *sql.DB, opts ...option) *Repository
func (*Repository) Provision ¶
func (r *Repository) Provision(ctx context.Context, updated Config) error
func (*Repository) SortingFields ¶
func (*Repository) SortingFields() []string
type TelemetryExporterOption ¶
type TelemetryExporterOption struct { ServiceName string `yaml:",omitempty" mapstructure:"serviceName"` Sampling float64 `yaml:",omitempty" mapstructure:"sampling"` MetricsReaderInterval time.Duration `yaml:",omitempty" mapstructure:"metricsReaderInterval"` Exporter ExporterConfig `yaml:",omitempty" mapstructure:"exporter"` }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.