crocospans

Documentation

Index

• Variables
• type Config
  • func NewConfig(params output.Params) (Config, error)
• type Output
  • func New(p output.Params) (*Output, error)
  • func (o *Output) AddMetricSamples(samples []metrics.SampleContainer)
  • func (o *Output) Description() string
  • func (o *Output) Start() error
  • func (o *Output) Stop() error
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (x *Request) GetEndTimeUnixNano() uint64
  • func (x *Request) GetGroup() string
  • func (x *Request) GetHTTPMethod() string
  • func (x *Request) GetHTTPStatus() int64
  • func (x *Request) GetHTTPUrl() string
  • func (x *Request) GetScenario() string
  • func (x *Request) GetStartTimeUnixNano() uint64
  • func (x *Request) GetTestRunID() int64
  • func (x *Request) GetTraceID() string
  • func (*Request) ProtoMessage()
  • func (x *Request) ProtoReflect() protoreflect.Message
  • func (x *Request) Reset()
  • func (x *Request) String() string
• type RequestBatch
  • func (*RequestBatch) Descriptor() ([]byte, []int)
  • func (x *RequestBatch) GetCount() int64
  • func (x *RequestBatch) GetRequests() []*Request
  • func (x *RequestBatch) GetSizeBytes() int64
  • func (*RequestBatch) ProtoMessage()
  • func (x *RequestBatch) ProtoReflect() protoreflect.Message
  • func (x *RequestBatch) Reset()
  • func (x *RequestBatch) String() string

Variables

var File_crocospans_proto protoreflect.FileDescriptor

Types

type Config

type Config struct {
	Endpoint     string
	PushInterval time.Duration
	OrgID        int64
	Token        string
}

Config is the config for the crocospans output.

func NewConfig

func NewConfig(params output.Params) (Config, error)

NewConfig creates a new Config instance from the provided output.Params

type Output

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

Output implements the k6 output.Output interface

func New

func New(p output.Params) (*Output, error)

New creates an instance of the output

func (*Output) AddMetricSamples

func (o *Output) AddMetricSamples(samples []metrics.SampleContainer)

AddMetricSamples adds the given metric samples to the internal buffer.

func (*Output) Description

func (o *Output) Description() string

func (*Output) Start

func (o *Output) Start() error

func (*Output) Stop

func (o *Output) Stop() error

type Request

type Request struct {
	StartTimeUnixNano uint64 `protobuf:"fixed64,1,opt,name=StartTimeUnixNano,proto3" json:"StartTimeUnixNano,omitempty"`
	EndTimeUnixNano   uint64 `protobuf:"fixed64,2,opt,name=EndTimeUnixNano,proto3" json:"EndTimeUnixNano,omitempty"`
	TraceID           string `protobuf:"bytes,3,opt,name=TraceID,proto3" json:"TraceID,omitempty"`
	TestRunID         int64  `protobuf:"varint,4,opt,name=TestRunID,proto3" json:"TestRunID,omitempty"`
	Scenario          string `protobuf:"bytes,5,opt,name=Scenario,proto3" json:"Scenario,omitempty"`
	Group             string `protobuf:"bytes,6,opt,name=Group,proto3" json:"Group,omitempty"`
	HTTPUrl           string `protobuf:"bytes,7,opt,name=HTTPUrl,proto3" json:"HTTPUrl,omitempty"`
	HTTPMethod        string `protobuf:"bytes,8,opt,name=HTTPMethod,proto3" json:"HTTPMethod,omitempty"`
	HTTPStatus        int64  `protobuf:"varint,9,opt,name=HTTPStatus,proto3" json:"HTTPStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetEndTimeUnixNano

func (x *Request) GetEndTimeUnixNano() uint64

func (*Request) GetGroup

func (x *Request) GetGroup() string

func (*Request) GetHTTPMethod

func (x *Request) GetHTTPMethod() string

func (*Request) GetHTTPStatus

func (x *Request) GetHTTPStatus() int64

func (*Request) GetHTTPUrl

func (x *Request) GetHTTPUrl() string

func (*Request) GetScenario

func (x *Request) GetScenario() string

func (*Request) GetStartTimeUnixNano

func (x *Request) GetStartTimeUnixNano() uint64

func (*Request) GetTestRunID

func (x *Request) GetTestRunID() int64

func (*Request) GetTraceID

func (x *Request) GetTraceID() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type RequestBatch

type RequestBatch struct {
	SizeBytes int64      `protobuf:"varint,2,opt,name=SizeBytes,proto3" json:"SizeBytes,omitempty"`
	Count     int64      `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`
	Requests  []*Request `protobuf:"bytes,4,rep,name=Requests,proto3" json:"Requests,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestBatch) Descriptor

func (*RequestBatch) Descriptor() ([]byte, []int)

Deprecated: Use RequestBatch.ProtoReflect.Descriptor instead.

func (*RequestBatch) GetCount

func (x *RequestBatch) GetCount() int64

func (*RequestBatch) GetRequests

func (x *RequestBatch) GetRequests() []*Request

func (*RequestBatch) GetSizeBytes

func (x *RequestBatch) GetSizeBytes() int64

func (*RequestBatch) ProtoMessage

func (*RequestBatch) ProtoMessage()

func (*RequestBatch) ProtoReflect

func (x *RequestBatch) ProtoReflect() protoreflect.Message

func (*RequestBatch) Reset

func (x *RequestBatch) Reset()

func (*RequestBatch) String

func (x *RequestBatch) String() string