package sources

import "github.com/tidbcloud/observability/data-collector/pkg/collector/config"

type Source interface {
	Run(timestamp int64, checkpoint int64) ([]Result, error)
	GetConfig() config.SourceInterface
}

type Result struct {
	Path string
	Body []byte
}