nflog

Apr 25, 2017

Changes in this version

type Log

+ Log func(r *pb.Receiver, key string, firing, resolved []uint64) error

Nov 24, 2016

Changes in this version

type Option

+ func WithMetrics(r prometheus.Registerer) Option

Nov 1, 2016

Changes in this version

+ var ErrNotFound = errors.New("not found")

+ type Log interface

+ GC func() (int, error)

+ LogActive func(r *pb.Receiver, key, hash []byte) error

+ LogResolved func(r *pb.Receiver, key, hash []byte) error

+ Query func(p ...QueryParam) ([]*pb.Entry, error)

+ Snapshot func(w io.Writer) (int, error)

+ func New(opts ...Option) (Log, error)

+ type Option func(*nlog) error

+ func WithLogger(logger log.Logger) Option

+ func WithMaintenance(d time.Duration, stopc chan struct{}, done func()) Option

+ func WithMesh(create func(g mesh.Gossiper) mesh.Gossip) Option

+ func WithNow(f func() time.Time) Option

+ func WithRetention(d time.Duration) Option

+ func WithSnapshot(sf string) Option

+ type QueryParam func(*query) error

+ func QGroupKey(gk []byte) QueryParam

+ func QReceiver(r *pb.Receiver) QueryParam