profiler

package

v0.41.1-data-migration... Latest Latest Go to latest Published: May 21, 2025 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(log zerolog.Logger, uploader Uploader, cfg ProfilerConfig) (*AutoProfiler, error)

New creates a new AutoProfiler instance performing profiling every interval for duration.

func (p *AutoProfiler) Done() <-chan struct{}

func (p *AutoProfiler) Enabled() bool

Enabled returns the current enabled state of the profiler.

func (p *AutoProfiler) Ready() <-chan struct{}

func (p *AutoProfiler) SetEnabled(enabled bool) error

SetEnabled sets whether the profiler is active. No errors are expected during normal operation.

func (p *AutoProfiler) TriggerRun(d time.Duration) error

TriggerRun manually triggers a profile run if one is not already running.

type NoopUploader struct{}

func (u *NoopUploader) Upload(ctx context.Context, filename string, pt pb.ProfileType) error

type Params struct {
	ProjectID string
	ChainID   string
	Role      string
	Version   string
	Commit    string
	Instance  string
}

type ProfilerConfig struct {
	Enabled         bool
	UploaderEnabled bool

	Dir      string
	Interval time.Duration
	Duration time.Duration
}

ProfilerConfig profiler parameters.

type Uploader interface {
	Upload(ctx context.Context, filename string, pt pb.ProfileType) error
}

func NewUploader(log zerolog.Logger, params Params, opts ...option.ClientOption) (Uploader, error)

type UploaderImpl struct {
	ProjectId  string
	Deployment *pb.Deployment
	// contains filtered or unexported fields
}

func (u *UploaderImpl) Upload(ctx context.Context, filename string, pt pb.ProfileType) error