dedup

package
v1.1.2 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultConfig = Config{
	CacheSize: pointer.Int(1000),
	Path:      "",
}

Functions

This section is empty.

Types

type Config

type Config struct {
	CacheSize *int   `json:"cacheSize,omitempty"`
	Path      string `json:"path,omitempty"`
}

Config can be passed into NewFilter() in order to configure the behavior of the sender.

func NewConfig

func NewConfig(config interface{}) (*Config, error)

func (*Config) FromJSON

func (c *Config) FromJSON(in string) error

func (*Config) FromYAML

func (c *Config) FromYAML(in string) error

func (*Config) JSON

func (c *Config) JSON() (string, error)

func (*Config) String

func (c *Config) String() string

func (*Config) Validate

func (c *Config) Validate() error

func (Config) WithDefaults

func (c Config) WithDefaults() *Config

func (*Config) YAML

func (c *Config) YAML() (string, error)

type Filter

type Filter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewFilter

func NewFilter(tid tenant.Id, plugin string, name string, config interface{}, secrets secret.Vault, tableSyncer syncer.DeltaSyncer) (*Filter, error)

func (*Filter) Config

func (f *Filter) Config() interface{}

func (*Filter) EventErrorCount added in v1.1.2

func (f *Filter) EventErrorCount() int

func (*Filter) EventErrorVelocity added in v1.1.2

func (f *Filter) EventErrorVelocity() int

func (*Filter) EventFilterCount added in v1.1.2

func (f *Filter) EventFilterCount() int

func (*Filter) EventFilterVelocity added in v1.1.2

func (f *Filter) EventFilterVelocity() int

func (*Filter) EventSuccessCount added in v1.1.2

func (f *Filter) EventSuccessCount() int

func (*Filter) EventSuccessVelocity added in v1.1.2

func (f *Filter) EventSuccessVelocity() int

func (*Filter) EventTs added in v1.1.2

func (f *Filter) EventTs() int64

func (*Filter) Filter

func (f *Filter) Filter(evt event.Event) []event.Event

func (*Filter) Hash added in v1.1.2

func (f *Filter) Hash() string

func (*Filter) Name added in v0.2.1

func (f *Filter) Name() string

func (*Filter) Plugin added in v0.2.1

func (f *Filter) Plugin() string

func (*Filter) Tenant added in v0.3.0

func (f *Filter) Tenant() tenant.Id

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL