reaper

package module

v0.0.0-...-8330614 Latest Latest Go to latest Published: Jan 7, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Collect data from multiple instances

This section is empty.

This section is empty.

func WithHandler(handler Handler) func(*Collector)

WithHandler sets handler of collected data.

func WithLogger(log Logger) func(*Collector)

WithLogger sets logger.

type Batcher interface {
	Put(v interface{})
	Close()
}

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

func New(redis *redis.Client, opts ...Option) *Collector

func (c *Collector) AsyncPush(ctx context.Context, d time.Duration, labels ...string) error

func (c *Collector) Close()

func (c *Collector) Push(ctx context.Context, d time.Duration, labels ...string) error

type ErrorFunc func(err error)

func (f ErrorFunc) Error(err error)

type Handler interface {
	Serve(ctx context.Context, item Item)
}

Handler handles collected messages.

type HandlerFunc func(ctx context.Context, item Item)

func (f HandlerFunc) Serve(ctx context.Context, item Item)

type Item struct {
	// Duration seconds
	Duration int
	Labels   []string
}

type Logger interface {
	Error(err error)
}

Logger handles errors.

type Option func(*Collector)

Option sets the batcher option.