flowstats

package

v1.6.0 Latest Latest Go to latest Published: Aug 14, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ekusiadadus/isutools

Links

Open Source Insights

Documentation ¶

Overview ¶

Package flowstats records bounded, pseudonymous user-flow transitions and explicit scenario journeys directly at the application middleware boundary. It is independent of the selected reverse proxy.

Index ¶

Constants
Variables
type Frozen
type GenerationCollector
- func NewGenerationCollector(registry *Registry) *GenerationCollector
type Registry
- func NewRegistry() *Registry
type Snapshot

Constants ¶

View Source

const SectionName = "flow"

Variables ¶

View Source

var (
	ErrForeignHandle  = errors.New("flowstats: foreign generation handle")
	ErrNotDrained     = errors.New("flowstats: generation was not drained")
	ErrHandleReleased = errors.New("flowstats: generation handle was released")
)

View Source

var Default = NewRegistry()

Functions ¶

This section is empty.

Types ¶

type Frozen ¶

type Frozen struct{ Snapshot Snapshot }

type GenerationCollector ¶

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

func NewGenerationCollector ¶

func NewGenerationCollector(registry *Registry) *GenerationCollector

func (*GenerationCollector) BeginBoundary ¶

func (c *GenerationCollector) BeginBoundary(ctx context.Context, runID string, epoch runctl.Epoch) (runctl.BoundaryResult, error)

func (*GenerationCollector) Collect ¶

func (c *GenerationCollector) Collect(handle runctl.GenerationHandle) (any, error)

func (*GenerationCollector) Drain ¶

func (c *GenerationCollector) Drain(ctx context.Context, handle runctl.GenerationHandle) error

func (*GenerationCollector) Freeze ¶

func (c *GenerationCollector) Freeze(ctx context.Context, runID string, epoch runctl.Epoch) (runctl.BoundaryResult, error)

func (*GenerationCollector) Name ¶

func (c *GenerationCollector) Name() string

func (*GenerationCollector) Release ¶

func (c *GenerationCollector) Release(handle runctl.GenerationHandle)

type Registry ¶

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

func NewRegistry ¶

func NewRegistry() *Registry

func (*Registry) Observe ¶

func (r *Registry) Observe(session, scenario, method, route string)

Observe receives only already-pseudonymized session labels, bounded scenario names, and registered route templates. Raw cookies and raw URL paths never enter this package.

func (*Registry) Reset ¶

func (r *Registry) Reset()

func (*Registry) Snapshot ¶

func (r *Registry) Snapshot() Snapshot

type Snapshot ¶

type Snapshot struct {
	Stories      []accesslog.StoryEntry `json:"stories,omitempty"`
	StoryDropped int64                  `json:"story_dropped,omitempty"`
	Flows        []accesslog.FlowEntry  `json:"flows,omitempty"`
	FlowDropped  int64                  `json:"flow_dropped,omitempty"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL