main
1package flux
2
3import (
4 "context"
5 "time"
6)
7
8// Source fetches entries from an external system.
9type Source interface {
10 // Name returns a human-readable label for this source.
11 Name() string
12
13 // Fetch retrieves entries newer than since. If since is zero, fetches all available.
14 Fetch(ctx context.Context, since time.Time) ([]Entry, error)
15}