file

type File struct {
	Name      string
	Contents  io.ReadCloser
	Created   time.Time
	PubSubMsg *pubsub.Message
}

type Source interface {
	// Start begins the process of looking for new files and as they arrive they
	// are sent on the returned channel.
	//
	// Should only be called once per instance.
	Start(ctx context.Context) (<-chan File, error)
}