Versions in this module Expand all Collapse all v0 v0.49.0 Jul 31, 2026 Changes in this version + func WithServerURL(ctx context.Context, u *url.URL) context.Context + type ActionName string + const ActionNameFreeOsMemory + const ActionNameGc + const ActionNameStorageMaintain + func (ActionName) AllValues() []ActionName + func (s *ActionName) Decode(d *jx.Decoder) error + func (s *ActionName) UnmarshalJSON(data []byte) error + func (s *ActionName) UnmarshalText(data []byte) error + func (s ActionName) Encode(e *jx.Encoder) + func (s ActionName) MarshalJSON() ([]byte, error) + func (s ActionName) MarshalText() ([]byte, error) + func (s ActionName) Validate() error + type ActionResult struct + Action ActionName + FreedBytes OptInt64 + Message string + Ok bool + func (s *ActionResult) Decode(d *jx.Decoder) error + func (s *ActionResult) Encode(e *jx.Encoder) + func (s *ActionResult) GetAction() ActionName + func (s *ActionResult) GetFreedBytes() OptInt64 + func (s *ActionResult) GetMessage() string + func (s *ActionResult) GetOk() bool + func (s *ActionResult) MarshalJSON() ([]byte, error) + func (s *ActionResult) SetAction(val ActionName) + func (s *ActionResult) SetFreedBytes(val OptInt64) + func (s *ActionResult) SetMessage(val string) + func (s *ActionResult) SetOk(val bool) + func (s *ActionResult) UnmarshalJSON(data []byte) error + func (s *ActionResult) Validate() error + type AdmissionStats struct + Accepted int64 + Overflowed int64 + RejectedCardinality int64 + RejectedInFlight int64 + RejectedOoo int64 + RejectedRate int64 + SampledDropped int64 + func (s *AdmissionStats) Decode(d *jx.Decoder) error + func (s *AdmissionStats) Encode(e *jx.Encoder) + func (s *AdmissionStats) GetAccepted() int64 + func (s *AdmissionStats) GetOverflowed() int64 + func (s *AdmissionStats) GetRejectedCardinality() int64 + func (s *AdmissionStats) GetRejectedInFlight() int64 + func (s *AdmissionStats) GetRejectedOoo() int64 + func (s *AdmissionStats) GetRejectedRate() int64 + func (s *AdmissionStats) GetSampledDropped() int64 + func (s *AdmissionStats) MarshalJSON() ([]byte, error) + func (s *AdmissionStats) SetAccepted(val int64) + func (s *AdmissionStats) SetOverflowed(val int64) + func (s *AdmissionStats) SetRejectedCardinality(val int64) + func (s *AdmissionStats) SetRejectedInFlight(val int64) + func (s *AdmissionStats) SetRejectedOoo(val int64) + func (s *AdmissionStats) SetRejectedRate(val int64) + func (s *AdmissionStats) SetSampledDropped(val int64) + func (s *AdmissionStats) UnmarshalJSON(data []byte) error + type CacheStats struct + DecodeCache DecodeCacheStats + func (s *CacheStats) Decode(d *jx.Decoder) error + func (s *CacheStats) Encode(e *jx.Encoder) + func (s *CacheStats) GetDecodeCache() DecodeCacheStats + func (s *CacheStats) MarshalJSON() ([]byte, error) + func (s *CacheStats) SetDecodeCache(val DecodeCacheStats) + func (s *CacheStats) UnmarshalJSON(data []byte) error + type ClickHouseStats struct + Tables []TableStats + func (s *ClickHouseStats) Decode(d *jx.Decoder) error + func (s *ClickHouseStats) Encode(e *jx.Encoder) + func (s *ClickHouseStats) GetTables() []TableStats + func (s *ClickHouseStats) MarshalJSON() ([]byte, error) + func (s *ClickHouseStats) SetTables(val []TableStats) + func (s *ClickHouseStats) UnmarshalJSON(data []byte) error + func (s *ClickHouseStats) Validate() error + type Client struct + func NewClient(serverURL string, opts ...ClientOption) (*Client, error) + func (c *Client) GetEfficiency(ctx context.Context) (*EfficiencyStats, error) + func (c *Client) GetHealth(ctx context.Context) (*HealthReport, error) + func (c *Client) GetInfo(ctx context.Context) (*InstanceInfo, error) + func (c *Client) GetRuntime(ctx context.Context) (*RuntimeStats, error) + func (c *Client) GetStorage(ctx context.Context) (*StorageStats, error) + func (c *Client) RunAction(ctx context.Context, params RunActionParams) (*ActionResult, error) + type ClientOption interface + func WithClient(client ht.Client) ClientOption + type ClusterMember struct + Addr OptString + ID string + Zone OptString + func (s *ClusterMember) Decode(d *jx.Decoder) error + func (s *ClusterMember) Encode(e *jx.Encoder) + func (s *ClusterMember) GetAddr() OptString + func (s *ClusterMember) GetID() string + func (s *ClusterMember) GetZone() OptString + func (s *ClusterMember) MarshalJSON() ([]byte, error) + func (s *ClusterMember) SetAddr(val OptString) + func (s *ClusterMember) SetID(val string) + func (s *ClusterMember) SetZone(val OptString) + func (s *ClusterMember) UnmarshalJSON(data []byte) error + type ClusterStats struct + Ec OptECStats + Members []ClusterMember + Owned []string + PartSync OptPartSyncStats + Self string + func (s *ClusterStats) Decode(d *jx.Decoder) error + func (s *ClusterStats) Encode(e *jx.Encoder) + func (s *ClusterStats) GetEc() OptECStats + func (s *ClusterStats) GetMembers() []ClusterMember + func (s *ClusterStats) GetOwned() []string + func (s *ClusterStats) GetPartSync() OptPartSyncStats + func (s *ClusterStats) GetSelf() string + func (s *ClusterStats) MarshalJSON() ([]byte, error) + func (s *ClusterStats) SetEc(val OptECStats) + func (s *ClusterStats) SetMembers(val []ClusterMember) + func (s *ClusterStats) SetOwned(val []string) + func (s *ClusterStats) SetPartSync(val OptPartSyncStats) + func (s *ClusterStats) SetSelf(val string) + func (s *ClusterStats) UnmarshalJSON(data []byte) error + func (s *ClusterStats) Validate() error + type ComponentHealth struct + Addr OptString + Error OptString + Name string + Status HealthStatus + func (s *ComponentHealth) Decode(d *jx.Decoder) error + func (s *ComponentHealth) Encode(e *jx.Encoder) + func (s *ComponentHealth) GetAddr() OptString + func (s *ComponentHealth) GetError() OptString + func (s *ComponentHealth) GetName() string + func (s *ComponentHealth) GetStatus() HealthStatus + func (s *ComponentHealth) MarshalJSON() ([]byte, error) + func (s *ComponentHealth) SetAddr(val OptString) + func (s *ComponentHealth) SetError(val OptString) + func (s *ComponentHealth) SetName(val string) + func (s *ComponentHealth) SetStatus(val HealthStatus) + func (s *ComponentHealth) UnmarshalJSON(data []byte) error + func (s *ComponentHealth) Validate() error + type DecodeCacheStats struct + Bytes int64 + Hits int64 + Items int64 + Misses int64 + func (s *DecodeCacheStats) Decode(d *jx.Decoder) error + func (s *DecodeCacheStats) Encode(e *jx.Encoder) + func (s *DecodeCacheStats) GetBytes() int64 + func (s *DecodeCacheStats) GetHits() int64 + func (s *DecodeCacheStats) GetItems() int64 + func (s *DecodeCacheStats) GetMisses() int64 + func (s *DecodeCacheStats) MarshalJSON() ([]byte, error) + func (s *DecodeCacheStats) SetBytes(val int64) + func (s *DecodeCacheStats) SetHits(val int64) + func (s *DecodeCacheStats) SetItems(val int64) + func (s *DecodeCacheStats) SetMisses(val int64) + func (s *DecodeCacheStats) UnmarshalJSON(data []byte) error + type ECStats struct + ConvertErrors int64 + Converted int64 + PrunedStagedParts int64 + ReconstructErrors int64 + Reconstructs int64 + RepairErrors int64 + RepairedSlots int64 + func (s *ECStats) Decode(d *jx.Decoder) error + func (s *ECStats) Encode(e *jx.Encoder) + func (s *ECStats) GetConvertErrors() int64 + func (s *ECStats) GetConverted() int64 + func (s *ECStats) GetPrunedStagedParts() int64 + func (s *ECStats) GetReconstructErrors() int64 + func (s *ECStats) GetReconstructs() int64 + func (s *ECStats) GetRepairErrors() int64 + func (s *ECStats) GetRepairedSlots() int64 + func (s *ECStats) MarshalJSON() ([]byte, error) + func (s *ECStats) SetConvertErrors(val int64) + func (s *ECStats) SetConverted(val int64) + func (s *ECStats) SetPrunedStagedParts(val int64) + func (s *ECStats) SetReconstructErrors(val int64) + func (s *ECStats) SetReconstructs(val int64) + func (s *ECStats) SetRepairErrors(val int64) + func (s *ECStats) SetRepairedSlots(val int64) + func (s *ECStats) UnmarshalJSON(data []byte) error + type EfficiencyStats struct + StorageEnabled bool + Tenants []TenantEfficiency + func (s *EfficiencyStats) Decode(d *jx.Decoder) error + func (s *EfficiencyStats) Encode(e *jx.Encoder) + func (s *EfficiencyStats) GetStorageEnabled() bool + func (s *EfficiencyStats) GetTenants() []TenantEfficiency + func (s *EfficiencyStats) MarshalJSON() ([]byte, error) + func (s *EfficiencyStats) SetStorageEnabled(val bool) + func (s *EfficiencyStats) SetTenants(val []TenantEfficiency) + func (s *EfficiencyStats) UnmarshalJSON(data []byte) error + func (s *EfficiencyStats) Validate() error + type EngineSignalStats struct + HeadBytes int64 + HeadItems int64 + MaxTime OptDateTime + MergeBacklog int64 + MergeRunning bool + MinTime OptDateTime + Parts int64 + Series int64 + Signal Signal + Wal bool + WalBytes int64 + WalSegments int64 + func (s *EngineSignalStats) Decode(d *jx.Decoder) error + func (s *EngineSignalStats) Encode(e *jx.Encoder) + func (s *EngineSignalStats) GetHeadBytes() int64 + func (s *EngineSignalStats) GetHeadItems() int64 + func (s *EngineSignalStats) GetMaxTime() OptDateTime + func (s *EngineSignalStats) GetMergeBacklog() int64 + func (s *EngineSignalStats) GetMergeRunning() bool + func (s *EngineSignalStats) GetMinTime() OptDateTime + func (s *EngineSignalStats) GetParts() int64 + func (s *EngineSignalStats) GetSeries() int64 + func (s *EngineSignalStats) GetSignal() Signal + func (s *EngineSignalStats) GetWal() bool + func (s *EngineSignalStats) GetWalBytes() int64 + func (s *EngineSignalStats) GetWalSegments() int64 + func (s *EngineSignalStats) MarshalJSON() ([]byte, error) + func (s *EngineSignalStats) SetHeadBytes(val int64) + func (s *EngineSignalStats) SetHeadItems(val int64) + func (s *EngineSignalStats) SetMaxTime(val OptDateTime) + func (s *EngineSignalStats) SetMergeBacklog(val int64) + func (s *EngineSignalStats) SetMergeRunning(val bool) + func (s *EngineSignalStats) SetMinTime(val OptDateTime) + func (s *EngineSignalStats) SetParts(val int64) + func (s *EngineSignalStats) SetSeries(val int64) + func (s *EngineSignalStats) SetSignal(val Signal) + func (s *EngineSignalStats) SetWal(val bool) + func (s *EngineSignalStats) SetWalBytes(val int64) + func (s *EngineSignalStats) SetWalSegments(val int64) + func (s *EngineSignalStats) UnmarshalJSON(data []byte) error + func (s *EngineSignalStats) Validate() error + type EngineStats struct + Caches CacheStats + Cluster OptClusterStats + Maintenance MaintenanceStats + Tenants []TenantStats + func (s *EngineStats) Decode(d *jx.Decoder) error + func (s *EngineStats) Encode(e *jx.Encoder) + func (s *EngineStats) GetCaches() CacheStats + func (s *EngineStats) GetCluster() OptClusterStats + func (s *EngineStats) GetMaintenance() MaintenanceStats + func (s *EngineStats) GetTenants() []TenantStats + func (s *EngineStats) MarshalJSON() ([]byte, error) + func (s *EngineStats) SetCaches(val CacheStats) + func (s *EngineStats) SetCluster(val OptClusterStats) + func (s *EngineStats) SetMaintenance(val MaintenanceStats) + func (s *EngineStats) SetTenants(val []TenantStats) + func (s *EngineStats) UnmarshalJSON(data []byte) error + func (s *EngineStats) Validate() error + type Error struct + ErrorMessage string + SpanID OptSpanID + TraceID OptTraceID + func (s *Error) Decode(d *jx.Decoder) error + func (s *Error) Encode(e *jx.Encoder) + func (s *Error) GetErrorMessage() string + func (s *Error) GetSpanID() OptSpanID + func (s *Error) GetTraceID() OptTraceID + func (s *Error) MarshalJSON() ([]byte, error) + func (s *Error) SetErrorMessage(val string) + func (s *Error) SetSpanID(val OptSpanID) + func (s *Error) SetTraceID(val OptTraceID) + func (s *Error) UnmarshalJSON(data []byte) error + func (s *Error) Validate() error + type ErrorHandler = ogenerrors.ErrorHandler + type ErrorStatusCode struct + Response Error + StatusCode int + func (s *ErrorStatusCode) Error() string + func (s *ErrorStatusCode) GetResponse() Error + func (s *ErrorStatusCode) GetStatusCode() int + func (s *ErrorStatusCode) SetResponse(val Error) + func (s *ErrorStatusCode) SetStatusCode(val int) + func (s *ErrorStatusCode) Validate() error + type Handler interface + GetEfficiency func(ctx context.Context) (*EfficiencyStats, error) + GetHealth func(ctx context.Context) (*HealthReport, error) + GetInfo func(ctx context.Context) (*InstanceInfo, error) + GetRuntime func(ctx context.Context) (*RuntimeStats, error) + GetStorage func(ctx context.Context) (*StorageStats, error) + NewError func(ctx context.Context, err error) *ErrorStatusCode + RunAction func(ctx context.Context, params RunActionParams) (*ActionResult, error) + type HealthReport struct + Components []ComponentHealth + Status HealthStatus + func (s *HealthReport) Decode(d *jx.Decoder) error + func (s *HealthReport) Encode(e *jx.Encoder) + func (s *HealthReport) GetComponents() []ComponentHealth + func (s *HealthReport) GetStatus() HealthStatus + func (s *HealthReport) MarshalJSON() ([]byte, error) + func (s *HealthReport) SetComponents(val []ComponentHealth) + func (s *HealthReport) SetStatus(val HealthStatus) + func (s *HealthReport) UnmarshalJSON(data []byte) error + func (s *HealthReport) Validate() error + type HealthStatus string + const HealthStatusDegraded + const HealthStatusHealthy + const HealthStatusUnhealthy + func (HealthStatus) AllValues() []HealthStatus + func (s *HealthStatus) Decode(d *jx.Decoder) error + func (s *HealthStatus) UnmarshalJSON(data []byte) error + func (s *HealthStatus) UnmarshalText(data []byte) error + func (s HealthStatus) Encode(e *jx.Encoder) + func (s HealthStatus) MarshalJSON() ([]byte, error) + func (s HealthStatus) MarshalText() ([]byte, error) + func (s HealthStatus) Validate() error + type InstanceInfo struct + Arch string + ClickhouseEnabled bool + Commit string + GoVersion string + Os string + Signals []SignalInfo + StartTime time.Time + StorageBackend OptString + StorageEnabled bool + UptimeSeconds float64 + Version string + func (s *InstanceInfo) Decode(d *jx.Decoder) error + func (s *InstanceInfo) Encode(e *jx.Encoder) + func (s *InstanceInfo) GetArch() string + func (s *InstanceInfo) GetClickhouseEnabled() bool + func (s *InstanceInfo) GetCommit() string + func (s *InstanceInfo) GetGoVersion() string + func (s *InstanceInfo) GetOs() string + func (s *InstanceInfo) GetSignals() []SignalInfo + func (s *InstanceInfo) GetStartTime() time.Time + func (s *InstanceInfo) GetStorageBackend() OptString + func (s *InstanceInfo) GetStorageEnabled() bool + func (s *InstanceInfo) GetUptimeSeconds() float64 + func (s *InstanceInfo) GetVersion() string + func (s *InstanceInfo) MarshalJSON() ([]byte, error) + func (s *InstanceInfo) SetArch(val string) + func (s *InstanceInfo) SetClickhouseEnabled(val bool) + func (s *InstanceInfo) SetCommit(val string) + func (s *InstanceInfo) SetGoVersion(val string) + func (s *InstanceInfo) SetOs(val string) + func (s *InstanceInfo) SetSignals(val []SignalInfo) + func (s *InstanceInfo) SetStartTime(val time.Time) + func (s *InstanceInfo) SetStorageBackend(val OptString) + func (s *InstanceInfo) SetStorageEnabled(val bool) + func (s *InstanceInfo) SetUptimeSeconds(val float64) + func (s *InstanceInfo) SetVersion(val string) + func (s *InstanceInfo) UnmarshalJSON(data []byte) error + func (s *InstanceInfo) Validate() error + type Invoker interface + GetEfficiency func(ctx context.Context) (*EfficiencyStats, error) + GetHealth func(ctx context.Context) (*HealthReport, error) + GetInfo func(ctx context.Context) (*InstanceInfo, error) + GetRuntime func(ctx context.Context) (*RuntimeStats, error) + GetStorage func(ctx context.Context) (*StorageStats, error) + RunAction func(ctx context.Context, params RunActionParams) (*ActionResult, error) + type Labeler struct + func LabelerFromContext(ctx context.Context) (*Labeler, bool) + func (l *Labeler) Add(attrs ...attribute.KeyValue) + func (l *Labeler) AttributeSet() attribute.Set + type MaintenanceStats struct + Cycles int64 + LastCycleDurationSeconds float64 + LastCycleStart OptDateTime + LastCycleTasks int64 + func (s *MaintenanceStats) Decode(d *jx.Decoder) error + func (s *MaintenanceStats) Encode(e *jx.Encoder) + func (s *MaintenanceStats) GetCycles() int64 + func (s *MaintenanceStats) GetLastCycleDurationSeconds() float64 + func (s *MaintenanceStats) GetLastCycleStart() OptDateTime + func (s *MaintenanceStats) GetLastCycleTasks() int64 + func (s *MaintenanceStats) MarshalJSON() ([]byte, error) + func (s *MaintenanceStats) SetCycles(val int64) + func (s *MaintenanceStats) SetLastCycleDurationSeconds(val float64) + func (s *MaintenanceStats) SetLastCycleStart(val OptDateTime) + func (s *MaintenanceStats) SetLastCycleTasks(val int64) + func (s *MaintenanceStats) UnmarshalJSON(data []byte) error + func (s *MaintenanceStats) Validate() error + type Middleware = middleware.Middleware + type OperationName = string + const GetEfficiencyOperation + const GetHealthOperation + const GetInfoOperation + const GetRuntimeOperation + const GetStorageOperation + const RunActionOperation + type OptClickHouseStats struct + Set bool + Value ClickHouseStats + func NewOptClickHouseStats(v ClickHouseStats) OptClickHouseStats + func (o *OptClickHouseStats) Decode(d *jx.Decoder) error + func (o *OptClickHouseStats) Reset() + func (o *OptClickHouseStats) SetTo(v ClickHouseStats) + func (o OptClickHouseStats) Encode(e *jx.Encoder) + func (o OptClickHouseStats) Get() (v ClickHouseStats, ok bool) + func (o OptClickHouseStats) IsSet() bool + func (o OptClickHouseStats) Or(d ClickHouseStats) ClickHouseStats + func (s *OptClickHouseStats) UnmarshalJSON(data []byte) error + func (s OptClickHouseStats) MarshalJSON() ([]byte, error) + type OptClusterStats struct + Set bool + Value ClusterStats + func NewOptClusterStats(v ClusterStats) OptClusterStats + func (o *OptClusterStats) Decode(d *jx.Decoder) error + func (o *OptClusterStats) Reset() + func (o *OptClusterStats) SetTo(v ClusterStats) + func (o OptClusterStats) Encode(e *jx.Encoder) + func (o OptClusterStats) Get() (v ClusterStats, ok bool) + func (o OptClusterStats) IsSet() bool + func (o OptClusterStats) Or(d ClusterStats) ClusterStats + func (s *OptClusterStats) UnmarshalJSON(data []byte) error + func (s OptClusterStats) MarshalJSON() ([]byte, error) + type OptDateTime struct + Set bool + Value time.Time + func NewOptDateTime(v time.Time) OptDateTime + func (o *OptDateTime) Decode(d *jx.Decoder, format func(*jx.Decoder) (time.Time, error)) error + func (o *OptDateTime) Reset() + func (o *OptDateTime) SetTo(v time.Time) + func (o OptDateTime) Encode(e *jx.Encoder, format func(*jx.Encoder, time.Time)) + func (o OptDateTime) Get() (v time.Time, ok bool) + func (o OptDateTime) IsSet() bool + func (o OptDateTime) Or(d time.Time) time.Time + func (s *OptDateTime) UnmarshalJSON(data []byte) error + func (s OptDateTime) MarshalJSON() ([]byte, error) + type OptECStats struct + Set bool + Value ECStats + func NewOptECStats(v ECStats) OptECStats + func (o *OptECStats) Decode(d *jx.Decoder) error + func (o *OptECStats) Reset() + func (o *OptECStats) SetTo(v ECStats) + func (o OptECStats) Encode(e *jx.Encoder) + func (o OptECStats) Get() (v ECStats, ok bool) + func (o OptECStats) IsSet() bool + func (o OptECStats) Or(d ECStats) ECStats + func (s *OptECStats) UnmarshalJSON(data []byte) error + func (s OptECStats) MarshalJSON() ([]byte, error) + type OptEngineStats struct + Set bool + Value EngineStats + func NewOptEngineStats(v EngineStats) OptEngineStats + func (o *OptEngineStats) Decode(d *jx.Decoder) error + func (o *OptEngineStats) Reset() + func (o *OptEngineStats) SetTo(v EngineStats) + func (o OptEngineStats) Encode(e *jx.Encoder) + func (o OptEngineStats) Get() (v EngineStats, ok bool) + func (o OptEngineStats) IsSet() bool + func (o OptEngineStats) Or(d EngineStats) EngineStats + func (s *OptEngineStats) UnmarshalJSON(data []byte) error + func (s OptEngineStats) MarshalJSON() ([]byte, error) + type OptFloat64 struct + Set bool + Value float64 + func NewOptFloat64(v float64) OptFloat64 + func (o *OptFloat64) Decode(d *jx.Decoder) error + func (o *OptFloat64) Reset() + func (o *OptFloat64) SetTo(v float64) + func (o OptFloat64) Encode(e *jx.Encoder) + func (o OptFloat64) Get() (v float64, ok bool) + func (o OptFloat64) IsSet() bool + func (o OptFloat64) Or(d float64) float64 + func (s *OptFloat64) UnmarshalJSON(data []byte) error + func (s OptFloat64) MarshalJSON() ([]byte, error) + type OptInt64 struct + Set bool + Value int64 + func NewOptInt64(v int64) OptInt64 + func (o *OptInt64) Decode(d *jx.Decoder) error + func (o *OptInt64) Reset() + func (o *OptInt64) SetTo(v int64) + func (o OptInt64) Encode(e *jx.Encoder) + func (o OptInt64) Get() (v int64, ok bool) + func (o OptInt64) IsSet() bool + func (o OptInt64) Or(d int64) int64 + func (s *OptInt64) UnmarshalJSON(data []byte) error + func (s OptInt64) MarshalJSON() ([]byte, error) + type OptPartSyncStats struct + Set bool + Value PartSyncStats + func NewOptPartSyncStats(v PartSyncStats) OptPartSyncStats + func (o *OptPartSyncStats) Decode(d *jx.Decoder) error + func (o *OptPartSyncStats) Reset() + func (o *OptPartSyncStats) SetTo(v PartSyncStats) + func (o OptPartSyncStats) Encode(e *jx.Encoder) + func (o OptPartSyncStats) Get() (v PartSyncStats, ok bool) + func (o OptPartSyncStats) IsSet() bool + func (o OptPartSyncStats) Or(d PartSyncStats) PartSyncStats + func (s *OptPartSyncStats) UnmarshalJSON(data []byte) error + func (s OptPartSyncStats) MarshalJSON() ([]byte, error) + type OptSpanID struct + Set bool + Value SpanID + func NewOptSpanID(v SpanID) OptSpanID + func (o *OptSpanID) Decode(d *jx.Decoder) error + func (o *OptSpanID) Reset() + func (o *OptSpanID) SetTo(v SpanID) + func (o OptSpanID) Encode(e *jx.Encoder) + func (o OptSpanID) Get() (v SpanID, ok bool) + func (o OptSpanID) IsSet() bool + func (o OptSpanID) Or(d SpanID) SpanID + func (s *OptSpanID) UnmarshalJSON(data []byte) error + func (s OptSpanID) MarshalJSON() ([]byte, error) + type OptString struct + Set bool + Value string + func NewOptString(v string) OptString + func (o *OptString) Decode(d *jx.Decoder) error + func (o *OptString) Reset() + func (o *OptString) SetTo(v string) + func (o OptString) Encode(e *jx.Encoder) + func (o OptString) Get() (v string, ok bool) + func (o OptString) IsSet() bool + func (o OptString) Or(d string) string + func (s *OptString) UnmarshalJSON(data []byte) error + func (s OptString) MarshalJSON() ([]byte, error) + type OptTraceID struct + Set bool + Value TraceID + func NewOptTraceID(v TraceID) OptTraceID + func (o *OptTraceID) Decode(d *jx.Decoder) error + func (o *OptTraceID) Reset() + func (o *OptTraceID) SetTo(v TraceID) + func (o OptTraceID) Encode(e *jx.Encoder) + func (o OptTraceID) Get() (v TraceID, ok bool) + func (o OptTraceID) IsSet() bool + func (o OptTraceID) Or(d TraceID) TraceID + func (s *OptTraceID) UnmarshalJSON(data []byte) error + func (s OptTraceID) MarshalJSON() ([]byte, error) + type Option interface + func WithAttributes(attributes ...attribute.KeyValue) Option + func WithMeterProvider(provider metric.MeterProvider) Option + func WithTracerProvider(provider trace.TracerProvider) Option + type PartSyncStats struct + Copied int64 + CopiedBytes int64 + Errors int64 + LastSync OptDateTime + Mirrored int64 + Passes int64 + Pruned int64 + func (s *PartSyncStats) Decode(d *jx.Decoder) error + func (s *PartSyncStats) Encode(e *jx.Encoder) + func (s *PartSyncStats) GetCopied() int64 + func (s *PartSyncStats) GetCopiedBytes() int64 + func (s *PartSyncStats) GetErrors() int64 + func (s *PartSyncStats) GetLastSync() OptDateTime + func (s *PartSyncStats) GetMirrored() int64 + func (s *PartSyncStats) GetPasses() int64 + func (s *PartSyncStats) GetPruned() int64 + func (s *PartSyncStats) MarshalJSON() ([]byte, error) + func (s *PartSyncStats) SetCopied(val int64) + func (s *PartSyncStats) SetCopiedBytes(val int64) + func (s *PartSyncStats) SetErrors(val int64) + func (s *PartSyncStats) SetLastSync(val OptDateTime) + func (s *PartSyncStats) SetMirrored(val int64) + func (s *PartSyncStats) SetPasses(val int64) + func (s *PartSyncStats) SetPruned(val int64) + func (s *PartSyncStats) UnmarshalJSON(data []byte) error + type Route struct + func (r Route) Args() []string + func (r Route) Name() string + func (r Route) OperationGroup() string + func (r Route) OperationID() string + func (r Route) PathPattern() string + func (r Route) Summary() string + type RunActionParams struct + Action ActionName + type RuntimeStats struct + GcCount int64 + Gomaxprocs int + Goroutines int64 + HeapAllocBytes int64 + HeapInuseBytes int64 + HeapSysBytes int64 + MemLimitBytes OptInt64 + NextGcBytes int64 + NumCPU int + StackInuseBytes int64 + func (s *RuntimeStats) Decode(d *jx.Decoder) error + func (s *RuntimeStats) Encode(e *jx.Encoder) + func (s *RuntimeStats) GetGcCount() int64 + func (s *RuntimeStats) GetGomaxprocs() int + func (s *RuntimeStats) GetGoroutines() int64 + func (s *RuntimeStats) GetHeapAllocBytes() int64 + func (s *RuntimeStats) GetHeapInuseBytes() int64 + func (s *RuntimeStats) GetHeapSysBytes() int64 + func (s *RuntimeStats) GetMemLimitBytes() OptInt64 + func (s *RuntimeStats) GetNextGcBytes() int64 + func (s *RuntimeStats) GetNumCPU() int + func (s *RuntimeStats) GetStackInuseBytes() int64 + func (s *RuntimeStats) MarshalJSON() ([]byte, error) + func (s *RuntimeStats) SetGcCount(val int64) + func (s *RuntimeStats) SetGomaxprocs(val int) + func (s *RuntimeStats) SetGoroutines(val int64) + func (s *RuntimeStats) SetHeapAllocBytes(val int64) + func (s *RuntimeStats) SetHeapInuseBytes(val int64) + func (s *RuntimeStats) SetHeapSysBytes(val int64) + func (s *RuntimeStats) SetMemLimitBytes(val OptInt64) + func (s *RuntimeStats) SetNextGcBytes(val int64) + func (s *RuntimeStats) SetNumCPU(val int) + func (s *RuntimeStats) SetStackInuseBytes(val int64) + func (s *RuntimeStats) UnmarshalJSON(data []byte) error + type Server struct + func NewServer(h Handler, opts ...ServerOption) (*Server, error) + func (s *Server) FindPath(method string, u *url.URL) (r Route, _ bool) + func (s *Server) FindRoute(method, path string) (Route, bool) + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + type ServerOption interface + func WithErrorHandler(h ErrorHandler) ServerOption + func WithMaxMultipartMemory(max int64) ServerOption + func WithMethodNotAllowed(methodNotAllowed func(w http.ResponseWriter, r *http.Request, allowed string)) ServerOption + func WithMiddleware(m ...Middleware) ServerOption + func WithNotFound(notFound http.HandlerFunc) ServerOption + func WithPathPrefix(prefix string) ServerOption + type Signal string + const SignalLogs + const SignalMetrics + const SignalProfiles + const SignalTraces + func (Signal) AllValues() []Signal + func (s *Signal) Decode(d *jx.Decoder) error + func (s *Signal) UnmarshalJSON(data []byte) error + func (s *Signal) UnmarshalText(data []byte) error + func (s Signal) Encode(e *jx.Encoder) + func (s Signal) MarshalJSON() ([]byte, error) + func (s Signal) MarshalText() ([]byte, error) + func (s Signal) Validate() error + type SignalEfficiency struct + BytesPerPoint float64 + CompressionRatio OptFloat64 + LogicalBytes OptInt64 + Parts int64 + Points int64 + Series int64 + Signal Signal + StoredBytes int64 + func (s *SignalEfficiency) Decode(d *jx.Decoder) error + func (s *SignalEfficiency) Encode(e *jx.Encoder) + func (s *SignalEfficiency) GetBytesPerPoint() float64 + func (s *SignalEfficiency) GetCompressionRatio() OptFloat64 + func (s *SignalEfficiency) GetLogicalBytes() OptInt64 + func (s *SignalEfficiency) GetParts() int64 + func (s *SignalEfficiency) GetPoints() int64 + func (s *SignalEfficiency) GetSeries() int64 + func (s *SignalEfficiency) GetSignal() Signal + func (s *SignalEfficiency) GetStoredBytes() int64 + func (s *SignalEfficiency) MarshalJSON() ([]byte, error) + func (s *SignalEfficiency) SetBytesPerPoint(val float64) + func (s *SignalEfficiency) SetCompressionRatio(val OptFloat64) + func (s *SignalEfficiency) SetLogicalBytes(val OptInt64) + func (s *SignalEfficiency) SetParts(val int64) + func (s *SignalEfficiency) SetPoints(val int64) + func (s *SignalEfficiency) SetSeries(val int64) + func (s *SignalEfficiency) SetSignal(val Signal) + func (s *SignalEfficiency) SetStoredBytes(val int64) + func (s *SignalEfficiency) UnmarshalJSON(data []byte) error + func (s *SignalEfficiency) Validate() error + type SignalInfo struct + Backend string + Bind OptString + Queryable bool + Signal Signal + func (s *SignalInfo) Decode(d *jx.Decoder) error + func (s *SignalInfo) Encode(e *jx.Encoder) + func (s *SignalInfo) GetBackend() string + func (s *SignalInfo) GetBind() OptString + func (s *SignalInfo) GetQueryable() bool + func (s *SignalInfo) GetSignal() Signal + func (s *SignalInfo) MarshalJSON() ([]byte, error) + func (s *SignalInfo) SetBackend(val string) + func (s *SignalInfo) SetBind(val OptString) + func (s *SignalInfo) SetQueryable(val bool) + func (s *SignalInfo) SetSignal(val Signal) + func (s *SignalInfo) UnmarshalJSON(data []byte) error + func (s *SignalInfo) Validate() error + type SpanID string + func (s *SpanID) Decode(d *jx.Decoder) error + func (s *SpanID) UnmarshalJSON(data []byte) error + func (s SpanID) Encode(e *jx.Encoder) + func (s SpanID) MarshalJSON() ([]byte, error) + func (s SpanID) Validate() error + type StorageStats struct + Clickhouse OptClickHouseStats + ClickhouseEnabled bool + Engine OptEngineStats + StorageEnabled bool + func (s *StorageStats) Decode(d *jx.Decoder) error + func (s *StorageStats) Encode(e *jx.Encoder) + func (s *StorageStats) GetClickhouse() OptClickHouseStats + func (s *StorageStats) GetClickhouseEnabled() bool + func (s *StorageStats) GetEngine() OptEngineStats + func (s *StorageStats) GetStorageEnabled() bool + func (s *StorageStats) MarshalJSON() ([]byte, error) + func (s *StorageStats) SetClickhouse(val OptClickHouseStats) + func (s *StorageStats) SetClickhouseEnabled(val bool) + func (s *StorageStats) SetEngine(val OptEngineStats) + func (s *StorageStats) SetStorageEnabled(val bool) + func (s *StorageStats) UnmarshalJSON(data []byte) error + func (s *StorageStats) Validate() error + type TableStats struct + BytesOnDisk int64 + DataUncompressedBytes int64 + Database string + MaxTime OptDateTime + MinTime OptDateTime + Parts int64 + Rows int64 + Table string + func (s *TableStats) Decode(d *jx.Decoder) error + func (s *TableStats) Encode(e *jx.Encoder) + func (s *TableStats) GetBytesOnDisk() int64 + func (s *TableStats) GetDataUncompressedBytes() int64 + func (s *TableStats) GetDatabase() string + func (s *TableStats) GetMaxTime() OptDateTime + func (s *TableStats) GetMinTime() OptDateTime + func (s *TableStats) GetParts() int64 + func (s *TableStats) GetRows() int64 + func (s *TableStats) GetTable() string + func (s *TableStats) MarshalJSON() ([]byte, error) + func (s *TableStats) SetBytesOnDisk(val int64) + func (s *TableStats) SetDataUncompressedBytes(val int64) + func (s *TableStats) SetDatabase(val string) + func (s *TableStats) SetMaxTime(val OptDateTime) + func (s *TableStats) SetMinTime(val OptDateTime) + func (s *TableStats) SetParts(val int64) + func (s *TableStats) SetRows(val int64) + func (s *TableStats) SetTable(val string) + func (s *TableStats) UnmarshalJSON(data []byte) error + type TenantEfficiency struct + Signals []SignalEfficiency + Tenant string + func (s *TenantEfficiency) Decode(d *jx.Decoder) error + func (s *TenantEfficiency) Encode(e *jx.Encoder) + func (s *TenantEfficiency) GetSignals() []SignalEfficiency + func (s *TenantEfficiency) GetTenant() string + func (s *TenantEfficiency) MarshalJSON() ([]byte, error) + func (s *TenantEfficiency) SetSignals(val []SignalEfficiency) + func (s *TenantEfficiency) SetTenant(val string) + func (s *TenantEfficiency) UnmarshalJSON(data []byte) error + func (s *TenantEfficiency) Validate() error + type TenantStats struct + Admission AdmissionStats + Signals []EngineSignalStats + Tenant string + TotalParts int64 + TotalSeries int64 + func (s *TenantStats) Decode(d *jx.Decoder) error + func (s *TenantStats) Encode(e *jx.Encoder) + func (s *TenantStats) GetAdmission() AdmissionStats + func (s *TenantStats) GetSignals() []EngineSignalStats + func (s *TenantStats) GetTenant() string + func (s *TenantStats) GetTotalParts() int64 + func (s *TenantStats) GetTotalSeries() int64 + func (s *TenantStats) MarshalJSON() ([]byte, error) + func (s *TenantStats) SetAdmission(val AdmissionStats) + func (s *TenantStats) SetSignals(val []EngineSignalStats) + func (s *TenantStats) SetTenant(val string) + func (s *TenantStats) SetTotalParts(val int64) + func (s *TenantStats) SetTotalSeries(val int64) + func (s *TenantStats) UnmarshalJSON(data []byte) error + func (s *TenantStats) Validate() error + type TraceID string + func (s *TraceID) Decode(d *jx.Decoder) error + func (s *TraceID) UnmarshalJSON(data []byte) error + func (s TraceID) Encode(e *jx.Encoder) + func (s TraceID) MarshalJSON() ([]byte, error) + func (s TraceID) Validate() error + type UnimplementedHandler struct + func (UnimplementedHandler) GetEfficiency(ctx context.Context) (r *EfficiencyStats, _ error) + func (UnimplementedHandler) GetHealth(ctx context.Context) (r *HealthReport, _ error) + func (UnimplementedHandler) GetInfo(ctx context.Context) (r *InstanceInfo, _ error) + func (UnimplementedHandler) GetRuntime(ctx context.Context) (r *RuntimeStats, _ error) + func (UnimplementedHandler) GetStorage(ctx context.Context) (r *StorageStats, _ error) + func (UnimplementedHandler) NewError(ctx context.Context, err error) (r *ErrorStatusCode) + func (UnimplementedHandler) RunAction(ctx context.Context, params RunActionParams) (r *ActionResult, _ error)
Go to main page