Documentation
¶
Index ¶
- type Config
- type RecordingRules
- func (r *RecordingRules) DeleteRecordingRule(ctx context.Context, ...) (*connect.Response[settingsv1.DeleteRecordingRuleResponse], error)
- func (r *RecordingRules) GetRecordingRule(ctx context.Context, req *connect.Request[settingsv1.GetRecordingRuleRequest]) (*connect.Response[settingsv1.GetRecordingRuleResponse], error)
- func (r *RecordingRules) ListRecordingRules(ctx context.Context, ...) (*connect.Response[settingsv1.ListRecordingRulesResponse], error)
- func (r *RecordingRules) UpsertRecordingRule(ctx context.Context, ...) (*connect.Response[settingsv1.UpsertRecordingRuleResponse], error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Enabled bool `yaml:"enabled" category:"experimental"`
}
func (*Config) RegisterFlags ¶
type RecordingRules ¶
type RecordingRules struct {
// contains filtered or unexported fields
}
RecordingRules is a collection that gathers rules coming from config and coming from the bucket storage. Rules coming from config work as overrides of store rules, and in case of repeated ID, config rules prevail.
func New ¶
func New(bucket objstore.Bucket, logger log.Logger, overrides *validation.Overrides) *RecordingRules
func (*RecordingRules) DeleteRecordingRule ¶
func (r *RecordingRules) DeleteRecordingRule(ctx context.Context, req *connect.Request[settingsv1.DeleteRecordingRuleRequest]) (*connect.Response[settingsv1.DeleteRecordingRuleResponse], error)
DeleteRecordingRule deletes a store rule Operational purposes: you can delete store rules (no matter if they exist in config)
func (*RecordingRules) GetRecordingRule ¶
func (r *RecordingRules) GetRecordingRule(ctx context.Context, req *connect.Request[settingsv1.GetRecordingRuleRequest]) (*connect.Response[settingsv1.GetRecordingRuleResponse], error)
GetRecordingRule will return a rule of the given ID or not found. Rules defined by config are returned over rules in the store.
func (*RecordingRules) ListRecordingRules ¶
func (r *RecordingRules) ListRecordingRules(ctx context.Context, req *connect.Request[settingsv1.ListRecordingRulesRequest]) (*connect.Response[settingsv1.ListRecordingRulesResponse], error)
ListRecordingRules will return all the rules defined by config and in the store. Rules in the store with the same ID as a rule in config will be filtered out.
func (*RecordingRules) UpsertRecordingRule ¶
func (r *RecordingRules) UpsertRecordingRule(ctx context.Context, req *connect.Request[settingsv1.UpsertRecordingRuleRequest]) (*connect.Response[settingsv1.UpsertRecordingRuleResponse], error)
UpsertRecordingRule upserts a rule in the storage. Operational purposes: you can upsert store rules (no matter if they exist in config)
Source Files
Directories