plugin

package
v3.0.0-...-de0fd11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Copyright (c) F5, Inc.

This source code is licensed under the Apache License, Version 2.0 license found in the LICENSE file in the root directory of this source tree.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadPlugins 

func LoadPlugins(agentConfig *config.Config, slogger *slog.Logger) []bus.Plugin

Types

type Config 

type Config struct {
	// contains filtered or unexported fields
}

func NewConfig 

func NewConfig(agentConfig *config.Config) *Config

func (*Config) Close 

func (c *Config) Close(ctx context.Context) error

func (*Config) GetInstance 

func (c *Config) GetInstance(instanceID string) *v1.Instance

func (*Config) Info 

func (*Config) Info() *bus.Info

func (*Config) Init 

func (c *Config) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

func (*Config) Process 

func (c *Config) Process(ctx context.Context, msg *bus.Message)

func (*Config) Subscriptions 

func (*Config) Subscriptions() []string

type GetProcessesFunc 

type GetProcessesFunc func(ctx context.Context) ([]*model.Process, error)

type GrpcClient 

type GrpcClient struct {
	// contains filtered or unexported fields
}

func NewGrpcClient 

func NewGrpcClient(agentConfig *config.Config) *GrpcClient

func (*GrpcClient) Close 

func (gc *GrpcClient) Close(ctx context.Context) error

func (*GrpcClient) GetFileContents 

func (gc *GrpcClient) GetFileContents(ctx context.Context, request *v1.GetFileRequest) (*v1.FileContents, error)

func (*GrpcClient) GetFileOverview 

func (gc *GrpcClient) GetFileOverview(ctx context.Context, request *v1.GetOverviewRequest) (*v1.FileOverview, error)

func (*GrpcClient) Info 

func (gc *GrpcClient) Info() *bus.Info

func (*GrpcClient) Init 

func (gc *GrpcClient) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) (err error)

func (*GrpcClient) Process 

func (gc *GrpcClient) Process(ctx context.Context, msg *bus.Message)

func (*GrpcClient) ProcessRequest 

func (gc *GrpcClient) ProcessRequest(ctx context.Context, request *v1.ManagementPlaneRequest)

func (*GrpcClient) Subscriptions 

func (gc *GrpcClient) Subscriptions() []string

type GrpcConfigClient 

type GrpcConfigClient struct {
	// contains filtered or unexported fields
}

func (*GrpcConfigClient) GetFile 

func (gcc *GrpcConfigClient) GetFile(ctx context.Context, request *v1.GetFileRequest) (*v1.FileContents, error)

func (*GrpcConfigClient) GetOverview 

func (gcc *GrpcConfigClient) GetOverview(
	ctx context.Context,
	request *v1.GetOverviewRequest,
) (*v1.FileOverview, error)

type Metrics 

type Metrics struct {
	// contains filtered or unexported fields
}

The Metrics plugin. Discovers and owns the data source that produce metrics for the Agent.

func NewMetrics 

func NewMetrics(conf *config.Config, options ...MetricsOption) (*Metrics, error)

NewMetrics is the constructor for the Metrics plugin.

func (*Metrics) Close 

func (m *Metrics) Close(_ context.Context) error

Close about the plugin. Required for the `Plugin` interface.

func (*Metrics) Info 

func (m *Metrics) Info() *bus.Info

Info about the plugin. Required for the `Plugin` interface.

func (*Metrics) Init 

func (m *Metrics) Init(ctx context.Context, mp bus.MessagePipeInterface) error

Init initializes and starts the plugin. Required for the `Plugin` interface.

func (*Metrics) Process 

func (m *Metrics) Process(_ context.Context, msg *bus.Message)

Process an incoming Message Bus message in the plugin. Required for the `Plugin` interface.

func (*Metrics) Subscriptions 

func (m *Metrics) Subscriptions() []string

Subscriptions returns the list of topics the plugin is subscribed to. Required for the `Plugin` interface.

type MetricsOption 

type MetricsOption func(*Metrics) error

MetricsOption a functional option for `*Metrics`.

func WithDataSource 

func WithDataSource(ds model.MetricsProducer) MetricsOption

WithDataSource appends a Metrics data source that will automatically collect metrics.

type ProcessMonitor 

type ProcessMonitor struct {
	// contains filtered or unexported fields
}

func NewProcessMonitor 

func NewProcessMonitor(agentConfig *config.Config) *ProcessMonitor

func (*ProcessMonitor) Close 

func (pm *ProcessMonitor) Close(ctx context.Context) error

func (*ProcessMonitor) Info 

func (*ProcessMonitor) Info() *bus.Info

func (*ProcessMonitor) Init 

func (pm *ProcessMonitor) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

func (*ProcessMonitor) Process 

func (*ProcessMonitor) Process(_ context.Context, _ *bus.Message)

func (*ProcessMonitor) Subscriptions 

func (*ProcessMonitor) Subscriptions() []string

type Resource 

type Resource struct {
	// contains filtered or unexported fields
}

func NewResource 

func NewResource(agentConfig *config.Config) *Resource

func (*Resource) Close 

func (*Resource) Close(ctx context.Context) error

func (*Resource) Info 

func (*Resource) Info() *bus.Info

func (*Resource) Init 

func (r *Resource) Init(ctx context.Context, messagePipe bus.MessagePipeInterface) error

nolint: unparam error is always nil

func (*Resource) Process 

func (r *Resource) Process(ctx context.Context, msg *bus.Message)

func (*Resource) Subscriptions 

func (*Resource) Subscriptions() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.