profile

type BlobRepository interface {
	// NewWriter should return an io.WriterCloser implementation that will store data written to it under the
	// provided key.
	NewWriter(ctx context.Context, key string) (io.WriteCloser, error)
	// NewReader should return an io.ReadCloser implementation that will read data from blob storage at the
	// provided key. It should return blob.ErrNotExist if no data exists at the given key.
	NewReader(ctx context.Context, key string) (io.ReadCloser, error)
	// Delete should remove data stored under the given key from the blob store. It should return blob.ErrNotExist
	// if no object exists at the given key.
	Delete(ctx context.Context, key string) error
	// List should return all objects within the repository that match the provided filter.
	List(ctx context.Context, filter blob.Filter) iter.Seq2[blob.Object, error]
	// Exists should return true if an object exists at the given path.
	Exists(ctx context.Context, path string) (bool, error)
}

type Client interface {
	// Upload should write the profile data stored within the io.Reader implementation to the profile server for
	// a specified application.
	Upload(ctx context.Context, app string, r io.Reader) error
	// Download should write the contents of a pprof profile from the profile server to the io.Writer implementation
	// for the specified application.
	Download(ctx context.Context, app string, w io.Writer) error
	// ProfileAndUpload should obtain a profile from the given src URL for the specified duration and upload it
	// to the server for the specified application.
	ProfileAndUpload(ctx context.Context, app, src string, duration time.Duration) error
}

type DeleteResponse struct{}

type DeletedEvent struct {
	// The application profile that has been deleted.
	App string `json:"app"`
}

type EventWriter interface {
	// Write should push the given event payload onto the event bus.
	Write(ctx context.Context, evt event.Payload) error
}

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

type ListResponse struct {
	Profiles []Profile `json:"profiles"`
}

type MergedEvent struct {
	// The application the profile relates to.
	App string `json:"app"`
	// The location of the uploaded profile within blob storage.
	ProfileKey string `json:"profileKey"`
	// The location of the base profile that has been merged.
	MergedKey string `json:"mergedKey"`
}

type Profile struct {
	// The location in blob storage of the profile.
	Key string `json:"key"`
	// The profile size in bytes.
	Size int64 `json:"size"`
	// When the profile was last modified.
	LastModified time.Time `json:"lastModified"`
}

type PruneConfig struct {
	// The application whose profiles should be pruned.
	App string `json:"app"`
	// The pruning rules to apply.
	Rules []PruneRule `json:"rules"`
}

type PruneRule struct {
	// Drop determines the node under which child nodes will be pruned.
	Drop *regexp.Regexp `json:"drop"`
	// Keep determines nodes under Drop that should be kept.
	Keep *regexp.Regexp `json:"keep"`
}

type ScrapeConfig struct {
	// How many profiles to obtain after the ProfileDuration has passed.
	SampleSize uint
	// How long targets should be profiled for, in seconds.
	ProfileDuration time.Duration
	// How frequently profiles are sampled, in seconds.
	ScrapeFrequency time.Duration
	// The application this scraper instance is collecting profiles for.
	App string
}

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

type TargetSource interface {
	// List should return all targets that are available to be scraped.
	List(ctx context.Context) ([]target.Target, error)
}

type UploadResponse struct {
	// The location in blob storage the profile is stored at.
	Key string `json:"key"`
}

type UploadedEvent struct {
	// The application the profile relates to.
	App string `json:"app"`
	// The location of the profile within blob storage.
	ProfileKey string `json:"profileKey"`
}

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