s4wave_debugdb

package
v0.51.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 11, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCDebugDbBenchmarkServiceServiceID = "s4wave.debugdb.DebugDbBenchmarkService"
View Source 
const SRPCDebugDbResourceServiceServiceID = "s4wave.debugdb.DebugDbResourceService"

Variables

This section is empty.

Functions

func NewSRPCDebugDbBenchmarkServiceHandler 

func NewSRPCDebugDbBenchmarkServiceHandler(impl SRPCDebugDbBenchmarkServiceServer, serviceID string) srpc.Handler

NewSRPCDebugDbBenchmarkServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.debugdb.DebugDbBenchmarkService

func NewSRPCDebugDbResourceServiceHandler 

func NewSRPCDebugDbResourceServiceHandler(impl SRPCDebugDbResourceServiceServer, serviceID string) srpc.Handler

NewSRPCDebugDbResourceServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: s4wave.debugdb.DebugDbResourceService

func SRPCRegisterDebugDbBenchmarkService 

func SRPCRegisterDebugDbBenchmarkService(mux srpc.Mux, impl SRPCDebugDbBenchmarkServiceServer) error

SRPCRegisterDebugDbBenchmarkService registers the implementation with the mux. Uses the default serviceID: s4wave.debugdb.DebugDbBenchmarkService

func SRPCRegisterDebugDbResourceService 

func SRPCRegisterDebugDbResourceService(mux srpc.Mux, impl SRPCDebugDbResourceServiceServer) error

SRPCRegisterDebugDbResourceService registers the implementation with the mux. Uses the default serviceID: s4wave.debugdb.DebugDbResourceService

Types

type BenchmarkConfig 

type BenchmarkConfig struct {

	// DurationSeconds is the total benchmark duration target in seconds.
	// Each suite gets a proportional share. Defaults to 10.
	DurationSeconds uint32 `protobuf:"varint,1,opt,name=duration_seconds,json=durationSeconds,proto3" json:"durationSeconds,omitempty"`
	// BlockSizes is the list of block sizes to test in bytes.
	// Defaults to [256, 1024, 4096, 16384, 65536].
	BlockSizes []uint32 `protobuf:"varint,2,rep,packed,name=block_sizes,json=blockSizes,proto3" json:"blockSizes,omitempty"`
	// IncludeWorldSuite enables the world transaction benchmark suite.
	IncludeWorldSuite bool `protobuf:"varint,3,opt,name=include_world_suite,json=includeWorldSuite,proto3" json:"includeWorldSuite,omitempty"`
	// AsyncIo runs the benchmark against OPFS async file writes.
	AsyncIo bool `protobuf:"varint,4,opt,name=async_io,json=asyncIo,proto3" json:"asyncIo,omitempty"`
	// contains filtered or unexported fields
}

BenchmarkConfig configures a benchmark run.

func (*BenchmarkConfig) CloneMessageVT 

func (m *BenchmarkConfig) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BenchmarkConfig) CloneVT 

func (m *BenchmarkConfig) CloneVT() *BenchmarkConfig

func (*BenchmarkConfig) EqualMessageVT 

func (this *BenchmarkConfig) EqualMessageVT(thatMsg any) bool

func (*BenchmarkConfig) EqualVT 

func (this *BenchmarkConfig) EqualVT(that *BenchmarkConfig) bool

func (*BenchmarkConfig) GetAsyncIo 

func (x *BenchmarkConfig) GetAsyncIo() bool

func (*BenchmarkConfig) GetBlockSizes 

func (x *BenchmarkConfig) GetBlockSizes() []uint32

func (*BenchmarkConfig) GetDurationSeconds 

func (x *BenchmarkConfig) GetDurationSeconds() uint32

func (*BenchmarkConfig) GetIncludeWorldSuite 

func (x *BenchmarkConfig) GetIncludeWorldSuite() bool

func (*BenchmarkConfig) MarshalJSON 

func (x *BenchmarkConfig) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BenchmarkConfig to JSON.

func (*BenchmarkConfig) MarshalProtoJSON 

func (x *BenchmarkConfig) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BenchmarkConfig message to JSON.

func (*BenchmarkConfig) MarshalProtoText 

func (x *BenchmarkConfig) MarshalProtoText() string

func (*BenchmarkConfig) MarshalToSizedBufferVT 

func (m *BenchmarkConfig) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BenchmarkConfig) MarshalToVT 

func (m *BenchmarkConfig) MarshalToVT(dAtA []byte) (int, error)

func (*BenchmarkConfig) MarshalVT 

func (m *BenchmarkConfig) MarshalVT() (dAtA []byte, err error)

func (*BenchmarkConfig) ProtoMessage 

func (*BenchmarkConfig) ProtoMessage()

func (*BenchmarkConfig) Reset 

func (x *BenchmarkConfig) Reset()

func (*BenchmarkConfig) SizeVT 

func (m *BenchmarkConfig) SizeVT() (n int)

func (*BenchmarkConfig) String 

func (x *BenchmarkConfig) String() string

func (*BenchmarkConfig) UnmarshalJSON 

func (x *BenchmarkConfig) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BenchmarkConfig from JSON.

func (*BenchmarkConfig) UnmarshalProtoJSON 

func (x *BenchmarkConfig) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BenchmarkConfig message from JSON.

func (*BenchmarkConfig) UnmarshalVT 

func (m *BenchmarkConfig) UnmarshalVT(dAtA []byte) error

type BenchmarkMetric 

type BenchmarkMetric struct {

	// Name is the metric name (e.g. "put-4096b").
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Unit is the measurement unit (e.g. "ms", "ops/s").
	Unit string `protobuf:"bytes,2,opt,name=unit,proto3" json:"unit,omitempty"`
	// Count is the number of operations measured.
	Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// TotalMs is the total time in milliseconds.
	TotalMs float64 `protobuf:"fixed64,4,opt,name=total_ms,json=totalMs,proto3" json:"totalMs,omitempty"`
	// MinMs is the minimum operation time.
	MinMs float64 `protobuf:"fixed64,5,opt,name=min_ms,json=minMs,proto3" json:"minMs,omitempty"`
	// P50Ms is the 50th percentile operation time.
	P50Ms float64 `protobuf:"fixed64,6,opt,name=p50_ms,json=p50Ms,proto3" json:"p50Ms,omitempty"`
	// P99Ms is the 99th percentile operation time.
	P99Ms float64 `protobuf:"fixed64,7,opt,name=p99_ms,json=p99Ms,proto3" json:"p99Ms,omitempty"`
	// MaxMs is the maximum operation time.
	MaxMs float64 `protobuf:"fixed64,8,opt,name=max_ms,json=maxMs,proto3" json:"maxMs,omitempty"`
	// Samples contains raw timing samples when count < 1000.
	// Empty for high-count metrics to keep response compact.
	Samples []float64 `protobuf:"fixed64,9,rep,packed,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

BenchmarkMetric contains measurements for one metric.

func (*BenchmarkMetric) CloneMessageVT 

func (m *BenchmarkMetric) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BenchmarkMetric) CloneVT 

func (m *BenchmarkMetric) CloneVT() *BenchmarkMetric

func (*BenchmarkMetric) EqualMessageVT 

func (this *BenchmarkMetric) EqualMessageVT(thatMsg any) bool

func (*BenchmarkMetric) EqualVT 

func (this *BenchmarkMetric) EqualVT(that *BenchmarkMetric) bool

func (*BenchmarkMetric) GetCount 

func (x *BenchmarkMetric) GetCount() uint64

func (*BenchmarkMetric) GetMaxMs 

func (x *BenchmarkMetric) GetMaxMs() float64

func (*BenchmarkMetric) GetMinMs 

func (x *BenchmarkMetric) GetMinMs() float64

func (*BenchmarkMetric) GetName 

func (x *BenchmarkMetric) GetName() string

func (*BenchmarkMetric) GetP50Ms 

func (x *BenchmarkMetric) GetP50Ms() float64

func (*BenchmarkMetric) GetP99Ms 

func (x *BenchmarkMetric) GetP99Ms() float64

func (*BenchmarkMetric) GetSamples 

func (x *BenchmarkMetric) GetSamples() []float64

func (*BenchmarkMetric) GetTotalMs 

func (x *BenchmarkMetric) GetTotalMs() float64

func (*BenchmarkMetric) GetUnit 

func (x *BenchmarkMetric) GetUnit() string

func (*BenchmarkMetric) MarshalJSON 

func (x *BenchmarkMetric) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BenchmarkMetric to JSON.

func (*BenchmarkMetric) MarshalProtoJSON 

func (x *BenchmarkMetric) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BenchmarkMetric message to JSON.

func (*BenchmarkMetric) MarshalProtoText 

func (x *BenchmarkMetric) MarshalProtoText() string

func (*BenchmarkMetric) MarshalToSizedBufferVT 

func (m *BenchmarkMetric) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BenchmarkMetric) MarshalToVT 

func (m *BenchmarkMetric) MarshalToVT(dAtA []byte) (int, error)

func (*BenchmarkMetric) MarshalVT 

func (m *BenchmarkMetric) MarshalVT() (dAtA []byte, err error)

func (*BenchmarkMetric) ProtoMessage 

func (*BenchmarkMetric) ProtoMessage()

func (*BenchmarkMetric) Reset 

func (x *BenchmarkMetric) Reset()

func (*BenchmarkMetric) SizeVT 

func (m *BenchmarkMetric) SizeVT() (n int)

func (*BenchmarkMetric) String 

func (x *BenchmarkMetric) String() string

func (*BenchmarkMetric) UnmarshalJSON 

func (x *BenchmarkMetric) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BenchmarkMetric from JSON.

func (*BenchmarkMetric) UnmarshalProtoJSON 

func (x *BenchmarkMetric) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BenchmarkMetric message from JSON.

func (*BenchmarkMetric) UnmarshalVT 

func (m *BenchmarkMetric) UnmarshalVT(dAtA []byte) error

type BenchmarkResults 

type BenchmarkResults struct {

	// Info is the storage info at benchmark time.
	Info *StorageInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// Config is the benchmark config that was used.
	Config *BenchmarkConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Suites is the list of benchmark suite results.
	Suites []*BenchmarkSuite `protobuf:"bytes,3,rep,name=suites,proto3" json:"suites,omitempty"`
	// StartTimeUnixMillis is the benchmark start time.
	StartTimeUnixMillis uint64 `protobuf:"varint,4,opt,name=start_time_unix_millis,json=startTimeUnixMillis,proto3" json:"startTimeUnixMillis,omitempty"`
	// TotalDurationMillis is the total wall-clock duration.
	TotalDurationMillis uint64 `protobuf:"varint,5,opt,name=total_duration_millis,json=totalDurationMillis,proto3" json:"totalDurationMillis,omitempty"`
	// contains filtered or unexported fields
}

BenchmarkResults contains the complete results of a benchmark run.

func (*BenchmarkResults) CloneMessageVT 

func (m *BenchmarkResults) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BenchmarkResults) CloneVT 

func (m *BenchmarkResults) CloneVT() *BenchmarkResults

func (*BenchmarkResults) EqualMessageVT 

func (this *BenchmarkResults) EqualMessageVT(thatMsg any) bool

func (*BenchmarkResults) EqualVT 

func (this *BenchmarkResults) EqualVT(that *BenchmarkResults) bool

func (*BenchmarkResults) GetConfig 

func (x *BenchmarkResults) GetConfig() *BenchmarkConfig

func (*BenchmarkResults) GetInfo 

func (x *BenchmarkResults) GetInfo() *StorageInfo

func (*BenchmarkResults) GetStartTimeUnixMillis 

func (x *BenchmarkResults) GetStartTimeUnixMillis() uint64

func (*BenchmarkResults) GetSuites 

func (x *BenchmarkResults) GetSuites() []*BenchmarkSuite

func (*BenchmarkResults) GetTotalDurationMillis 

func (x *BenchmarkResults) GetTotalDurationMillis() uint64

func (*BenchmarkResults) MarshalJSON 

func (x *BenchmarkResults) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BenchmarkResults to JSON.

func (*BenchmarkResults) MarshalProtoJSON 

func (x *BenchmarkResults) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BenchmarkResults message to JSON.

func (*BenchmarkResults) MarshalProtoText 

func (x *BenchmarkResults) MarshalProtoText() string

func (*BenchmarkResults) MarshalToSizedBufferVT 

func (m *BenchmarkResults) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BenchmarkResults) MarshalToVT 

func (m *BenchmarkResults) MarshalToVT(dAtA []byte) (int, error)

func (*BenchmarkResults) MarshalVT 

func (m *BenchmarkResults) MarshalVT() (dAtA []byte, err error)

func (*BenchmarkResults) ProtoMessage 

func (*BenchmarkResults) ProtoMessage()

func (*BenchmarkResults) Reset 

func (x *BenchmarkResults) Reset()

func (*BenchmarkResults) SizeVT 

func (m *BenchmarkResults) SizeVT() (n int)

func (*BenchmarkResults) String 

func (x *BenchmarkResults) String() string

func (*BenchmarkResults) UnmarshalJSON 

func (x *BenchmarkResults) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BenchmarkResults from JSON.

func (*BenchmarkResults) UnmarshalProtoJSON 

func (x *BenchmarkResults) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BenchmarkResults message from JSON.

func (*BenchmarkResults) UnmarshalVT 

func (m *BenchmarkResults) UnmarshalVT(dAtA []byte) error

type BenchmarkSuite 

type BenchmarkSuite struct {

	// Name is the suite name (e.g. "blockshard-put-single").
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Metrics is the list of measured metrics.
	Metrics []*BenchmarkMetric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

BenchmarkSuite contains results for one benchmark suite.

func (*BenchmarkSuite) CloneMessageVT 

func (m *BenchmarkSuite) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BenchmarkSuite) CloneVT 

func (m *BenchmarkSuite) CloneVT() *BenchmarkSuite

func (*BenchmarkSuite) EqualMessageVT 

func (this *BenchmarkSuite) EqualMessageVT(thatMsg any) bool

func (*BenchmarkSuite) EqualVT 

func (this *BenchmarkSuite) EqualVT(that *BenchmarkSuite) bool

func (*BenchmarkSuite) GetMetrics 

func (x *BenchmarkSuite) GetMetrics() []*BenchmarkMetric

func (*BenchmarkSuite) GetName 

func (x *BenchmarkSuite) GetName() string

func (*BenchmarkSuite) MarshalJSON 

func (x *BenchmarkSuite) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BenchmarkSuite to JSON.

func (*BenchmarkSuite) MarshalProtoJSON 

func (x *BenchmarkSuite) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BenchmarkSuite message to JSON.

func (*BenchmarkSuite) MarshalProtoText 

func (x *BenchmarkSuite) MarshalProtoText() string

func (*BenchmarkSuite) MarshalToSizedBufferVT 

func (m *BenchmarkSuite) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BenchmarkSuite) MarshalToVT 

func (m *BenchmarkSuite) MarshalToVT(dAtA []byte) (int, error)

func (*BenchmarkSuite) MarshalVT 

func (m *BenchmarkSuite) MarshalVT() (dAtA []byte, err error)

func (*BenchmarkSuite) ProtoMessage 

func (*BenchmarkSuite) ProtoMessage()

func (*BenchmarkSuite) Reset 

func (x *BenchmarkSuite) Reset()

func (*BenchmarkSuite) SizeVT 

func (m *BenchmarkSuite) SizeVT() (n int)

func (*BenchmarkSuite) String 

func (x *BenchmarkSuite) String() string

func (*BenchmarkSuite) UnmarshalJSON 

func (x *BenchmarkSuite) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BenchmarkSuite from JSON.

func (*BenchmarkSuite) UnmarshalProtoJSON 

func (x *BenchmarkSuite) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BenchmarkSuite message from JSON.

func (*BenchmarkSuite) UnmarshalVT 

func (m *BenchmarkSuite) UnmarshalVT(dAtA []byte) error

type GetResultsRequest 

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

GetResultsRequest is the request type for GetResults.

func (*GetResultsRequest) CloneMessageVT 

func (m *GetResultsRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetResultsRequest) CloneVT 

func (m *GetResultsRequest) CloneVT() *GetResultsRequest

func (*GetResultsRequest) EqualMessageVT 

func (this *GetResultsRequest) EqualMessageVT(thatMsg any) bool

func (*GetResultsRequest) EqualVT 

func (this *GetResultsRequest) EqualVT(that *GetResultsRequest) bool

func (*GetResultsRequest) MarshalJSON 

func (x *GetResultsRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetResultsRequest to JSON.

func (*GetResultsRequest) MarshalProtoJSON 

func (x *GetResultsRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetResultsRequest message to JSON.

func (*GetResultsRequest) MarshalProtoText 

func (x *GetResultsRequest) MarshalProtoText() string

func (*GetResultsRequest) MarshalToSizedBufferVT 

func (m *GetResultsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResultsRequest) MarshalToVT 

func (m *GetResultsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetResultsRequest) MarshalVT 

func (m *GetResultsRequest) MarshalVT() (dAtA []byte, err error)

func (*GetResultsRequest) ProtoMessage 

func (*GetResultsRequest) ProtoMessage()

func (*GetResultsRequest) Reset 

func (x *GetResultsRequest) Reset()

func (*GetResultsRequest) SizeVT 

func (m *GetResultsRequest) SizeVT() (n int)

func (*GetResultsRequest) String 

func (x *GetResultsRequest) String() string

func (*GetResultsRequest) UnmarshalJSON 

func (x *GetResultsRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetResultsRequest from JSON.

func (*GetResultsRequest) UnmarshalProtoJSON 

func (x *GetResultsRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetResultsRequest message from JSON.

func (*GetResultsRequest) UnmarshalVT 

func (m *GetResultsRequest) UnmarshalVT(dAtA []byte) error

type GetResultsResponse 

type GetResultsResponse struct {

	// Results is the full benchmark results.
	Results *BenchmarkResults `protobuf:"bytes,1,opt,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

GetResultsResponse is the response type for GetResults.

func (*GetResultsResponse) CloneMessageVT 

func (m *GetResultsResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetResultsResponse) CloneVT 

func (m *GetResultsResponse) CloneVT() *GetResultsResponse

func (*GetResultsResponse) EqualMessageVT 

func (this *GetResultsResponse) EqualMessageVT(thatMsg any) bool

func (*GetResultsResponse) EqualVT 

func (this *GetResultsResponse) EqualVT(that *GetResultsResponse) bool

func (*GetResultsResponse) GetResults 

func (x *GetResultsResponse) GetResults() *BenchmarkResults

func (*GetResultsResponse) MarshalJSON 

func (x *GetResultsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetResultsResponse to JSON.

func (*GetResultsResponse) MarshalProtoJSON 

func (x *GetResultsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetResultsResponse message to JSON.

func (*GetResultsResponse) MarshalProtoText 

func (x *GetResultsResponse) MarshalProtoText() string

func (*GetResultsResponse) MarshalToSizedBufferVT 

func (m *GetResultsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResultsResponse) MarshalToVT 

func (m *GetResultsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetResultsResponse) MarshalVT 

func (m *GetResultsResponse) MarshalVT() (dAtA []byte, err error)

func (*GetResultsResponse) ProtoMessage 

func (*GetResultsResponse) ProtoMessage()

func (*GetResultsResponse) Reset 

func (x *GetResultsResponse) Reset()

func (*GetResultsResponse) SizeVT 

func (m *GetResultsResponse) SizeVT() (n int)

func (*GetResultsResponse) String 

func (x *GetResultsResponse) String() string

func (*GetResultsResponse) UnmarshalJSON 

func (x *GetResultsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetResultsResponse from JSON.

func (*GetResultsResponse) UnmarshalProtoJSON 

func (x *GetResultsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetResultsResponse message from JSON.

func (*GetResultsResponse) UnmarshalVT 

func (m *GetResultsResponse) UnmarshalVT(dAtA []byte) error

type GetStorageInfoRequest 

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

GetStorageInfoRequest is the request type for GetStorageInfo.

func (*GetStorageInfoRequest) CloneMessageVT 

func (m *GetStorageInfoRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetStorageInfoRequest) CloneVT 

func (m *GetStorageInfoRequest) CloneVT() *GetStorageInfoRequest

func (*GetStorageInfoRequest) EqualMessageVT 

func (this *GetStorageInfoRequest) EqualMessageVT(thatMsg any) bool

func (*GetStorageInfoRequest) EqualVT 

func (this *GetStorageInfoRequest) EqualVT(that *GetStorageInfoRequest) bool

func (*GetStorageInfoRequest) MarshalJSON 

func (x *GetStorageInfoRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetStorageInfoRequest to JSON.

func (*GetStorageInfoRequest) MarshalProtoJSON 

func (x *GetStorageInfoRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetStorageInfoRequest message to JSON.

func (*GetStorageInfoRequest) MarshalProtoText 

func (x *GetStorageInfoRequest) MarshalProtoText() string

func (*GetStorageInfoRequest) MarshalToSizedBufferVT 

func (m *GetStorageInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetStorageInfoRequest) MarshalToVT 

func (m *GetStorageInfoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetStorageInfoRequest) MarshalVT 

func (m *GetStorageInfoRequest) MarshalVT() (dAtA []byte, err error)

func (*GetStorageInfoRequest) ProtoMessage 

func (*GetStorageInfoRequest) ProtoMessage()

func (*GetStorageInfoRequest) Reset 

func (x *GetStorageInfoRequest) Reset()

func (*GetStorageInfoRequest) SizeVT 

func (m *GetStorageInfoRequest) SizeVT() (n int)

func (*GetStorageInfoRequest) String 

func (x *GetStorageInfoRequest) String() string

func (*GetStorageInfoRequest) UnmarshalJSON 

func (x *GetStorageInfoRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetStorageInfoRequest from JSON.

func (*GetStorageInfoRequest) UnmarshalProtoJSON 

func (x *GetStorageInfoRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetStorageInfoRequest message from JSON.

func (*GetStorageInfoRequest) UnmarshalVT 

func (m *GetStorageInfoRequest) UnmarshalVT(dAtA []byte) error

type GetStorageInfoResponse 

type GetStorageInfoResponse struct {

	// Info is the current storage information.
	Info *StorageInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

GetStorageInfoResponse is the response type for GetStorageInfo.

func (*GetStorageInfoResponse) CloneMessageVT 

func (m *GetStorageInfoResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetStorageInfoResponse) CloneVT 

func (m *GetStorageInfoResponse) CloneVT() *GetStorageInfoResponse

func (*GetStorageInfoResponse) EqualMessageVT 

func (this *GetStorageInfoResponse) EqualMessageVT(thatMsg any) bool

func (*GetStorageInfoResponse) EqualVT 

func (this *GetStorageInfoResponse) EqualVT(that *GetStorageInfoResponse) bool

func (*GetStorageInfoResponse) GetInfo 

func (x *GetStorageInfoResponse) GetInfo() *StorageInfo

func (*GetStorageInfoResponse) MarshalJSON 

func (x *GetStorageInfoResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetStorageInfoResponse to JSON.

func (*GetStorageInfoResponse) MarshalProtoJSON 

func (x *GetStorageInfoResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetStorageInfoResponse message to JSON.

func (*GetStorageInfoResponse) MarshalProtoText 

func (x *GetStorageInfoResponse) MarshalProtoText() string

func (*GetStorageInfoResponse) MarshalToSizedBufferVT 

func (m *GetStorageInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetStorageInfoResponse) MarshalToVT 

func (m *GetStorageInfoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetStorageInfoResponse) MarshalVT 

func (m *GetStorageInfoResponse) MarshalVT() (dAtA []byte, err error)

func (*GetStorageInfoResponse) ProtoMessage 

func (*GetStorageInfoResponse) ProtoMessage()

func (*GetStorageInfoResponse) Reset 

func (x *GetStorageInfoResponse) Reset()

func (*GetStorageInfoResponse) SizeVT 

func (m *GetStorageInfoResponse) SizeVT() (n int)

func (*GetStorageInfoResponse) String 

func (x *GetStorageInfoResponse) String() string

func (*GetStorageInfoResponse) UnmarshalJSON 

func (x *GetStorageInfoResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetStorageInfoResponse from JSON.

func (*GetStorageInfoResponse) UnmarshalProtoJSON 

func (x *GetStorageInfoResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetStorageInfoResponse message from JSON.

func (*GetStorageInfoResponse) UnmarshalVT 

func (m *GetStorageInfoResponse) UnmarshalVT(dAtA []byte) error

type SRPCDebugDbBenchmarkServiceClient 

type SRPCDebugDbBenchmarkServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	WatchProgress(ctx context.Context, in *WatchProgressRequest) (SRPCDebugDbBenchmarkService_WatchProgressClient, error)

	GetResults(ctx context.Context, in *GetResultsRequest) (*GetResultsResponse, error)
}

func NewSRPCDebugDbBenchmarkServiceClient 

func NewSRPCDebugDbBenchmarkServiceClient(cc srpc.Client) SRPCDebugDbBenchmarkServiceClient

func NewSRPCDebugDbBenchmarkServiceClientWithServiceID 

func NewSRPCDebugDbBenchmarkServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCDebugDbBenchmarkServiceClient

type SRPCDebugDbBenchmarkServiceHandler 

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

func (SRPCDebugDbBenchmarkServiceHandler) GetMethodIDs 

func (SRPCDebugDbBenchmarkServiceHandler) GetMethodIDs() []string

func (*SRPCDebugDbBenchmarkServiceHandler) GetServiceID 

func (d *SRPCDebugDbBenchmarkServiceHandler) GetServiceID() string

func (*SRPCDebugDbBenchmarkServiceHandler) InvokeMethod 

func (d *SRPCDebugDbBenchmarkServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCDebugDbBenchmarkServiceHandler) InvokeMethod_GetResults 

func (SRPCDebugDbBenchmarkServiceHandler) InvokeMethod_GetResults(impl SRPCDebugDbBenchmarkServiceServer, strm srpc.Stream) error

func (SRPCDebugDbBenchmarkServiceHandler) InvokeMethod_WatchProgress 

func (SRPCDebugDbBenchmarkServiceHandler) InvokeMethod_WatchProgress(impl SRPCDebugDbBenchmarkServiceServer, strm srpc.Stream) error

type SRPCDebugDbBenchmarkServiceServer 

type SRPCDebugDbBenchmarkServiceServer interface {
	WatchProgress(*WatchProgressRequest, SRPCDebugDbBenchmarkService_WatchProgressStream) error

	GetResults(context.Context, *GetResultsRequest) (*GetResultsResponse, error)
}

type SRPCDebugDbBenchmarkService_GetResultsStream 

type SRPCDebugDbBenchmarkService_GetResultsStream interface {
	srpc.Stream
}

type SRPCDebugDbBenchmarkService_WatchProgressClient 

type SRPCDebugDbBenchmarkService_WatchProgressClient interface {
	srpc.Stream
	Recv() (*WatchProgressResponse, error)
	RecvTo(*WatchProgressResponse) error
}

type SRPCDebugDbBenchmarkService_WatchProgressStream 

type SRPCDebugDbBenchmarkService_WatchProgressStream interface {
	srpc.Stream
	Send(*WatchProgressResponse) error
	SendAndClose(*WatchProgressResponse) error
}

type SRPCDebugDbResourceServiceClient 

type SRPCDebugDbResourceServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	GetStorageInfo(ctx context.Context, in *GetStorageInfoRequest) (*GetStorageInfoResponse, error)

	StartBenchmark(ctx context.Context, in *StartBenchmarkRequest) (*StartBenchmarkResponse, error)
}

func NewSRPCDebugDbResourceServiceClient 

func NewSRPCDebugDbResourceServiceClient(cc srpc.Client) SRPCDebugDbResourceServiceClient

func NewSRPCDebugDbResourceServiceClientWithServiceID 

func NewSRPCDebugDbResourceServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCDebugDbResourceServiceClient

type SRPCDebugDbResourceServiceHandler 

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

func (SRPCDebugDbResourceServiceHandler) GetMethodIDs 

func (SRPCDebugDbResourceServiceHandler) GetMethodIDs() []string

func (*SRPCDebugDbResourceServiceHandler) GetServiceID 

func (d *SRPCDebugDbResourceServiceHandler) GetServiceID() string

func (*SRPCDebugDbResourceServiceHandler) InvokeMethod 

func (d *SRPCDebugDbResourceServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCDebugDbResourceServiceHandler) InvokeMethod_GetStorageInfo 

func (SRPCDebugDbResourceServiceHandler) InvokeMethod_GetStorageInfo(impl SRPCDebugDbResourceServiceServer, strm srpc.Stream) error

func (SRPCDebugDbResourceServiceHandler) InvokeMethod_StartBenchmark 

func (SRPCDebugDbResourceServiceHandler) InvokeMethod_StartBenchmark(impl SRPCDebugDbResourceServiceServer, strm srpc.Stream) error

type SRPCDebugDbResourceServiceServer 

type SRPCDebugDbResourceServiceServer interface {
	GetStorageInfo(context.Context, *GetStorageInfoRequest) (*GetStorageInfoResponse, error)

	StartBenchmark(context.Context, *StartBenchmarkRequest) (*StartBenchmarkResponse, error)
}

type SRPCDebugDbResourceService_GetStorageInfoStream 

type SRPCDebugDbResourceService_GetStorageInfoStream interface {
	srpc.Stream
}

type SRPCDebugDbResourceService_StartBenchmarkStream 

type SRPCDebugDbResourceService_StartBenchmarkStream interface {
	srpc.Stream
}

type StartBenchmarkRequest 

type StartBenchmarkRequest struct {

	// Config is the benchmark configuration.
	Config *BenchmarkConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

StartBenchmarkRequest is the request type for StartBenchmark.

func (*StartBenchmarkRequest) CloneMessageVT 

func (m *StartBenchmarkRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StartBenchmarkRequest) CloneVT 

func (m *StartBenchmarkRequest) CloneVT() *StartBenchmarkRequest

func (*StartBenchmarkRequest) EqualMessageVT 

func (this *StartBenchmarkRequest) EqualMessageVT(thatMsg any) bool

func (*StartBenchmarkRequest) EqualVT 

func (this *StartBenchmarkRequest) EqualVT(that *StartBenchmarkRequest) bool

func (*StartBenchmarkRequest) GetConfig 

func (x *StartBenchmarkRequest) GetConfig() *BenchmarkConfig

func (*StartBenchmarkRequest) MarshalJSON 

func (x *StartBenchmarkRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StartBenchmarkRequest to JSON.

func (*StartBenchmarkRequest) MarshalProtoJSON 

func (x *StartBenchmarkRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StartBenchmarkRequest message to JSON.

func (*StartBenchmarkRequest) MarshalProtoText 

func (x *StartBenchmarkRequest) MarshalProtoText() string

func (*StartBenchmarkRequest) MarshalToSizedBufferVT 

func (m *StartBenchmarkRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartBenchmarkRequest) MarshalToVT 

func (m *StartBenchmarkRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartBenchmarkRequest) MarshalVT 

func (m *StartBenchmarkRequest) MarshalVT() (dAtA []byte, err error)

func (*StartBenchmarkRequest) ProtoMessage 

func (*StartBenchmarkRequest) ProtoMessage()

func (*StartBenchmarkRequest) Reset 

func (x *StartBenchmarkRequest) Reset()

func (*StartBenchmarkRequest) SizeVT 

func (m *StartBenchmarkRequest) SizeVT() (n int)

func (*StartBenchmarkRequest) String 

func (x *StartBenchmarkRequest) String() string

func (*StartBenchmarkRequest) UnmarshalJSON 

func (x *StartBenchmarkRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StartBenchmarkRequest from JSON.

func (*StartBenchmarkRequest) UnmarshalProtoJSON 

func (x *StartBenchmarkRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StartBenchmarkRequest message from JSON.

func (*StartBenchmarkRequest) UnmarshalVT 

func (m *StartBenchmarkRequest) UnmarshalVT(dAtA []byte) error

type StartBenchmarkResponse 

type StartBenchmarkResponse struct {

	// ResourceId is the ID of the benchmark resource.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// contains filtered or unexported fields
}

StartBenchmarkResponse is the response type for StartBenchmark.

func (*StartBenchmarkResponse) CloneMessageVT 

func (m *StartBenchmarkResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StartBenchmarkResponse) CloneVT 

func (m *StartBenchmarkResponse) CloneVT() *StartBenchmarkResponse

func (*StartBenchmarkResponse) EqualMessageVT 

func (this *StartBenchmarkResponse) EqualMessageVT(thatMsg any) bool

func (*StartBenchmarkResponse) EqualVT 

func (this *StartBenchmarkResponse) EqualVT(that *StartBenchmarkResponse) bool

func (*StartBenchmarkResponse) GetResourceId 

func (x *StartBenchmarkResponse) GetResourceId() uint32

func (*StartBenchmarkResponse) MarshalJSON 

func (x *StartBenchmarkResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StartBenchmarkResponse to JSON.

func (*StartBenchmarkResponse) MarshalProtoJSON 

func (x *StartBenchmarkResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StartBenchmarkResponse message to JSON.

func (*StartBenchmarkResponse) MarshalProtoText 

func (x *StartBenchmarkResponse) MarshalProtoText() string

func (*StartBenchmarkResponse) MarshalToSizedBufferVT 

func (m *StartBenchmarkResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartBenchmarkResponse) MarshalToVT 

func (m *StartBenchmarkResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartBenchmarkResponse) MarshalVT 

func (m *StartBenchmarkResponse) MarshalVT() (dAtA []byte, err error)

func (*StartBenchmarkResponse) ProtoMessage 

func (*StartBenchmarkResponse) ProtoMessage()

func (*StartBenchmarkResponse) Reset 

func (x *StartBenchmarkResponse) Reset()

func (*StartBenchmarkResponse) SizeVT 

func (m *StartBenchmarkResponse) SizeVT() (n int)

func (*StartBenchmarkResponse) String 

func (x *StartBenchmarkResponse) String() string

func (*StartBenchmarkResponse) UnmarshalJSON 

func (x *StartBenchmarkResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StartBenchmarkResponse from JSON.

func (*StartBenchmarkResponse) UnmarshalProtoJSON 

func (x *StartBenchmarkResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StartBenchmarkResponse message from JSON.

func (*StartBenchmarkResponse) UnmarshalVT 

func (m *StartBenchmarkResponse) UnmarshalVT(dAtA []byte) error

type StorageInfo 

type StorageInfo struct {

	// VolumeType is the volume implementation type (e.g. "hydra/volume/opfs").
	VolumeType string `protobuf:"bytes,1,opt,name=volume_type,json=volumeType,proto3" json:"volumeType,omitempty"`
	// BlockShardCount is the number of block shards.
	BlockShardCount uint32 `protobuf:"varint,2,opt,name=block_shard_count,json=blockShardCount,proto3" json:"blockShardCount,omitempty"`
	// BlockFlushThreshold is the per-shard flush entry threshold.
	BlockFlushThreshold uint32 `protobuf:"varint,3,opt,name=block_flush_threshold,json=blockFlushThreshold,proto3" json:"blockFlushThreshold,omitempty"`
	// BlockFlushMaxAgeMillis is the max coalescing age in milliseconds.
	BlockFlushMaxAgeMillis uint32 `` /* 130-byte string literal not displayed */
	// PageSize is the metadata page size in bytes.
	PageSize uint32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"pageSize,omitempty"`
	// AsyncIo is true if the async OPFS API is enabled.
	AsyncIo bool `protobuf:"varint,6,opt,name=async_io,json=asyncIo,proto3" json:"asyncIo,omitempty"`
	// Goos is the Go runtime GOOS value.
	Goos string `protobuf:"bytes,7,opt,name=goos,proto3" json:"goos,omitempty"`
	// Goarch is the Go runtime GOARCH value.
	Goarch string `protobuf:"bytes,8,opt,name=goarch,proto3" json:"goarch,omitempty"`
	// UserAgent is the browser user agent string.
	UserAgent string `protobuf:"bytes,9,opt,name=user_agent,json=userAgent,proto3" json:"userAgent,omitempty"`
	// contains filtered or unexported fields
}

StorageInfo describes the current storage backend configuration.

func (*StorageInfo) CloneMessageVT 

func (m *StorageInfo) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*StorageInfo) CloneVT 

func (m *StorageInfo) CloneVT() *StorageInfo

func (*StorageInfo) EqualMessageVT 

func (this *StorageInfo) EqualMessageVT(thatMsg any) bool

func (*StorageInfo) EqualVT 

func (this *StorageInfo) EqualVT(that *StorageInfo) bool

func (*StorageInfo) GetAsyncIo 

func (x *StorageInfo) GetAsyncIo() bool

func (*StorageInfo) GetBlockFlushMaxAgeMillis 

func (x *StorageInfo) GetBlockFlushMaxAgeMillis() uint32

func (*StorageInfo) GetBlockFlushThreshold 

func (x *StorageInfo) GetBlockFlushThreshold() uint32

func (*StorageInfo) GetBlockShardCount 

func (x *StorageInfo) GetBlockShardCount() uint32

func (*StorageInfo) GetGoarch 

func (x *StorageInfo) GetGoarch() string

func (*StorageInfo) GetGoos 

func (x *StorageInfo) GetGoos() string

func (*StorageInfo) GetPageSize 

func (x *StorageInfo) GetPageSize() uint32

func (*StorageInfo) GetUserAgent 

func (x *StorageInfo) GetUserAgent() string

func (*StorageInfo) GetVolumeType 

func (x *StorageInfo) GetVolumeType() string

func (*StorageInfo) MarshalJSON 

func (x *StorageInfo) MarshalJSON() ([]byte, error)

MarshalJSON marshals the StorageInfo to JSON.

func (*StorageInfo) MarshalProtoJSON 

func (x *StorageInfo) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the StorageInfo message to JSON.

func (*StorageInfo) MarshalProtoText 

func (x *StorageInfo) MarshalProtoText() string

func (*StorageInfo) MarshalToSizedBufferVT 

func (m *StorageInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StorageInfo) MarshalToVT 

func (m *StorageInfo) MarshalToVT(dAtA []byte) (int, error)

func (*StorageInfo) MarshalVT 

func (m *StorageInfo) MarshalVT() (dAtA []byte, err error)

func (*StorageInfo) ProtoMessage 

func (*StorageInfo) ProtoMessage()

func (*StorageInfo) Reset 

func (x *StorageInfo) Reset()

func (*StorageInfo) SizeVT 

func (m *StorageInfo) SizeVT() (n int)

func (*StorageInfo) String 

func (x *StorageInfo) String() string

func (*StorageInfo) UnmarshalJSON 

func (x *StorageInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the StorageInfo from JSON.

func (*StorageInfo) UnmarshalProtoJSON 

func (x *StorageInfo) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the StorageInfo message from JSON.

func (*StorageInfo) UnmarshalVT 

func (m *StorageInfo) UnmarshalVT(dAtA []byte) error

type WatchProgressRequest 

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

WatchProgressRequest is the request type for WatchProgress.

func (*WatchProgressRequest) CloneMessageVT 

func (m *WatchProgressRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WatchProgressRequest) CloneVT 

func (m *WatchProgressRequest) CloneVT() *WatchProgressRequest

func (*WatchProgressRequest) EqualMessageVT 

func (this *WatchProgressRequest) EqualMessageVT(thatMsg any) bool

func (*WatchProgressRequest) EqualVT 

func (this *WatchProgressRequest) EqualVT(that *WatchProgressRequest) bool

func (*WatchProgressRequest) MarshalJSON 

func (x *WatchProgressRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchProgressRequest to JSON.

func (*WatchProgressRequest) MarshalProtoJSON 

func (x *WatchProgressRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchProgressRequest message to JSON.

func (*WatchProgressRequest) MarshalProtoText 

func (x *WatchProgressRequest) MarshalProtoText() string

func (*WatchProgressRequest) MarshalToSizedBufferVT 

func (m *WatchProgressRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchProgressRequest) MarshalToVT 

func (m *WatchProgressRequest) MarshalToVT(dAtA []byte) (int, error)

func (*WatchProgressRequest) MarshalVT 

func (m *WatchProgressRequest) MarshalVT() (dAtA []byte, err error)

func (*WatchProgressRequest) ProtoMessage 

func (*WatchProgressRequest) ProtoMessage()

func (*WatchProgressRequest) Reset 

func (x *WatchProgressRequest) Reset()

func (*WatchProgressRequest) SizeVT 

func (m *WatchProgressRequest) SizeVT() (n int)

func (*WatchProgressRequest) String 

func (x *WatchProgressRequest) String() string

func (*WatchProgressRequest) UnmarshalJSON 

func (x *WatchProgressRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchProgressRequest from JSON.

func (*WatchProgressRequest) UnmarshalProtoJSON 

func (x *WatchProgressRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchProgressRequest message from JSON.

func (*WatchProgressRequest) UnmarshalVT 

func (m *WatchProgressRequest) UnmarshalVT(dAtA []byte) error

type WatchProgressResponse 

type WatchProgressResponse struct {

	// SuiteName is the name of the currently running suite.
	SuiteName string `protobuf:"bytes,1,opt,name=suite_name,json=suiteName,proto3" json:"suiteName,omitempty"`
	// SuiteIndex is the zero-based index of the current suite.
	SuiteIndex uint32 `protobuf:"varint,2,opt,name=suite_index,json=suiteIndex,proto3" json:"suiteIndex,omitempty"`
	// SuiteCount is the total number of suites.
	SuiteCount uint32 `protobuf:"varint,3,opt,name=suite_count,json=suiteCount,proto3" json:"suiteCount,omitempty"`
	// PercentComplete is the overall progress (0-100).
	PercentComplete uint32 `protobuf:"varint,4,opt,name=percent_complete,json=percentComplete,proto3" json:"percentComplete,omitempty"`
	// MetricName is the name of the current metric being measured.
	MetricName string `protobuf:"bytes,5,opt,name=metric_name,json=metricName,proto3" json:"metricName,omitempty"`
	// Done is true when the benchmark has completed.
	Done bool `protobuf:"varint,6,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

WatchProgressResponse is the response type for WatchProgress.

func (*WatchProgressResponse) CloneMessageVT 

func (m *WatchProgressResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*WatchProgressResponse) CloneVT 

func (m *WatchProgressResponse) CloneVT() *WatchProgressResponse

func (*WatchProgressResponse) EqualMessageVT 

func (this *WatchProgressResponse) EqualMessageVT(thatMsg any) bool

func (*WatchProgressResponse) EqualVT 

func (this *WatchProgressResponse) EqualVT(that *WatchProgressResponse) bool

func (*WatchProgressResponse) GetDone 

func (x *WatchProgressResponse) GetDone() bool

func (*WatchProgressResponse) GetMetricName 

func (x *WatchProgressResponse) GetMetricName() string

func (*WatchProgressResponse) GetPercentComplete 

func (x *WatchProgressResponse) GetPercentComplete() uint32

func (*WatchProgressResponse) GetSuiteCount 

func (x *WatchProgressResponse) GetSuiteCount() uint32

func (*WatchProgressResponse) GetSuiteIndex 

func (x *WatchProgressResponse) GetSuiteIndex() uint32

func (*WatchProgressResponse) GetSuiteName 

func (x *WatchProgressResponse) GetSuiteName() string

func (*WatchProgressResponse) MarshalJSON 

func (x *WatchProgressResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the WatchProgressResponse to JSON.

func (*WatchProgressResponse) MarshalProtoJSON 

func (x *WatchProgressResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the WatchProgressResponse message to JSON.

func (*WatchProgressResponse) MarshalProtoText 

func (x *WatchProgressResponse) MarshalProtoText() string

func (*WatchProgressResponse) MarshalToSizedBufferVT 

func (m *WatchProgressResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WatchProgressResponse) MarshalToVT 

func (m *WatchProgressResponse) MarshalToVT(dAtA []byte) (int, error)

func (*WatchProgressResponse) MarshalVT 

func (m *WatchProgressResponse) MarshalVT() (dAtA []byte, err error)

func (*WatchProgressResponse) ProtoMessage 

func (*WatchProgressResponse) ProtoMessage()

func (*WatchProgressResponse) Reset 

func (x *WatchProgressResponse) Reset()

func (*WatchProgressResponse) SizeVT 

func (m *WatchProgressResponse) SizeVT() (n int)

func (*WatchProgressResponse) String 

func (x *WatchProgressResponse) String() string

func (*WatchProgressResponse) UnmarshalJSON 

func (x *WatchProgressResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the WatchProgressResponse from JSON.

func (*WatchProgressResponse) UnmarshalProtoJSON 

func (x *WatchProgressResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the WatchProgressResponse message from JSON.

func (*WatchProgressResponse) UnmarshalVT 

func (m *WatchProgressResponse) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.