daemon

type Daemon struct {
	Listener  net.Listener
	Logger    log.Printer
	Groups    map[string][]Rule
	Cache     MessageCache
	Store     MessageStore
	SampleSrc rand.Source
	SamplePct float64
	// contains filtered or unexported fields
}

type EvalRecord struct {
	Message *Message
	// contains filtered or unexported fields
}

type Message struct {
	Envelope *enmime.Envelope
	// contains filtered or unexported fields
}

type MessageCache interface {
	Get(cacheKey string) *Message
	Put(cacheKey string, msg *Message, size uint64)
}

type MessageStore interface {
	GetMetadata(storeID string) (Metadata, bool, error)
	PutMessage(storeID string, msg *Message) error
	RecordEval(storeID string, r *EvalRecord) error
}

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

type Rule interface {
	fmt.Stringer
	Eval(ctx context.Context, logger log.Printer, msg *Message, tagger Tagger) (match bool, err error)
}

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

type TagChange struct {
	Time  time.Time
	Key   string
	Value *string
}

type Tagger interface {
	Keys() []string
	GetTag(key string) (value string, hit bool)
	SetTag(key, value string)
	DeleteTag(key string)
}