csv

Documentation

Index

• func IsStringInSlice(slice []string, str string) bool
• func MakeHeader(tags []string) []string
• func SampleToRow(sample *stats.Sample, resTags []string, ignoredTags []string, row []string) []string
• type Collector
  • func New(logger logrus.FieldLogger, fs afero.Fs, tags stats.TagSet, config Config) (*Collector, error)
  • func (c *Collector) Collect(scs []stats.SampleContainer)
  • func (c *Collector) Init() error
  • func (c *Collector) Link() string
  • func (c *Collector) Run(ctx context.Context)
• type Config
  • func GetConsolidatedConfig(jsonRawConf json.RawMessage, env map[string]string, arg string) (Config, error)
  • func NewConfig() Config
  • func ParseArg(arg string) (Config, error)
  • func (c Config) Apply(cfg Config) Config

Functions

func IsStringInSlice

func IsStringInSlice(slice []string, str string) bool

IsStringInSlice returns whether the string is contained within a string slice

func MakeHeader

func MakeHeader(tags []string) []string

MakeHeader creates list of column names for csv file

func SampleToRow

func SampleToRow(sample *stats.Sample, resTags []string, ignoredTags []string, row []string) []string

SampleToRow converts sample into array of strings

Types

type Collector

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

Collector saving output to csv implements the lib.Collector interface

func New

func New(logger logrus.FieldLogger, fs afero.Fs, tags stats.TagSet, config Config) (*Collector, error)

New Creates new instance of CSV collector

func (*Collector) Collect

func (c *Collector) Collect(scs []stats.SampleContainer)

Collect Saves samples to buffer

func (*Collector) Init

func (c *Collector) Init() error

Init writes column names to csv file

func (*Collector) Link

func (c *Collector) Link() string

Link returns a dummy string, it's only included to satisfy the lib.Collector interface

func (*Collector) Run

func (c *Collector) Run(ctx context.Context)

Run just blocks until the context is done

type Config

type Config struct {
	// Samples.
	FileName     null.String        `json:"file_name" envconfig:"K6_CSV_FILENAME"`
	SaveInterval types.NullDuration `json:"save_interval" envconfig:"K6_CSV_SAVE_INTERVAL"`
}

Config is the config for the csv collector

func GetConsolidatedConfig

func GetConsolidatedConfig(jsonRawConf json.RawMessage, env map[string]string, arg string) (Config, error)

GetConsolidatedConfig combines {default config values + JSON config + environment vars + arg config values}, and returns the final result.

func NewConfig

func NewConfig() Config

NewConfig creates a new Config instance with default values for some fields.

func ParseArg

func ParseArg(arg string) (Config, error)

ParseArg takes an arg string and converts it to a config

func (Config) Apply

func (c Config) Apply(cfg Config) Config

Apply merges two configs by overwriting properties in the old config