Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterGravityControlServer(s grpc.ServiceRegistrar, srv GravityControlServer)
- func RegisterGravityTunnelServer(s grpc.ServiceRegistrar, srv GravityTunnelServer)
- type ClientCapabilities
- func (*ClientCapabilities) Descriptor() ([]byte, []int)deprecated
- func (x *ClientCapabilities) GetDynamicHostname() bool
- func (x *ClientCapabilities) GetDynamicProjectRouting() string
- func (x *ClientCapabilities) GetProvisionDeployments() bool
- func (x *ClientCapabilities) GetUnprovisionDeployments() bool
- func (*ClientCapabilities) ProtoMessage()
- func (x *ClientCapabilities) ProtoReflect() protoreflect.Message
- func (x *ClientCapabilities) Reset()
- func (x *ClientCapabilities) String() string
- type CloseRequest
- type CodeMetadata
- func (*CodeMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *CodeMetadata) GetEnv() []string
- func (x *CodeMetadata) GetSecrets() []string
- func (*CodeMetadata) ProtoMessage()
- func (x *CodeMetadata) ProtoReflect() protoreflect.Message
- func (x *CodeMetadata) Reset()
- func (x *CodeMetadata) String() string
- type ConfigItem
- type ConfigurationUpdate
- func (*ConfigurationUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigurationUpdate) GetConfig() []*ConfigItem
- func (x *ConfigurationUpdate) GetId() string
- func (*ConfigurationUpdate) ProtoMessage()
- func (x *ConfigurationUpdate) ProtoReflect() protoreflect.Message
- func (x *ConfigurationUpdate) Reset()
- func (x *ConfigurationUpdate) String() string
- type ConfigurationUpdateResponse
- func (*ConfigurationUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigurationUpdateResponse) GetError() string
- func (x *ConfigurationUpdateResponse) GetId() string
- func (x *ConfigurationUpdateResponse) GetSuccess() bool
- func (*ConfigurationUpdateResponse) ProtoMessage()
- func (x *ConfigurationUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigurationUpdateResponse) Reset()
- func (x *ConfigurationUpdateResponse) String() string
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectRequest) GetCapabilities() *ClientCapabilities
- func (x *ConnectRequest) GetClientName() string
- func (x *ConnectRequest) GetClientVersion() string
- func (x *ConnectRequest) GetDeployments() []*ExistingDeployment
- func (x *ConnectRequest) GetHostInfo() *HostInfo
- func (x *ConnectRequest) GetProtocolVersion() int32
- func (*ConnectRequest) ProtoMessage()
- func (x *ConnectRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectRequest) Reset()
- func (x *ConnectRequest) String() string
- type ConnectResponse
- func (*ConnectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectResponse) GetApiUrl() string
- func (x *ConnectResponse) GetEnvironment() []string
- func (x *ConnectResponse) GetGravityServer() string
- func (x *ConnectResponse) GetHostMapping() []*HostMapping
- func (x *ConnectResponse) GetHostname() string
- func (x *ConnectResponse) GetOrgId() string
- func (x *ConnectResponse) GetOtlpKey() string
- func (x *ConnectResponse) GetOtlpUrl() string
- func (x *ConnectResponse) GetSshPublicKey() []byte
- func (x *ConnectResponse) GetSubnetRoutes() []string
- func (*ConnectResponse) ProtoMessage()
- func (x *ConnectResponse) ProtoReflect() protoreflect.Message
- func (x *ConnectResponse) Reset()
- func (x *ConnectResponse) String() string
- type ControlMessage
- func (*ControlMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ControlMessage) GetClose() *CloseRequest
- func (x *ControlMessage) GetConfigUpdate() *ConfigurationUpdate
- func (x *ControlMessage) GetConfigUpdateResponse() *ConfigurationUpdateResponse
- func (x *ControlMessage) GetConnect() *ConnectRequest
- func (x *ControlMessage) GetConnectResponse() *ConnectResponse
- func (x *ControlMessage) GetEvent() *ProtocolEvent
- func (x *ControlMessage) GetId() string
- func (x *ControlMessage) GetMessageType() isControlMessage_MessageType
- func (x *ControlMessage) GetPause() *PauseRequest
- func (x *ControlMessage) GetPing() *PingRequest
- func (x *ControlMessage) GetPong() *PongResponse
- func (x *ControlMessage) GetReport() *ReportRequest
- func (x *ControlMessage) GetResponse() *ProtocolResponse
- func (x *ControlMessage) GetResume() *ResumeRequest
- func (x *ControlMessage) GetRouteDeployment() *RouteDeploymentRequest
- func (x *ControlMessage) GetRouteDeploymentResponse() *RouteDeploymentResponse
- func (x *ControlMessage) GetRouteSandbox() *RouteSandboxRequest
- func (x *ControlMessage) GetRouteSandboxResponse() *RouteSandboxResponse
- func (x *ControlMessage) GetStreamId() string
- func (x *ControlMessage) GetUnprovision() *UnprovisionRequest
- func (*ControlMessage) ProtoMessage()
- func (x *ControlMessage) ProtoReflect() protoreflect.Message
- func (x *ControlMessage) Reset()
- func (x *ControlMessage) String() string
- type ControlMessage_Close
- type ControlMessage_ConfigUpdate
- type ControlMessage_ConfigUpdateResponse
- type ControlMessage_Connect
- type ControlMessage_ConnectResponse
- type ControlMessage_Event
- type ControlMessage_Pause
- type ControlMessage_Ping
- type ControlMessage_Pong
- type ControlMessage_Report
- type ControlMessage_Response
- type ControlMessage_Resume
- type ControlMessage_RouteDeployment
- type ControlMessage_RouteDeploymentResponse
- type ControlMessage_RouteSandbox
- type ControlMessage_RouteSandboxResponse
- type ControlMessage_Unprovision
- type DeploymentCert
- func (*DeploymentCert) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentCert) GetCa() string
- func (x *DeploymentCert) GetCert() string
- func (x *DeploymentCert) GetDnsname() string
- func (x *DeploymentCert) GetKey() string
- func (*DeploymentCert) ProtoMessage()
- func (x *DeploymentCert) ProtoReflect() protoreflect.Message
- func (x *DeploymentCert) Reset()
- func (x *DeploymentCert) String() string
- type DeploymentMetadataRequest
- func (*DeploymentMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentMetadataRequest) GetDeploymentId() string
- func (x *DeploymentMetadataRequest) GetOrgId() string
- func (*DeploymentMetadataRequest) ProtoMessage()
- func (x *DeploymentMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *DeploymentMetadataRequest) Reset()
- func (x *DeploymentMetadataRequest) String() string
- type DeploymentMetadataResponse
- func (*DeploymentMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentMetadataResponse) GetAuthToken() string
- func (x *DeploymentMetadataResponse) GetCodeMetadata() *CodeMetadata
- func (x *DeploymentMetadataResponse) GetDeploymentCert() *DeploymentCert
- func (x *DeploymentMetadataResponse) GetError() string
- func (x *DeploymentMetadataResponse) GetExtraHosts() []string
- func (x *DeploymentMetadataResponse) GetOtlpToken() string
- func (x *DeploymentMetadataResponse) GetSuccess() bool
- func (*DeploymentMetadataResponse) ProtoMessage()
- func (x *DeploymentMetadataResponse) ProtoReflect() protoreflect.Message
- func (x *DeploymentMetadataResponse) Reset()
- func (x *DeploymentMetadataResponse) String() string
- type DeploymentSpecdeprecated
- type ErrorRateSample
- func (*ErrorRateSample) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorRateSample) GetErrorRate() float64
- func (x *ErrorRateSample) GetTimestamp() int64
- func (x *ErrorRateSample) GetTotalErrors() int64
- func (*ErrorRateSample) ProtoMessage()
- func (x *ErrorRateSample) ProtoReflect() protoreflect.Message
- func (x *ErrorRateSample) Reset()
- func (x *ErrorRateSample) String() string
- type ExistingDeployment
- func (*ExistingDeployment) Descriptor() ([]byte, []int)deprecated
- func (x *ExistingDeployment) GetDeploymentCert() *DeploymentCert
- func (x *ExistingDeployment) GetId() string
- func (x *ExistingDeployment) GetIpv6Address() string
- func (x *ExistingDeployment) GetOnDemand() bool
- func (x *ExistingDeployment) GetOrgId() string
- func (x *ExistingDeployment) GetPaused() bool
- func (x *ExistingDeployment) GetPausedDuration() *durationpb.Duration
- func (x *ExistingDeployment) GetResources() *ResourceRequirements
- func (x *ExistingDeployment) GetStarted() *timestamppb.Timestamp
- func (x *ExistingDeployment) GetUsedPrivateKey() bool
- func (*ExistingDeployment) ProtoMessage()
- func (x *ExistingDeployment) ProtoReflect() protoreflect.Message
- func (x *ExistingDeployment) Reset()
- func (x *ExistingDeployment) String() string
- type GRPCConnectionMetrics
- func (*GRPCConnectionMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *GRPCConnectionMetrics) GetActiveConnections() int32
- func (x *GRPCConnectionMetrics) GetActiveStreams() int32
- func (x *GRPCConnectionMetrics) GetCompressionEnabled() bool
- func (x *GRPCConnectionMetrics) GetConnectionStates() []string
- func (x *GRPCConnectionMetrics) GetControlStreams() int32
- func (x *GRPCConnectionMetrics) GetFailedConnections() int32
- func (x *GRPCConnectionMetrics) GetHealthCheckIntervalNs() int64
- func (x *GRPCConnectionMetrics) GetHealthyStreams() int32
- func (x *GRPCConnectionMetrics) GetIdleConnections() int32
- func (x *GRPCConnectionMetrics) GetLastHealthCheck() int64
- func (x *GRPCConnectionMetrics) GetPoolSize() int32
- func (x *GRPCConnectionMetrics) GetProtocolVersion() string
- func (x *GRPCConnectionMetrics) GetStreamAllocation() string
- func (x *GRPCConnectionMetrics) GetTlsVersion() string
- func (x *GRPCConnectionMetrics) GetTotalStreams() int32
- func (x *GRPCConnectionMetrics) GetTunnelStreams() int32
- func (x *GRPCConnectionMetrics) GetUnhealthyStreams() []string
- func (*GRPCConnectionMetrics) ProtoMessage()
- func (x *GRPCConnectionMetrics) ProtoReflect() protoreflect.Message
- func (x *GRPCConnectionMetrics) Reset()
- func (x *GRPCConnectionMetrics) String() string
- type GravityControlClient
- type GravityControlServer
- type GravityTunnelClient
- type GravityTunnelServer
- type GravityTunnel_EstablishTunnelClient
- type GravityTunnel_EstablishTunnelServer
- type GravityTunnel_StreamPacketsClient
- type GravityTunnel_StreamPacketsServer
- type HealthSample
- func (*HealthSample) Descriptor() ([]byte, []int)deprecated
- func (x *HealthSample) GetActiveConnections() int32
- func (x *HealthSample) GetHealthScore() float64
- func (x *HealthSample) GetHealthyStreams() int32
- func (x *HealthSample) GetTimestamp() int64
- func (x *HealthSample) GetTotalStreams() int32
- func (*HealthSample) ProtoMessage()
- func (x *HealthSample) ProtoReflect() protoreflect.Message
- func (x *HealthSample) Reset()
- func (x *HealthSample) String() string
- type HistoricalMetrics
- func (*HistoricalMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *HistoricalMetrics) GetErrorRateHistory() []*ErrorRateSample
- func (x *HistoricalMetrics) GetHealthHistory() []*HealthSample
- func (x *HistoricalMetrics) GetLatencyHistory() []*LatencySample
- func (x *HistoricalMetrics) GetMaxHistoryLength() int32
- func (x *HistoricalMetrics) GetThroughputHistory() []*ThroughputSample
- func (*HistoricalMetrics) ProtoMessage()
- func (x *HistoricalMetrics) ProtoReflect() protoreflect.Message
- func (x *HistoricalMetrics) Reset()
- func (x *HistoricalMetrics) String() string
- type HostInfo
- func (*HostInfo) Descriptor() ([]byte, []int)deprecated
- func (x *HostInfo) GetCpu() uint32
- func (x *HostInfo) GetDisk() uint64
- func (x *HostInfo) GetHostname() string
- func (x *HostInfo) GetInstanceId() string
- func (x *HostInfo) GetIpv4Address() string
- func (x *HostInfo) GetIpv6Address() string
- func (x *HostInfo) GetMemory() uint64
- func (x *HostInfo) GetStarted() uint64
- func (*HostInfo) ProtoMessage()
- func (x *HostInfo) ProtoReflect() protoreflect.Message
- func (x *HostInfo) Reset()
- func (x *HostInfo) String() string
- type HostMapping
- func (*HostMapping) Descriptor() ([]byte, []int)deprecated
- func (x *HostMapping) GetHostname() string
- func (x *HostMapping) GetIpAddress() string
- func (*HostMapping) ProtoMessage()
- func (x *HostMapping) ProtoReflect() protoreflect.Message
- func (x *HostMapping) Reset()
- func (x *HostMapping) String() string
- type LatencySample
- func (*LatencySample) Descriptor() ([]byte, []int)deprecated
- func (x *LatencySample) GetAvgLatencyNs() int64
- func (x *LatencySample) GetMaxLatencyNs() int64
- func (x *LatencySample) GetP95LatencyNs() int64
- func (x *LatencySample) GetP99LatencyNs() int64
- func (x *LatencySample) GetTimestamp() int64
- func (*LatencySample) ProtoMessage()
- func (x *LatencySample) ProtoReflect() protoreflect.Message
- func (x *LatencySample) Reset()
- func (x *LatencySample) String() string
- type MessageStatistics
- func (*MessageStatistics) Descriptor() ([]byte, []int)deprecated
- func (x *MessageStatistics) GetAvgPacketSize() float64
- func (x *MessageStatistics) GetBytesPerSecond() float64
- func (x *MessageStatistics) GetControlMessageBytes() int64
- func (x *MessageStatistics) GetControlMessagesReceived() int64
- func (x *MessageStatistics) GetControlMessagesSent() int64
- func (x *MessageStatistics) GetMessageDeliveryRate() float64
- func (x *MessageStatistics) GetMessagesByType() map[string]int64
- func (x *MessageStatistics) GetPacketBytes() int64
- func (x *MessageStatistics) GetPacketLossRate() float64
- func (x *MessageStatistics) GetPacketsDropped() int64
- func (x *MessageStatistics) GetPacketsPerSecond() float64
- func (x *MessageStatistics) GetPacketsReceived() int64
- func (x *MessageStatistics) GetPacketsSent() int64
- func (*MessageStatistics) ProtoMessage()
- func (x *MessageStatistics) ProtoReflect() protoreflect.Message
- func (x *MessageStatistics) Reset()
- func (x *MessageStatistics) String() string
- type PauseRequest
- type PerformanceMetrics
- func (*PerformanceMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *PerformanceMetrics) GetActiveConnections() int64
- func (x *PerformanceMetrics) GetAvgControlLatencyNs() int64
- func (x *PerformanceMetrics) GetAvgPacketLatencyNs() int64
- func (x *PerformanceMetrics) GetAvgRecoveryTimeNs() int64
- func (x *PerformanceMetrics) GetBufferPoolHits() int64
- func (x *PerformanceMetrics) GetBufferPoolMisses() int64
- func (x *PerformanceMetrics) GetBufferPoolSize() int64
- func (x *PerformanceMetrics) GetBytesPerSecond() float64
- func (x *PerformanceMetrics) GetBytesSaved() int64
- func (x *PerformanceMetrics) GetCircuitBreakerStates() []string
- func (x *PerformanceMetrics) GetCollectionIntervalNs() int64
- func (x *PerformanceMetrics) GetCompressionRatio() float64
- func (x *PerformanceMetrics) GetCompressionTimeNs() int64
- func (x *PerformanceMetrics) GetConnectionErrors() int64
- func (x *PerformanceMetrics) GetConnectionResets() int64
- func (x *PerformanceMetrics) GetControlMessagesPerSec() float64
- func (x *PerformanceMetrics) GetDecompressionTimeNs() int64
- func (x *PerformanceMetrics) GetErrorRate() float64
- func (x *PerformanceMetrics) GetFailedRetries() int64
- func (x *PerformanceMetrics) GetHealthyStreams() int64
- func (x *PerformanceMetrics) GetIdleConnections() int64
- func (x *PerformanceMetrics) GetLastUpdated() int64
- func (x *PerformanceMetrics) GetMaxPacketLatencyNs() int64
- func (x *PerformanceMetrics) GetMemoryUsageBytes() int64
- func (x *PerformanceMetrics) GetP95ControlLatencyNs() int64
- func (x *PerformanceMetrics) GetP95PacketLatencyNs() int64
- func (x *PerformanceMetrics) GetP99PacketLatencyNs() int64
- func (x *PerformanceMetrics) GetPacketDrops() int64
- func (x *PerformanceMetrics) GetPacketsPerSecond() float64
- func (x *PerformanceMetrics) GetPoolUtilization() float64
- func (x *PerformanceMetrics) GetRetrySuccessRate() float64
- func (x *PerformanceMetrics) GetRuntimeStats() map[string]*ProjectRuntimeStats
- func (x *PerformanceMetrics) GetStreamErrors() int64
- func (x *PerformanceMetrics) GetStreamUtilization() float64
- func (x *PerformanceMetrics) GetSuccessfulRetries() int64
- func (x *PerformanceMetrics) GetTotalCircuitBreaks() int64
- func (x *PerformanceMetrics) GetTotalRetryAttempts() int64
- func (x *PerformanceMetrics) GetTotalStreams() int64
- func (x *PerformanceMetrics) GetUnhealthyStreams() int64
- func (*PerformanceMetrics) ProtoMessage()
- func (x *PerformanceMetrics) ProtoReflect() protoreflect.Message
- func (x *PerformanceMetrics) Reset()
- func (x *PerformanceMetrics) String() string
- type PingRequest
- type PongResponse
- type ProjectRuntimeStats
- func (*ProjectRuntimeStats) Descriptor() ([]byte, []int)deprecated
- func (x *ProjectRuntimeStats) GetBlockIoReadBytes() uint64
- func (x *ProjectRuntimeStats) GetBlockIoReadOps() uint64
- func (x *ProjectRuntimeStats) GetBlockIoWriteBytes() uint64
- func (x *ProjectRuntimeStats) GetBlockIoWriteOps() uint64
- func (x *ProjectRuntimeStats) GetCpuLimit() float64
- func (x *ProjectRuntimeStats) GetCpuThrottledPeriods() uint64
- func (x *ProjectRuntimeStats) GetCpuThrottledTimeNs() uint64
- func (x *ProjectRuntimeStats) GetCpuUsageKernelNs() uint64
- func (x *ProjectRuntimeStats) GetCpuUsagePercent() float64
- func (x *ProjectRuntimeStats) GetCpuUsageTotalNs() uint64
- func (x *ProjectRuntimeStats) GetCpuUsageUserNs() uint64
- func (x *ProjectRuntimeStats) GetDeploymentId() string
- func (x *ProjectRuntimeStats) GetHealthy() bool
- func (x *ProjectRuntimeStats) GetHostname() string
- func (x *ProjectRuntimeStats) GetImage() string
- func (x *ProjectRuntimeStats) GetInflightRequests() int64
- func (x *ProjectRuntimeStats) GetIpv4Address() string
- func (x *ProjectRuntimeStats) GetIpv6Address() string
- func (x *ProjectRuntimeStats) GetLastUpdated() int64
- func (x *ProjectRuntimeStats) GetMemoryCacheBytes() uint64
- func (x *ProjectRuntimeStats) GetMemoryLimitBytes() uint64
- func (x *ProjectRuntimeStats) GetMemoryMaxUsageBytes() uint64
- func (x *ProjectRuntimeStats) GetMemoryRssBytes() uint64
- func (x *ProjectRuntimeStats) GetMemorySwapBytes() uint64
- func (x *ProjectRuntimeStats) GetMemorySwapLimitBytes() uint64
- func (x *ProjectRuntimeStats) GetMemoryUsageBytes() uint64
- func (x *ProjectRuntimeStats) GetMemoryUsagePercent() float64
- func (x *ProjectRuntimeStats) GetNetworkRxBytes() uint64
- func (x *ProjectRuntimeStats) GetNetworkRxDropped() uint64
- func (x *ProjectRuntimeStats) GetNetworkRxErrors() uint64
- func (x *ProjectRuntimeStats) GetNetworkRxPackets() uint64
- func (x *ProjectRuntimeStats) GetNetworkTxBytes() uint64
- func (x *ProjectRuntimeStats) GetNetworkTxDropped() uint64
- func (x *ProjectRuntimeStats) GetNetworkTxErrors() uint64
- func (x *ProjectRuntimeStats) GetNetworkTxPackets() uint64
- func (x *ProjectRuntimeStats) GetOomKills() uint64
- func (x *ProjectRuntimeStats) GetPaused() bool
- func (x *ProjectRuntimeStats) GetPausedTime() int64
- func (x *ProjectRuntimeStats) GetPidsCurrent() uint64
- func (x *ProjectRuntimeStats) GetPidsLimit() uint64
- func (x *ProjectRuntimeStats) GetRestartCount() int64
- func (x *ProjectRuntimeStats) GetRuntimeId() string
- func (x *ProjectRuntimeStats) GetRuntimeName() string
- func (x *ProjectRuntimeStats) GetStartedTime() int64
- func (x *ProjectRuntimeStats) GetStatus() string
- func (*ProjectRuntimeStats) ProtoMessage()
- func (x *ProjectRuntimeStats) ProtoReflect() protoreflect.Message
- func (x *ProjectRuntimeStats) Reset()
- func (x *ProjectRuntimeStats) String() string
- type ProtocolEvent
- func (*ProtocolEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ProtocolEvent) GetEvent() string
- func (x *ProtocolEvent) GetId() string
- func (x *ProtocolEvent) GetPayload() []byte
- func (*ProtocolEvent) ProtoMessage()
- func (x *ProtocolEvent) ProtoReflect() protoreflect.Message
- func (x *ProtocolEvent) Reset()
- func (x *ProtocolEvent) String() string
- type ProtocolResponse
- func (*ProtocolResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProtocolResponse) GetError() string
- func (x *ProtocolResponse) GetEvent() string
- func (x *ProtocolResponse) GetId() string
- func (x *ProtocolResponse) GetPayload() []byte
- func (x *ProtocolResponse) GetSuccess() bool
- func (*ProtocolResponse) ProtoMessage()
- func (x *ProtocolResponse) ProtoReflect() protoreflect.Message
- func (x *ProtocolResponse) Reset()
- func (x *ProtocolResponse) String() string
- type ProvisionRequest
- func (*ProvisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProvisionRequest) GetAvailabilityZone() string
- func (x *ProvisionRequest) GetCapabilities() *ClientCapabilities
- func (x *ProvisionRequest) GetEphemeral() bool
- func (x *ProvisionRequest) GetErrorMessage() string
- func (x *ProvisionRequest) GetHostname() string
- func (x *ProvisionRequest) GetInstanceId() string
- func (x *ProvisionRequest) GetPrivateIpv4() string
- func (x *ProvisionRequest) GetProvider() string
- func (x *ProvisionRequest) GetPublicKey() string
- func (x *ProvisionRequest) GetRegion() string
- func (*ProvisionRequest) ProtoMessage()
- func (x *ProvisionRequest) ProtoReflect() protoreflect.Message
- func (x *ProvisionRequest) Reset()
- func (x *ProvisionRequest) String() string
- type ProvisionResponse
- func (*ProvisionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProvisionResponse) GetCaCertificate() []byte
- func (x *ProvisionResponse) GetCertificate() []byte
- func (x *ProvisionResponse) GetClientToken() string
- func (x *ProvisionResponse) GetClusterId() string
- func (x *ProvisionResponse) GetDeploymentPrivateKey() []byte
- func (x *ProvisionResponse) GetExpires() *timestamppb.Timestamp
- func (x *ProvisionResponse) GetOrgId() string
- func (x *ProvisionResponse) GetPrivateKey() []byte
- func (*ProvisionResponse) ProtoMessage()
- func (x *ProvisionResponse) ProtoReflect() protoreflect.Message
- func (x *ProvisionResponse) Reset()
- func (x *ProvisionResponse) String() string
- type ReportRequest
- type ResourceRequirements
- func (*ResourceRequirements) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceRequirements) GetCpuLimit() int64
- func (x *ResourceRequirements) GetCpuRequest() int64
- func (x *ResourceRequirements) GetDiskLimit() int64
- func (x *ResourceRequirements) GetDiskRequest() int64
- func (x *ResourceRequirements) GetMemoryLimit() int64
- func (x *ResourceRequirements) GetMemoryRequest() int64
- func (*ResourceRequirements) ProtoMessage()
- func (x *ResourceRequirements) ProtoReflect() protoreflect.Message
- func (x *ResourceRequirements) Reset()
- func (x *ResourceRequirements) String() string
- type ResumeRequest
- type RouteDeploymentRequest
- func (*RouteDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RouteDeploymentRequest) GetDeploymentId() string
- func (x *RouteDeploymentRequest) GetHostname() string
- func (x *RouteDeploymentRequest) GetVirtualIp() string
- func (*RouteDeploymentRequest) ProtoMessage()
- func (x *RouteDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *RouteDeploymentRequest) Reset()
- func (x *RouteDeploymentRequest) String() string
- type RouteDeploymentResponse
- func (*RouteDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RouteDeploymentResponse) GetIp() string
- func (*RouteDeploymentResponse) ProtoMessage()
- func (x *RouteDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *RouteDeploymentResponse) Reset()
- func (x *RouteDeploymentResponse) String() string
- type RouteSandboxRequest
- func (*RouteSandboxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RouteSandboxRequest) GetSandboxId() string
- func (x *RouteSandboxRequest) GetVirtualIp() string
- func (*RouteSandboxRequest) ProtoMessage()
- func (x *RouteSandboxRequest) ProtoReflect() protoreflect.Message
- func (x *RouteSandboxRequest) Reset()
- func (x *RouteSandboxRequest) String() string
- type RouteSandboxResponse
- func (*RouteSandboxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RouteSandboxResponse) GetIp() string
- func (*RouteSandboxResponse) ProtoMessage()
- func (x *RouteSandboxResponse) ProtoReflect() protoreflect.Message
- func (x *RouteSandboxResponse) Reset()
- func (x *RouteSandboxResponse) String() string
- type ServerMetrics
- func (*ServerMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMetrics) GetConnectedTime() int64
- func (x *ServerMetrics) GetGrpcMetrics() *GRPCConnectionMetrics
- func (x *ServerMetrics) GetHistoricalData() *HistoricalMetrics
- func (x *ServerMetrics) GetIsConnected() bool
- func (x *ServerMetrics) GetLastMessageTime() int64
- func (x *ServerMetrics) GetMessageStats() *MessageStatistics
- func (x *ServerMetrics) GetPerformance() *PerformanceMetrics
- func (x *ServerMetrics) GetReconnectCount() int64
- func (x *ServerMetrics) GetStartTime() int64
- func (x *ServerMetrics) GetSystemMetrics() *SystemResourceMetrics
- func (x *ServerMetrics) GetTotalConnections() int64
- func (x *ServerMetrics) GetUptime() uint64
- func (*ServerMetrics) ProtoMessage()
- func (x *ServerMetrics) ProtoReflect() protoreflect.Message
- func (x *ServerMetrics) Reset()
- func (x *ServerMetrics) String() string
- type SystemResourceMetrics
- func (*SystemResourceMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *SystemResourceMetrics) GetAllocatedMemory() int64
- func (x *SystemResourceMetrics) GetBufferPoolHitRate() float64
- func (x *SystemResourceMetrics) GetBufferPoolHits() int64
- func (x *SystemResourceMetrics) GetBufferPoolMisses() int64
- func (x *SystemResourceMetrics) GetBufferPoolSize() int64
- func (x *SystemResourceMetrics) GetCpuUsagePercent() float64
- func (x *SystemResourceMetrics) GetGcPauseTimeNs() int64
- func (x *SystemResourceMetrics) GetMemoryUsageBytes() int64
- func (x *SystemResourceMetrics) GetMemoryUsageMb() float64
- func (x *SystemResourceMetrics) GetNumGoroutines() int32
- func (x *SystemResourceMetrics) GetOpenFileDescriptors() int32
- func (*SystemResourceMetrics) ProtoMessage()
- func (x *SystemResourceMetrics) ProtoReflect() protoreflect.Message
- func (x *SystemResourceMetrics) Reset()
- func (x *SystemResourceMetrics) String() string
- type ThroughputSample
- func (*ThroughputSample) Descriptor() ([]byte, []int)deprecated
- func (x *ThroughputSample) GetBytesPerSec() float64
- func (x *ThroughputSample) GetMessagesPerSec() float64
- func (x *ThroughputSample) GetPacketsPerSec() float64
- func (x *ThroughputSample) GetTimestamp() int64
- func (*ThroughputSample) ProtoMessage()
- func (x *ThroughputSample) ProtoReflect() protoreflect.Message
- func (x *ThroughputSample) Reset()
- func (x *ThroughputSample) String() string
- type TunnelPacket
- func (*TunnelPacket) Descriptor() ([]byte, []int)deprecated
- func (x *TunnelPacket) GetData() []byte
- func (x *TunnelPacket) GetStreamId() string
- func (*TunnelPacket) ProtoMessage()
- func (x *TunnelPacket) ProtoReflect() protoreflect.Message
- func (x *TunnelPacket) Reset()
- func (x *TunnelPacket) String() string
- type UnimplementedGravityControlServer
- type UnimplementedGravityTunnelServer
- type UnprovisionRequest
- func (*UnprovisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnprovisionRequest) GetDeploymentId() string
- func (*UnprovisionRequest) ProtoMessage()
- func (x *UnprovisionRequest) ProtoReflect() protoreflect.Message
- func (x *UnprovisionRequest) Reset()
- func (x *UnprovisionRequest) String() string
- type UnsafeGravityControlServer
- type UnsafeGravityTunnelServer
Constants ¶
const ( GravityControl_Provision_FullMethodName = "/gravity.GravityControl/Provision" GravityControl_GetDeploymentMetadata_FullMethodName = "/gravity.GravityControl/GetDeploymentMetadata" )
const ( GravityTunnel_EstablishTunnel_FullMethodName = "/gravity.GravityTunnel/EstablishTunnel" GravityTunnel_StreamPackets_FullMethodName = "/gravity.GravityTunnel/StreamPackets" )
Variables ¶
var File_gravity_proto protoreflect.FileDescriptor
var GravityControl_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gravity.GravityControl", HandlerType: (*GravityControlServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Provision", Handler: _GravityControl_Provision_Handler, }, { MethodName: "GetDeploymentMetadata", Handler: _GravityControl_GetDeploymentMetadata_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gravity.proto", }
GravityControl_ServiceDesc is the grpc.ServiceDesc for GravityControl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var GravityTunnel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gravity.GravityTunnel", HandlerType: (*GravityTunnelServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "EstablishTunnel", Handler: _GravityTunnel_EstablishTunnel_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "StreamPackets", Handler: _GravityTunnel_StreamPackets_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "gravity.proto", }
GravityTunnel_ServiceDesc is the grpc.ServiceDesc for GravityTunnel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGravityControlServer ¶
func RegisterGravityControlServer(s grpc.ServiceRegistrar, srv GravityControlServer)
func RegisterGravityTunnelServer ¶
func RegisterGravityTunnelServer(s grpc.ServiceRegistrar, srv GravityTunnelServer)
Types ¶
type ClientCapabilities ¶
type ClientCapabilities struct {
ProvisionDeployments bool `protobuf:"varint,1,opt,name=provision_deployments,json=provisionDeployments,proto3" json:"provision_deployments,omitempty"` // Can handle provision deployment requests
UnprovisionDeployments bool `` // Can handle unprovision deployment requests
/* 128-byte string literal not displayed */
DynamicProjectRouting string `` // Project ID for dynamic routing (empty = no routing)
/* 126-byte string literal not displayed */
DynamicHostname bool `protobuf:"varint,4,opt,name=dynamic_hostname,json=dynamicHostname,proto3" json:"dynamic_hostname,omitempty"` // Request dynamic hostname generation and routing
// contains filtered or unexported fields
}
ClientCapabilities defines what capabilities a client supports
func (*ClientCapabilities) Descriptor
deprecated
func (*ClientCapabilities) Descriptor() ([]byte, []int)
Deprecated: Use ClientCapabilities.ProtoReflect.Descriptor instead.
func (*ClientCapabilities) GetDynamicHostname ¶
func (x *ClientCapabilities) GetDynamicHostname() bool
func (*ClientCapabilities) GetDynamicProjectRouting ¶
func (x *ClientCapabilities) GetDynamicProjectRouting() string
func (*ClientCapabilities) GetProvisionDeployments ¶
func (x *ClientCapabilities) GetProvisionDeployments() bool
func (*ClientCapabilities) GetUnprovisionDeployments ¶
func (x *ClientCapabilities) GetUnprovisionDeployments() bool
func (*ClientCapabilities) ProtoMessage ¶
func (*ClientCapabilities) ProtoMessage()
func (*ClientCapabilities) ProtoReflect ¶
func (x *ClientCapabilities) ProtoReflect() protoreflect.Message
func (*ClientCapabilities) Reset ¶
func (x *ClientCapabilities) Reset()
func (*ClientCapabilities) String ¶
func (x *ClientCapabilities) String() string
type CloseRequest ¶
type CloseRequest struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for closing the connection
// contains filtered or unexported fields
}
Close request
func (*CloseRequest) Descriptor
deprecated
func (*CloseRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.
func (*CloseRequest) GetReason ¶
func (x *CloseRequest) GetReason() string
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) ProtoReflect ¶
func (x *CloseRequest) ProtoReflect() protoreflect.Message
func (*CloseRequest) Reset ¶
func (x *CloseRequest) Reset()
func (*CloseRequest) String ¶
func (x *CloseRequest) String() string
type CodeMetadata ¶
type CodeMetadata struct {
Env []string `protobuf:"bytes,1,rep,name=env,proto3" json:"env,omitempty"` // Environment variable names
Secrets []string `protobuf:"bytes,2,rep,name=secrets,proto3" json:"secrets,omitempty"` // Secret names required by the code
// contains filtered or unexported fields
}
func (*CodeMetadata) Descriptor
deprecated
func (*CodeMetadata) Descriptor() ([]byte, []int)
Deprecated: Use CodeMetadata.ProtoReflect.Descriptor instead.
func (*CodeMetadata) GetEnv ¶
func (x *CodeMetadata) GetEnv() []string
func (*CodeMetadata) GetSecrets ¶
func (x *CodeMetadata) GetSecrets() []string
func (*CodeMetadata) ProtoMessage ¶
func (*CodeMetadata) ProtoMessage()
func (*CodeMetadata) ProtoReflect ¶
func (x *CodeMetadata) ProtoReflect() protoreflect.Message
func (*CodeMetadata) Reset ¶
func (x *CodeMetadata) Reset()
func (*CodeMetadata) String ¶
func (x *CodeMetadata) String() string
type ConfigItem ¶
type ConfigItem struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Configuration key name
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Configuration value
// contains filtered or unexported fields
}
func (*ConfigItem) Descriptor
deprecated
func (*ConfigItem) Descriptor() ([]byte, []int)
Deprecated: Use ConfigItem.ProtoReflect.Descriptor instead.
func (*ConfigItem) GetKey ¶
func (x *ConfigItem) GetKey() string
func (*ConfigItem) GetValue ¶
func (x *ConfigItem) GetValue() string
func (*ConfigItem) ProtoMessage ¶
func (*ConfigItem) ProtoMessage()
func (*ConfigItem) ProtoReflect ¶
func (x *ConfigItem) ProtoReflect() protoreflect.Message
func (*ConfigItem) Reset ¶
func (x *ConfigItem) Reset()
func (*ConfigItem) String ¶
func (x *ConfigItem) String() string
type ConfigurationUpdate ¶
type ConfigurationUpdate struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for tracking this update
Config []*ConfigItem `protobuf:"bytes,2,rep,name=config,proto3" json:"config,omitempty"` // List of configuration items to set
// contains filtered or unexported fields
}
Configuration update from server to client
func (*ConfigurationUpdate) Descriptor
deprecated
func (*ConfigurationUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ConfigurationUpdate.ProtoReflect.Descriptor instead.
func (*ConfigurationUpdate) GetConfig ¶
func (x *ConfigurationUpdate) GetConfig() []*ConfigItem
func (*ConfigurationUpdate) GetId ¶
func (x *ConfigurationUpdate) GetId() string
func (*ConfigurationUpdate) ProtoMessage ¶
func (*ConfigurationUpdate) ProtoMessage()
func (*ConfigurationUpdate) ProtoReflect ¶
func (x *ConfigurationUpdate) ProtoReflect() protoreflect.Message
func (*ConfigurationUpdate) Reset ¶
func (x *ConfigurationUpdate) Reset()
func (*ConfigurationUpdate) String ¶
func (x *ConfigurationUpdate) String() string
type ConfigurationUpdateResponse ¶
type ConfigurationUpdateResponse struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Identifier matching the ConfigurationUpdate
Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` // Whether the configuration was successful
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // Error message if configuration failed
// contains filtered or unexported fields
}
Configuration update response from client to server
func (*ConfigurationUpdateResponse) Descriptor
deprecated
func (*ConfigurationUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigurationUpdateResponse.ProtoReflect.Descriptor instead.
func (*ConfigurationUpdateResponse) GetError ¶
func (x *ConfigurationUpdateResponse) GetError() string
func (*ConfigurationUpdateResponse) GetId ¶
func (x *ConfigurationUpdateResponse) GetId() string
func (*ConfigurationUpdateResponse) GetSuccess ¶
func (x *ConfigurationUpdateResponse) GetSuccess() bool
func (*ConfigurationUpdateResponse) ProtoMessage ¶
func (*ConfigurationUpdateResponse) ProtoMessage()
func (*ConfigurationUpdateResponse) ProtoReflect ¶
func (x *ConfigurationUpdateResponse) ProtoReflect() protoreflect.Message
func (*ConfigurationUpdateResponse) Reset ¶
func (x *ConfigurationUpdateResponse) Reset()
func (*ConfigurationUpdateResponse) String ¶
func (x *ConfigurationUpdateResponse) String() string
type ConnectRequest ¶
type ConnectRequest struct {
ProtocolVersion int32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` // Protocol version number for compatibility
ClientVersion string `protobuf:"bytes,2,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"` // Version string of the client (e.g., SHA, semver)
ClientName string `protobuf:"bytes,3,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"` // Name of the client application (e.g., "hadron")
Deployments []*ExistingDeployment `protobuf:"bytes,4,rep,name=deployments,proto3" json:"deployments,omitempty"` // List of existing deployments to restore
HostInfo *HostInfo `protobuf:"bytes,5,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"` // Information about the host system
Capabilities *ClientCapabilities `protobuf:"bytes,6,opt,name=capabilities,proto3" json:"capabilities,omitempty"` // Client capabilities for this connection
// contains filtered or unexported fields
}
Connect request from client to Gravity
func (*ConnectRequest) Descriptor
deprecated
func (*ConnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.
func (*ConnectRequest) GetCapabilities ¶
func (x *ConnectRequest) GetCapabilities() *ClientCapabilities
func (*ConnectRequest) GetClientName ¶
func (x *ConnectRequest) GetClientName() string
func (*ConnectRequest) GetClientVersion ¶
func (x *ConnectRequest) GetClientVersion() string
func (*ConnectRequest) GetDeployments ¶
func (x *ConnectRequest) GetDeployments() []*ExistingDeployment
func (*ConnectRequest) GetHostInfo ¶
func (x *ConnectRequest) GetHostInfo() *HostInfo
func (*ConnectRequest) GetProtocolVersion ¶
func (x *ConnectRequest) GetProtocolVersion() int32
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) ProtoReflect ¶
func (x *ConnectRequest) ProtoReflect() protoreflect.Message
func (*ConnectRequest) Reset ¶
func (x *ConnectRequest) Reset()
func (*ConnectRequest) String ¶
func (x *ConnectRequest) String() string
type ConnectResponse ¶
type ConnectResponse struct {
OtlpUrl string `protobuf:"bytes,1,opt,name=otlp_url,json=otlpUrl,proto3" json:"otlp_url,omitempty"` // OpenTelemetry endpoint URL for metrics
ApiUrl string `protobuf:"bytes,3,opt,name=api_url,json=apiUrl,proto3" json:"api_url,omitempty"` // Base URL for API operations
Environment []string `protobuf:"bytes,4,rep,name=environment,proto3" json:"environment,omitempty"` // Environment variables to set
HostMapping []*HostMapping `protobuf:"bytes,5,rep,name=host_mapping,json=hostMapping,proto3" json:"host_mapping,omitempty"` // Host to IP address mappings
SubnetRoutes []string `protobuf:"bytes,6,rep,name=subnet_routes,json=subnetRoutes,proto3" json:"subnet_routes,omitempty"`
GravityServer string `protobuf:"bytes,7,opt,name=gravity_server,json=gravityServer,proto3" json:"gravity_server,omitempty"` // the gravity server that we're connected to
Hostname string `protobuf:"bytes,8,opt,name=hostname,proto3" json:"hostname,omitempty"` // this hostname if dynamic hostname is requested
OtlpKey string `protobuf:"bytes,9,opt,name=otlp_key,json=otlpKey,proto3" json:"otlp_key,omitempty"` // OpenTelemetry API key for authentication (if needed)
OrgId string `protobuf:"bytes,10,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` // Organization ID for authentication
SshPublicKey []byte `protobuf:"bytes,11,opt,name=ssh_public_key,json=sshPublicKey,proto3" json:"ssh_public_key,omitempty"` // SSH public key for internal trusted connections (SSH wire format)
// contains filtered or unexported fields
}
Connect response from Gravity to client
func (*ConnectResponse) Descriptor
deprecated
func (*ConnectResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.
func (*ConnectResponse) GetApiUrl ¶
func (x *ConnectResponse) GetApiUrl() string
func (*ConnectResponse) GetEnvironment ¶
func (x *ConnectResponse) GetEnvironment() []string
func (*ConnectResponse) GetGravityServer ¶
func (x *ConnectResponse) GetGravityServer() string
func (*ConnectResponse) GetHostMapping ¶
func (x *ConnectResponse) GetHostMapping() []*HostMapping
func (*ConnectResponse) GetHostname ¶ added in v1.0.94
func (x *ConnectResponse) GetHostname() string
func (*ConnectResponse) GetOrgId ¶ added in v1.0.95
func (x *ConnectResponse) GetOrgId() string
func (*ConnectResponse) GetOtlpKey ¶ added in v1.0.94
func (x *ConnectResponse) GetOtlpKey() string
func (*ConnectResponse) GetOtlpUrl ¶
func (x *ConnectResponse) GetOtlpUrl() string
func (*ConnectResponse) GetSshPublicKey ¶ added in v1.0.123
func (x *ConnectResponse) GetSshPublicKey() []byte
func (*ConnectResponse) GetSubnetRoutes ¶
func (x *ConnectResponse) GetSubnetRoutes() []string
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) ProtoReflect ¶
func (x *ConnectResponse) ProtoReflect() protoreflect.Message
func (*ConnectResponse) Reset ¶
func (x *ConnectResponse) Reset()
func (*ConnectResponse) String ¶
func (x *ConnectResponse) String() string
type ControlMessage ¶
type ControlMessage struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` // Logical stream identifier for multiplexing
// Types that are valid to be assigned to MessageType:
//
// *ControlMessage_Connect
// *ControlMessage_ConnectResponse
// *ControlMessage_Close
// *ControlMessage_RouteDeployment
// *ControlMessage_RouteDeploymentResponse
// *ControlMessage_Unprovision
// *ControlMessage_RouteSandbox
// *ControlMessage_RouteSandboxResponse
// *ControlMessage_Ping
// *ControlMessage_Pong
// *ControlMessage_Report
// *ControlMessage_Pause
// *ControlMessage_Resume
// *ControlMessage_ConfigUpdate
// *ControlMessage_ConfigUpdateResponse
// *ControlMessage_Response
// *ControlMessage_Event
MessageType isControlMessage_MessageType `protobuf_oneof:"message_type"`
// contains filtered or unexported fields
}
ControlMessage represents all control plane communications
func (*ControlMessage) Descriptor
deprecated
func (*ControlMessage) Descriptor() ([]byte, []int)
Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.
func (*ControlMessage) GetClose ¶
func (x *ControlMessage) GetClose() *CloseRequest
func (*ControlMessage) GetConfigUpdate ¶
func (x *ControlMessage) GetConfigUpdate() *ConfigurationUpdate
func (*ControlMessage) GetConfigUpdateResponse ¶
func (x *ControlMessage) GetConfigUpdateResponse() *ConfigurationUpdateResponse
func (*ControlMessage) GetConnect ¶
func (x *ControlMessage) GetConnect() *ConnectRequest
func (*ControlMessage) GetConnectResponse ¶
func (x *ControlMessage) GetConnectResponse() *ConnectResponse
func (*ControlMessage) GetEvent ¶
func (x *ControlMessage) GetEvent() *ProtocolEvent
func (*ControlMessage) GetId ¶
func (x *ControlMessage) GetId() string
func (*ControlMessage) GetMessageType ¶
func (x *ControlMessage) GetMessageType() isControlMessage_MessageType
func (*ControlMessage) GetPause ¶
func (x *ControlMessage) GetPause() *PauseRequest
func (*ControlMessage) GetPing ¶
func (x *ControlMessage) GetPing() *PingRequest
func (*ControlMessage) GetPong ¶
func (x *ControlMessage) GetPong() *PongResponse
func (*ControlMessage) GetReport ¶
func (x *ControlMessage) GetReport() *ReportRequest
func (*ControlMessage) GetResponse ¶
func (x *ControlMessage) GetResponse() *ProtocolResponse
func (*ControlMessage) GetResume ¶
func (x *ControlMessage) GetResume() *ResumeRequest
func (*ControlMessage) GetRouteDeployment ¶
func (x *ControlMessage) GetRouteDeployment() *RouteDeploymentRequest
func (*ControlMessage) GetRouteDeploymentResponse ¶
func (x *ControlMessage) GetRouteDeploymentResponse() *RouteDeploymentResponse
func (*ControlMessage) GetRouteSandbox ¶ added in v1.0.136
func (x *ControlMessage) GetRouteSandbox() *RouteSandboxRequest
func (*ControlMessage) GetRouteSandboxResponse ¶ added in v1.0.136
func (x *ControlMessage) GetRouteSandboxResponse() *RouteSandboxResponse
func (*ControlMessage) GetStreamId ¶
func (x *ControlMessage) GetStreamId() string
func (*ControlMessage) GetUnprovision ¶
func (x *ControlMessage) GetUnprovision() *UnprovisionRequest
func (*ControlMessage) ProtoMessage ¶
func (*ControlMessage) ProtoMessage()
func (*ControlMessage) ProtoReflect ¶
func (x *ControlMessage) ProtoReflect() protoreflect.Message
func (*ControlMessage) Reset ¶
func (x *ControlMessage) Reset()
func (*ControlMessage) String ¶
func (x *ControlMessage) String() string
type ControlMessage_Close ¶
type ControlMessage_Close struct {
Close *CloseRequest `protobuf:"bytes,15,opt,name=close,proto3,oneof"`
}
type ControlMessage_ConfigUpdate ¶
type ControlMessage_ConfigUpdate struct {
// Configuration management (45-49)
ConfigUpdate *ConfigurationUpdate `protobuf:"bytes,45,opt,name=config_update,json=configUpdate,proto3,oneof"`
}
type ControlMessage_ConfigUpdateResponse ¶
type ControlMessage_ConfigUpdateResponse struct {
ConfigUpdateResponse *ConfigurationUpdateResponse `protobuf:"bytes,46,opt,name=config_update_response,json=configUpdateResponse,proto3,oneof"`
}
type ControlMessage_Connect ¶
type ControlMessage_Connect struct {
// Connection lifecycle (10-19)
Connect *ConnectRequest `protobuf:"bytes,10,opt,name=connect,proto3,oneof"`
}
type ControlMessage_ConnectResponse ¶
type ControlMessage_ConnectResponse struct {
ConnectResponse *ConnectResponse `protobuf:"bytes,11,opt,name=connect_response,json=connectResponse,proto3,oneof"`
}
type ControlMessage_Event ¶
type ControlMessage_Event struct {
Event *ProtocolEvent `protobuf:"bytes,51,opt,name=event,proto3,oneof"`
}
type ControlMessage_Pause ¶
type ControlMessage_Pause struct {
// Session control (40-49)
Pause *PauseRequest `protobuf:"bytes,40,opt,name=pause,proto3,oneof"`
}
type ControlMessage_Ping ¶
type ControlMessage_Ping struct {
// Health and monitoring (30-39)
Ping *PingRequest `protobuf:"bytes,30,opt,name=ping,proto3,oneof"`
}
type ControlMessage_Pong ¶
type ControlMessage_Pong struct {
Pong *PongResponse `protobuf:"bytes,31,opt,name=pong,proto3,oneof"`
}
type ControlMessage_Report ¶
type ControlMessage_Report struct {
Report *ReportRequest `protobuf:"bytes,32,opt,name=report,proto3,oneof"`
}
type ControlMessage_Response ¶
type ControlMessage_Response struct {
// Generic protocol messages (50-59)
Response *ProtocolResponse `protobuf:"bytes,50,opt,name=response,proto3,oneof"`
}
type ControlMessage_Resume ¶
type ControlMessage_Resume struct {
Resume *ResumeRequest `protobuf:"bytes,41,opt,name=resume,proto3,oneof"`
}
type ControlMessage_RouteDeployment ¶
type ControlMessage_RouteDeployment struct {
// Deployment management (20-29)
RouteDeployment *RouteDeploymentRequest `protobuf:"bytes,22,opt,name=route_deployment,json=routeDeployment,proto3,oneof"`
}
type ControlMessage_RouteDeploymentResponse ¶
type ControlMessage_RouteDeploymentResponse struct {
RouteDeploymentResponse *RouteDeploymentResponse `protobuf:"bytes,23,opt,name=route_deployment_response,json=routeDeploymentResponse,proto3,oneof"`
}
type ControlMessage_RouteSandbox ¶ added in v1.0.136
type ControlMessage_RouteSandbox struct {
RouteSandbox *RouteSandboxRequest `protobuf:"bytes,26,opt,name=route_sandbox,json=routeSandbox,proto3,oneof"`
}
type ControlMessage_RouteSandboxResponse ¶ added in v1.0.136
type ControlMessage_RouteSandboxResponse struct {
RouteSandboxResponse *RouteSandboxResponse `protobuf:"bytes,27,opt,name=route_sandbox_response,json=routeSandboxResponse,proto3,oneof"`
}
type ControlMessage_Unprovision ¶
type ControlMessage_Unprovision struct {
Unprovision *UnprovisionRequest `protobuf:"bytes,25,opt,name=unprovision,proto3,oneof"`
}
type DeploymentCert ¶
type DeploymentCert struct {
Cert string `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"` // TLS certificate in PEM format
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // TLS private key in PEM format
Ca string `protobuf:"bytes,3,opt,name=ca,proto3" json:"ca,omitempty"` // Certificate Authority certificate
Dnsname string `protobuf:"bytes,4,opt,name=dnsname,proto3" json:"dnsname,omitempty"` // DNS name for the certificate
// contains filtered or unexported fields
}
func (*DeploymentCert) Descriptor
deprecated
func (*DeploymentCert) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentCert.ProtoReflect.Descriptor instead.
func (*DeploymentCert) GetCa ¶
func (x *DeploymentCert) GetCa() string
func (*DeploymentCert) GetCert ¶
func (x *DeploymentCert) GetCert() string
func (*DeploymentCert) GetDnsname ¶
func (x *DeploymentCert) GetDnsname() string
func (*DeploymentCert) GetKey ¶
func (x *DeploymentCert) GetKey() string
func (*DeploymentCert) ProtoMessage ¶
func (*DeploymentCert) ProtoMessage()
func (*DeploymentCert) ProtoReflect ¶
func (x *DeploymentCert) ProtoReflect() protoreflect.Message
func (*DeploymentCert) Reset ¶
func (x *DeploymentCert) Reset()
func (*DeploymentCert) String ¶
func (x *DeploymentCert) String() string
type DeploymentMetadataRequest ¶
type DeploymentMetadataRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Unique identifier for the deployment
OrgId string `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` // Organization identifier
// contains filtered or unexported fields
}
Deployment metadata request
func (*DeploymentMetadataRequest) Descriptor
deprecated
func (*DeploymentMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentMetadataRequest.ProtoReflect.Descriptor instead.
func (*DeploymentMetadataRequest) GetDeploymentId ¶
func (x *DeploymentMetadataRequest) GetDeploymentId() string
func (*DeploymentMetadataRequest) GetOrgId ¶
func (x *DeploymentMetadataRequest) GetOrgId() string
func (*DeploymentMetadataRequest) ProtoMessage ¶
func (*DeploymentMetadataRequest) ProtoMessage()
func (*DeploymentMetadataRequest) ProtoReflect ¶
func (x *DeploymentMetadataRequest) ProtoReflect() protoreflect.Message
func (*DeploymentMetadataRequest) Reset ¶
func (x *DeploymentMetadataRequest) Reset()
func (*DeploymentMetadataRequest) String ¶
func (x *DeploymentMetadataRequest) String() string
type DeploymentMetadataResponse ¶
type DeploymentMetadataResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Whether the request was successful
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // Error message if request failed
CodeMetadata *CodeMetadata `protobuf:"bytes,3,opt,name=code_metadata,json=codeMetadata,proto3" json:"code_metadata,omitempty"` // Code metadata from FetchEnv
DeploymentCert *DeploymentCert `protobuf:"bytes,4,opt,name=deployment_cert,json=deploymentCert,proto3" json:"deployment_cert,omitempty"` // Generated deployment certificate
OtlpToken string `protobuf:"bytes,5,opt,name=otlp_token,json=otlpToken,proto3" json:"otlp_token,omitempty"` // OpenTelemetry token for metrics
AuthToken string `protobuf:"bytes,6,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"` // Authentication token
ExtraHosts []string `protobuf:"bytes,7,rep,name=extra_hosts,json=extraHosts,proto3" json:"extra_hosts,omitempty"` // Extra /etc/hosts entries for the deployment
// contains filtered or unexported fields
}
Deployment metadata response
func (*DeploymentMetadataResponse) Descriptor
deprecated
func (*DeploymentMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentMetadataResponse.ProtoReflect.Descriptor instead.
func (*DeploymentMetadataResponse) GetAuthToken ¶
func (x *DeploymentMetadataResponse) GetAuthToken() string
func (*DeploymentMetadataResponse) GetCodeMetadata ¶
func (x *DeploymentMetadataResponse) GetCodeMetadata() *CodeMetadata
func (*DeploymentMetadataResponse) GetDeploymentCert ¶
func (x *DeploymentMetadataResponse) GetDeploymentCert() *DeploymentCert
func (*DeploymentMetadataResponse) GetError ¶
func (x *DeploymentMetadataResponse) GetError() string
func (*DeploymentMetadataResponse) GetExtraHosts ¶ added in v1.0.125
func (x *DeploymentMetadataResponse) GetExtraHosts() []string
func (*DeploymentMetadataResponse) GetOtlpToken ¶
func (x *DeploymentMetadataResponse) GetOtlpToken() string
func (*DeploymentMetadataResponse) GetSuccess ¶
func (x *DeploymentMetadataResponse) GetSuccess() bool
func (*DeploymentMetadataResponse) ProtoMessage ¶
func (*DeploymentMetadataResponse) ProtoMessage()
func (*DeploymentMetadataResponse) ProtoReflect ¶
func (x *DeploymentMetadataResponse) ProtoReflect() protoreflect.Message
func (*DeploymentMetadataResponse) Reset ¶
func (x *DeploymentMetadataResponse) Reset()
func (*DeploymentMetadataResponse) String ¶
func (x *DeploymentMetadataResponse) String() string
type DeploymentSpec
deprecated
type DeploymentSpec struct {
// contains filtered or unexported fields
}
Deprecated: Marked as deprecated in gravity.proto.
func (*DeploymentSpec) Descriptor
deprecated
func (*DeploymentSpec) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentSpec.ProtoReflect.Descriptor instead.
func (*DeploymentSpec) ProtoMessage ¶
func (*DeploymentSpec) ProtoMessage()
func (*DeploymentSpec) ProtoReflect ¶
func (x *DeploymentSpec) ProtoReflect() protoreflect.Message
func (*DeploymentSpec) Reset ¶
func (x *DeploymentSpec) Reset()
func (*DeploymentSpec) String ¶
func (x *DeploymentSpec) String() string
type ErrorRateSample ¶
type ErrorRateSample struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
ErrorRate float64 `protobuf:"fixed64,2,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"` // percentage
TotalErrors int64 `protobuf:"varint,3,opt,name=total_errors,json=totalErrors,proto3" json:"total_errors,omitempty"`
// contains filtered or unexported fields
}
ErrorRateSample represents error rate at a point in time
func (*ErrorRateSample) Descriptor
deprecated
func (*ErrorRateSample) Descriptor() ([]byte, []int)
Deprecated: Use ErrorRateSample.ProtoReflect.Descriptor instead.
func (*ErrorRateSample) GetErrorRate ¶
func (x *ErrorRateSample) GetErrorRate() float64
func (*ErrorRateSample) GetTimestamp ¶
func (x *ErrorRateSample) GetTimestamp() int64
func (*ErrorRateSample) GetTotalErrors ¶
func (x *ErrorRateSample) GetTotalErrors() int64
func (*ErrorRateSample) ProtoMessage ¶
func (*ErrorRateSample) ProtoMessage()
func (*ErrorRateSample) ProtoReflect ¶
func (x *ErrorRateSample) ProtoReflect() protoreflect.Message
func (*ErrorRateSample) Reset ¶
func (x *ErrorRateSample) Reset()
func (*ErrorRateSample) String ¶
func (x *ErrorRateSample) String() string
type ExistingDeployment ¶
type ExistingDeployment struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for the deployment
Started *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"` // When the deployment was started
Ipv6Address string `protobuf:"bytes,4,opt,name=ipv6_address,json=ipv6Address,proto3" json:"ipv6_address,omitempty"` // Assigned IPv6 address for the deployment
OrgId string `protobuf:"bytes,5,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
Resources *ResourceRequirements `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` // CPU and memory requirements
DeploymentCert *DeploymentCert `protobuf:"bytes,7,opt,name=deployment_cert,json=deploymentCert,proto3" json:"deployment_cert,omitempty"`
UsedPrivateKey bool `protobuf:"varint,8,opt,name=used_private_key,json=usedPrivateKey,proto3" json:"used_private_key,omitempty"` // Deployment used private key
Paused bool `protobuf:"varint,9,opt,name=paused,proto3" json:"paused,omitempty"`
PausedDuration *durationpb.Duration `protobuf:"bytes,10,opt,name=pausedDuration,proto3" json:"pausedDuration,omitempty"`
OnDemand bool `protobuf:"varint,11,opt,name=on_demand,json=onDemand,proto3" json:"on_demand,omitempty"`
// contains filtered or unexported fields
}
func (*ExistingDeployment) Descriptor
deprecated
func (*ExistingDeployment) Descriptor() ([]byte, []int)
Deprecated: Use ExistingDeployment.ProtoReflect.Descriptor instead.
func (*ExistingDeployment) GetDeploymentCert ¶ added in v1.0.111
func (x *ExistingDeployment) GetDeploymentCert() *DeploymentCert
func (*ExistingDeployment) GetId ¶
func (x *ExistingDeployment) GetId() string
func (*ExistingDeployment) GetIpv6Address ¶
func (x *ExistingDeployment) GetIpv6Address() string
func (*ExistingDeployment) GetOnDemand ¶ added in v1.0.114
func (x *ExistingDeployment) GetOnDemand() bool
func (*ExistingDeployment) GetOrgId ¶ added in v1.0.111
func (x *ExistingDeployment) GetOrgId() string
func (*ExistingDeployment) GetPaused ¶ added in v1.0.111
func (x *ExistingDeployment) GetPaused() bool
func (*ExistingDeployment) GetPausedDuration ¶ added in v1.0.111
func (x *ExistingDeployment) GetPausedDuration() *durationpb.Duration
func (*ExistingDeployment) GetResources ¶ added in v1.0.111
func (x *ExistingDeployment) GetResources() *ResourceRequirements
func (*ExistingDeployment) GetStarted ¶
func (x *ExistingDeployment) GetStarted() *timestamppb.Timestamp
func (*ExistingDeployment) GetUsedPrivateKey ¶ added in v1.0.111
func (x *ExistingDeployment) GetUsedPrivateKey() bool
func (*ExistingDeployment) ProtoMessage ¶
func (*ExistingDeployment) ProtoMessage()
func (*ExistingDeployment) ProtoReflect ¶
func (x *ExistingDeployment) ProtoReflect() protoreflect.Message
func (*ExistingDeployment) Reset ¶
func (x *ExistingDeployment) Reset()
func (*ExistingDeployment) String ¶
func (x *ExistingDeployment) String() string
type GRPCConnectionMetrics ¶
type GRPCConnectionMetrics struct {
// Connection pool information (1-10)
PoolSize int32 `protobuf:"varint,1,opt,name=pool_size,json=poolSize,proto3" json:"pool_size,omitempty"`
ActiveConnections int32 `protobuf:"varint,2,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
IdleConnections int32 `protobuf:"varint,3,opt,name=idle_connections,json=idleConnections,proto3" json:"idle_connections,omitempty"`
FailedConnections int32 `protobuf:"varint,4,opt,name=failed_connections,json=failedConnections,proto3" json:"failed_connections,omitempty"`
ConnectionStates []string `protobuf:"bytes,5,rep,name=connection_states,json=connectionStates,proto3" json:"connection_states,omitempty"`
// Stream information (11-20)
TotalStreams int32 `protobuf:"varint,11,opt,name=total_streams,json=totalStreams,proto3" json:"total_streams,omitempty"`
ControlStreams int32 `protobuf:"varint,12,opt,name=control_streams,json=controlStreams,proto3" json:"control_streams,omitempty"`
TunnelStreams int32 `protobuf:"varint,13,opt,name=tunnel_streams,json=tunnelStreams,proto3" json:"tunnel_streams,omitempty"`
HealthyStreams int32 `protobuf:"varint,14,opt,name=healthy_streams,json=healthyStreams,proto3" json:"healthy_streams,omitempty"`
ActiveStreams int32 `protobuf:"varint,15,opt,name=active_streams,json=activeStreams,proto3" json:"active_streams,omitempty"`
StreamAllocation string `protobuf:"bytes,16,opt,name=stream_allocation,json=streamAllocation,proto3" json:"stream_allocation,omitempty"` // allocation strategy
// Protocol information (21-30)
ProtocolVersion string `protobuf:"bytes,21,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
CompressionEnabled bool `protobuf:"varint,22,opt,name=compression_enabled,json=compressionEnabled,proto3" json:"compression_enabled,omitempty"`
TlsVersion string `protobuf:"bytes,23,opt,name=tls_version,json=tlsVersion,proto3" json:"tls_version,omitempty"`
// Health monitoring (31-40)
LastHealthCheck int64 `protobuf:"varint,31,opt,name=last_health_check,json=lastHealthCheck,proto3" json:"last_health_check,omitempty"` // epoch milliseconds
HealthCheckIntervalNs int64 `` // nanoseconds
/* 130-byte string literal not displayed */
UnhealthyStreams []string `protobuf:"bytes,33,rep,name=unhealthy_streams,json=unhealthyStreams,proto3" json:"unhealthy_streams,omitempty"`
// contains filtered or unexported fields
}
GRPCConnectionMetrics contains gRPC-specific connection metrics
func (*GRPCConnectionMetrics) Descriptor
deprecated
func (*GRPCConnectionMetrics) Descriptor() ([]byte, []int)
Deprecated: Use GRPCConnectionMetrics.ProtoReflect.Descriptor instead.
func (*GRPCConnectionMetrics) GetActiveConnections ¶
func (x *GRPCConnectionMetrics) GetActiveConnections() int32
func (*GRPCConnectionMetrics) GetActiveStreams ¶
func (x *GRPCConnectionMetrics) GetActiveStreams() int32
func (*GRPCConnectionMetrics) GetCompressionEnabled ¶
func (x *GRPCConnectionMetrics) GetCompressionEnabled() bool
func (*GRPCConnectionMetrics) GetConnectionStates ¶
func (x *GRPCConnectionMetrics) GetConnectionStates() []string
func (*GRPCConnectionMetrics) GetControlStreams ¶
func (x *GRPCConnectionMetrics) GetControlStreams() int32
func (*GRPCConnectionMetrics) GetFailedConnections ¶
func (x *GRPCConnectionMetrics) GetFailedConnections() int32
func (*GRPCConnectionMetrics) GetHealthCheckIntervalNs ¶
func (x *GRPCConnectionMetrics) GetHealthCheckIntervalNs() int64
func (*GRPCConnectionMetrics) GetHealthyStreams ¶
func (x *GRPCConnectionMetrics) GetHealthyStreams() int32
func (*GRPCConnectionMetrics) GetIdleConnections ¶
func (x *GRPCConnectionMetrics) GetIdleConnections() int32
func (*GRPCConnectionMetrics) GetLastHealthCheck ¶
func (x *GRPCConnectionMetrics) GetLastHealthCheck() int64
func (*GRPCConnectionMetrics) GetPoolSize ¶
func (x *GRPCConnectionMetrics) GetPoolSize() int32
func (*GRPCConnectionMetrics) GetProtocolVersion ¶
func (x *GRPCConnectionMetrics) GetProtocolVersion() string
func (*GRPCConnectionMetrics) GetStreamAllocation ¶
func (x *GRPCConnectionMetrics) GetStreamAllocation() string
func (*GRPCConnectionMetrics) GetTlsVersion ¶
func (x *GRPCConnectionMetrics) GetTlsVersion() string
func (*GRPCConnectionMetrics) GetTotalStreams ¶
func (x *GRPCConnectionMetrics) GetTotalStreams() int32
func (*GRPCConnectionMetrics) GetTunnelStreams ¶
func (x *GRPCConnectionMetrics) GetTunnelStreams() int32
func (*GRPCConnectionMetrics) GetUnhealthyStreams ¶
func (x *GRPCConnectionMetrics) GetUnhealthyStreams() []string
func (*GRPCConnectionMetrics) ProtoMessage ¶
func (*GRPCConnectionMetrics) ProtoMessage()
func (*GRPCConnectionMetrics) ProtoReflect ¶
func (x *GRPCConnectionMetrics) ProtoReflect() protoreflect.Message
func (*GRPCConnectionMetrics) Reset ¶
func (x *GRPCConnectionMetrics) Reset()
func (*GRPCConnectionMetrics) String ¶
func (x *GRPCConnectionMetrics) String() string
type GravityControlClient ¶
type GravityControlClient interface {
// provision is called on startup to get certificates and configuration
Provision(ctx context.Context, in *ProvisionRequest, opts ...grpc.CallOption) (*ProvisionResponse, error)
// get deployment metadata for provisioning
GetDeploymentMetadata(ctx context.Context, in *DeploymentMetadataRequest, opts ...grpc.CallOption) (*DeploymentMetadataResponse, error)
}
GravityControlClient is the client API for GravityControl service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
GravityControl service handles client provisioning and metadata
func NewGravityControlClient ¶
func NewGravityControlClient(cc grpc.ClientConnInterface) GravityControlClient
type GravityControlServer ¶
type GravityControlServer interface {
// provision is called on startup to get certificates and configuration
Provision(context.Context, *ProvisionRequest) (*ProvisionResponse, error)
// get deployment metadata for provisioning
GetDeploymentMetadata(context.Context, *DeploymentMetadataRequest) (*DeploymentMetadataResponse, error)
// contains filtered or unexported methods
}
GravityControlServer is the server API for GravityControl service. All implementations must embed UnimplementedGravityControlServer for forward compatibility.
GravityControl service handles client provisioning and metadata
type GravityTunnelClient ¶
type GravityTunnelClient interface {
// establish a tunnel for the client to send and receive control messages
// after it has been provisioned
EstablishTunnel(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ControlMessage, ControlMessage], error)
// stream packet data with multiplexing
StreamPackets(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[TunnelPacket, TunnelPacket], error)
}
GravityTunnelClient is the client API for GravityTunnel service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
GravityTunnel service handles bidirectional streaming for packet data and control messages
func NewGravityTunnelClient ¶
func NewGravityTunnelClient(cc grpc.ClientConnInterface) GravityTunnelClient
type GravityTunnelServer ¶
type GravityTunnelServer interface {
// establish a tunnel for the client to send and receive control messages
// after it has been provisioned
EstablishTunnel(grpc.BidiStreamingServer[ControlMessage, ControlMessage]) error
// stream packet data with multiplexing
StreamPackets(grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]) error
// contains filtered or unexported methods
}
GravityTunnelServer is the server API for GravityTunnel service. All implementations must embed UnimplementedGravityTunnelServer for forward compatibility.
GravityTunnel service handles bidirectional streaming for packet data and control messages
type GravityTunnel_EstablishTunnelClient ¶
type GravityTunnel_EstablishTunnelClient = grpc.BidiStreamingClient[ControlMessage, ControlMessage]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type GravityTunnel_EstablishTunnelServer ¶
type GravityTunnel_EstablishTunnelServer = grpc.BidiStreamingServer[ControlMessage, ControlMessage]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type GravityTunnel_StreamPacketsClient ¶
type GravityTunnel_StreamPacketsClient = grpc.BidiStreamingClient[TunnelPacket, TunnelPacket]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type GravityTunnel_StreamPacketsServer ¶
type GravityTunnel_StreamPacketsServer = grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type HealthSample ¶
type HealthSample struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
HealthyStreams int32 `protobuf:"varint,2,opt,name=healthy_streams,json=healthyStreams,proto3" json:"healthy_streams,omitempty"`
TotalStreams int32 `protobuf:"varint,3,opt,name=total_streams,json=totalStreams,proto3" json:"total_streams,omitempty"`
ActiveConnections int32 `protobuf:"varint,4,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
HealthScore float64 `protobuf:"fixed64,5,opt,name=health_score,json=healthScore,proto3" json:"health_score,omitempty"` // percentage
// contains filtered or unexported fields
}
HealthSample represents system health at a point in time
func (*HealthSample) Descriptor
deprecated
func (*HealthSample) Descriptor() ([]byte, []int)
Deprecated: Use HealthSample.ProtoReflect.Descriptor instead.
func (*HealthSample) GetActiveConnections ¶
func (x *HealthSample) GetActiveConnections() int32
func (*HealthSample) GetHealthScore ¶
func (x *HealthSample) GetHealthScore() float64
func (*HealthSample) GetHealthyStreams ¶
func (x *HealthSample) GetHealthyStreams() int32
func (*HealthSample) GetTimestamp ¶
func (x *HealthSample) GetTimestamp() int64
func (*HealthSample) GetTotalStreams ¶
func (x *HealthSample) GetTotalStreams() int32
func (*HealthSample) ProtoMessage ¶
func (*HealthSample) ProtoMessage()
func (*HealthSample) ProtoReflect ¶
func (x *HealthSample) ProtoReflect() protoreflect.Message
func (*HealthSample) Reset ¶
func (x *HealthSample) Reset()
func (*HealthSample) String ¶
func (x *HealthSample) String() string
type HistoricalMetrics ¶
type HistoricalMetrics struct {
// Recent throughput samples (last 60 samples, 1 per minute)
ThroughputHistory []*ThroughputSample `protobuf:"bytes,1,rep,name=throughput_history,json=throughputHistory,proto3" json:"throughput_history,omitempty"`
// Recent latency samples
LatencyHistory []*LatencySample `protobuf:"bytes,2,rep,name=latency_history,json=latencyHistory,proto3" json:"latency_history,omitempty"`
// Error rate samples
ErrorRateHistory []*ErrorRateSample `protobuf:"bytes,3,rep,name=error_rate_history,json=errorRateHistory,proto3" json:"error_rate_history,omitempty"`
// Connection health samples
HealthHistory []*HealthSample `protobuf:"bytes,4,rep,name=health_history,json=healthHistory,proto3" json:"health_history,omitempty"`
// Maximum history length
MaxHistoryLength int32 `protobuf:"varint,5,opt,name=max_history_length,json=maxHistoryLength,proto3" json:"max_history_length,omitempty"`
// contains filtered or unexported fields
}
HistoricalMetrics contains time-series data for trend analysis
func (*HistoricalMetrics) Descriptor
deprecated
func (*HistoricalMetrics) Descriptor() ([]byte, []int)
Deprecated: Use HistoricalMetrics.ProtoReflect.Descriptor instead.
func (*HistoricalMetrics) GetErrorRateHistory ¶
func (x *HistoricalMetrics) GetErrorRateHistory() []*ErrorRateSample
func (*HistoricalMetrics) GetHealthHistory ¶
func (x *HistoricalMetrics) GetHealthHistory() []*HealthSample
func (*HistoricalMetrics) GetLatencyHistory ¶
func (x *HistoricalMetrics) GetLatencyHistory() []*LatencySample
func (*HistoricalMetrics) GetMaxHistoryLength ¶
func (x *HistoricalMetrics) GetMaxHistoryLength() int32
func (*HistoricalMetrics) GetThroughputHistory ¶
func (x *HistoricalMetrics) GetThroughputHistory() []*ThroughputSample
func (*HistoricalMetrics) ProtoMessage ¶
func (*HistoricalMetrics) ProtoMessage()
func (*HistoricalMetrics) ProtoReflect ¶
func (x *HistoricalMetrics) ProtoReflect() protoreflect.Message
func (*HistoricalMetrics) Reset ¶
func (x *HistoricalMetrics) Reset()
func (*HistoricalMetrics) String ¶
func (x *HistoricalMetrics) String() string
type HostInfo ¶
type HostInfo struct {
Started uint64 `protobuf:"varint,1,opt,name=started,proto3" json:"started,omitempty"` // epoch time in milliseconds since server started
Cpu uint32 `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"` // number of CPUs
Memory uint64 `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"` // memory in bytes
Disk uint64 `protobuf:"varint,4,opt,name=disk,proto3" json:"disk,omitempty"` // disk free space in bytes
Ipv4Address string `protobuf:"bytes,5,opt,name=ipv4_address,json=ipv4Address,proto3" json:"ipv4_address,omitempty"` // IPv4 address
Ipv6Address string `protobuf:"bytes,6,opt,name=ipv6_address,json=ipv6Address,proto3" json:"ipv6_address,omitempty"` // IPv6 address
Hostname string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"` // hostname
InstanceId string `protobuf:"bytes,8,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // instance id of the client
// contains filtered or unexported fields
}
Supporting data structures
func (*HostInfo) Descriptor
deprecated
func (*HostInfo) GetHostname ¶
func (*HostInfo) GetInstanceId ¶
func (*HostInfo) GetIpv4Address ¶
func (*HostInfo) GetIpv6Address ¶
func (*HostInfo) GetStarted ¶
func (*HostInfo) ProtoMessage ¶
func (*HostInfo) ProtoMessage()
func (*HostInfo) ProtoReflect ¶
func (x *HostInfo) ProtoReflect() protoreflect.Message
type HostMapping ¶
type HostMapping struct {
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // Hostname to map
IpAddress string `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"` // IP address to map the hostname to
// contains filtered or unexported fields
}
func (*HostMapping) Descriptor
deprecated
func (*HostMapping) Descriptor() ([]byte, []int)
Deprecated: Use HostMapping.ProtoReflect.Descriptor instead.
func (*HostMapping) GetHostname ¶
func (x *HostMapping) GetHostname() string
func (*HostMapping) GetIpAddress ¶
func (x *HostMapping) GetIpAddress() string
func (*HostMapping) ProtoMessage ¶
func (*HostMapping) ProtoMessage()
func (*HostMapping) ProtoReflect ¶
func (x *HostMapping) ProtoReflect() protoreflect.Message
func (*HostMapping) Reset ¶
func (x *HostMapping) Reset()
func (*HostMapping) String ¶
func (x *HostMapping) String() string
type LatencySample ¶
type LatencySample struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
AvgLatencyNs int64 `protobuf:"varint,2,opt,name=avg_latency_ns,json=avgLatencyNs,proto3" json:"avg_latency_ns,omitempty"`
P95LatencyNs int64 `protobuf:"varint,3,opt,name=p95_latency_ns,json=p95LatencyNs,proto3" json:"p95_latency_ns,omitempty"`
P99LatencyNs int64 `protobuf:"varint,4,opt,name=p99_latency_ns,json=p99LatencyNs,proto3" json:"p99_latency_ns,omitempty"`
MaxLatencyNs int64 `protobuf:"varint,5,opt,name=max_latency_ns,json=maxLatencyNs,proto3" json:"max_latency_ns,omitempty"`
// contains filtered or unexported fields
}
LatencySample represents latency measurements at a point in time
func (*LatencySample) Descriptor
deprecated
func (*LatencySample) Descriptor() ([]byte, []int)
Deprecated: Use LatencySample.ProtoReflect.Descriptor instead.
func (*LatencySample) GetAvgLatencyNs ¶
func (x *LatencySample) GetAvgLatencyNs() int64
func (*LatencySample) GetMaxLatencyNs ¶
func (x *LatencySample) GetMaxLatencyNs() int64
func (*LatencySample) GetP95LatencyNs ¶
func (x *LatencySample) GetP95LatencyNs() int64
func (*LatencySample) GetP99LatencyNs ¶
func (x *LatencySample) GetP99LatencyNs() int64
func (*LatencySample) GetTimestamp ¶
func (x *LatencySample) GetTimestamp() int64
func (*LatencySample) ProtoMessage ¶
func (*LatencySample) ProtoMessage()
func (*LatencySample) ProtoReflect ¶
func (x *LatencySample) ProtoReflect() protoreflect.Message
func (*LatencySample) Reset ¶
func (x *LatencySample) Reset()
func (*LatencySample) String ¶
func (x *LatencySample) String() string
type MessageStatistics ¶
type MessageStatistics struct {
// Packet statistics (1-10)
PacketsSent int64 `protobuf:"varint,1,opt,name=packets_sent,json=packetsSent,proto3" json:"packets_sent,omitempty"`
PacketsReceived int64 `protobuf:"varint,2,opt,name=packets_received,json=packetsReceived,proto3" json:"packets_received,omitempty"`
PacketsDropped int64 `protobuf:"varint,3,opt,name=packets_dropped,json=packetsDropped,proto3" json:"packets_dropped,omitempty"`
PacketBytes int64 `protobuf:"varint,4,opt,name=packet_bytes,json=packetBytes,proto3" json:"packet_bytes,omitempty"`
AvgPacketSize float64 `protobuf:"fixed64,5,opt,name=avg_packet_size,json=avgPacketSize,proto3" json:"avg_packet_size,omitempty"` // bytes
// Control message statistics (11-20)
ControlMessagesSent int64 `protobuf:"varint,11,opt,name=control_messages_sent,json=controlMessagesSent,proto3" json:"control_messages_sent,omitempty"`
ControlMessagesReceived int64 `` /* 134-byte string literal not displayed */
ControlMessageBytes int64 `protobuf:"varint,13,opt,name=control_message_bytes,json=controlMessageBytes,proto3" json:"control_message_bytes,omitempty"`
// Message breakdown (21-30)
MessagesByType map[string]int64 `` /* 181-byte string literal not displayed */
// Throughput metrics (31-40)
PacketsPerSecond float64 `protobuf:"fixed64,31,opt,name=packets_per_second,json=packetsPerSecond,proto3" json:"packets_per_second,omitempty"`
BytesPerSecond float64 `protobuf:"fixed64,32,opt,name=bytes_per_second,json=bytesPerSecond,proto3" json:"bytes_per_second,omitempty"`
// Quality metrics (41-50)
PacketLossRate float64 `protobuf:"fixed64,41,opt,name=packet_loss_rate,json=packetLossRate,proto3" json:"packet_loss_rate,omitempty"` // percentage
MessageDeliveryRate float64 `protobuf:"fixed64,42,opt,name=message_delivery_rate,json=messageDeliveryRate,proto3" json:"message_delivery_rate,omitempty"` // percentage
// contains filtered or unexported fields
}
MessageStatistics contains detailed message flow statistics
func (*MessageStatistics) Descriptor
deprecated
func (*MessageStatistics) Descriptor() ([]byte, []int)
Deprecated: Use MessageStatistics.ProtoReflect.Descriptor instead.
func (*MessageStatistics) GetAvgPacketSize ¶
func (x *MessageStatistics) GetAvgPacketSize() float64
func (*MessageStatistics) GetBytesPerSecond ¶
func (x *MessageStatistics) GetBytesPerSecond() float64
func (*MessageStatistics) GetControlMessageBytes ¶
func (x *MessageStatistics) GetControlMessageBytes() int64
func (*MessageStatistics) GetControlMessagesReceived ¶
func (x *MessageStatistics) GetControlMessagesReceived() int64
func (*MessageStatistics) GetControlMessagesSent ¶
func (x *MessageStatistics) GetControlMessagesSent() int64
func (*MessageStatistics) GetMessageDeliveryRate ¶
func (x *MessageStatistics) GetMessageDeliveryRate() float64
func (*MessageStatistics) GetMessagesByType ¶
func (x *MessageStatistics) GetMessagesByType() map[string]int64
func (*MessageStatistics) GetPacketBytes ¶
func (x *MessageStatistics) GetPacketBytes() int64
func (*MessageStatistics) GetPacketLossRate ¶
func (x *MessageStatistics) GetPacketLossRate() float64
func (*MessageStatistics) GetPacketsDropped ¶
func (x *MessageStatistics) GetPacketsDropped() int64
func (*MessageStatistics) GetPacketsPerSecond ¶
func (x *MessageStatistics) GetPacketsPerSecond() float64
func (*MessageStatistics) GetPacketsReceived ¶
func (x *MessageStatistics) GetPacketsReceived() int64
func (*MessageStatistics) GetPacketsSent ¶
func (x *MessageStatistics) GetPacketsSent() int64
func (*MessageStatistics) ProtoMessage ¶
func (*MessageStatistics) ProtoMessage()
func (*MessageStatistics) ProtoReflect ¶
func (x *MessageStatistics) ProtoReflect() protoreflect.Message
func (*MessageStatistics) Reset ¶
func (x *MessageStatistics) Reset()
func (*MessageStatistics) String ¶
func (x *MessageStatistics) String() string
type PauseRequest ¶
type PauseRequest struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for pausing the session
// contains filtered or unexported fields
}
Pause request
func (*PauseRequest) Descriptor
deprecated
func (*PauseRequest) Descriptor() ([]byte, []int)
Deprecated: Use PauseRequest.ProtoReflect.Descriptor instead.
func (*PauseRequest) GetReason ¶
func (x *PauseRequest) GetReason() string
func (*PauseRequest) ProtoMessage ¶
func (*PauseRequest) ProtoMessage()
func (*PauseRequest) ProtoReflect ¶
func (x *PauseRequest) ProtoReflect() protoreflect.Message
func (*PauseRequest) Reset ¶
func (x *PauseRequest) Reset()
func (*PauseRequest) String ¶
func (x *PauseRequest) String() string
type PerformanceMetrics ¶
type PerformanceMetrics struct {
// Latency metrics (1-10) - all in nanoseconds
AvgPacketLatencyNs int64 `protobuf:"varint,1,opt,name=avg_packet_latency_ns,json=avgPacketLatencyNs,proto3" json:"avg_packet_latency_ns,omitempty"`
P95PacketLatencyNs int64 `protobuf:"varint,2,opt,name=p95_packet_latency_ns,json=p95PacketLatencyNs,proto3" json:"p95_packet_latency_ns,omitempty"`
P99PacketLatencyNs int64 `protobuf:"varint,3,opt,name=p99_packet_latency_ns,json=p99PacketLatencyNs,proto3" json:"p99_packet_latency_ns,omitempty"`
MaxPacketLatencyNs int64 `protobuf:"varint,4,opt,name=max_packet_latency_ns,json=maxPacketLatencyNs,proto3" json:"max_packet_latency_ns,omitempty"`
AvgControlLatencyNs int64 `protobuf:"varint,5,opt,name=avg_control_latency_ns,json=avgControlLatencyNs,proto3" json:"avg_control_latency_ns,omitempty"`
P95ControlLatencyNs int64 `protobuf:"varint,6,opt,name=p95_control_latency_ns,json=p95ControlLatencyNs,proto3" json:"p95_control_latency_ns,omitempty"`
// Throughput metrics (11-20)
PacketsPerSecond float64 `protobuf:"fixed64,11,opt,name=packets_per_second,json=packetsPerSecond,proto3" json:"packets_per_second,omitempty"`
BytesPerSecond float64 `protobuf:"fixed64,12,opt,name=bytes_per_second,json=bytesPerSecond,proto3" json:"bytes_per_second,omitempty"`
ControlMessagesPerSec float64 `` /* 131-byte string literal not displayed */
// Error metrics (21-30)
ErrorRate float64 `protobuf:"fixed64,21,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"` // percentage
PacketDrops int64 `protobuf:"varint,22,opt,name=packet_drops,json=packetDrops,proto3" json:"packet_drops,omitempty"`
StreamErrors int64 `protobuf:"varint,23,opt,name=stream_errors,json=streamErrors,proto3" json:"stream_errors,omitempty"`
ConnectionErrors int64 `protobuf:"varint,24,opt,name=connection_errors,json=connectionErrors,proto3" json:"connection_errors,omitempty"`
// Stream health (31-40)
HealthyStreams int64 `protobuf:"varint,31,opt,name=healthy_streams,json=healthyStreams,proto3" json:"healthy_streams,omitempty"`
TotalStreams int64 `protobuf:"varint,32,opt,name=total_streams,json=totalStreams,proto3" json:"total_streams,omitempty"`
ActiveConnections int64 `protobuf:"varint,33,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
UnhealthyStreams int64 `protobuf:"varint,34,opt,name=unhealthy_streams,json=unhealthyStreams,proto3" json:"unhealthy_streams,omitempty"`
StreamUtilization float64 `protobuf:"fixed64,35,opt,name=stream_utilization,json=streamUtilization,proto3" json:"stream_utilization,omitempty"` // percentage
// Circuit breaker metrics (41-50)
CircuitBreakerStates []string `protobuf:"bytes,41,rep,name=circuit_breaker_states,json=circuitBreakerStates,proto3" json:"circuit_breaker_states,omitempty"`
TotalCircuitBreaks int64 `protobuf:"varint,42,opt,name=total_circuit_breaks,json=totalCircuitBreaks,proto3" json:"total_circuit_breaks,omitempty"`
AvgRecoveryTimeNs int64 `protobuf:"varint,43,opt,name=avg_recovery_time_ns,json=avgRecoveryTimeNs,proto3" json:"avg_recovery_time_ns,omitempty"`
// Compression metrics (51-60)
CompressionRatio float64 `protobuf:"fixed64,51,opt,name=compression_ratio,json=compressionRatio,proto3" json:"compression_ratio,omitempty"` // percentage
BytesSaved int64 `protobuf:"varint,52,opt,name=bytes_saved,json=bytesSaved,proto3" json:"bytes_saved,omitempty"`
CompressionTimeNs int64 `protobuf:"varint,53,opt,name=compression_time_ns,json=compressionTimeNs,proto3" json:"compression_time_ns,omitempty"`
DecompressionTimeNs int64 `protobuf:"varint,54,opt,name=decompression_time_ns,json=decompressionTimeNs,proto3" json:"decompression_time_ns,omitempty"`
// Retry metrics (61-70)
TotalRetryAttempts int64 `protobuf:"varint,61,opt,name=total_retry_attempts,json=totalRetryAttempts,proto3" json:"total_retry_attempts,omitempty"`
SuccessfulRetries int64 `protobuf:"varint,62,opt,name=successful_retries,json=successfulRetries,proto3" json:"successful_retries,omitempty"`
FailedRetries int64 `protobuf:"varint,63,opt,name=failed_retries,json=failedRetries,proto3" json:"failed_retries,omitempty"`
RetrySuccessRate float64 `protobuf:"fixed64,64,opt,name=retry_success_rate,json=retrySuccessRate,proto3" json:"retry_success_rate,omitempty"` // percentage
// Connection pool metrics (71-80)
PoolUtilization float64 `protobuf:"fixed64,71,opt,name=pool_utilization,json=poolUtilization,proto3" json:"pool_utilization,omitempty"` // percentage
IdleConnections int64 `protobuf:"varint,72,opt,name=idle_connections,json=idleConnections,proto3" json:"idle_connections,omitempty"`
ConnectionResets int64 `protobuf:"varint,73,opt,name=connection_resets,json=connectionResets,proto3" json:"connection_resets,omitempty"`
// Resource utilization (81-90)
MemoryUsageBytes int64 `protobuf:"varint,81,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
BufferPoolSize int64 `protobuf:"varint,82,opt,name=buffer_pool_size,json=bufferPoolSize,proto3" json:"buffer_pool_size,omitempty"`
BufferPoolHits int64 `protobuf:"varint,83,opt,name=buffer_pool_hits,json=bufferPoolHits,proto3" json:"buffer_pool_hits,omitempty"`
BufferPoolMisses int64 `protobuf:"varint,84,opt,name=buffer_pool_misses,json=bufferPoolMisses,proto3" json:"buffer_pool_misses,omitempty"`
// Metadata and timing (91-100)
LastUpdated int64 `protobuf:"varint,91,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"` // epoch milliseconds
CollectionIntervalNs int64 `protobuf:"varint,92,opt,name=collection_interval_ns,json=collectionIntervalNs,proto3" json:"collection_interval_ns,omitempty"` // nanoseconds
// Runtime metrics (101-110)
RuntimeStats map[string]*ProjectRuntimeStats `` /* 173-byte string literal not displayed */
// contains filtered or unexported fields
}
PerformanceMetrics contains performance data from MetricsCollector
func (*PerformanceMetrics) Descriptor
deprecated
func (*PerformanceMetrics) Descriptor() ([]byte, []int)
Deprecated: Use PerformanceMetrics.ProtoReflect.Descriptor instead.
func (*PerformanceMetrics) GetActiveConnections ¶
func (x *PerformanceMetrics) GetActiveConnections() int64
func (*PerformanceMetrics) GetAvgControlLatencyNs ¶
func (x *PerformanceMetrics) GetAvgControlLatencyNs() int64
func (*PerformanceMetrics) GetAvgPacketLatencyNs ¶
func (x *PerformanceMetrics) GetAvgPacketLatencyNs() int64
func (*PerformanceMetrics) GetAvgRecoveryTimeNs ¶
func (x *PerformanceMetrics) GetAvgRecoveryTimeNs() int64
func (*PerformanceMetrics) GetBufferPoolHits ¶
func (x *PerformanceMetrics) GetBufferPoolHits() int64
func (*PerformanceMetrics) GetBufferPoolMisses ¶
func (x *PerformanceMetrics) GetBufferPoolMisses() int64
func (*PerformanceMetrics) GetBufferPoolSize ¶
func (x *PerformanceMetrics) GetBufferPoolSize() int64
func (*PerformanceMetrics) GetBytesPerSecond ¶
func (x *PerformanceMetrics) GetBytesPerSecond() float64
func (*PerformanceMetrics) GetBytesSaved ¶
func (x *PerformanceMetrics) GetBytesSaved() int64
func (*PerformanceMetrics) GetCircuitBreakerStates ¶
func (x *PerformanceMetrics) GetCircuitBreakerStates() []string
func (*PerformanceMetrics) GetCollectionIntervalNs ¶
func (x *PerformanceMetrics) GetCollectionIntervalNs() int64
func (*PerformanceMetrics) GetCompressionRatio ¶
func (x *PerformanceMetrics) GetCompressionRatio() float64
func (*PerformanceMetrics) GetCompressionTimeNs ¶
func (x *PerformanceMetrics) GetCompressionTimeNs() int64
func (*PerformanceMetrics) GetConnectionErrors ¶
func (x *PerformanceMetrics) GetConnectionErrors() int64
func (*PerformanceMetrics) GetConnectionResets ¶
func (x *PerformanceMetrics) GetConnectionResets() int64
func (*PerformanceMetrics) GetControlMessagesPerSec ¶
func (x *PerformanceMetrics) GetControlMessagesPerSec() float64
func (*PerformanceMetrics) GetDecompressionTimeNs ¶
func (x *PerformanceMetrics) GetDecompressionTimeNs() int64
func (*PerformanceMetrics) GetErrorRate ¶
func (x *PerformanceMetrics) GetErrorRate() float64
func (*PerformanceMetrics) GetFailedRetries ¶
func (x *PerformanceMetrics) GetFailedRetries() int64
func (*PerformanceMetrics) GetHealthyStreams ¶
func (x *PerformanceMetrics) GetHealthyStreams() int64
func (*PerformanceMetrics) GetIdleConnections ¶
func (x *PerformanceMetrics) GetIdleConnections() int64
func (*PerformanceMetrics) GetLastUpdated ¶
func (x *PerformanceMetrics) GetLastUpdated() int64
func (*PerformanceMetrics) GetMaxPacketLatencyNs ¶
func (x *PerformanceMetrics) GetMaxPacketLatencyNs() int64
func (*PerformanceMetrics) GetMemoryUsageBytes ¶
func (x *PerformanceMetrics) GetMemoryUsageBytes() int64
func (*PerformanceMetrics) GetP95ControlLatencyNs ¶
func (x *PerformanceMetrics) GetP95ControlLatencyNs() int64
func (*PerformanceMetrics) GetP95PacketLatencyNs ¶
func (x *PerformanceMetrics) GetP95PacketLatencyNs() int64
func (*PerformanceMetrics) GetP99PacketLatencyNs ¶
func (x *PerformanceMetrics) GetP99PacketLatencyNs() int64
func (*PerformanceMetrics) GetPacketDrops ¶
func (x *PerformanceMetrics) GetPacketDrops() int64
func (*PerformanceMetrics) GetPacketsPerSecond ¶
func (x *PerformanceMetrics) GetPacketsPerSecond() float64
func (*PerformanceMetrics) GetPoolUtilization ¶
func (x *PerformanceMetrics) GetPoolUtilization() float64
func (*PerformanceMetrics) GetRetrySuccessRate ¶
func (x *PerformanceMetrics) GetRetrySuccessRate() float64
func (*PerformanceMetrics) GetRuntimeStats ¶
func (x *PerformanceMetrics) GetRuntimeStats() map[string]*ProjectRuntimeStats
func (*PerformanceMetrics) GetStreamErrors ¶
func (x *PerformanceMetrics) GetStreamErrors() int64
func (*PerformanceMetrics) GetStreamUtilization ¶
func (x *PerformanceMetrics) GetStreamUtilization() float64
func (*PerformanceMetrics) GetSuccessfulRetries ¶
func (x *PerformanceMetrics) GetSuccessfulRetries() int64
func (*PerformanceMetrics) GetTotalCircuitBreaks ¶
func (x *PerformanceMetrics) GetTotalCircuitBreaks() int64
func (*PerformanceMetrics) GetTotalRetryAttempts ¶
func (x *PerformanceMetrics) GetTotalRetryAttempts() int64
func (*PerformanceMetrics) GetTotalStreams ¶
func (x *PerformanceMetrics) GetTotalStreams() int64
func (*PerformanceMetrics) GetUnhealthyStreams ¶
func (x *PerformanceMetrics) GetUnhealthyStreams() int64
func (*PerformanceMetrics) ProtoMessage ¶
func (*PerformanceMetrics) ProtoMessage()
func (*PerformanceMetrics) ProtoReflect ¶
func (x *PerformanceMetrics) ProtoReflect() protoreflect.Message
func (*PerformanceMetrics) Reset ¶
func (x *PerformanceMetrics) Reset()
func (*PerformanceMetrics) String ¶
func (x *PerformanceMetrics) String() string
type PingRequest ¶
type PingRequest struct {
Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
Ping request for health checking
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) GetTimestamp ¶
func (x *PingRequest) GetTimestamp() *timestamppb.Timestamp
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PongResponse ¶
type PongResponse struct {
Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
Pong response
func (*PongResponse) Descriptor
deprecated
func (*PongResponse) Descriptor() ([]byte, []int)
Deprecated: Use PongResponse.ProtoReflect.Descriptor instead.
func (*PongResponse) GetTimestamp ¶
func (x *PongResponse) GetTimestamp() *timestamppb.Timestamp
func (*PongResponse) ProtoMessage ¶
func (*PongResponse) ProtoMessage()
func (*PongResponse) ProtoReflect ¶
func (x *PongResponse) ProtoReflect() protoreflect.Message
func (*PongResponse) Reset ¶
func (x *PongResponse) Reset()
func (*PongResponse) String ¶
func (x *PongResponse) String() string
type ProjectRuntimeStats ¶
type ProjectRuntimeStats struct {
// Runtime identity (1-10)
RuntimeId string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
RuntimeName string `protobuf:"bytes,2,opt,name=runtime_name,json=runtimeName,proto3" json:"runtime_name,omitempty"`
Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
DeploymentId string `protobuf:"bytes,4,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
// Runtime state (11-20)
Status string `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
Paused bool `protobuf:"varint,12,opt,name=paused,proto3" json:"paused,omitempty"`
PausedTime int64 `protobuf:"varint,13,opt,name=paused_time,json=pausedTime,proto3" json:"paused_time,omitempty"` // epoch milliseconds, 0 if not paused
StartedTime int64 `protobuf:"varint,14,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"` // epoch milliseconds
RestartCount int64 `protobuf:"varint,15,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
// CPU metrics (21-30)
CpuUsagePercent float64 `protobuf:"fixed64,21,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"`
CpuUsageTotalNs uint64 `protobuf:"varint,22,opt,name=cpu_usage_total_ns,json=cpuUsageTotalNs,proto3" json:"cpu_usage_total_ns,omitempty"`
CpuUsageKernelNs uint64 `protobuf:"varint,23,opt,name=cpu_usage_kernel_ns,json=cpuUsageKernelNs,proto3" json:"cpu_usage_kernel_ns,omitempty"`
CpuUsageUserNs uint64 `protobuf:"varint,24,opt,name=cpu_usage_user_ns,json=cpuUsageUserNs,proto3" json:"cpu_usage_user_ns,omitempty"`
CpuThrottledPeriods uint64 `protobuf:"varint,25,opt,name=cpu_throttled_periods,json=cpuThrottledPeriods,proto3" json:"cpu_throttled_periods,omitempty"`
CpuThrottledTimeNs uint64 `protobuf:"varint,26,opt,name=cpu_throttled_time_ns,json=cpuThrottledTimeNs,proto3" json:"cpu_throttled_time_ns,omitempty"`
CpuLimit float64 `protobuf:"fixed64,27,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
// Memory metrics (31-40)
MemoryUsageBytes uint64 `protobuf:"varint,31,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
MemoryLimitBytes uint64 `protobuf:"varint,32,opt,name=memory_limit_bytes,json=memoryLimitBytes,proto3" json:"memory_limit_bytes,omitempty"`
MemoryUsagePercent float64 `protobuf:"fixed64,33,opt,name=memory_usage_percent,json=memoryUsagePercent,proto3" json:"memory_usage_percent,omitempty"`
MemoryMaxUsageBytes uint64 `protobuf:"varint,34,opt,name=memory_max_usage_bytes,json=memoryMaxUsageBytes,proto3" json:"memory_max_usage_bytes,omitempty"`
MemoryCacheBytes uint64 `protobuf:"varint,35,opt,name=memory_cache_bytes,json=memoryCacheBytes,proto3" json:"memory_cache_bytes,omitempty"`
MemoryRssBytes uint64 `protobuf:"varint,36,opt,name=memory_rss_bytes,json=memoryRssBytes,proto3" json:"memory_rss_bytes,omitempty"`
MemorySwapBytes uint64 `protobuf:"varint,37,opt,name=memory_swap_bytes,json=memorySwapBytes,proto3" json:"memory_swap_bytes,omitempty"`
MemorySwapLimitBytes uint64 `` /* 127-byte string literal not displayed */
OomKills uint64 `protobuf:"varint,39,opt,name=oom_kills,json=oomKills,proto3" json:"oom_kills,omitempty"`
// Network metrics (41-50)
NetworkRxBytes uint64 `protobuf:"varint,41,opt,name=network_rx_bytes,json=networkRxBytes,proto3" json:"network_rx_bytes,omitempty"`
NetworkTxBytes uint64 `protobuf:"varint,42,opt,name=network_tx_bytes,json=networkTxBytes,proto3" json:"network_tx_bytes,omitempty"`
NetworkRxPackets uint64 `protobuf:"varint,43,opt,name=network_rx_packets,json=networkRxPackets,proto3" json:"network_rx_packets,omitempty"`
NetworkTxPackets uint64 `protobuf:"varint,44,opt,name=network_tx_packets,json=networkTxPackets,proto3" json:"network_tx_packets,omitempty"`
NetworkRxErrors uint64 `protobuf:"varint,45,opt,name=network_rx_errors,json=networkRxErrors,proto3" json:"network_rx_errors,omitempty"`
NetworkTxErrors uint64 `protobuf:"varint,46,opt,name=network_tx_errors,json=networkTxErrors,proto3" json:"network_tx_errors,omitempty"`
NetworkRxDropped uint64 `protobuf:"varint,47,opt,name=network_rx_dropped,json=networkRxDropped,proto3" json:"network_rx_dropped,omitempty"`
NetworkTxDropped uint64 `protobuf:"varint,48,opt,name=network_tx_dropped,json=networkTxDropped,proto3" json:"network_tx_dropped,omitempty"`
// Disk I/O metrics (51-60)
BlockIoReadBytes uint64 `protobuf:"varint,51,opt,name=block_io_read_bytes,json=blockIoReadBytes,proto3" json:"block_io_read_bytes,omitempty"`
BlockIoWriteBytes uint64 `protobuf:"varint,52,opt,name=block_io_write_bytes,json=blockIoWriteBytes,proto3" json:"block_io_write_bytes,omitempty"`
BlockIoReadOps uint64 `protobuf:"varint,53,opt,name=block_io_read_ops,json=blockIoReadOps,proto3" json:"block_io_read_ops,omitempty"`
BlockIoWriteOps uint64 `protobuf:"varint,54,opt,name=block_io_write_ops,json=blockIoWriteOps,proto3" json:"block_io_write_ops,omitempty"`
// Process metrics (61-70)
PidsCurrent uint64 `protobuf:"varint,61,opt,name=pids_current,json=pidsCurrent,proto3" json:"pids_current,omitempty"`
PidsLimit uint64 `protobuf:"varint,62,opt,name=pids_limit,json=pidsLimit,proto3" json:"pids_limit,omitempty"`
// Network interface information (71-80)
Ipv4Address string `protobuf:"bytes,71,opt,name=ipv4_address,json=ipv4Address,proto3" json:"ipv4_address,omitempty"`
Ipv6Address string `protobuf:"bytes,72,opt,name=ipv6_address,json=ipv6Address,proto3" json:"ipv6_address,omitempty"`
Hostname string `protobuf:"bytes,73,opt,name=hostname,proto3" json:"hostname,omitempty"`
// Runtime metrics (81-90)
InflightRequests int64 `protobuf:"varint,81,opt,name=inflight_requests,json=inflightRequests,proto3" json:"inflight_requests,omitempty"`
// Health and timing (91-100)
Healthy bool `protobuf:"varint,91,opt,name=healthy,proto3" json:"healthy,omitempty"`
LastUpdated int64 `protobuf:"varint,92,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"` // epoch milliseconds
// contains filtered or unexported fields
}
ProjectRuntimeStats contains real-time project runtime statistics
func (*ProjectRuntimeStats) Descriptor
deprecated
func (*ProjectRuntimeStats) Descriptor() ([]byte, []int)
Deprecated: Use ProjectRuntimeStats.ProtoReflect.Descriptor instead.
func (*ProjectRuntimeStats) GetBlockIoReadBytes ¶
func (x *ProjectRuntimeStats) GetBlockIoReadBytes() uint64
func (*ProjectRuntimeStats) GetBlockIoReadOps ¶
func (x *ProjectRuntimeStats) GetBlockIoReadOps() uint64
func (*ProjectRuntimeStats) GetBlockIoWriteBytes ¶
func (x *ProjectRuntimeStats) GetBlockIoWriteBytes() uint64
func (*ProjectRuntimeStats) GetBlockIoWriteOps ¶
func (x *ProjectRuntimeStats) GetBlockIoWriteOps() uint64
func (*ProjectRuntimeStats) GetCpuLimit ¶
func (x *ProjectRuntimeStats) GetCpuLimit() float64
func (*ProjectRuntimeStats) GetCpuThrottledPeriods ¶
func (x *ProjectRuntimeStats) GetCpuThrottledPeriods() uint64
func (*ProjectRuntimeStats) GetCpuThrottledTimeNs ¶
func (x *ProjectRuntimeStats) GetCpuThrottledTimeNs() uint64
func (*ProjectRuntimeStats) GetCpuUsageKernelNs ¶
func (x *ProjectRuntimeStats) GetCpuUsageKernelNs() uint64
func (*ProjectRuntimeStats) GetCpuUsagePercent ¶
func (x *ProjectRuntimeStats) GetCpuUsagePercent() float64
func (*ProjectRuntimeStats) GetCpuUsageTotalNs ¶
func (x *ProjectRuntimeStats) GetCpuUsageTotalNs() uint64
func (*ProjectRuntimeStats) GetCpuUsageUserNs ¶
func (x *ProjectRuntimeStats) GetCpuUsageUserNs() uint64
func (*ProjectRuntimeStats) GetDeploymentId ¶
func (x *ProjectRuntimeStats) GetDeploymentId() string
func (*ProjectRuntimeStats) GetHealthy ¶
func (x *ProjectRuntimeStats) GetHealthy() bool
func (*ProjectRuntimeStats) GetHostname ¶
func (x *ProjectRuntimeStats) GetHostname() string
func (*ProjectRuntimeStats) GetImage ¶
func (x *ProjectRuntimeStats) GetImage() string
func (*ProjectRuntimeStats) GetInflightRequests ¶
func (x *ProjectRuntimeStats) GetInflightRequests() int64
func (*ProjectRuntimeStats) GetIpv4Address ¶
func (x *ProjectRuntimeStats) GetIpv4Address() string
func (*ProjectRuntimeStats) GetIpv6Address ¶
func (x *ProjectRuntimeStats) GetIpv6Address() string
func (*ProjectRuntimeStats) GetLastUpdated ¶
func (x *ProjectRuntimeStats) GetLastUpdated() int64
func (*ProjectRuntimeStats) GetMemoryCacheBytes ¶
func (x *ProjectRuntimeStats) GetMemoryCacheBytes() uint64
func (*ProjectRuntimeStats) GetMemoryLimitBytes ¶
func (x *ProjectRuntimeStats) GetMemoryLimitBytes() uint64
func (*ProjectRuntimeStats) GetMemoryMaxUsageBytes ¶
func (x *ProjectRuntimeStats) GetMemoryMaxUsageBytes() uint64
func (*ProjectRuntimeStats) GetMemoryRssBytes ¶
func (x *ProjectRuntimeStats) GetMemoryRssBytes() uint64
func (*ProjectRuntimeStats) GetMemorySwapBytes ¶
func (x *ProjectRuntimeStats) GetMemorySwapBytes() uint64
func (*ProjectRuntimeStats) GetMemorySwapLimitBytes ¶
func (x *ProjectRuntimeStats) GetMemorySwapLimitBytes() uint64
func (*ProjectRuntimeStats) GetMemoryUsageBytes ¶
func (x *ProjectRuntimeStats) GetMemoryUsageBytes() uint64
func (*ProjectRuntimeStats) GetMemoryUsagePercent ¶
func (x *ProjectRuntimeStats) GetMemoryUsagePercent() float64
func (*ProjectRuntimeStats) GetNetworkRxBytes ¶
func (x *ProjectRuntimeStats) GetNetworkRxBytes() uint64
func (*ProjectRuntimeStats) GetNetworkRxDropped ¶
func (x *ProjectRuntimeStats) GetNetworkRxDropped() uint64
func (*ProjectRuntimeStats) GetNetworkRxErrors ¶
func (x *ProjectRuntimeStats) GetNetworkRxErrors() uint64
func (*ProjectRuntimeStats) GetNetworkRxPackets ¶
func (x *ProjectRuntimeStats) GetNetworkRxPackets() uint64
func (*ProjectRuntimeStats) GetNetworkTxBytes ¶
func (x *ProjectRuntimeStats) GetNetworkTxBytes() uint64
func (*ProjectRuntimeStats) GetNetworkTxDropped ¶
func (x *ProjectRuntimeStats) GetNetworkTxDropped() uint64
func (*ProjectRuntimeStats) GetNetworkTxErrors ¶
func (x *ProjectRuntimeStats) GetNetworkTxErrors() uint64
func (*ProjectRuntimeStats) GetNetworkTxPackets ¶
func (x *ProjectRuntimeStats) GetNetworkTxPackets() uint64
func (*ProjectRuntimeStats) GetOomKills ¶
func (x *ProjectRuntimeStats) GetOomKills() uint64
func (*ProjectRuntimeStats) GetPaused ¶
func (x *ProjectRuntimeStats) GetPaused() bool
func (*ProjectRuntimeStats) GetPausedTime ¶
func (x *ProjectRuntimeStats) GetPausedTime() int64
func (*ProjectRuntimeStats) GetPidsCurrent ¶
func (x *ProjectRuntimeStats) GetPidsCurrent() uint64
func (*ProjectRuntimeStats) GetPidsLimit ¶
func (x *ProjectRuntimeStats) GetPidsLimit() uint64
func (*ProjectRuntimeStats) GetRestartCount ¶
func (x *ProjectRuntimeStats) GetRestartCount() int64
func (*ProjectRuntimeStats) GetRuntimeId ¶
func (x *ProjectRuntimeStats) GetRuntimeId() string
func (*ProjectRuntimeStats) GetRuntimeName ¶
func (x *ProjectRuntimeStats) GetRuntimeName() string
func (*ProjectRuntimeStats) GetStartedTime ¶
func (x *ProjectRuntimeStats) GetStartedTime() int64
func (*ProjectRuntimeStats) GetStatus ¶
func (x *ProjectRuntimeStats) GetStatus() string
func (*ProjectRuntimeStats) ProtoMessage ¶
func (*ProjectRuntimeStats) ProtoMessage()
func (*ProjectRuntimeStats) ProtoReflect ¶
func (x *ProjectRuntimeStats) ProtoReflect() protoreflect.Message
func (*ProjectRuntimeStats) Reset ¶
func (x *ProjectRuntimeStats) Reset()
func (*ProjectRuntimeStats) String ¶
func (x *ProjectRuntimeStats) String() string
type ProtocolEvent ¶
type ProtocolEvent struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for the event
Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // Event type being sent
Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // Event payload data
// contains filtered or unexported fields
}
Generic protocol event (server-initiated)
func (*ProtocolEvent) Descriptor
deprecated
func (*ProtocolEvent) Descriptor() ([]byte, []int)
Deprecated: Use ProtocolEvent.ProtoReflect.Descriptor instead.
func (*ProtocolEvent) GetEvent ¶
func (x *ProtocolEvent) GetEvent() string
func (*ProtocolEvent) GetId ¶
func (x *ProtocolEvent) GetId() string
func (*ProtocolEvent) GetPayload ¶
func (x *ProtocolEvent) GetPayload() []byte
func (*ProtocolEvent) ProtoMessage ¶
func (*ProtocolEvent) ProtoMessage()
func (*ProtocolEvent) ProtoReflect ¶
func (x *ProtocolEvent) ProtoReflect() protoreflect.Message
func (*ProtocolEvent) Reset ¶
func (x *ProtocolEvent) Reset()
func (*ProtocolEvent) String ¶
func (x *ProtocolEvent) String() string
type ProtocolResponse ¶
type ProtocolResponse struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for the response
Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // Event type this response is for
Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"` // Whether the operation was successful
Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` // Error message if operation failed
Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"` // Optional response payload data
// contains filtered or unexported fields
}
Generic protocol response
func (*ProtocolResponse) Descriptor
deprecated
func (*ProtocolResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProtocolResponse.ProtoReflect.Descriptor instead.
func (*ProtocolResponse) GetError ¶
func (x *ProtocolResponse) GetError() string
func (*ProtocolResponse) GetEvent ¶
func (x *ProtocolResponse) GetEvent() string
func (*ProtocolResponse) GetId ¶
func (x *ProtocolResponse) GetId() string
func (*ProtocolResponse) GetPayload ¶
func (x *ProtocolResponse) GetPayload() []byte
func (*ProtocolResponse) GetSuccess ¶
func (x *ProtocolResponse) GetSuccess() bool
func (*ProtocolResponse) ProtoMessage ¶
func (*ProtocolResponse) ProtoMessage()
func (*ProtocolResponse) ProtoReflect ¶
func (x *ProtocolResponse) ProtoReflect() protoreflect.Message
func (*ProtocolResponse) Reset ¶
func (x *ProtocolResponse) Reset()
func (*ProtocolResponse) String ¶
func (x *ProtocolResponse) String() string
type ProvisionRequest ¶
type ProvisionRequest struct {
Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"` // the region for the client
AvailabilityZone string `protobuf:"bytes,2,opt,name=availability_zone,json=availabilityZone,proto3" json:"availability_zone,omitempty"` // the availability zone for the client
Provider string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"` // the provider for the client
InstanceId string `protobuf:"bytes,4,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // the unique client id for the server
PrivateIpv4 string `protobuf:"bytes,5,opt,name=private_ipv4,json=privateIpv4,proto3" json:"private_ipv4,omitempty"` // the ip v4 address to use for the server
PublicKey string `protobuf:"bytes,6,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // the public key to use for the server
Hostname string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"` // the hostname of the server
ErrorMessage string `protobuf:"bytes,8,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // the error message if the client has an error
// during boot or provisioning
Ephemeral bool `protobuf:"varint,9,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"` // if the client is ephemeral
Capabilities *ClientCapabilities `protobuf:"bytes,10,opt,name=capabilities,proto3" json:"capabilities,omitempty"` // the client capabilities requested
// contains filtered or unexported fields
}
func (*ProvisionRequest) Descriptor
deprecated
func (*ProvisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProvisionRequest.ProtoReflect.Descriptor instead.
func (*ProvisionRequest) GetAvailabilityZone ¶
func (x *ProvisionRequest) GetAvailabilityZone() string
func (*ProvisionRequest) GetCapabilities ¶ added in v1.0.96
func (x *ProvisionRequest) GetCapabilities() *ClientCapabilities
func (*ProvisionRequest) GetEphemeral ¶
func (x *ProvisionRequest) GetEphemeral() bool
func (*ProvisionRequest) GetErrorMessage ¶
func (x *ProvisionRequest) GetErrorMessage() string
func (*ProvisionRequest) GetHostname ¶
func (x *ProvisionRequest) GetHostname() string
func (*ProvisionRequest) GetInstanceId ¶
func (x *ProvisionRequest) GetInstanceId() string
func (*ProvisionRequest) GetPrivateIpv4 ¶
func (x *ProvisionRequest) GetPrivateIpv4() string
func (*ProvisionRequest) GetProvider ¶
func (x *ProvisionRequest) GetProvider() string
func (*ProvisionRequest) GetPublicKey ¶
func (x *ProvisionRequest) GetPublicKey() string
func (*ProvisionRequest) GetRegion ¶
func (x *ProvisionRequest) GetRegion() string
func (*ProvisionRequest) ProtoMessage ¶
func (*ProvisionRequest) ProtoMessage()
func (*ProvisionRequest) ProtoReflect ¶
func (x *ProvisionRequest) ProtoReflect() protoreflect.Message
func (*ProvisionRequest) Reset ¶
func (x *ProvisionRequest) Reset()
func (*ProvisionRequest) String ¶
func (x *ProvisionRequest) String() string
type ProvisionResponse ¶
type ProvisionResponse struct {
CaCertificate []byte `protobuf:"bytes,1,opt,name=ca_certificate,json=caCertificate,proto3" json:"ca_certificate,omitempty"` // the CA certificate to trust for self-signed server certificates
Certificate []byte `protobuf:"bytes,2,opt,name=certificate,proto3" json:"certificate,omitempty"` // the cert to use for the server
PrivateKey []byte `protobuf:"bytes,3,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"` // the key to use for the server
Expires *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"` // the expiration time of the certificates
ClientToken string `protobuf:"bytes,5,opt,name=client_token,json=clientToken,proto3" json:"client_token,omitempty"` // the client token to use for communication with APIs
OrgId string `protobuf:"bytes,6,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` // the organization id for the client
ClusterId string `protobuf:"bytes,7,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // the cluster id for the client
DeploymentPrivateKey []byte `protobuf:"bytes,8,opt,name=deployment_private_key,json=deploymentPrivateKey,proto3" json:"deployment_private_key,omitempty"` // the sourcecode private key for the organization, usually nil unless
// contains filtered or unexported fields
}
func (*ProvisionResponse) Descriptor
deprecated
func (*ProvisionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProvisionResponse.ProtoReflect.Descriptor instead.
func (*ProvisionResponse) GetCaCertificate ¶
func (x *ProvisionResponse) GetCaCertificate() []byte
func (*ProvisionResponse) GetCertificate ¶
func (x *ProvisionResponse) GetCertificate() []byte
func (*ProvisionResponse) GetClientToken ¶ added in v1.0.94
func (x *ProvisionResponse) GetClientToken() string
func (*ProvisionResponse) GetClusterId ¶
func (x *ProvisionResponse) GetClusterId() string
func (*ProvisionResponse) GetDeploymentPrivateKey ¶
func (x *ProvisionResponse) GetDeploymentPrivateKey() []byte
func (*ProvisionResponse) GetExpires ¶
func (x *ProvisionResponse) GetExpires() *timestamppb.Timestamp
func (*ProvisionResponse) GetOrgId ¶
func (x *ProvisionResponse) GetOrgId() string
func (*ProvisionResponse) GetPrivateKey ¶
func (x *ProvisionResponse) GetPrivateKey() []byte
func (*ProvisionResponse) ProtoMessage ¶
func (*ProvisionResponse) ProtoMessage()
func (*ProvisionResponse) ProtoReflect ¶
func (x *ProvisionResponse) ProtoReflect() protoreflect.Message
func (*ProvisionResponse) Reset ¶
func (x *ProvisionResponse) Reset()
func (*ProvisionResponse) String ¶
func (x *ProvisionResponse) String() string
type ReportRequest ¶
type ReportRequest struct {
Metrics *ServerMetrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` // Comprehensive server metrics and performance data
// contains filtered or unexported fields
}
Report request for metrics
func (*ReportRequest) Descriptor
deprecated
func (*ReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportRequest.ProtoReflect.Descriptor instead.
func (*ReportRequest) GetMetrics ¶
func (x *ReportRequest) GetMetrics() *ServerMetrics
func (*ReportRequest) ProtoMessage ¶
func (*ReportRequest) ProtoMessage()
func (*ReportRequest) ProtoReflect ¶
func (x *ReportRequest) ProtoReflect() protoreflect.Message
func (*ReportRequest) Reset ¶
func (x *ReportRequest) Reset()
func (*ReportRequest) String ¶
func (x *ReportRequest) String() string
type ResourceRequirements ¶
type ResourceRequirements struct {
MemoryLimit int64 `protobuf:"varint,1,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"` // Maximum memory in bytes
CpuLimit int64 `protobuf:"varint,2,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"` // Maximum CPU in millicores (1000 = 1 core)
MemoryRequest int64 `protobuf:"varint,3,opt,name=memory_request,json=memoryRequest,proto3" json:"memory_request,omitempty"` // Requested memory in bytes
CpuRequest int64 `protobuf:"varint,4,opt,name=cpu_request,json=cpuRequest,proto3" json:"cpu_request,omitempty"` // Requested CPU in millicores
DiskLimit int64 `protobuf:"varint,5,opt,name=disk_limit,json=diskLimit,proto3" json:"disk_limit,omitempty"` // Maximum storage in bytes
DiskRequest int64 `protobuf:"varint,6,opt,name=disk_request,json=diskRequest,proto3" json:"disk_request,omitempty"` // Requested storage in bytes
// contains filtered or unexported fields
}
func (*ResourceRequirements) Descriptor
deprecated
func (*ResourceRequirements) Descriptor() ([]byte, []int)
Deprecated: Use ResourceRequirements.ProtoReflect.Descriptor instead.
func (*ResourceRequirements) GetCpuLimit ¶
func (x *ResourceRequirements) GetCpuLimit() int64
func (*ResourceRequirements) GetCpuRequest ¶
func (x *ResourceRequirements) GetCpuRequest() int64
func (*ResourceRequirements) GetDiskLimit ¶ added in v1.0.113
func (x *ResourceRequirements) GetDiskLimit() int64
func (*ResourceRequirements) GetDiskRequest ¶ added in v1.0.113
func (x *ResourceRequirements) GetDiskRequest() int64
func (*ResourceRequirements) GetMemoryLimit ¶
func (x *ResourceRequirements) GetMemoryLimit() int64
func (*ResourceRequirements) GetMemoryRequest ¶
func (x *ResourceRequirements) GetMemoryRequest() int64
func (*ResourceRequirements) ProtoMessage ¶
func (*ResourceRequirements) ProtoMessage()
func (*ResourceRequirements) ProtoReflect ¶
func (x *ResourceRequirements) ProtoReflect() protoreflect.Message
func (*ResourceRequirements) Reset ¶
func (x *ResourceRequirements) Reset()
func (*ResourceRequirements) String ¶
func (x *ResourceRequirements) String() string
type ResumeRequest ¶
type ResumeRequest struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for resuming the session
// contains filtered or unexported fields
}
Resume request
func (*ResumeRequest) Descriptor
deprecated
func (*ResumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.
func (*ResumeRequest) GetReason ¶
func (x *ResumeRequest) GetReason() string
func (*ResumeRequest) ProtoMessage ¶
func (*ResumeRequest) ProtoMessage()
func (*ResumeRequest) ProtoReflect ¶
func (x *ResumeRequest) ProtoReflect() protoreflect.Message
func (*ResumeRequest) Reset ¶
func (x *ResumeRequest) Reset()
func (*ResumeRequest) String ¶
func (x *ResumeRequest) String() string
type RouteDeploymentRequest ¶
type RouteDeploymentRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Unique identifier for the deployment
Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"` // Deprecated: unused and will be removed
VirtualIp string `protobuf:"bytes,3,opt,name=virtual_ip,json=virtualIp,proto3" json:"virtual_ip,omitempty"` // Hadron virtual IP for the deployment
// contains filtered or unexported fields
}
func (*RouteDeploymentRequest) Descriptor
deprecated
func (*RouteDeploymentRequest) Descriptor() ([]byte, []int)
Deprecated: Use RouteDeploymentRequest.ProtoReflect.Descriptor instead.
func (*RouteDeploymentRequest) GetDeploymentId ¶
func (x *RouteDeploymentRequest) GetDeploymentId() string
func (*RouteDeploymentRequest) GetHostname ¶
func (x *RouteDeploymentRequest) GetHostname() string
func (*RouteDeploymentRequest) GetVirtualIp ¶
func (x *RouteDeploymentRequest) GetVirtualIp() string
func (*RouteDeploymentRequest) ProtoMessage ¶
func (*RouteDeploymentRequest) ProtoMessage()
func (*RouteDeploymentRequest) ProtoReflect ¶
func (x *RouteDeploymentRequest) ProtoReflect() protoreflect.Message
func (*RouteDeploymentRequest) Reset ¶
func (x *RouteDeploymentRequest) Reset()
func (*RouteDeploymentRequest) String ¶
func (x *RouteDeploymentRequest) String() string
type RouteDeploymentResponse ¶
type RouteDeploymentResponse struct {
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
// contains filtered or unexported fields
}
func (*RouteDeploymentResponse) Descriptor
deprecated
func (*RouteDeploymentResponse) Descriptor() ([]byte, []int)
Deprecated: Use RouteDeploymentResponse.ProtoReflect.Descriptor instead.
func (*RouteDeploymentResponse) GetIp ¶
func (x *RouteDeploymentResponse) GetIp() string
func (*RouteDeploymentResponse) ProtoMessage ¶
func (*RouteDeploymentResponse) ProtoMessage()
func (*RouteDeploymentResponse) ProtoReflect ¶
func (x *RouteDeploymentResponse) ProtoReflect() protoreflect.Message
func (*RouteDeploymentResponse) Reset ¶
func (x *RouteDeploymentResponse) Reset()
func (*RouteDeploymentResponse) String ¶
func (x *RouteDeploymentResponse) String() string
type RouteSandboxRequest ¶ added in v1.0.136
type RouteSandboxRequest struct {
SandboxId string `protobuf:"bytes,1,opt,name=sandbox_id,json=sandboxId,proto3" json:"sandbox_id,omitempty"`
VirtualIp string `protobuf:"bytes,2,opt,name=virtual_ip,json=virtualIp,proto3" json:"virtual_ip,omitempty"` // Hadron virtual IP for the sandbox
// contains filtered or unexported fields
}
func (*RouteSandboxRequest) Descriptor
deprecated
added in
v1.0.136
func (*RouteSandboxRequest) Descriptor() ([]byte, []int)
Deprecated: Use RouteSandboxRequest.ProtoReflect.Descriptor instead.
func (*RouteSandboxRequest) GetSandboxId ¶ added in v1.0.136
func (x *RouteSandboxRequest) GetSandboxId() string
func (*RouteSandboxRequest) GetVirtualIp ¶ added in v1.0.136
func (x *RouteSandboxRequest) GetVirtualIp() string
func (*RouteSandboxRequest) ProtoMessage ¶ added in v1.0.136
func (*RouteSandboxRequest) ProtoMessage()
func (*RouteSandboxRequest) ProtoReflect ¶ added in v1.0.136
func (x *RouteSandboxRequest) ProtoReflect() protoreflect.Message
func (*RouteSandboxRequest) Reset ¶ added in v1.0.136
func (x *RouteSandboxRequest) Reset()
func (*RouteSandboxRequest) String ¶ added in v1.0.136
func (x *RouteSandboxRequest) String() string
type RouteSandboxResponse ¶ added in v1.0.136
type RouteSandboxResponse struct {
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
// contains filtered or unexported fields
}
func (*RouteSandboxResponse) Descriptor
deprecated
added in
v1.0.136
func (*RouteSandboxResponse) Descriptor() ([]byte, []int)
Deprecated: Use RouteSandboxResponse.ProtoReflect.Descriptor instead.
func (*RouteSandboxResponse) GetIp ¶ added in v1.0.136
func (x *RouteSandboxResponse) GetIp() string
func (*RouteSandboxResponse) ProtoMessage ¶ added in v1.0.136
func (*RouteSandboxResponse) ProtoMessage()
func (*RouteSandboxResponse) ProtoReflect ¶ added in v1.0.136
func (x *RouteSandboxResponse) ProtoReflect() protoreflect.Message
func (*RouteSandboxResponse) Reset ¶ added in v1.0.136
func (x *RouteSandboxResponse) Reset()
func (*RouteSandboxResponse) String ¶ added in v1.0.136
func (x *RouteSandboxResponse) String() string
type ServerMetrics ¶
type ServerMetrics struct {
// Basic server metrics (1-10)
StartTime int64 `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // epoch milliseconds
Uptime uint64 `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty"` // milliseconds since start
ConnectedTime int64 `protobuf:"varint,3,opt,name=connected_time,json=connectedTime,proto3" json:"connected_time,omitempty"` // epoch milliseconds (optional)
LastMessageTime int64 `protobuf:"varint,4,opt,name=last_message_time,json=lastMessageTime,proto3" json:"last_message_time,omitempty"` // epoch milliseconds (optional)
// Connection metrics (11-20)
IsConnected bool `protobuf:"varint,11,opt,name=is_connected,json=isConnected,proto3" json:"is_connected,omitempty"`
ReconnectCount int64 `protobuf:"varint,12,opt,name=reconnect_count,json=reconnectCount,proto3" json:"reconnect_count,omitempty"`
TotalConnections int64 `protobuf:"varint,13,opt,name=total_connections,json=totalConnections,proto3" json:"total_connections,omitempty"`
// Component metrics (21-40)
GrpcMetrics *GRPCConnectionMetrics `protobuf:"bytes,21,opt,name=grpc_metrics,json=grpcMetrics,proto3" json:"grpc_metrics,omitempty"`
Performance *PerformanceMetrics `protobuf:"bytes,22,opt,name=performance,proto3" json:"performance,omitempty"`
MessageStats *MessageStatistics `protobuf:"bytes,23,opt,name=message_stats,json=messageStats,proto3" json:"message_stats,omitempty"`
SystemMetrics *SystemResourceMetrics `protobuf:"bytes,24,opt,name=system_metrics,json=systemMetrics,proto3" json:"system_metrics,omitempty"`
// Historical data (41-50)
HistoricalData *HistoricalMetrics `protobuf:"bytes,41,opt,name=historical_data,json=historicalData,proto3" json:"historical_data,omitempty"`
// contains filtered or unexported fields
}
Enhanced ServerMetrics with comprehensive performance and health data
func (*ServerMetrics) Descriptor
deprecated
func (*ServerMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ServerMetrics.ProtoReflect.Descriptor instead.
func (*ServerMetrics) GetConnectedTime ¶
func (x *ServerMetrics) GetConnectedTime() int64
func (*ServerMetrics) GetGrpcMetrics ¶
func (x *ServerMetrics) GetGrpcMetrics() *GRPCConnectionMetrics
func (*ServerMetrics) GetHistoricalData ¶
func (x *ServerMetrics) GetHistoricalData() *HistoricalMetrics
func (*ServerMetrics) GetIsConnected ¶
func (x *ServerMetrics) GetIsConnected() bool
func (*ServerMetrics) GetLastMessageTime ¶
func (x *ServerMetrics) GetLastMessageTime() int64
func (*ServerMetrics) GetMessageStats ¶
func (x *ServerMetrics) GetMessageStats() *MessageStatistics
func (*ServerMetrics) GetPerformance ¶
func (x *ServerMetrics) GetPerformance() *PerformanceMetrics
func (*ServerMetrics) GetReconnectCount ¶
func (x *ServerMetrics) GetReconnectCount() int64
func (*ServerMetrics) GetStartTime ¶
func (x *ServerMetrics) GetStartTime() int64
func (*ServerMetrics) GetSystemMetrics ¶
func (x *ServerMetrics) GetSystemMetrics() *SystemResourceMetrics
func (*ServerMetrics) GetTotalConnections ¶
func (x *ServerMetrics) GetTotalConnections() int64
func (*ServerMetrics) GetUptime ¶
func (x *ServerMetrics) GetUptime() uint64
func (*ServerMetrics) ProtoMessage ¶
func (*ServerMetrics) ProtoMessage()
func (*ServerMetrics) ProtoReflect ¶
func (x *ServerMetrics) ProtoReflect() protoreflect.Message
func (*ServerMetrics) Reset ¶
func (x *ServerMetrics) Reset()
func (*ServerMetrics) String ¶
func (x *ServerMetrics) String() string
type SystemResourceMetrics ¶
type SystemResourceMetrics struct {
// Memory metrics (1-10)
MemoryUsageBytes int64 `protobuf:"varint,1,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
MemoryUsageMb float64 `protobuf:"fixed64,2,opt,name=memory_usage_mb,json=memoryUsageMb,proto3" json:"memory_usage_mb,omitempty"`
AllocatedMemory int64 `protobuf:"varint,3,opt,name=allocated_memory,json=allocatedMemory,proto3" json:"allocated_memory,omitempty"`
GcPauseTimeNs int64 `protobuf:"varint,4,opt,name=gc_pause_time_ns,json=gcPauseTimeNs,proto3" json:"gc_pause_time_ns,omitempty"`
NumGoroutines int32 `protobuf:"varint,5,opt,name=num_goroutines,json=numGoroutines,proto3" json:"num_goroutines,omitempty"`
// CPU metrics (11-20)
CpuUsagePercent float64 `protobuf:"fixed64,11,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"`
// Buffer pool metrics (21-30)
BufferPoolSize int64 `protobuf:"varint,21,opt,name=buffer_pool_size,json=bufferPoolSize,proto3" json:"buffer_pool_size,omitempty"`
BufferPoolHits int64 `protobuf:"varint,22,opt,name=buffer_pool_hits,json=bufferPoolHits,proto3" json:"buffer_pool_hits,omitempty"`
BufferPoolMisses int64 `protobuf:"varint,23,opt,name=buffer_pool_misses,json=bufferPoolMisses,proto3" json:"buffer_pool_misses,omitempty"`
BufferPoolHitRate float64 `protobuf:"fixed64,24,opt,name=buffer_pool_hit_rate,json=bufferPoolHitRate,proto3" json:"buffer_pool_hit_rate,omitempty"` // percentage
// File descriptor metrics (31-40)
OpenFileDescriptors int32 `protobuf:"varint,31,opt,name=open_file_descriptors,json=openFileDescriptors,proto3" json:"open_file_descriptors,omitempty"`
// contains filtered or unexported fields
}
SystemResourceMetrics contains system resource utilization
func (*SystemResourceMetrics) Descriptor
deprecated
func (*SystemResourceMetrics) Descriptor() ([]byte, []int)
Deprecated: Use SystemResourceMetrics.ProtoReflect.Descriptor instead.
func (*SystemResourceMetrics) GetAllocatedMemory ¶
func (x *SystemResourceMetrics) GetAllocatedMemory() int64
func (*SystemResourceMetrics) GetBufferPoolHitRate ¶
func (x *SystemResourceMetrics) GetBufferPoolHitRate() float64
func (*SystemResourceMetrics) GetBufferPoolHits ¶
func (x *SystemResourceMetrics) GetBufferPoolHits() int64
func (*SystemResourceMetrics) GetBufferPoolMisses ¶
func (x *SystemResourceMetrics) GetBufferPoolMisses() int64
func (*SystemResourceMetrics) GetBufferPoolSize ¶
func (x *SystemResourceMetrics) GetBufferPoolSize() int64
func (*SystemResourceMetrics) GetCpuUsagePercent ¶
func (x *SystemResourceMetrics) GetCpuUsagePercent() float64
func (*SystemResourceMetrics) GetGcPauseTimeNs ¶
func (x *SystemResourceMetrics) GetGcPauseTimeNs() int64
func (*SystemResourceMetrics) GetMemoryUsageBytes ¶
func (x *SystemResourceMetrics) GetMemoryUsageBytes() int64
func (*SystemResourceMetrics) GetMemoryUsageMb ¶
func (x *SystemResourceMetrics) GetMemoryUsageMb() float64
func (*SystemResourceMetrics) GetNumGoroutines ¶
func (x *SystemResourceMetrics) GetNumGoroutines() int32
func (*SystemResourceMetrics) GetOpenFileDescriptors ¶
func (x *SystemResourceMetrics) GetOpenFileDescriptors() int32
func (*SystemResourceMetrics) ProtoMessage ¶
func (*SystemResourceMetrics) ProtoMessage()
func (*SystemResourceMetrics) ProtoReflect ¶
func (x *SystemResourceMetrics) ProtoReflect() protoreflect.Message
func (*SystemResourceMetrics) Reset ¶
func (x *SystemResourceMetrics) Reset()
func (*SystemResourceMetrics) String ¶
func (x *SystemResourceMetrics) String() string
type ThroughputSample ¶
type ThroughputSample struct {
Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
PacketsPerSec float64 `protobuf:"fixed64,2,opt,name=packets_per_sec,json=packetsPerSec,proto3" json:"packets_per_sec,omitempty"`
BytesPerSec float64 `protobuf:"fixed64,3,opt,name=bytes_per_sec,json=bytesPerSec,proto3" json:"bytes_per_sec,omitempty"`
MessagesPerSec float64 `protobuf:"fixed64,4,opt,name=messages_per_sec,json=messagesPerSec,proto3" json:"messages_per_sec,omitempty"`
// contains filtered or unexported fields
}
ThroughputSample represents a throughput measurement at a point in time
func (*ThroughputSample) Descriptor
deprecated
func (*ThroughputSample) Descriptor() ([]byte, []int)
Deprecated: Use ThroughputSample.ProtoReflect.Descriptor instead.
func (*ThroughputSample) GetBytesPerSec ¶
func (x *ThroughputSample) GetBytesPerSec() float64
func (*ThroughputSample) GetMessagesPerSec ¶
func (x *ThroughputSample) GetMessagesPerSec() float64
func (*ThroughputSample) GetPacketsPerSec ¶
func (x *ThroughputSample) GetPacketsPerSec() float64
func (*ThroughputSample) GetTimestamp ¶
func (x *ThroughputSample) GetTimestamp() int64
func (*ThroughputSample) ProtoMessage ¶
func (*ThroughputSample) ProtoMessage()
func (*ThroughputSample) ProtoReflect ¶
func (x *ThroughputSample) ProtoReflect() protoreflect.Message
func (*ThroughputSample) Reset ¶
func (x *ThroughputSample) Reset()
func (*ThroughputSample) String ¶
func (x *ThroughputSample) String() string
type TunnelPacket ¶
type TunnelPacket struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Raw IP packet data
StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` // Logical stream identifier for multiplexing
// contains filtered or unexported fields
}
TunnelPacket represents network packet data for the tunnel
func (*TunnelPacket) Descriptor
deprecated
func (*TunnelPacket) Descriptor() ([]byte, []int)
Deprecated: Use TunnelPacket.ProtoReflect.Descriptor instead.
func (*TunnelPacket) GetData ¶
func (x *TunnelPacket) GetData() []byte
func (*TunnelPacket) GetStreamId ¶
func (x *TunnelPacket) GetStreamId() string
func (*TunnelPacket) ProtoMessage ¶
func (*TunnelPacket) ProtoMessage()
func (*TunnelPacket) ProtoReflect ¶
func (x *TunnelPacket) ProtoReflect() protoreflect.Message
func (*TunnelPacket) Reset ¶
func (x *TunnelPacket) Reset()
func (*TunnelPacket) String ¶
func (x *TunnelPacket) String() string
type UnimplementedGravityControlServer ¶
type UnimplementedGravityControlServer struct{}
UnimplementedGravityControlServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedGravityControlServer) GetDeploymentMetadata ¶
func (UnimplementedGravityControlServer) GetDeploymentMetadata(context.Context, *DeploymentMetadataRequest) (*DeploymentMetadataResponse, error)
func (UnimplementedGravityControlServer) Provision ¶
func (UnimplementedGravityControlServer) Provision(context.Context, *ProvisionRequest) (*ProvisionResponse, error)
type UnimplementedGravityTunnelServer ¶
type UnimplementedGravityTunnelServer struct{}
UnimplementedGravityTunnelServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedGravityTunnelServer) EstablishTunnel ¶
func (UnimplementedGravityTunnelServer) EstablishTunnel(grpc.BidiStreamingServer[ControlMessage, ControlMessage]) error
func (UnimplementedGravityTunnelServer) StreamPackets ¶
func (UnimplementedGravityTunnelServer) StreamPackets(grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]) error
type UnprovisionRequest ¶
type UnprovisionRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Unique identifier of deployment to remove
// contains filtered or unexported fields
}
Unprovision request
func (*UnprovisionRequest) Descriptor
deprecated
func (*UnprovisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnprovisionRequest.ProtoReflect.Descriptor instead.
func (*UnprovisionRequest) GetDeploymentId ¶
func (x *UnprovisionRequest) GetDeploymentId() string
func (*UnprovisionRequest) ProtoMessage ¶
func (*UnprovisionRequest) ProtoMessage()
func (*UnprovisionRequest) ProtoReflect ¶
func (x *UnprovisionRequest) ProtoReflect() protoreflect.Message
func (*UnprovisionRequest) Reset ¶
func (x *UnprovisionRequest) Reset()
func (*UnprovisionRequest) String ¶
func (x *UnprovisionRequest) String() string
type UnsafeGravityControlServer ¶
type UnsafeGravityControlServer interface {
// contains filtered or unexported methods
}
UnsafeGravityControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GravityControlServer will result in compilation errors.
type UnsafeGravityTunnelServer ¶
type UnsafeGravityTunnelServer interface {
// contains filtered or unexported methods
}
UnsafeGravityTunnelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GravityTunnelServer will result in compilation errors.