netsample

Documentation

Index

• Constants
• func WrapAggregator(a Aggregator) core.Aggregator
• type Aggregator
  • func NewPhout(fs afero.Fs, conf PhoutConfig) (a Aggregator, err error)
  • func UnwrapAggregator(a core.Aggregator) Aggregator
• type PhoutConfig
  • func DefaultPhoutConfig() PhoutConfig
• type Sample
  • func Acquire(tag string) *Sample
  • func DiscardedShootSample() *Sample
  • func (s *Sample) AddTag(tag string)
  • func (s *Sample) Err() error
  • func (s *Sample) ID() int
  • func (s *Sample) ProtoCode() int
  • func (s *Sample) SetConnectTime(d time.Duration)
  • func (s *Sample) SetErr(err error)
  • func (s *Sample) SetID(id int)
  • func (s *Sample) SetLatency(d time.Duration)
  • func (s *Sample) SetProtoCode(code int)
  • func (s *Sample) SetReceiveTime(d time.Duration)
  • func (s *Sample) SetRequestBytes(b int)
  • func (s *Sample) SetResponseBytes(b int)
  • func (s *Sample) SetSendTime(d time.Duration)
  • func (s *Sample) SetUserDuration(d time.Duration)
  • func (s *Sample) SetUserNet(code int)
  • func (s *Sample) SetUserProto(code int)
  • func (s *Sample) String() string
  • func (s *Sample) Tags() string
• type TestAggregator
  • func (t *TestAggregator) Report(s *Sample)
  • func (t *TestAggregator) Run(ctx context.Context, _ core.AggregatorDeps) error

Constants

const (
	ProtoCodeError          = 999
	DiscardedShootCodeError = 777
	DiscardedShootTag       = "discarded"
)

Functions

func WrapAggregator

func WrapAggregator(a Aggregator) core.Aggregator

Types

type Aggregator

type Aggregator interface {
	Run(ctx context.Context, deps core.AggregatorDeps) error
	Report(sample *Sample)
}

func NewPhout

func NewPhout(fs afero.Fs, conf PhoutConfig) (a Aggregator, err error)

func UnwrapAggregator

func UnwrapAggregator(a core.Aggregator) Aggregator

type PhoutConfig

type PhoutConfig struct {
	Destination     string                    // Destination file name
	ID              bool                      // Print ammo ids if true.
	FlushTime       time.Duration             `config:"flush-time"`
	SampleQueueSize int                       `config:"sample-queue-size"`
	Buffer          coreutil.BufferSizeConfig `config:",squash"`
}

func DefaultPhoutConfig

func DefaultPhoutConfig() PhoutConfig

type Sample

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

func Acquire

func Acquire(tag string) *Sample

func DiscardedShootSample

func DiscardedShootSample() *Sample

func (*Sample) AddTag

func (s *Sample) AddTag(tag string)

func (*Sample) Err

func (s *Sample) Err() error

func (*Sample) ID

func (s *Sample) ID() int

func (*Sample) ProtoCode

func (s *Sample) ProtoCode() int

func (*Sample) SetConnectTime

func (s *Sample) SetConnectTime(d time.Duration)

func (*Sample) SetErr

func (s *Sample) SetErr(err error)

func (*Sample) SetID

func (s *Sample) SetID(id int)

func (*Sample) SetLatency

func (s *Sample) SetLatency(d time.Duration)

func (*Sample) SetProtoCode

func (s *Sample) SetProtoCode(code int)

func (*Sample) SetReceiveTime

func (s *Sample) SetReceiveTime(d time.Duration)

func (*Sample) SetRequestBytes

func (s *Sample) SetRequestBytes(b int)

func (*Sample) SetResponseBytes

func (s *Sample) SetResponseBytes(b int)

func (*Sample) SetSendTime

func (s *Sample) SetSendTime(d time.Duration)

func (*Sample) SetUserDuration

func (s *Sample) SetUserDuration(d time.Duration)

func (*Sample) SetUserNet

func (s *Sample) SetUserNet(code int)

func (*Sample) SetUserProto

func (s *Sample) SetUserProto(code int)

func (*Sample) String

func (s *Sample) String() string

func (*Sample) Tags

func (s *Sample) Tags() string

type TestAggregator

type TestAggregator struct {
	Samples []*Sample
}

func (*TestAggregator) Report

func (t *TestAggregator) Report(s *Sample)

func (*TestAggregator) Run

func (t *TestAggregator) Run(ctx context.Context, _ core.AggregatorDeps) error