collection

package
v0.0.101-dev Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2025 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Collection 

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

Collection handles the communication with Grafana Alloy, and ensures that subscribed instance received updates to rules. For each tenant and scope a new hub is created.

func New 

func New(cfg Config, bucket objstore.Bucket, logger log.Logger) *Collection

func (*Collection) DeleteCollectionRule 

func (c *Collection) DeleteCollectionRule(
	ctx context.Context,
	req *connect.Request[settingsv1.DeleteCollectionRuleRequest],
) (*connect.Response[settingsv1.DeleteCollectionRuleResponse], error)

func (*Collection) GetCollectionRule 

func (c *Collection) GetCollectionRule(
	ctx context.Context,
	req *connect.Request[settingsv1.GetCollectionRuleRequest],
) (*connect.Response[settingsv1.GetCollectionRuleResponse], error)

func (*Collection) ListCollectionRules 

func (c *Collection) ListCollectionRules(
	ctx context.Context,
	_ *connect.Request[settingsv1.ListCollectionRulesRequest],
) (*connect.Response[settingsv1.ListCollectionRulesResponse], error)

func (*Collection) UpsertCollectionRule 

func (c *Collection) UpsertCollectionRule(
	ctx context.Context,
	req *connect.Request[settingsv1.UpsertCollectionRuleRequest],
) (*connect.Response[settingsv1.GetCollectionRuleResponse], error)

type Config 

type Config struct {
	Enabled           bool   `yaml:"enabled"             category:"experimental"`
	PyroscopeURL      string `yaml:"pyroscope_url"       category:"experimental"` // required to be set when enabled is true
	AlloyTemplatePath string `yaml:"alloy_template_path" category:"experimental"`
}

func (*Config) RegisterFlags 

func (cfg *Config) RegisterFlags(fs *flag.FlagSet)

func (*Config) Validate 

func (cfg *Config) Validate() error

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.