Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigOption ¶
type ConfigOption func(cfg *Config)
func WithAction ¶
func WithAction(action func([][]byte)) ConfigOption
func WithBufferLimit ¶
func WithBufferLimit(limit int) ConfigOption
func WithKeys ¶
func WithKeys(keys ...string) ConfigOption
func WithPeriod ¶
func WithPeriod(period time.Duration) ConfigOption
type Debouncer ¶
type Debouncer interface {
Add(...PayloadOption)
}
type Deduper ¶
type Deduper struct {
Config
// contains filtered or unexported fields
}
func NewDeduper ¶
func NewDeduper(ctx context.Context, opts ...ConfigOption) *Deduper
func (*Deduper) Add ¶
func (d *Deduper) Add(oss ...PayloadOption)
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
func NewFactory(t Type, opts ...ConfigOption) *Factory
type Limiter ¶
type Limiter struct {
Config
// contains filtered or unexported fields
}
func NewLimiter ¶
func NewLimiter(ctx context.Context, opts ...ConfigOption) *Limiter
func (*Limiter) Add ¶
func (d *Limiter) Add(oss ...PayloadOption)
type PayloadOption ¶
type PayloadOption func(o *Payload)
func Bytes ¶
func Bytes(buf []byte) PayloadOption
Source Files
Click to show internal directories.
Click to hide internal directories.