operator

Documentation

Index

• Constants
• type Client
  • func NewClient(log logr.Logger, c client.Client, componentsAllowed map[string]map[string]bool) *Client
  • func (c Client) Apply(name string, namespace string, configmap *protobufs.AgentConfigFile) error
  • func (c Client) Delete(name string, namespace string) error
  • func (c Client) GetInstance(name string, namespace string) (*v1alpha1.OpenTelemetryCollector, error)
  • func (c Client) ListInstances() ([]v1alpha1.OpenTelemetryCollector, error)
• type ConfigApplier

Constants

const (
	CollectorResource       = "OpenTelemetryCollector"
	ResourceIdentifierKey   = "created-by"
	ResourceIdentifierValue = "operator-opamp-bridge"
	ReportingAnnotationKey  = "opentelemetry.io/opamp-reporting"
)

Types

type Client

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

func NewClient

func NewClient(log logr.Logger, c client.Client, componentsAllowed map[string]map[string]bool) *Client

func (Client) Apply

func (c Client) Apply(name string, namespace string, configmap *protobufs.AgentConfigFile) error

func (Client) Delete

func (c Client) Delete(name string, namespace string) error

func (Client) GetInstance

func (c Client) GetInstance(name string, namespace string) (*v1alpha1.OpenTelemetryCollector, error)

func (Client) ListInstances

func (c Client) ListInstances() ([]v1alpha1.OpenTelemetryCollector, error)

type ConfigApplier

type ConfigApplier interface {
	// Apply receives a name and namespace to apply an OpenTelemetryCollector CRD that is contained in the configmap.
	Apply(name string, namespace string, configmap *protobufs.AgentConfigFile) error

	// GetInstance retrieves an OpenTelemetryCollector CRD given a name and namespace.
	GetInstance(name string, namespace string) (*v1alpha1.OpenTelemetryCollector, error)

	// ListInstances retrieves all OpenTelemetryCollector CRDs created by the operator-opamp-bridge agent.
	ListInstances() ([]v1alpha1.OpenTelemetryCollector, error)

	// Delete attempts to delete an OpenTelemetryCollector object given a name and namespace.
	Delete(name string, namespace string) error
}