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

plugin

package

Go to main page

Versions in this module

v1

v1.14.0

Nov 13, 2024

v1.14.0-rc.1

Nov 12, 2024

v1.13.0

Jul 16, 2024

v1.13.0-rc.1

Jul 12, 2024

v1.12.0

May 29, 2024

v1.12.0-rc.1

May 29, 2024

v1.11.0

May 13, 2024

v1.11.0-rc.1

May 10, 2024

v1.10.0

Apr 8, 2024

v1.10.0-rc.1

Apr 8, 2024

v1.9.1

Feb 27, 2024

v1.9.1-rc.1

Feb 27, 2024

v1.9.0

Feb 26, 2024

Changes in this version

+ const DependencyDirEnvName

+ var ErrNotStartedPluginManager = errors.New("plugin manager is not started yet")

+ func DoesBinaryExist(path string) bool

+ func ExecuteCommandWithEnvs(ctx context.Context, rawCmd string, envs map[string]string) (string, error)

+ func GenerateKubeConfig(restCfg *rest.Config, clusterName string, pluginCtx config.PluginContext, ...) ([]byte, error)

+ func IsNotFoundError(err error) bool

+ func MergeExecutorConfigs(in []*executor.Config, dest any) error

+ func MergeExecutorConfigsWithDefaults(defaults any, in []*executor.Config, dest any) error

+ func MergeSourceConfigs(in []*source.Config, dest any) error

+ func MergeSourceConfigsWithDefaults(defaults any, in []*source.Config, dest any) error

+ func NewPluginLoggers(bkLogger logrus.FieldLogger, logConfig config.Logger, pluginKey string, ...) (hclog.Logger, io.Writer, io.Writer)

+ func NewStaticPluginServer(cfg StaticPluginServerConfig) (string, func() error)

+ func ParseCommand(pluginName, command string, destination any) error

+ func PersistKubeConfig(_ context.Context, kc []byte) (string, func(context.Context) error, error)

+ func ValidateKubeConfigProvided(pluginName string, kubeconfig []byte) error

+ type Collector struct

+ func NewCollector(log logrus.FieldLogger) *Collector

+ func (c *Collector) GetAllEnabledAndUsedPlugins(cfg *config.Config) ([]string, []string)

+ type Dependencies map[string]Dependency

+ type Dependency struct

+ URL string

+ type ExecuteCommandMutation func(*ExecuteCommandOptions)

+ func ExecuteClearColorCodes() ExecuteCommandMutation

+ func ExecuteCommandDependencyDir(dir string) ExecuteCommandMutation

+ func ExecuteCommandEnvs(envs map[string]string) ExecuteCommandMutation

+ func ExecuteCommandStdin(in io.Reader) ExecuteCommandMutation

+ func ExecuteCommandWorkingDir(dir string) ExecuteCommandMutation

+ type ExecuteCommandOptions struct

+ ClearColorCodes bool

+ DependencyDir string

+ Envs map[string]string

+ Stdin io.Reader

+ WorkDir string

+ type ExecuteCommandOutput struct

+ ExitCode int

+ Stderr string

+ Stdout string

+ func ExecuteCommand(ctx context.Context, rawCmd string, mutators ...ExecuteCommandMutation) (ExecuteCommandOutput, error)

+ func (out ExecuteCommandOutput) CombinedOutput() string

+ type ExternalRequest struct

+ Payload ExternalRequestPayload

+ type ExternalRequestPayload struct

+ JSONSchema JSONSchema

+ type HealthMonitor struct

+ func NewHealthMonitor(logger logrus.FieldLogger, logCfg config.Logger, ...) *HealthMonitor

+ func (m *HealthMonitor) Start(ctx context.Context)

+ type HealthStats struct

+ func NewHealthStats(threshold int) *HealthStats

+ func (h *HealthStats) GetRestartCount(plugin string) int

+ func (h *HealthStats) GetStats(plugin string) (status string, restarts int, threshold int, timestamp string)

+ func (h *HealthStats) Increment(plugin string)

+ type Index struct

+ Entries []IndexEntry

+ func (in Index) Validate() error

+ type IndexBuilder struct

+ func NewIndexBuilder(log logrus.FieldLogger) *IndexBuilder

+ func (i *IndexBuilder) Build(dir, urlBasePath, pluginNameFilter string, skipChecksum, useArchive bool) (Index, error)

+ type IndexEntry struct

+ Description string

+ DocumentationURL string

+ ExternalRequest ExternalRequest

+ JSONSchema JSONSchema

+ Name string

+ Recommended bool

+ Type Type

+ URLs []IndexURL

+ Version string

+ type IndexRenderData struct

+ Remote remote.Config

+ type IndexURL struct

+ Checksum string

+ Dependencies Dependencies

+ Platform IndexURLPlatform

+ URL string

+ type IndexURLPlatform struct

+ Arch string

+ OS string

+ type JSONSchema struct

+ RefURL string

+ Value string

+ func (s *JSONSchema) Get(ctx context.Context, httpCli *http.Client) (json.RawMessage, error)

+ type KubeConfigInput struct

+ Channel string

+ type Manager struct

+ func NewManager(logger logrus.FieldLogger, logCfg config.Logger, cfg config.PluginManagement, ...) *Manager

+ func (m *Manager) GetExecutor(name string) (executor.Executor, error)

+ func (m *Manager) GetSource(name string) (source.Source, error)

+ func (m *Manager) Shutdown()

+ func (m *Manager) Start(ctx context.Context) error

+ type NotFoundPluginError struct

+ func NewNotFoundPluginError(msg string, args ...any) *NotFoundPluginError

+ func (n *NotFoundPluginError) Is(target error) bool

+ func (n NotFoundPluginError) Error() string

+ type StaticPluginServerConfig struct

+ BinariesDirectory string

+ Host string

+ Port int

+ type TmpDir string

+ func (t TmpDir) Get() (string, bool)

+ func (t TmpDir) GetDirectory() string

+ type Type string

+ const TypeExecutor

+ const TypeSource

+ func (t Type) IsValid() bool

+ func (t Type) String() string

+ type URL struct

+ Checksum string

+ URL string

v1.9.0-rc.2

Feb 23, 2024

v1.9.0-rc.1

Feb 23, 2024