collect

package

v1.0.0 Latest Latest Go to latest Published: Aug 20, 2021 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(processor Processor, opts *Options) (*Collector, error)

func (c *Collector) Collect(req *Job) error

func (c *Collector) Get(id string) (io.ReadCloser, error)

func (c *Collector) List() []*Entry

type Entry struct {
	Snapshot *Snapshot
	Status   Status
	Message  string
}

type Job struct {
	URL      string
	Duration int
}

type Options struct {
	WorkDir   string
	FileName  string
	EventName string
	EventHub  *event.Hub
}

type Processor interface {
	Process(snapshot *Snapshot) (io.ReadCloser, error)
	Cacheable() bool
}

type Snapshot struct {
	SnapshotMeta
	SnapshotPath `json:"-"`
}

func (s *Snapshot) Collect() error

func (s *Snapshot) Prune() error

type SnapshotMeta struct {
	ID       string
	Datetime time.Time
	URL      string
	Duration int
}

type SnapshotPath struct {
	Meta  string
	Body  string
	Cache string
}

type Status string

const (
	StatusOk      Status = "ok"
	StatusFail    Status = "fail"
	StatusPending Status = "pending"
)

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

func (s *Storage) List() ([]*Snapshot, error)

func (s *Storage) PrepareSnapshot(url string, duration int) *Snapshot