source

Documentation

Index

• type Crawler
  • func (c *Crawler) AddGetter(scheme string, getter Getter)
  • func (c *Crawler) Run(ctx context.Context) error
• type Directory
• type EcoCounter
  • func (g *EcoCounter) AddPrivateDomain(dom EcoCounterPrivateDomain) error
  • func (g *EcoCounter) Counters(ctx context.Context, id string) ([]directory.Counter, error)
  • func (g *EcoCounter) Get(ctx context.Context, req GetRequest) ([]submit.Point, error)
• type EcoCounterPrivateDomain
• type GetRequest
• type Getter
• type HalifaxTransit
  • func (h *HalifaxTransit) Counters(ctx context.Context) ([]directory.Counter, error)
  • func (h *HalifaxTransit) Get(ctx context.Context, req GetRequest) ([]submit.Point, error)
• type Querier

Types

type Crawler

type Crawler struct {
	Directory Directory
	Querier   Querier
	Submitter submit.Submitter
	// contains filtered or unexported fields
}

func (*Crawler) AddGetter

func (c *Crawler) AddGetter(scheme string, getter Getter)

func (*Crawler) Run

func (c *Crawler) Run(ctx context.Context) error

type Directory

type Directory interface {
	Counters(context.Context) ([]directory.Counter, error)
}

type EcoCounter

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

func (*EcoCounter) AddPrivateDomain

func (g *EcoCounter) AddPrivateDomain(dom EcoCounterPrivateDomain) error

func (*EcoCounter) Counters

func (g *EcoCounter) Counters(ctx context.Context, id string) ([]directory.Counter, error)

func (*EcoCounter) Get

func (g *EcoCounter) Get(ctx context.Context, req GetRequest) ([]submit.Point, error)

type EcoCounterPrivateDomain

type EcoCounterPrivateDomain struct {
	Name     string
	Username string
	Password string
	UserID   string
	DomainID string
	// contains filtered or unexported fields
}

type GetRequest

type GetRequest struct {
	URL   *url.URL
	After time.Time
}

type Getter

type Getter interface {
	Get(ctx context.Context, req GetRequest) ([]submit.Point, error)
}

type HalifaxTransit

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

func (*HalifaxTransit) Counters

func (h *HalifaxTransit) Counters(ctx context.Context) ([]directory.Counter, error)

func (*HalifaxTransit) Get

func (h *HalifaxTransit) Get(ctx context.Context, req GetRequest) ([]submit.Point, error)

type Querier

type Querier interface {
	Query(ctx context.Context, q string) ([]query.Point, error)
}