atlas

Documentation

Index

• func InitCache(ttl, cleanup time.Duration)
• type Strategy
  • func NewRequestStrategy(cfg *config.Config, workers uint) Strategy
  • func NewStreamingStrategy(ctx context.Context, cfg *config.Config, bufferSize uint, ...) Strategy

Functions

func InitCache

func InitCache(ttl, cleanup time.Duration)

InitCache initializes the cache

Types

type Strategy

type Strategy interface {
	// MeasurementResults gets results for a list of measurements
	MeasurementResults(ctx context.Context, ids []string) ([]*exporter.Measurement, error)
}

Strategy defines an strategy to retrieve data for generating metrics

func NewRequestStrategy

func NewRequestStrategy(cfg *config.Config, workers uint) Strategy

NewRequestStrategy returns an strategy to retrieve data from Atlas API using requests

func NewStreamingStrategy

func NewStreamingStrategy(ctx context.Context, cfg *config.Config, bufferSize uint, defaultTimeout time.Duration) Strategy

NewStreamingStrategy returns an strategy using the RIPE Atlas Streaming API