Versions in this module Expand all Collapse all v0 v0.2.0 Oct 13, 2026 Changes in this version + const FileConfig + const FilePipes + const FilePolicies + const FileRoles + const MaxKeepaliveBuckets + const MinDedupeRetention + func Files() []string + func HasErrors(findings []Finding) bool + func Open(dir string) (*Registry, []Finding) + func Seed() (map[string][]byte, error) + func Validate(root string) (*Tree, []Finding) + func ValidateDir(dir string) (*Document, []Finding) + func WriteSeed(dir string) error + type Auth struct + JWKSURL string + JWTSecret string + RoleClaim string + type AuthConfig struct + JWKSURL *string + JWTSecret *string + RoleClaim *string + type CORSConfig struct + AllowedOrigins []string + type ClickHouse struct + Addr string + Database string + HTTPPort int + HTTPScheme string + Headers map[string]string + MaxIdleConns int + MaxOpenConns int + Password string + QueryTimeout time.Duration + TLS TLS + Username string + type ClickHouseConfig struct + Addr *string + Database *string + HTTPPort *int + HTTPScheme *string + Headers map[string]string + MaxIdleConns *int + MaxOpenConns *int + Password *string + QueryTimeout *int + TLS *ClickHouseTLS + Username *string + type ClickHouseTLS struct + CAFile *string + CertFile *string + Enabled *bool + InsecureSkipVerify *bool + KeyFile *string + ServerName *string + type DLQConfig struct + Enabled *bool + Tables map[string]TableDLQ + type Dedupe struct + Enabled bool + IDField string + RequireID bool + Retention time.Duration + type DedupeConfig struct + Enabled *bool + IDField *string + RequireID *bool + Retention *string + Tables map[string]TableDedupe + type Document struct + Config TenantConfig + Pipes []pipes.NamedQuery + Policy *policy.Policy + Roles []string + type Finding struct + File string + Message string + Path string + Severity Severity + func (f Finding) String() string + type MQConfig struct + MaxBytesGB *int + type PipesFile struct + Pipes []pipes.NamedQuery + type QueryConfig struct + DefaultMaxRows *int + TimestampBucketSeconds *int + type Registry struct + func NewRegistry(store *Store) *Registry + func (r *Registry) AfterAdopt(fn func(adopted []tenant.ID)) + func (r *Registry) All() iter.Seq2[tenant.ID, *Store] + func (r *Registry) Dir() string + func (r *Registry) For(id tenant.ID) (*Store, bool) + func (r *Registry) Known() iter.Seq2[tenant.ID, *Store] + func (r *Registry) Nested() bool + func (r *Registry) Reload(trigger string) ([]Finding, bool) + func (r *Registry) ReloadTenant(id tenant.ID, trigger string) (findings []Finding, adopted, known bool) + func (r *Registry) Resolve(id tenant.ID) (store *Store, known bool) + func (r *Registry) Watch(ctx context.Context) error + type RolesFile struct + Roles []string + type SchemaConfig struct + RefreshInterval *int + type Severity string + const SeverityError + const SeverityWarning + type Store struct + func (s *Store) Auth() Auth + func (s *Store) CORSOrigins() []string + func (s *Store) ClickHouse() ClickHouse + func (s *Store) DLQFor(table string) bool + func (s *Store) DedupeEnabled() bool + func (s *Store) DedupeFor(table string) Dedupe + func (s *Store) DedupeRetentions() map[string]time.Duration + func (s *Store) DefaultMaxRows() int + func (s *Store) GapWindow() time.Duration + func (s *Store) Keepalive() (period time.Duration, buckets int) + func (s *Store) MQMaxBytes() int64 + func (s *Store) Pipe(name string) *pipes.NamedQuery + func (s *Store) Pipes() []*pipes.NamedQuery + func (s *Store) Policy() *policy.Policy + func (s *Store) SchemaRefreshInterval() time.Duration + func (s *Store) Tenant() tenant.ID + func (s *Store) TimestampBucketSeconds() int + type StreamConfig struct + GapWindowMinutes *int + KeepaliveBuckets *int + KeepaliveInterval *int + type TLS struct + CAFile string + CertFile string + Enabled bool + InsecureSkipVerify bool + KeyFile string + ServerName string + type TableDLQ struct + Enabled *bool + type TableDedupe struct + IDField *string + RequireID *bool + Retention *string + type TenantConfig struct + Auth *AuthConfig + CORS *CORSConfig + ClickHouse *ClickHouseConfig + DLQ *DLQConfig + Dedupe *DedupeConfig + MQ *MQConfig + Query *QueryConfig + Schema *SchemaConfig + Stream *StreamConfig + type TenantResult struct + Doc *Document + Findings []Finding + type Tree struct + Nested bool + Tenants map[tenant.ID]TenantResult
Go to main page