pkg/pb/agent.pb.go - master - t3/cli

pkg/pb/agent.pb.go
950 строк27 KB
Ivan
fix TUI metrics
09 июл 2026, 15:21
09 июл 2026, 15:21f8d1b63
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        v6.33.1
// source: agent.proto

package pb

import (
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

type AgentRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Payload:
	//
	//	*AgentRequest_Start
	//	*AgentRequest_Stop
	Payload       isAgentRequest_Payload `protobuf_oneof:"payload"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AgentRequest) Reset() {
	*x = AgentRequest{}
	mi := &file_agent_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AgentRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AgentRequest) ProtoMessage() {}

func (x *AgentRequest) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AgentRequest.ProtoReflect.Descriptor instead.
func (*AgentRequest) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{0}
}

func (x *AgentRequest) GetPayload() isAgentRequest_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *AgentRequest) GetStart() *StartRequest {
	if x != nil {
		if x, ok := x.Payload.(*AgentRequest_Start); ok {
			return x.Start
		}
	}
	return nil
}

func (x *AgentRequest) GetStop() *StopRequest {
	if x != nil {
		if x, ok := x.Payload.(*AgentRequest_Stop); ok {
			return x.Stop
		}
	}
	return nil
}

type isAgentRequest_Payload interface {
	isAgentRequest_Payload()
}

type AgentRequest_Start struct {
	Start *StartRequest `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type AgentRequest_Stop struct {
	Stop *StopRequest `protobuf:"bytes,2,opt,name=stop,proto3,oneof"`
}

func (*AgentRequest_Start) isAgentRequest_Payload() {}

func (*AgentRequest_Stop) isAgentRequest_Payload() {}

type StartRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Token         string                 `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Users         int32                  `protobuf:"varint,2,opt,name=users,proto3" json:"users,omitempty"`
	DurationMs    int64                  `protobuf:"varint,3,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	Script        []byte                 `protobuf:"bytes,4,opt,name=script,proto3" json:"script,omitempty"`
	Setup         []byte                 `protobuf:"bytes,5,opt,name=setup,proto3" json:"setup,omitempty"`
	RunId         string                 `protobuf:"bytes,6,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ThinkTimeMs   *int64                 `protobuf:"varint,7,opt,name=think_time_ms,json=thinkTimeMs,proto3,oneof" json:"think_time_ms,omitempty"` // static sleep between iterations (ms), not set = use pacing
	PacingMs      *int64                 `protobuf:"varint,8,opt,name=pacing_ms,json=pacingMs,proto3,oneof" json:"pacing_ms,omitempty"`            // pacing interval (ms), not set = use static think_time
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StartRequest) Reset() {
	*x = StartRequest{}
	mi := &file_agent_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StartRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StartRequest) ProtoMessage() {}

func (x *StartRequest) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{1}
}

func (x *StartRequest) GetToken() string {
	if x != nil {
		return x.Token
	}
	return ""
}

func (x *StartRequest) GetUsers() int32 {
	if x != nil {
		return x.Users
	}
	return 0
}

func (x *StartRequest) GetDurationMs() int64 {
	if x != nil {
		return x.DurationMs
	}
	return 0
}

func (x *StartRequest) GetScript() []byte {
	if x != nil {
		return x.Script
	}
	return nil
}

func (x *StartRequest) GetSetup() []byte {
	if x != nil {
		return x.Setup
	}
	return nil
}

func (x *StartRequest) GetRunId() string {
	if x != nil {
		return x.RunId
	}
	return ""
}

func (x *StartRequest) GetThinkTimeMs() int64 {
	if x != nil && x.ThinkTimeMs != nil {
		return *x.ThinkTimeMs
	}
	return 0
}

func (x *StartRequest) GetPacingMs() int64 {
	if x != nil && x.PacingMs != nil {
		return *x.PacingMs
	}
	return 0
}

type StopRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	RunId         string                 `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StopRequest) Reset() {
	*x = StopRequest{}
	mi := &file_agent_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StopRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StopRequest) ProtoMessage() {}

func (x *StopRequest) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{2}
}

func (x *StopRequest) GetRunId() string {
	if x != nil {
		return x.RunId
	}
	return ""
}

type AgentResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Payload:
	//
	//	*AgentResponse_Status
	//	*AgentResponse_Logs
	//	*AgentResponse_Metrics
	Payload       isAgentResponse_Payload `protobuf_oneof:"payload"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AgentResponse) Reset() {
	*x = AgentResponse{}
	mi := &file_agent_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AgentResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AgentResponse) ProtoMessage() {}

func (x *AgentResponse) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AgentResponse.ProtoReflect.Descriptor instead.
func (*AgentResponse) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{3}
}

func (x *AgentResponse) GetPayload() isAgentResponse_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *AgentResponse) GetStatus() *StatusUpdate {
	if x != nil {
		if x, ok := x.Payload.(*AgentResponse_Status); ok {
			return x.Status
		}
	}
	return nil
}

func (x *AgentResponse) GetLogs() *LogEvents {
	if x != nil {
		if x, ok := x.Payload.(*AgentResponse_Logs); ok {
			return x.Logs
		}
	}
	return nil
}

func (x *AgentResponse) GetMetrics() *MetricsSnapshot {
	if x != nil {
		if x, ok := x.Payload.(*AgentResponse_Metrics); ok {
			return x.Metrics
		}
	}
	return nil
}

type isAgentResponse_Payload interface {
	isAgentResponse_Payload()
}

type AgentResponse_Status struct {
	Status *StatusUpdate `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type AgentResponse_Logs struct {
	Logs *LogEvents `protobuf:"bytes,2,opt,name=logs,proto3,oneof"`
}

type AgentResponse_Metrics struct {
	Metrics *MetricsSnapshot `protobuf:"bytes,3,opt,name=metrics,proto3,oneof"`
}

func (*AgentResponse_Status) isAgentResponse_Payload() {}

func (*AgentResponse_Logs) isAgentResponse_Payload() {}

func (*AgentResponse_Metrics) isAgentResponse_Payload() {}

type StatusUpdate struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	State         string                 `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`       // STARTING, RUNNING, STOPPING, STOPPED
	Status        string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`     // status for STOPPED state: SUCCESS, FAIL
	Message       string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`   // error message for FAIL status only
	Hostname      string                 `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"` // agent hostname for identification
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StatusUpdate) Reset() {
	*x = StatusUpdate{}
	mi := &file_agent_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StatusUpdate) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StatusUpdate) ProtoMessage() {}

func (x *StatusUpdate) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StatusUpdate.ProtoReflect.Descriptor instead.
func (*StatusUpdate) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{4}
}

func (x *StatusUpdate) GetState() string {
	if x != nil {
		return x.State
	}
	return ""
}

func (x *StatusUpdate) GetStatus() string {
	if x != nil {
		return x.Status
	}
	return ""
}

func (x *StatusUpdate) GetMessage() string {
	if x != nil {
		return x.Message
	}
	return ""
}

func (x *StatusUpdate) GetHostname() string {
	if x != nil {
		return x.Hostname
	}
	return ""
}

type LogEvents struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Logs          []*LogEvent            `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *LogEvents) Reset() {
	*x = LogEvents{}
	mi := &file_agent_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *LogEvents) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*LogEvents) ProtoMessage() {}

func (x *LogEvents) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use LogEvents.ProtoReflect.Descriptor instead.
func (*LogEvents) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{5}
}

func (x *LogEvents) GetLogs() []*LogEvent {
	if x != nil {
		return x.Logs
	}
	return nil
}

type MetricsSnapshot struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	Hostname        string                 `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	TimestampMs     int64                  `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	ActiveUsers     int64                  `protobuf:"varint,3,opt,name=active_users,json=activeUsers,proto3" json:"active_users,omitempty"`
	TotalIterations int64                  `protobuf:"varint,4,opt,name=total_iterations,json=totalIterations,proto3" json:"total_iterations,omitempty"`
	ErrorIterations int64                  `protobuf:"varint,5,opt,name=error_iterations,json=errorIterations,proto3" json:"error_iterations,omitempty"`
	CustomMetrics   []*CustomMetric        `protobuf:"bytes,6,rep,name=custom_metrics,json=customMetrics,proto3" json:"custom_metrics,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *MetricsSnapshot) Reset() {
	*x = MetricsSnapshot{}
	mi := &file_agent_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *MetricsSnapshot) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*MetricsSnapshot) ProtoMessage() {}

func (x *MetricsSnapshot) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use MetricsSnapshot.ProtoReflect.Descriptor instead.
func (*MetricsSnapshot) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{6}
}

func (x *MetricsSnapshot) GetHostname() string {
	if x != nil {
		return x.Hostname
	}
	return ""
}

func (x *MetricsSnapshot) GetTimestampMs() int64 {
	if x != nil {
		return x.TimestampMs
	}
	return 0
}

func (x *MetricsSnapshot) GetActiveUsers() int64 {
	if x != nil {
		return x.ActiveUsers
	}
	return 0
}

func (x *MetricsSnapshot) GetTotalIterations() int64 {
	if x != nil {
		return x.TotalIterations
	}
	return 0
}

func (x *MetricsSnapshot) GetErrorIterations() int64 {
	if x != nil {
		return x.ErrorIterations
	}
	return 0
}

func (x *MetricsSnapshot) GetCustomMetrics() []*CustomMetric {
	if x != nil {
		return x.CustomMetrics
	}
	return nil
}

type CustomMetric struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Name          string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type          string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // "counter" | "gauge" | "histogram"
	Value         *MetricValue           `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Tags          map[string]string      `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CustomMetric) Reset() {
	*x = CustomMetric{}
	mi := &file_agent_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CustomMetric) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CustomMetric) ProtoMessage() {}

func (x *CustomMetric) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CustomMetric.ProtoReflect.Descriptor instead.
func (*CustomMetric) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{7}
}

func (x *CustomMetric) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *CustomMetric) GetType() string {
	if x != nil {
		return x.Type
	}
	return ""
}

func (x *CustomMetric) GetValue() *MetricValue {
	if x != nil {
		return x.Value
	}
	return nil
}

func (x *CustomMetric) GetTags() map[string]string {
	if x != nil {
		return x.Tags
	}
	return nil
}

type MetricValue struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Value:
	//
	//	*MetricValue_Counter
	//	*MetricValue_Gauge
	//	*MetricValue_Histogram
	Value         isMetricValue_Value `protobuf_oneof:"value"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *MetricValue) Reset() {
	*x = MetricValue{}
	mi := &file_agent_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *MetricValue) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*MetricValue) ProtoMessage() {}

func (x *MetricValue) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.
func (*MetricValue) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{8}
}

func (x *MetricValue) GetValue() isMetricValue_Value {
	if x != nil {
		return x.Value
	}
	return nil
}

func (x *MetricValue) GetCounter() int64 {
	if x != nil {
		if x, ok := x.Value.(*MetricValue_Counter); ok {
			return x.Counter
		}
	}
	return 0
}

func (x *MetricValue) GetGauge() float64 {
	if x != nil {
		if x, ok := x.Value.(*MetricValue_Gauge); ok {
			return x.Gauge
		}
	}
	return 0
}

func (x *MetricValue) GetHistogram() *HistogramData {
	if x != nil {
		if x, ok := x.Value.(*MetricValue_Histogram); ok {
			return x.Histogram
		}
	}
	return nil
}

type isMetricValue_Value interface {
	isMetricValue_Value()
}

type MetricValue_Counter struct {
	Counter int64 `protobuf:"varint,1,opt,name=counter,proto3,oneof"`
}

type MetricValue_Gauge struct {
	Gauge float64 `protobuf:"fixed64,2,opt,name=gauge,proto3,oneof"`
}

type MetricValue_Histogram struct {
	Histogram *HistogramData `protobuf:"bytes,3,opt,name=histogram,proto3,oneof"`
}

func (*MetricValue_Counter) isMetricValue_Value() {}

func (*MetricValue_Gauge) isMetricValue_Value() {}

func (*MetricValue_Histogram) isMetricValue_Value() {}

type HistogramData struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Count         int64                  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Sum           float64                `protobuf:"fixed64,2,opt,name=sum,proto3" json:"sum,omitempty"`
	Min           float64                `protobuf:"fixed64,3,opt,name=min,proto3" json:"min,omitempty"`
	Max           float64                `protobuf:"fixed64,4,opt,name=max,proto3" json:"max,omitempty"`
	Values        []float64              `protobuf:"fixed64,5,rep,packed,name=values,proto3" json:"values,omitempty"`
	Quantiles     map[int32]float64      `protobuf:"bytes,6,rep,name=quantiles,proto3" json:"quantiles,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"fixed64,2,opt,name=value"` // e.g. key=90 means p90, value=123.45ms
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *HistogramData) Reset() {
	*x = HistogramData{}
	mi := &file_agent_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *HistogramData) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*HistogramData) ProtoMessage() {}

func (x *HistogramData) ProtoReflect() protoreflect.Message {
	mi := &file_agent_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use HistogramData.ProtoReflect.Descriptor instead.
func (*HistogramData) Descriptor() ([]byte, []int) {
	return file_agent_proto_rawDescGZIP(), []int{9}
}

func (x *HistogramData) GetCount() int64 {
	if x != nil {
		return x.Count
	}
	return 0
}

func (x *HistogramData) GetSum() float64 {
	if x != nil {
		return x.Sum
	}
	return 0
}

func (x *HistogramData) GetMin() float64 {
	if x != nil {
		return x.Min
	}
	return 0
}

func (x *HistogramData) GetMax() float64 {
	if x != nil {
		return x.Max
	}
	return 0
}

func (x *HistogramData) GetValues() []float64 {
	if x != nil {
		return x.Values
	}
	return nil
}

func (x *HistogramData) GetQuantiles() map[int32]float64 {
	if x != nil {
		return x.Quantiles
	}
	return nil
}

var File_agent_proto protoreflect.FileDescriptor

const file_agent_proto_rawDesc = "" +
	"\n" +
	"\vagent.proto\x12\x05agent\x1a\tlog.proto\"p\n" +
	"\fAgentRequest\x12+\n" +
	"\x05start\x18\x01 \x01(\v2\x13.agent.StartRequestH\x00R\x05start\x12(\n" +
	"\x04stop\x18\x02 \x01(\v2\x12.agent.StopRequestH\x00R\x04stopB\t\n" +
	"\apayload\"\x8b\x02\n" +
	"\fStartRequest\x12\x14\n" +
	"\x05token\x18\x01 \x01(\tR\x05token\x12\x14\n" +
	"\x05users\x18\x02 \x01(\x05R\x05users\x12\x1f\n" +
	"\vduration_ms\x18\x03 \x01(\x03R\n" +
	"durationMs\x12\x16\n" +
	"\x06script\x18\x04 \x01(\fR\x06script\x12\x14\n" +
	"\x05setup\x18\x05 \x01(\fR\x05setup\x12\x15\n" +
	"\x06run_id\x18\x06 \x01(\tR\x05runId\x12'\n" +
	"\rthink_time_ms\x18\a \x01(\x03H\x00R\vthinkTimeMs\x88\x01\x01\x12 \n" +
	"\tpacing_ms\x18\b \x01(\x03H\x01R\bpacingMs\x88\x01\x01B\x10\n" +
	"\x0e_think_time_msB\f\n" +
	"\n" +
	"_pacing_ms\"$\n" +
	"\vStopRequest\x12\x15\n" +
	"\x06run_id\x18\x01 \x01(\tR\x05runId\"\xa5\x01\n" +
	"\rAgentResponse\x12-\n" +
	"\x06status\x18\x01 \x01(\v2\x13.agent.StatusUpdateH\x00R\x06status\x12&\n" +
	"\x04logs\x18\x02 \x01(\v2\x10.agent.LogEventsH\x00R\x04logs\x122\n" +
	"\ametrics\x18\x03 \x01(\v2\x16.agent.MetricsSnapshotH\x00R\ametricsB\t\n" +
	"\apayload\"r\n" +
	"\fStatusUpdate\x12\x14\n" +
	"\x05state\x18\x01 \x01(\tR\x05state\x12\x16\n" +
	"\x06status\x18\x02 \x01(\tR\x06status\x12\x18\n" +
	"\amessage\x18\x03 \x01(\tR\amessage\x12\x1a\n" +
	"\bhostname\x18\x04 \x01(\tR\bhostname\"0\n" +
	"\tLogEvents\x12#\n" +
	"\x04logs\x18\x01 \x03(\v2\x0f.agent.LogEventR\x04logs\"\x85\x02\n" +
	"\x0fMetricsSnapshot\x12\x1a\n" +
	"\bhostname\x18\x01 \x01(\tR\bhostname\x12!\n" +
	"\ftimestamp_ms\x18\x02 \x01(\x03R\vtimestampMs\x12!\n" +
	"\factive_users\x18\x03 \x01(\x03R\vactiveUsers\x12)\n" +
	"\x10total_iterations\x18\x04 \x01(\x03R\x0ftotalIterations\x12)\n" +
	"\x10error_iterations\x18\x05 \x01(\x03R\x0ferrorIterations\x12:\n" +
	"\x0ecustom_metrics\x18\x06 \x03(\v2\x13.agent.CustomMetricR\rcustomMetrics\"\xcc\x01\n" +
	"\fCustomMetric\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n" +
	"\x04type\x18\x02 \x01(\tR\x04type\x12(\n" +
	"\x05value\x18\x03 \x01(\v2\x12.agent.MetricValueR\x05value\x121\n" +
	"\x04tags\x18\x04 \x03(\v2\x1d.agent.CustomMetric.TagsEntryR\x04tags\x1a7\n" +
	"\tTagsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"\x80\x01\n" +
	"\vMetricValue\x12\x1a\n" +
	"\acounter\x18\x01 \x01(\x03H\x00R\acounter\x12\x16\n" +
	"\x05gauge\x18\x02 \x01(\x01H\x00R\x05gauge\x124\n" +
	"\thistogram\x18\x03 \x01(\v2\x14.agent.HistogramDataH\x00R\thistogramB\a\n" +
	"\x05value\"\xf4\x01\n" +
	"\rHistogramData\x12\x14\n" +
	"\x05count\x18\x01 \x01(\x03R\x05count\x12\x10\n" +
	"\x03sum\x18\x02 \x01(\x01R\x03sum\x12\x10\n" +
	"\x03min\x18\x03 \x01(\x01R\x03min\x12\x10\n" +
	"\x03max\x18\x04 \x01(\x01R\x03max\x12\x16\n" +
	"\x06values\x18\x05 \x03(\x01R\x06values\x12A\n" +
	"\tquantiles\x18\x06 \x03(\v2#.agent.HistogramData.QuantilesEntryR\tquantiles\x1a<\n" +
	"\x0eQuantilesEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\x05R\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\x01R\x05value:\x028\x012G\n" +
	"\fAgentService\x127\n" +
	"\x06Stream\x12\x13.agent.AgentRequest\x1a\x14.agent.AgentResponse(\x010\x01B\x1bZ\x19gitverse.ru/t3/cli/pkg/pbb\x06proto3"

var (
	file_agent_proto_rawDescOnce sync.Once
	file_agent_proto_rawDescData []byte
)

func file_agent_proto_rawDescGZIP() []byte {
	file_agent_proto_rawDescOnce.Do(func() {
		file_agent_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_agent_proto_rawDesc), len(file_agent_proto_rawDesc)))
	})
	return file_agent_proto_rawDescData
}

var file_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 12)
var file_agent_proto_goTypes = []any{
	(*AgentRequest)(nil),    // 0: agent.AgentRequest
	(*StartRequest)(nil),    // 1: agent.StartRequest
	(*StopRequest)(nil),     // 2: agent.StopRequest
	(*AgentResponse)(nil),   // 3: agent.AgentResponse
	(*StatusUpdate)(nil),    // 4: agent.StatusUpdate
	(*LogEvents)(nil),       // 5: agent.LogEvents
	(*MetricsSnapshot)(nil), // 6: agent.MetricsSnapshot
	(*CustomMetric)(nil),    // 7: agent.CustomMetric
	(*MetricValue)(nil),     // 8: agent.MetricValue
	(*HistogramData)(nil),   // 9: agent.HistogramData
	nil,                     // 10: agent.CustomMetric.TagsEntry
	nil,                     // 11: agent.HistogramData.QuantilesEntry
	(*LogEvent)(nil),        // 12: agent.LogEvent
}
var file_agent_proto_depIdxs = []int32{
	1,  // 0: agent.AgentRequest.start:type_name -> agent.StartRequest
	2,  // 1: agent.AgentRequest.stop:type_name -> agent.StopRequest
	4,  // 2: agent.AgentResponse.status:type_name -> agent.StatusUpdate
	5,  // 3: agent.AgentResponse.logs:type_name -> agent.LogEvents
	6,  // 4: agent.AgentResponse.metrics:type_name -> agent.MetricsSnapshot
	12, // 5: agent.LogEvents.logs:type_name -> agent.LogEvent
	7,  // 6: agent.MetricsSnapshot.custom_metrics:type_name -> agent.CustomMetric
	8,  // 7: agent.CustomMetric.value:type_name -> agent.MetricValue
	10, // 8: agent.CustomMetric.tags:type_name -> agent.CustomMetric.TagsEntry
	9,  // 9: agent.MetricValue.histogram:type_name -> agent.HistogramData
	11, // 10: agent.HistogramData.quantiles:type_name -> agent.HistogramData.QuantilesEntry
	0,  // 11: agent.AgentService.Stream:input_type -> agent.AgentRequest
	3,  // 12: agent.AgentService.Stream:output_type -> agent.AgentResponse
	12, // [12:13] is the sub-list for method output_type
	11, // [11:12] is the sub-list for method input_type
	11, // [11:11] is the sub-list for extension type_name
	11, // [11:11] is the sub-list for extension extendee
	0,  // [0:11] is the sub-list for field type_name
}

func init() { file_agent_proto_init() }
func file_agent_proto_init() {
	if File_agent_proto != nil {
		return
	}
	file_log_proto_init()
	file_agent_proto_msgTypes[0].OneofWrappers = []any{
		(*AgentRequest_Start)(nil),
		(*AgentRequest_Stop)(nil),
	}
	file_agent_proto_msgTypes[1].OneofWrappers = []any{}
	file_agent_proto_msgTypes[3].OneofWrappers = []any{
		(*AgentResponse_Status)(nil),
		(*AgentResponse_Logs)(nil),
		(*AgentResponse_Metrics)(nil),
	}
	file_agent_proto_msgTypes[8].OneofWrappers = []any{
		(*MetricValue_Counter)(nil),
		(*MetricValue_Gauge)(nil),
		(*MetricValue_Histogram)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_proto_rawDesc), len(file_agent_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   12,
			NumExtensions: 0,
			NumServices:   1,
		},
		GoTypes:           file_agent_proto_goTypes,
		DependencyIndexes: file_agent_proto_depIdxs,
		MessageInfos:      file_agent_proto_msgTypes,
	}.Build()
	File_agent_proto = out.File
	file_agent_proto_goTypes = nil
	file_agent_proto_depIdxs = nil
}