discovery

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

type ArchiveFetcher interface {
	Fetch(ctx context.Context, hour time.Time) (io.ReadCloser, error)
}

type ArchiveReader struct {
	Include       map[string]bool
	Store         CheckpointStore
	MaxEventBytes int
	// MaxTotalBytes bounds the total decompressed bytes for an hour. Zero
	// disables the limit.
	MaxTotalBytes int
}

type CheckpointStore interface {
	// GetTime returns the timestamp checkpoint for key. If no checkpoint exists,
	// the bool is false.
	GetTime(ctx context.Context, key string) (time.Time, bool, error)

	// SetTime stores a timestamp checkpoint for key.
	SetTime(ctx context.Context, key string, t time.Time) error

	// IsImported reports whether the given GH Archive hour has already been
	// imported.
	IsImported(ctx context.Context, hour string) (bool, error)

	// MarkImported records the given GH Archive hour as imported.
	MarkImported(ctx context.Context, hour string) error
}

type EventType string

type LimitedReader struct {
	R         io.Reader
	N         int64
	Err       error
	CloseFunc func() error
	// contains filtered or unexported fields
}

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

type Qualifier string

type SearchItem struct {
	Repo   domain.RepoRef
	Kind   domain.ThreadKind
	Number int
	Title  string
}

type SearchPartitioner struct {
	Searcher Searcher
	// Limit is the result count that triggers splitting. Zero means 1000.
	Limit int
}

type SearchResponse struct {
	Total      int
	Items      []SearchItem
	Incomplete bool
}

type Searcher interface {
	Search(ctx context.Context, query string) (SearchResponse, error)
}

type Signal struct {
	Source       string
	Hour         time.Time
	ObservedAt   time.Time
	EventType    EventType
	Action       string
	Repo         domain.RepoRef
	RepoID       int64
	Actor        string
	ThreadKind   domain.ThreadKind
	ThreadNumber int
	ThreadTitle  string
	ThreadAuthor string
	ThreadState  domain.ThreadState
	Merged       bool
	Ref          string
	SHA          string
	Size         int
	TagName      string
}

type Window struct {
	Query        string
	Qualifier    Qualifier
	Start        time.Time
	End          time.Time
	Total        int
	Incomplete   bool
	Unsplittable bool
}