flowdebug

package

v0.0.0-...-fbdc16a Latest Latest Go to latest Published: Feb 8, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Details

This section is empty.

This section is empty.

func GraphInterceptor(p *Profiler) flow.Interceptor

func Graphviz(topology *types.Topology) (string, error)

func ParseStatsMessage() func(string) (*StatsMessage, error)

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

type Metric struct {
	*atomic.Int32
	// contains filtered or unexported fields
}

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

func NewProfiler(opt *ProfilerOptions) *Profiler

func (p *Profiler) AddGraph(id string, topology *types.Topology, metricsPrefix []string) error

func (p *Profiler) AddMetric(id string, isRate bool) Metric

func (p *Profiler) DeleteMetrics(metricsPrefix []string)

func (p *Profiler) RemoveGraph(id string, err error)

func (p *Profiler) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (p *Profiler) Stop()

type ProfilerOptions struct {
	Debug         bool
	HistoryLength int
	SampleRate    time.Duration

	Logger *logrus.Logger
}

type StatsMessage struct {
	GraphId string
	StatId  string
	TagMsgs []StatsTagMessage
}

func RegexStatsMessage(str string) (*StatsMessage, error)

func (msg *StatsMessage) ToString() string

id.stat;[tag=value|metric@ratio;].

type StatsTagMessage struct {
	Tag     string
	HasSign bool
	Value   int
	Ratio   float64
	Metric  string
}