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
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

plugins

package

Go to main page

Versions in this module

v0

v0.1.3

Jun 11, 2025

v0.1.2

Jun 10, 2025

v0.1.1

Jun 10, 2025

Changes in this version

+ func CreateDestinationConfig(options ...DestinationOption) map[string]interface

+ type Backend interface

+ Close func() error

+ Configure func(options map[string]interface{}) error

+ Flush func() error

+ Name func() string

+ SupportsAtomic func() bool

+ Version func() string

+ Write func(entry []byte) (int, error)

+ type BackendFactory func(config map[string]interface{}) (Backend, error)

+ type BackendPlugin interface

+ CreateBackend func(uri string, config map[string]interface{}) (Backend, error)

+ SupportedSchemes func() []string

+ type DestinationOption func(map[string]interface{})

+ func WithBatchSize(size int) DestinationOption

+ func WithCustomConfig(key string, value interface{}) DestinationOption

+ func WithFlushInterval(seconds int) DestinationOption

+ func WithRetryAttempts(attempts int) DestinationOption

+ func WithTimeout(seconds int) DestinationOption

+ type Discovery interface

+ DiscoverPlugins func(paths []string) ([]PluginInfo, error)

+ LoadPlugin func(path string) (Plugin, error)

+ ValidatePlugin func(path string) error

+ type DiscoveryImpl struct

+ func NewDiscovery(manager *Manager) *DiscoveryImpl

+ func (d *DiscoveryImpl) AddSearchPath(path string)

+ func (d *DiscoveryImpl) DiscoverPlugins() ([]string, error)

+ func (d *DiscoveryImpl) LoadDiscoveredPlugins() error

+ func (d *DiscoveryImpl) LoadPluginConfig(configPath string) error

+ func (d *DiscoveryImpl) LoadPluginSpecs(specs []PluginSpec) error

+ func (d *DiscoveryImpl) SetPattern(pattern string)

+ func (d *DiscoveryImpl) SetSearchPaths(paths []string)

+ func (d *DiscoveryImpl) WatchPluginDirectory(dir string, interval time.Duration)

+ type Filter interface

+ Configure func(options map[string]interface{}) error

+ Name func() string

+ ShouldLog func(level int, message string, fields map[string]interface{}) bool

+ type FilterFactory func(config map[string]interface{}) (Filter, error)

+ type FilterPlugin interface

+ CreateFilter func(config map[string]interface{}) (types.FilterFunc, error)

+ FilterType func() string

+ type Formatter interface

+ Configure func(options map[string]interface{}) error

+ Format func(msg types.LogMessage) ([]byte, error)

+ Name func() string

+ type FormatterFactory func(config map[string]interface{}) (Formatter, error)

+ type FormatterPlugin interface

+ CreateFormatter func(config map[string]interface{}) (Formatter, error)

+ FormatName func() string

+ type HealthStatus struct

+ Details map[string]interface{}

+ Healthy bool

+ Message string

+ type Integration struct

+ func NewIntegration(manager *Manager) *Integration

+ func (i *Integration) CreateBackendFromURI(uri string) (Backend, error)

+ func (i *Integration) CreateFilterByType(filterType string, config map[string]interface{}) (types.FilterFunc, error)

+ func (i *Integration) CreateFormatterByName(name string, config map[string]interface{}) (Formatter, error)

+ func (i *Integration) GetAvailableBackends() []string

+ func (i *Integration) GetAvailableFilters() []string

+ func (i *Integration) GetAvailableFormatters() []string

+ func (i *Integration) GetCapabilities() PluginCapabilities

+ func (i *Integration) IsBackendSupported(scheme string) bool

+ func (i *Integration) IsFilterSupported(filterType string) bool

+ func (i *Integration) IsFormatterSupported(name string) bool

+ func (i *Integration) ShutdownAll(ctx context.Context) error

+ func (i *Integration) ValidatePluginHealth() error

+ type Manager struct

+ func NewManager() *Manager

+ func (m *Manager) GetBackendPlugin(scheme string) (BackendPlugin, bool)

+ func (m *Manager) GetFilterPlugin(filterType string) (FilterPlugin, bool)

+ func (m *Manager) GetFormatterPlugin(format string) (FormatterPlugin, bool)

+ func (m *Manager) GetPluginInfo() []PluginInfo

+ func (m *Manager) InitializePlugin(name string, config map[string]interface{}) error

+ func (m *Manager) ListPlugins() []Plugin

+ func (m *Manager) LoadPlugin(path string) error

+ func (m *Manager) RegisterBackendPlugin(plugin BackendPlugin) error

+ func (m *Manager) RegisterFilterPlugin(plugin FilterPlugin) error

+ func (m *Manager) RegisterFormatterPlugin(plugin FormatterPlugin) error

+ func (m *Manager) UnloadPlugin(name string) error

+ type ManagerInterface interface

+ GetBackend func(name string) (Backend, error)

+ GetFilter func(name string) (Filter, error)

+ GetFormatter func(name string) (Formatter, error)

+ ListPlugins func() []PluginInfo

+ LoadFromDirectory func(dir string) error

+ RegisterBackend func(name string, factory BackendFactory) error

+ RegisterFilter func(name string, factory FilterFactory) error

+ RegisterFormatter func(name string, factory FormatterFactory) error

+ UnloadPlugin func(name string) error

+ type Plugin interface

+ Description func() string

+ Health func() HealthStatus

+ Initialize func(config map[string]interface{}) error

+ Name func() string

+ Shutdown func(ctx context.Context) error

+ Version func() string

+ type PluginCapabilities struct

+ BackendSchemes []string

+ FilterTypes []string

+ FormatNames []string

+ PluginCount int

+ type PluginInfo struct

+ Description string

+ Details map[string]interface{}

+ Name string

+ Status string

+ Type string

+ Version string

+ type PluginMetadata struct

+ Author string

+ Dependencies []string

+ Description string

+ FilterType string

+ FormatName string

+ Homepage string

+ License string

+ Name string

+ Schemes []string

+ Type string

+ Version string

+ func LoadPluginMetadata(metadataPath string) (*PluginMetadata, error)

+ type PluginSpec struct

+ Config map[string]interface{}

+ Name string

+ Path string

+ URL string