dashboardv1

type CapturedRequest struct {
	Headers   map[string]string      `` /* 180-byte string literal not displayed */
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=timestamp,proto3"                    json:"timestamp,omitempty"`
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3"                           json:"id,omitempty"`
	Method    string                 `protobuf:"bytes,2,opt,name=method,proto3"                       json:"method,omitempty"`
	Path      string                 `protobuf:"bytes,3,opt,name=path,proto3"                         json:"path,omitempty"`
	Body      string                 `protobuf:"bytes,5,opt,name=body,proto3"                         json:"body,omitempty"`

	DurationMs int64 `protobuf:"varint,7,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`

	Status int32 `protobuf:"varint,6,opt,name=status,proto3"                      json:"status,omitempty"`
	// contains filtered or unexported fields
}

type DashboardMetrics struct {
	Runtime *RuntimeMetrics `protobuf:"bytes,1,opt,name=runtime,proto3"    json:"runtime,omitempty"`

	Operations []*OperationSummary `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	Deadlocks  []*DeadlockInfo     `protobuf:"bytes,3,rep,name=deadlocks,proto3"  json:"deadlocks,omitempty"`
	Workers    []*WorkerStats      `protobuf:"bytes,4,rep,name=workers,proto3"    json:"workers,omitempty"`
	// contains filtered or unexported fields
}

type DeadlockInfo struct {
	Lock      string `protobuf:"bytes,1,opt,name=lock,proto3"                    json:"lock,omitempty"`
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3"               json:"operation,omitempty"`

	HeldSec float64 `protobuf:"fixed64,3,opt,name=held_sec,json=heldSec,proto3" json:"held_sec,omitempty"`

	Waiters int32 `protobuf:"varint,4,opt,name=waiters,proto3"                json:"waiters,omitempty"`
	// contains filtered or unexported fields
}

type OperationSummary struct {
	Operation string `protobuf:"bytes,1,opt,name=operation,proto3"                    json:"operation,omitempty"`

	Count      int64   `protobuf:"varint,2,opt,name=count,proto3"                       json:"count,omitempty"`
	ErrorCount int64   `protobuf:"varint,3,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	P50Ms      float64 `protobuf:"fixed64,4,opt,name=p50_ms,json=p50Ms,proto3"          json:"p50_ms,omitempty"`
	P95Ms      float64 `protobuf:"fixed64,5,opt,name=p95_ms,json=p95Ms,proto3"          json:"p95_ms,omitempty"`
	P99Ms      float64 `protobuf:"fixed64,6,opt,name=p99_ms,json=p99Ms,proto3"          json:"p99_ms,omitempty"`
	AvgMs      float64 `protobuf:"fixed64,7,opt,name=avg_ms,json=avgMs,proto3"          json:"avg_ms,omitempty"`
	MaxMs      float64 `protobuf:"fixed64,8,opt,name=max_ms,json=maxMs,proto3"          json:"max_ms,omitempty"`
	// contains filtered or unexported fields
}

type RuntimeMetrics struct {
	HeapAllocMb   float64 `protobuf:"fixed64,2,opt,name=heap_alloc_mb,json=heapAllocMb,proto3"      json:"heap_alloc_mb,omitempty"`
	HeapInuseMb   float64 `protobuf:"fixed64,3,opt,name=heap_inuse_mb,json=heapInuseMb,proto3"      json:"heap_inuse_mb,omitempty"`
	HeapSysMb     float64 `protobuf:"fixed64,4,opt,name=heap_sys_mb,json=heapSysMb,proto3"          json:"heap_sys_mb,omitempty"`
	LastGcPauseMs float64 `protobuf:"fixed64,6,opt,name=last_gc_pause_ms,json=lastGcPauseMs,proto3" json:"last_gc_pause_ms,omitempty"`
	TotalAllocMb  float64 `protobuf:"fixed64,7,opt,name=total_alloc_mb,json=totalAllocMb,proto3"    json:"total_alloc_mb,omitempty"`

	Goroutines  int32  `protobuf:"varint,1,opt,name=goroutines,proto3"                           json:"goroutines,omitempty"`
	NumGc       uint32 `protobuf:"varint,5,opt,name=num_gc,json=numGc,proto3"                    json:"num_gc,omitempty"`
	NumServices int32  `protobuf:"varint,8,opt,name=num_services,json=numServices,proto3"        json:"num_services,omitempty"`
	// contains filtered or unexported fields
}

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

type StreamConsoleResponse struct {
	Request *CapturedRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

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

type StreamMetricsResponse struct {
	Dashboard *DashboardMetrics `protobuf:"bytes,1,opt,name=dashboard,proto3" json:"dashboard,omitempty"`
	// contains filtered or unexported fields
}

type WorkerStats struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3"                                         json:"service,omitempty"`
	Worker  string `protobuf:"bytes,2,opt,name=worker,proto3"                                          json:"worker,omitempty"`

	TasksTotal          int64 `protobuf:"varint,4,opt,name=tasks_total,json=tasksTotal,proto3"                    json:"tasks_total,omitempty"`
	ErrorsTotal         int64 `protobuf:"varint,5,opt,name=errors_total,json=errorsTotal,proto3"                  json:"errors_total,omitempty"`
	ItemsProcessedTotal int64 `protobuf:"varint,6,opt,name=items_processed_total,json=itemsProcessedTotal,proto3" json:"items_processed_total,omitempty"`

	QueueDepth int32 `protobuf:"varint,3,opt,name=queue_depth,json=queueDepth,proto3"                    json:"queue_depth,omitempty"`
	// contains filtered or unexported fields
}