Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

logsinks

package

Go to main page

Versions in this module

v0

v0.5.81

Sep 5, 2026

v0.5.9

Sep 8, 2026

v0.5.8

Sep 3, 2026

Changes in this version

+ const CatCarveData

+ const CatCarveMeta

+ const CatQuery

+ const CatResult

+ const CatStatus

+ var AllCategories = []string

+ func DecodeCategories(stored string) []string

+ func IsAllCategories(categories []string) bool

+ func IsValidCategory(cat string) bool

+ func MatchesCategory(categories []string, cat string) bool

+ func NormalizeCategories(cats []string) ([]string, error)

+ func ValidateCategories(cats []string) error

type LogSink

+ Categories string

v0.5.7

Aug 24, 2026

Changes in this version

+ const NoEnvironmentID

+ const SourceDB

+ const SourceService

+ const SourceYAML

+ var ErrInvalidSinkConfig = errors.New("invalid log sink configuration")

+ var ErrInvalidSinkType = errors.New("invalid log sink type")

+ var ErrSinkNotFound = errors.New("log sink not found")

+ var ErrTargetHasSinks = errors.New("target environment already has log sinks")

+ var Registry = map[string]SinkSpec

+ func BuildExporters(rows []LogSink, smgr *settings.Settings) *logging.MultiExporter

+ func MergeSecrets(typ, prevCfgJSON, newCfgJSON string) (string, error)

+ func RedactedConfig(typ, cfgJSON string) string

+ func SupportedTypes() []string

+ func ValidateSink(name, typ, cfgJSON string) error

+ func ValidateType(typ string) bool

+ type FieldSpec struct

+ Default any

+ Help string

+ Label string

+ Name string

+ Options []string

+ Placeholder string

+ Required bool

+ Secret bool

+ Type FieldType

+ type FieldType string

+ const FieldBoolean

+ const FieldInteger

+ const FieldPassword

+ const FieldSelect

+ const FieldString

+ type LogSink struct

+ BytesSent int64

+ Config string

+ Enabled bool

+ EnvironmentID uint

+ ExportsCount int64

+ Info string

+ Name string

+ Order int

+ Source string

+ Type string

+ type LogSinksManager struct

+ DB *gorm.DB

+ func NewLogSinksManager(backend *gorm.DB) *LogSinksManager

+ func (m *LogSinksManager) AllGrouped() (map[uint][]LogSink, error)

+ func (m *LogSinksManager) BuildExportersForEnvironments(smgr *settings.Settings) (map[uint]*logging.MultiExporter, error)

+ func (m *LogSinksManager) CloneEnvironment(sourceEnvID, targetEnvID uint, overwrite bool) ([]LogSink, error)

+ func (m *LogSinksManager) Create(name, typ string, enabled bool, order int, cfgJSON string, envID uint, ...) (LogSink, error)

+ func (m *LogSinksManager) Delete(id uint) error

+ func (m *LogSinksManager) EffectiveFor(envID uint) ([]LogSink, error)

+ func (m *LogSinksManager) Get(id uint) (LogSink, error)

+ func (m *LogSinksManager) List(envID *uint) ([]LogSink, error)

+ func (m *LogSinksManager) ListByEnvironment(envID uint) ([]LogSink, error)

+ func (m *LogSinksManager) RevertToService(id uint) error

+ func (m *LogSinksManager) Seed(params *config.ServiceParameters, envID uint) error

+ func (m *LogSinksManager) Update(id uint, name, typ string, enabled bool, order int, cfgJSON string, ...) (LogSink, error)

+ func (m *LogSinksManager) UpdateSinkStats(sinkID uint, bytesSent, exportCount int64) error

+ type SinkSpec struct

+ Build func(any, *settings.Settings) (logging.DataExporter, error)

+ Decode func(json.RawMessage) (any, error)

+ Description string

+ Fields []FieldSpec

+ HasSecret bool

+ SecretFields []string

+ Type string

+ type SinkStatsWriter struct

+ func NewSinkStatsWriter(mgr *LogSinksManager, logTLS *logging.LoggerTLS, interval time.Duration) *SinkStatsWriter

+ func (w *SinkStatsWriter) Start()

+ func (w *SinkStatsWriter) Stop()