Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterGravitySessionServiceServer(s grpc.ServiceRegistrar, srv GravitySessionServiceServer)
- 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 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) GetCertBundle() 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) GetCert() string
- 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 GravitySessionServiceClient
- type GravitySessionServiceServer
- type GravitySessionService_EstablishSessionClient
- type GravitySessionService_EstablishSessionServer
- type GravitySessionService_StreamSessionPacketsClient
- type GravitySessionService_StreamSessionPacketsServer
- 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) GetAvailabilityZone() string
- func (x *HostInfo) GetCpu() uint32
- func (x *HostInfo) GetDisk() uint64
- func (x *HostInfo) GetHostname() string
- func (x *HostInfo) GetInstanceId() string
- func (x *HostInfo) GetInstanceTags() []string
- func (x *HostInfo) GetInstanceType() string
- func (x *HostInfo) GetIpv4Address() string
- func (x *HostInfo) GetIpv6Address() string
- func (x *HostInfo) GetMemory() uint64
- func (x *HostInfo) GetProvider() string
- func (x *HostInfo) GetRegion() string
- 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 IdentifyRequest
- type IdentifyResponse
- 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 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 SandboxMetadataRequest
- func (*SandboxMetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SandboxMetadataRequest) GetGenerateCertificate() bool
- func (x *SandboxMetadataRequest) GetOrgId() string
- func (x *SandboxMetadataRequest) GetSandboxId() string
- func (*SandboxMetadataRequest) ProtoMessage()
- func (x *SandboxMetadataRequest) ProtoReflect() protoreflect.Message
- func (x *SandboxMetadataRequest) Reset()
- func (x *SandboxMetadataRequest) String() string
- type SandboxMetadataResponse
- func (*SandboxMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SandboxMetadataResponse) GetCertBundle() string
- func (x *SandboxMetadataResponse) GetError() string
- func (x *SandboxMetadataResponse) GetExtraHosts() []string
- func (x *SandboxMetadataResponse) GetSuccess() bool
- func (*SandboxMetadataResponse) ProtoMessage()
- func (x *SandboxMetadataResponse) ProtoReflect() protoreflect.Message
- func (x *SandboxMetadataResponse) Reset()
- func (x *SandboxMetadataResponse) 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 SessionCloseRequest
- func (*SessionCloseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SessionCloseRequest) GetReason() string
- func (*SessionCloseRequest) ProtoMessage()
- func (x *SessionCloseRequest) ProtoReflect() protoreflect.Message
- func (x *SessionCloseRequest) Reset()
- func (x *SessionCloseRequest) String() string
- type SessionHello
- func (*SessionHello) Descriptor() ([]byte, []int)deprecated
- func (x *SessionHello) GetCapabilities() *ClientCapabilities
- func (x *SessionHello) GetClientName() string
- func (x *SessionHello) GetClientVersion() string
- func (x *SessionHello) GetDeployments() []*ExistingDeployment
- func (x *SessionHello) GetHostInfo() *HostInfo
- func (x *SessionHello) GetInstanceId() string
- func (x *SessionHello) GetProtocolVersion() int32
- func (*SessionHello) ProtoMessage()
- func (x *SessionHello) ProtoReflect() protoreflect.Message
- func (x *SessionHello) Reset()
- func (x *SessionHello) String() string
- type SessionHelloResponse
- func (*SessionHelloResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SessionHelloResponse) GetApiUrl() string
- func (x *SessionHelloResponse) GetEnvironment() []string
- func (x *SessionHelloResponse) GetGravityServer() string
- func (x *SessionHelloResponse) GetHostMapping() []*HostMapping
- func (x *SessionHelloResponse) GetHostname() string
- func (x *SessionHelloResponse) GetMachineCertBundle() string
- func (x *SessionHelloResponse) GetMachineId() string
- func (x *SessionHelloResponse) GetMachineToken() string
- func (x *SessionHelloResponse) GetOrgId() string
- func (x *SessionHelloResponse) GetOtlpKey() string
- func (x *SessionHelloResponse) GetOtlpUrl() string
- func (x *SessionHelloResponse) GetSshPublicKey() []byte
- func (x *SessionHelloResponse) GetSubnetRoutes() []string
- func (*SessionHelloResponse) ProtoMessage()
- func (x *SessionHelloResponse) ProtoReflect() protoreflect.Message
- func (x *SessionHelloResponse) Reset()
- func (x *SessionHelloResponse) String() string
- type SessionMessage
- func (*SessionMessage) Descriptor() ([]byte, []int)deprecated
- func (x *SessionMessage) GetConfigUpdate() *ConfigurationUpdate
- func (x *SessionMessage) GetConfigUpdateResponse() *ConfigurationUpdateResponse
- func (x *SessionMessage) GetEvent() *ProtocolEvent
- func (x *SessionMessage) GetId() string
- func (x *SessionMessage) GetMessageType() isSessionMessage_MessageType
- func (x *SessionMessage) GetPause() *PauseRequest
- func (x *SessionMessage) GetPing() *PingRequest
- func (x *SessionMessage) GetPong() *PongResponse
- func (x *SessionMessage) GetReport() *ReportRequest
- func (x *SessionMessage) GetResponse() *ProtocolResponse
- func (x *SessionMessage) GetResume() *ResumeRequest
- func (x *SessionMessage) GetRouteDeployment() *RouteDeploymentRequest
- func (x *SessionMessage) GetRouteDeploymentResponse() *RouteDeploymentResponse
- func (x *SessionMessage) GetRouteSandbox() *RouteSandboxRequest
- func (x *SessionMessage) GetRouteSandboxResponse() *RouteSandboxResponse
- func (x *SessionMessage) GetSessionClose() *SessionCloseRequest
- func (x *SessionMessage) GetSessionHello() *SessionHello
- func (x *SessionMessage) GetSessionHelloResponse() *SessionHelloResponse
- func (x *SessionMessage) GetStreamId() string
- func (x *SessionMessage) GetUnprovision() *UnprovisionRequest
- func (*SessionMessage) ProtoMessage()
- func (x *SessionMessage) ProtoReflect() protoreflect.Message
- func (x *SessionMessage) Reset()
- func (x *SessionMessage) String() string
- type SessionMessage_ConfigUpdate
- type SessionMessage_ConfigUpdateResponse
- type SessionMessage_Event
- type SessionMessage_Pause
- type SessionMessage_Ping
- type SessionMessage_Pong
- type SessionMessage_Report
- type SessionMessage_Response
- type SessionMessage_Resume
- type SessionMessage_RouteDeployment
- type SessionMessage_RouteDeploymentResponse
- type SessionMessage_RouteSandbox
- type SessionMessage_RouteSandboxResponse
- type SessionMessage_SessionClose
- type SessionMessage_SessionHello
- type SessionMessage_SessionHelloResponse
- type SessionMessage_Unprovision
- 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 UnimplementedGravitySessionServiceServer
- func (UnimplementedGravitySessionServiceServer) EstablishSession(grpc.BidiStreamingServer[SessionMessage, SessionMessage]) error
- func (UnimplementedGravitySessionServiceServer) GetDeploymentMetadata(context.Context, *DeploymentMetadataRequest) (*DeploymentMetadataResponse, error)
- func (UnimplementedGravitySessionServiceServer) GetSandboxMetadata(context.Context, *SandboxMetadataRequest) (*SandboxMetadataResponse, error)
- func (UnimplementedGravitySessionServiceServer) Identify(context.Context, *IdentifyRequest) (*IdentifyResponse, error)
- func (UnimplementedGravitySessionServiceServer) StreamSessionPackets(grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]) error
- 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 UnsafeGravitySessionServiceServer
Constants ¶
const ( GravitySessionService_EstablishSession_FullMethodName = "/gravity.GravitySessionService/EstablishSession" GravitySessionService_StreamSessionPackets_FullMethodName = "/gravity.GravitySessionService/StreamSessionPackets" GravitySessionService_GetDeploymentMetadata_FullMethodName = "/gravity.GravitySessionService/GetDeploymentMetadata" GravitySessionService_GetSandboxMetadata_FullMethodName = "/gravity.GravitySessionService/GetSandboxMetadata" GravitySessionService_Identify_FullMethodName = "/gravity.GravitySessionService/Identify" )
Variables ¶
var File_gravity_metrics_proto protoreflect.FileDescriptor
var File_gravity_session_proto protoreflect.FileDescriptor
var GravitySessionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gravity.GravitySessionService", HandlerType: (*GravitySessionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetDeploymentMetadata", Handler: _GravitySessionService_GetDeploymentMetadata_Handler, }, { MethodName: "GetSandboxMetadata", Handler: _GravitySessionService_GetSandboxMetadata_Handler, }, { MethodName: "Identify", Handler: _GravitySessionService_Identify_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "EstablishSession", Handler: _GravitySessionService_EstablishSession_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "StreamSessionPackets", Handler: _GravitySessionService_StreamSessionPackets_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "gravity_session.proto", }
GravitySessionService_ServiceDesc is the grpc.ServiceDesc for GravitySessionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGravitySessionServiceServer ¶ added in v1.0.139
func RegisterGravitySessionServiceServer(s grpc.ServiceRegistrar, srv GravitySessionServiceServer)
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 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
CertBundle string `protobuf:"bytes,8,opt,name=cert_bundle,json=certBundle,proto3" json:"cert_bundle,omitempty"` // PEM certificate bundle (cert, ca, key)
// 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) GetCertBundle ¶ added in v1.0.138
func (x *DeploymentMetadataResponse) GetCertBundle() 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_session.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"`
Cert string `protobuf:"bytes,12,opt,name=cert,proto3" json:"cert,omitempty"` // PEM certificate that was issued (just cert, ca + key not required)
// contains filtered or unexported fields
}
func (*ExistingDeployment) Descriptor
deprecated
func (*ExistingDeployment) Descriptor() ([]byte, []int)
Deprecated: Use ExistingDeployment.ProtoReflect.Descriptor instead.
func (*ExistingDeployment) GetCert ¶ added in v1.0.138
func (x *ExistingDeployment) GetCert() string
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 GravitySessionServiceClient ¶ added in v1.0.139
type GravitySessionServiceClient interface {
// EstablishSession creates a bidirectional control stream.
// Authentication is performed via mTLS using self-signed client certificates.
// The client's certificate public key is verified against the org's registered key.
EstablishSession(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SessionMessage, SessionMessage], error)
// StreamSessionPackets handles bidirectional packet data streaming.
// Same as the legacy GravityTunnel.StreamPackets but on the new service.
StreamSessionPackets(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[TunnelPacket, TunnelPacket], error)
// GetDeploymentMetadata retrieves metadata for a deployment.
GetDeploymentMetadata(ctx context.Context, in *DeploymentMetadataRequest, opts ...grpc.CallOption) (*DeploymentMetadataResponse, error)
// GetSandboxMetadata retrieves metadata for a sandbox.
GetSandboxMetadata(ctx context.Context, in *SandboxMetadataRequest, opts ...grpc.CallOption) (*SandboxMetadataResponse, error)
// Identify performs a one-shot authentication to retrieve the org ID.
// Authentication is performed via mTLS using self-signed client certificates.
Identify(ctx context.Context, in *IdentifyRequest, opts ...grpc.CallOption) (*IdentifyResponse, error)
}
GravitySessionServiceClient is the client API for GravitySessionService 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.
GravitySessionService handles session establishment and tunnel management using self-signed client certificates authenticated against the org's registered public key.
This service replaces the legacy Provision + EstablishTunnel two-step flow with a single-step session establishment.
func NewGravitySessionServiceClient ¶ added in v1.0.139
func NewGravitySessionServiceClient(cc grpc.ClientConnInterface) GravitySessionServiceClient
type GravitySessionServiceServer ¶ added in v1.0.139
type GravitySessionServiceServer interface {
// EstablishSession creates a bidirectional control stream.
// Authentication is performed via mTLS using self-signed client certificates.
// The client's certificate public key is verified against the org's registered key.
EstablishSession(grpc.BidiStreamingServer[SessionMessage, SessionMessage]) error
// StreamSessionPackets handles bidirectional packet data streaming.
// Same as the legacy GravityTunnel.StreamPackets but on the new service.
StreamSessionPackets(grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]) error
// GetDeploymentMetadata retrieves metadata for a deployment.
GetDeploymentMetadata(context.Context, *DeploymentMetadataRequest) (*DeploymentMetadataResponse, error)
// GetSandboxMetadata retrieves metadata for a sandbox.
GetSandboxMetadata(context.Context, *SandboxMetadataRequest) (*SandboxMetadataResponse, error)
// Identify performs a one-shot authentication to retrieve the org ID.
// Authentication is performed via mTLS using self-signed client certificates.
Identify(context.Context, *IdentifyRequest) (*IdentifyResponse, error)
// contains filtered or unexported methods
}
GravitySessionServiceServer is the server API for GravitySessionService service. All implementations must embed UnimplementedGravitySessionServiceServer for forward compatibility.
GravitySessionService handles session establishment and tunnel management using self-signed client certificates authenticated against the org's registered public key.
This service replaces the legacy Provision + EstablishTunnel two-step flow with a single-step session establishment.
type GravitySessionService_EstablishSessionClient ¶ added in v1.0.139
type GravitySessionService_EstablishSessionClient = grpc.BidiStreamingClient[SessionMessage, SessionMessage]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type GravitySessionService_EstablishSessionServer ¶ added in v1.0.139
type GravitySessionService_EstablishSessionServer = grpc.BidiStreamingServer[SessionMessage, SessionMessage]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type GravitySessionService_StreamSessionPacketsClient ¶ added in v1.0.139
type GravitySessionService_StreamSessionPacketsClient = 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 GravitySessionService_StreamSessionPacketsServer ¶ added in v1.0.139
type GravitySessionService_StreamSessionPacketsServer = 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
Provider string `protobuf:"bytes,9,opt,name=provider,proto3" json:"provider,omitempty"` // Cloud provider (e.g., "aws", "gcp", "azure")
Region string `protobuf:"bytes,10,opt,name=region,proto3" json:"region,omitempty"` // Cloud region
InstanceType string `protobuf:"bytes,11,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"` // instance type of the client (n1-standard-32, m6i.8xlarge)
InstanceTags []string `protobuf:"bytes,12,rep,name=instance_tags,json=instanceTags,proto3" json:"instance_tags,omitempty"` // tags on the instance
AvailabilityZone string `protobuf:"bytes,13,opt,name=availability_zone,json=availabilityZone,proto3" json:"availability_zone,omitempty"` // the availability zone for the client
// contains filtered or unexported fields
}
Supporting data structures
func (*HostInfo) Descriptor
deprecated
func (*HostInfo) GetAvailabilityZone ¶ added in v1.0.142
func (*HostInfo) GetHostname ¶
func (*HostInfo) GetInstanceId ¶
func (*HostInfo) GetInstanceTags ¶ added in v1.0.141
func (*HostInfo) GetInstanceType ¶ added in v1.0.141
func (*HostInfo) GetIpv4Address ¶
func (*HostInfo) GetIpv6Address ¶
func (*HostInfo) GetProvider ¶ added in v1.0.141
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 IdentifyRequest ¶ added in v1.0.139
type IdentifyRequest struct {
InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // Instance ID (must match cert CN)
// contains filtered or unexported fields
}
IdentifyRequest is sent by the client to identify the org associated with the key.
func (*IdentifyRequest) Descriptor
deprecated
added in
v1.0.139
func (*IdentifyRequest) Descriptor() ([]byte, []int)
Deprecated: Use IdentifyRequest.ProtoReflect.Descriptor instead.
func (*IdentifyRequest) GetInstanceId ¶ added in v1.0.139
func (x *IdentifyRequest) GetInstanceId() string
func (*IdentifyRequest) ProtoMessage ¶ added in v1.0.139
func (*IdentifyRequest) ProtoMessage()
func (*IdentifyRequest) ProtoReflect ¶ added in v1.0.139
func (x *IdentifyRequest) ProtoReflect() protoreflect.Message
func (*IdentifyRequest) Reset ¶ added in v1.0.139
func (x *IdentifyRequest) Reset()
func (*IdentifyRequest) String ¶ added in v1.0.139
func (x *IdentifyRequest) String() string
type IdentifyResponse ¶ added in v1.0.139
type IdentifyResponse struct {
OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` // Organization ID (from cert verification)
// contains filtered or unexported fields
}
IdentifyResponse contains the org ID from cert verification.
func (*IdentifyResponse) Descriptor
deprecated
added in
v1.0.139
func (*IdentifyResponse) Descriptor() ([]byte, []int)
Deprecated: Use IdentifyResponse.ProtoReflect.Descriptor instead.
func (*IdentifyResponse) GetOrgId ¶ added in v1.0.139
func (x *IdentifyResponse) GetOrgId() string
func (*IdentifyResponse) ProtoMessage ¶ added in v1.0.139
func (*IdentifyResponse) ProtoMessage()
func (*IdentifyResponse) ProtoReflect ¶ added in v1.0.139
func (x *IdentifyResponse) ProtoReflect() protoreflect.Message
func (*IdentifyResponse) Reset ¶ added in v1.0.139
func (x *IdentifyResponse) Reset()
func (*IdentifyResponse) String ¶ added in v1.0.139
func (x *IdentifyResponse) 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 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 SandboxMetadataRequest ¶ added in v1.0.138
type SandboxMetadataRequest struct {
SandboxId string `protobuf:"bytes,1,opt,name=sandbox_id,json=sandboxId,proto3" json:"sandbox_id,omitempty"`
OrgId string `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
GenerateCertificate bool `protobuf:"varint,3,opt,name=generate_certificate,json=generateCertificate,proto3" json:"generate_certificate,omitempty"` // Whether to generate a certificate
// contains filtered or unexported fields
}
Sandbox metadata request
func (*SandboxMetadataRequest) Descriptor
deprecated
added in
v1.0.138
func (*SandboxMetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use SandboxMetadataRequest.ProtoReflect.Descriptor instead.
func (*SandboxMetadataRequest) GetGenerateCertificate ¶ added in v1.0.138
func (x *SandboxMetadataRequest) GetGenerateCertificate() bool
func (*SandboxMetadataRequest) GetOrgId ¶ added in v1.0.138
func (x *SandboxMetadataRequest) GetOrgId() string
func (*SandboxMetadataRequest) GetSandboxId ¶ added in v1.0.138
func (x *SandboxMetadataRequest) GetSandboxId() string
func (*SandboxMetadataRequest) ProtoMessage ¶ added in v1.0.138
func (*SandboxMetadataRequest) ProtoMessage()
func (*SandboxMetadataRequest) ProtoReflect ¶ added in v1.0.138
func (x *SandboxMetadataRequest) ProtoReflect() protoreflect.Message
func (*SandboxMetadataRequest) Reset ¶ added in v1.0.138
func (x *SandboxMetadataRequest) Reset()
func (*SandboxMetadataRequest) String ¶ added in v1.0.138
func (x *SandboxMetadataRequest) String() string
type SandboxMetadataResponse ¶ added in v1.0.138
type SandboxMetadataResponse 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
ExtraHosts []string `protobuf:"bytes,3,rep,name=extra_hosts,json=extraHosts,proto3" json:"extra_hosts,omitempty"` // Extra /etc/hosts entries for the sandbox
CertBundle string `protobuf:"bytes,4,opt,name=cert_bundle,json=certBundle,proto3" json:"cert_bundle,omitempty"` // PEM certificate bundle (cert, ca, key)
// contains filtered or unexported fields
}
Sandbox metadata response
func (*SandboxMetadataResponse) Descriptor
deprecated
added in
v1.0.138
func (*SandboxMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use SandboxMetadataResponse.ProtoReflect.Descriptor instead.
func (*SandboxMetadataResponse) GetCertBundle ¶ added in v1.0.138
func (x *SandboxMetadataResponse) GetCertBundle() string
func (*SandboxMetadataResponse) GetError ¶ added in v1.0.138
func (x *SandboxMetadataResponse) GetError() string
func (*SandboxMetadataResponse) GetExtraHosts ¶ added in v1.0.138
func (x *SandboxMetadataResponse) GetExtraHosts() []string
func (*SandboxMetadataResponse) GetSuccess ¶ added in v1.0.138
func (x *SandboxMetadataResponse) GetSuccess() bool
func (*SandboxMetadataResponse) ProtoMessage ¶ added in v1.0.138
func (*SandboxMetadataResponse) ProtoMessage()
func (*SandboxMetadataResponse) ProtoReflect ¶ added in v1.0.138
func (x *SandboxMetadataResponse) ProtoReflect() protoreflect.Message
func (*SandboxMetadataResponse) Reset ¶ added in v1.0.138
func (x *SandboxMetadataResponse) Reset()
func (*SandboxMetadataResponse) String ¶ added in v1.0.138
func (x *SandboxMetadataResponse) 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 SessionCloseRequest ¶ added in v1.0.139
type SessionCloseRequest struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for closing the session
// contains filtered or unexported fields
}
SessionCloseRequest is sent to gracefully close the session.
func (*SessionCloseRequest) Descriptor
deprecated
added in
v1.0.139
func (*SessionCloseRequest) Descriptor() ([]byte, []int)
Deprecated: Use SessionCloseRequest.ProtoReflect.Descriptor instead.
func (*SessionCloseRequest) GetReason ¶ added in v1.0.139
func (x *SessionCloseRequest) GetReason() string
func (*SessionCloseRequest) ProtoMessage ¶ added in v1.0.139
func (*SessionCloseRequest) ProtoMessage()
func (*SessionCloseRequest) ProtoReflect ¶ added in v1.0.139
func (x *SessionCloseRequest) ProtoReflect() protoreflect.Message
func (*SessionCloseRequest) Reset ¶ added in v1.0.139
func (x *SessionCloseRequest) Reset()
func (*SessionCloseRequest) String ¶ added in v1.0.139
func (x *SessionCloseRequest) String() string
type SessionHello ¶ added in v1.0.139
type SessionHello 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 session
// Instance metadata (extracted from cert but also sent for validation)
InstanceId string `protobuf:"bytes,7,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // Instance ID (must match cert CN)
// contains filtered or unexported fields
}
SessionHello is sent by the client as the first message after TLS handshake. The org_id and instance_id are extracted from the client certificate.
func (*SessionHello) Descriptor
deprecated
added in
v1.0.139
func (*SessionHello) Descriptor() ([]byte, []int)
Deprecated: Use SessionHello.ProtoReflect.Descriptor instead.
func (*SessionHello) GetCapabilities ¶ added in v1.0.139
func (x *SessionHello) GetCapabilities() *ClientCapabilities
func (*SessionHello) GetClientName ¶ added in v1.0.139
func (x *SessionHello) GetClientName() string
func (*SessionHello) GetClientVersion ¶ added in v1.0.139
func (x *SessionHello) GetClientVersion() string
func (*SessionHello) GetDeployments ¶ added in v1.0.139
func (x *SessionHello) GetDeployments() []*ExistingDeployment
func (*SessionHello) GetHostInfo ¶ added in v1.0.139
func (x *SessionHello) GetHostInfo() *HostInfo
func (*SessionHello) GetInstanceId ¶ added in v1.0.139
func (x *SessionHello) GetInstanceId() string
func (*SessionHello) GetProtocolVersion ¶ added in v1.0.139
func (x *SessionHello) GetProtocolVersion() int32
func (*SessionHello) ProtoMessage ¶ added in v1.0.139
func (*SessionHello) ProtoMessage()
func (*SessionHello) ProtoReflect ¶ added in v1.0.139
func (x *SessionHello) ProtoReflect() protoreflect.Message
func (*SessionHello) Reset ¶ added in v1.0.139
func (x *SessionHello) Reset()
func (*SessionHello) String ¶ added in v1.0.139
func (x *SessionHello) String() string
type SessionHelloResponse ¶ added in v1.0.139
type SessionHelloResponse struct {
MachineId string `protobuf:"bytes,1,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"` // Deterministic machine ID assigned by server
OrgId string `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` // Organization ID (from cert verification)
OtlpUrl string `protobuf:"bytes,3,opt,name=otlp_url,json=otlpUrl,proto3" json:"otlp_url,omitempty"` // OpenTelemetry endpoint URL for metrics
OtlpKey string `protobuf:"bytes,4,opt,name=otlp_key,json=otlpKey,proto3" json:"otlp_key,omitempty"` // OpenTelemetry API key for authentication
ApiUrl string `protobuf:"bytes,5,opt,name=api_url,json=apiUrl,proto3" json:"api_url,omitempty"` // Base URL for API operations
Environment []string `protobuf:"bytes,6,rep,name=environment,proto3" json:"environment,omitempty"` // Environment variables to set
HostMapping []*HostMapping `protobuf:"bytes,7,rep,name=host_mapping,json=hostMapping,proto3" json:"host_mapping,omitempty"` // Host to IP address mappings
SubnetRoutes []string `protobuf:"bytes,8,rep,name=subnet_routes,json=subnetRoutes,proto3" json:"subnet_routes,omitempty"` // Subnet routes for the session
GravityServer string `protobuf:"bytes,9,opt,name=gravity_server,json=gravityServer,proto3" json:"gravity_server,omitempty"` // The gravity server that we're connected to
Hostname string `protobuf:"bytes,10,opt,name=hostname,proto3" json:"hostname,omitempty"` // Dynamic hostname if requested
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
MachineToken string `protobuf:"bytes,12,opt,name=machine_token,json=machineToken,proto3" json:"machine_token,omitempty"` // JWT token for machine to authenticate with catalyst
MachineCertBundle string `protobuf:"bytes,13,opt,name=machine_cert_bundle,json=machineCertBundle,proto3" json:"machine_cert_bundle,omitempty"` // PEM certificate bundle (cert, ca, key)
// contains filtered or unexported fields
}
SessionHelloResponse is sent by the server after successful authentication.
func (*SessionHelloResponse) Descriptor
deprecated
added in
v1.0.139
func (*SessionHelloResponse) Descriptor() ([]byte, []int)
Deprecated: Use SessionHelloResponse.ProtoReflect.Descriptor instead.
func (*SessionHelloResponse) GetApiUrl ¶ added in v1.0.139
func (x *SessionHelloResponse) GetApiUrl() string
func (*SessionHelloResponse) GetEnvironment ¶ added in v1.0.139
func (x *SessionHelloResponse) GetEnvironment() []string
func (*SessionHelloResponse) GetGravityServer ¶ added in v1.0.139
func (x *SessionHelloResponse) GetGravityServer() string
func (*SessionHelloResponse) GetHostMapping ¶ added in v1.0.139
func (x *SessionHelloResponse) GetHostMapping() []*HostMapping
func (*SessionHelloResponse) GetHostname ¶ added in v1.0.139
func (x *SessionHelloResponse) GetHostname() string
func (*SessionHelloResponse) GetMachineCertBundle ¶ added in v1.0.139
func (x *SessionHelloResponse) GetMachineCertBundle() string
func (*SessionHelloResponse) GetMachineId ¶ added in v1.0.139
func (x *SessionHelloResponse) GetMachineId() string
func (*SessionHelloResponse) GetMachineToken ¶ added in v1.0.139
func (x *SessionHelloResponse) GetMachineToken() string
func (*SessionHelloResponse) GetOrgId ¶ added in v1.0.139
func (x *SessionHelloResponse) GetOrgId() string
func (*SessionHelloResponse) GetOtlpKey ¶ added in v1.0.139
func (x *SessionHelloResponse) GetOtlpKey() string
func (*SessionHelloResponse) GetOtlpUrl ¶ added in v1.0.139
func (x *SessionHelloResponse) GetOtlpUrl() string
func (*SessionHelloResponse) GetSshPublicKey ¶ added in v1.0.139
func (x *SessionHelloResponse) GetSshPublicKey() []byte
func (*SessionHelloResponse) GetSubnetRoutes ¶ added in v1.0.139
func (x *SessionHelloResponse) GetSubnetRoutes() []string
func (*SessionHelloResponse) ProtoMessage ¶ added in v1.0.139
func (*SessionHelloResponse) ProtoMessage()
func (*SessionHelloResponse) ProtoReflect ¶ added in v1.0.139
func (x *SessionHelloResponse) ProtoReflect() protoreflect.Message
func (*SessionHelloResponse) Reset ¶ added in v1.0.139
func (x *SessionHelloResponse) Reset()
func (*SessionHelloResponse) String ¶ added in v1.0.139
func (x *SessionHelloResponse) String() string
type SessionMessage ¶ added in v1.0.139
type SessionMessage 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:
//
// *SessionMessage_SessionHello
// *SessionMessage_SessionHelloResponse
// *SessionMessage_SessionClose
// *SessionMessage_RouteDeployment
// *SessionMessage_RouteDeploymentResponse
// *SessionMessage_Unprovision
// *SessionMessage_RouteSandbox
// *SessionMessage_RouteSandboxResponse
// *SessionMessage_Ping
// *SessionMessage_Pong
// *SessionMessage_Report
// *SessionMessage_Pause
// *SessionMessage_Resume
// *SessionMessage_ConfigUpdate
// *SessionMessage_ConfigUpdateResponse
// *SessionMessage_Response
// *SessionMessage_Event
MessageType isSessionMessage_MessageType `protobuf_oneof:"message_type"`
// contains filtered or unexported fields
}
SessionMessage is the bidirectional message type for EstablishSession. It contains all control plane messages for the session lifecycle.
func (*SessionMessage) Descriptor
deprecated
added in
v1.0.139
func (*SessionMessage) Descriptor() ([]byte, []int)
Deprecated: Use SessionMessage.ProtoReflect.Descriptor instead.
func (*SessionMessage) GetConfigUpdate ¶ added in v1.0.139
func (x *SessionMessage) GetConfigUpdate() *ConfigurationUpdate
func (*SessionMessage) GetConfigUpdateResponse ¶ added in v1.0.139
func (x *SessionMessage) GetConfigUpdateResponse() *ConfigurationUpdateResponse
func (*SessionMessage) GetEvent ¶ added in v1.0.139
func (x *SessionMessage) GetEvent() *ProtocolEvent
func (*SessionMessage) GetId ¶ added in v1.0.139
func (x *SessionMessage) GetId() string
func (*SessionMessage) GetMessageType ¶ added in v1.0.139
func (x *SessionMessage) GetMessageType() isSessionMessage_MessageType
func (*SessionMessage) GetPause ¶ added in v1.0.139
func (x *SessionMessage) GetPause() *PauseRequest
func (*SessionMessage) GetPing ¶ added in v1.0.139
func (x *SessionMessage) GetPing() *PingRequest
func (*SessionMessage) GetPong ¶ added in v1.0.139
func (x *SessionMessage) GetPong() *PongResponse
func (*SessionMessage) GetReport ¶ added in v1.0.139
func (x *SessionMessage) GetReport() *ReportRequest
func (*SessionMessage) GetResponse ¶ added in v1.0.139
func (x *SessionMessage) GetResponse() *ProtocolResponse
func (*SessionMessage) GetResume ¶ added in v1.0.139
func (x *SessionMessage) GetResume() *ResumeRequest
func (*SessionMessage) GetRouteDeployment ¶ added in v1.0.139
func (x *SessionMessage) GetRouteDeployment() *RouteDeploymentRequest
func (*SessionMessage) GetRouteDeploymentResponse ¶ added in v1.0.139
func (x *SessionMessage) GetRouteDeploymentResponse() *RouteDeploymentResponse
func (*SessionMessage) GetRouteSandbox ¶ added in v1.0.139
func (x *SessionMessage) GetRouteSandbox() *RouteSandboxRequest
func (*SessionMessage) GetRouteSandboxResponse ¶ added in v1.0.139
func (x *SessionMessage) GetRouteSandboxResponse() *RouteSandboxResponse
func (*SessionMessage) GetSessionClose ¶ added in v1.0.139
func (x *SessionMessage) GetSessionClose() *SessionCloseRequest
func (*SessionMessage) GetSessionHello ¶ added in v1.0.139
func (x *SessionMessage) GetSessionHello() *SessionHello
func (*SessionMessage) GetSessionHelloResponse ¶ added in v1.0.139
func (x *SessionMessage) GetSessionHelloResponse() *SessionHelloResponse
func (*SessionMessage) GetStreamId ¶ added in v1.0.139
func (x *SessionMessage) GetStreamId() string
func (*SessionMessage) GetUnprovision ¶ added in v1.0.139
func (x *SessionMessage) GetUnprovision() *UnprovisionRequest
func (*SessionMessage) ProtoMessage ¶ added in v1.0.139
func (*SessionMessage) ProtoMessage()
func (*SessionMessage) ProtoReflect ¶ added in v1.0.139
func (x *SessionMessage) ProtoReflect() protoreflect.Message
func (*SessionMessage) Reset ¶ added in v1.0.139
func (x *SessionMessage) Reset()
func (*SessionMessage) String ¶ added in v1.0.139
func (x *SessionMessage) String() string
type SessionMessage_ConfigUpdate ¶ added in v1.0.139
type SessionMessage_ConfigUpdate struct {
// Configuration management (45-49)
ConfigUpdate *ConfigurationUpdate `protobuf:"bytes,45,opt,name=config_update,json=configUpdate,proto3,oneof"`
}
type SessionMessage_ConfigUpdateResponse ¶ added in v1.0.139
type SessionMessage_ConfigUpdateResponse struct {
ConfigUpdateResponse *ConfigurationUpdateResponse `protobuf:"bytes,46,opt,name=config_update_response,json=configUpdateResponse,proto3,oneof"`
}
type SessionMessage_Event ¶ added in v1.0.139
type SessionMessage_Event struct {
Event *ProtocolEvent `protobuf:"bytes,51,opt,name=event,proto3,oneof"`
}
type SessionMessage_Pause ¶ added in v1.0.139
type SessionMessage_Pause struct {
// Session control (40-49)
Pause *PauseRequest `protobuf:"bytes,40,opt,name=pause,proto3,oneof"`
}
type SessionMessage_Ping ¶ added in v1.0.139
type SessionMessage_Ping struct {
// Health and monitoring (30-39)
Ping *PingRequest `protobuf:"bytes,30,opt,name=ping,proto3,oneof"`
}
type SessionMessage_Pong ¶ added in v1.0.139
type SessionMessage_Pong struct {
Pong *PongResponse `protobuf:"bytes,31,opt,name=pong,proto3,oneof"`
}
type SessionMessage_Report ¶ added in v1.0.139
type SessionMessage_Report struct {
Report *ReportRequest `protobuf:"bytes,32,opt,name=report,proto3,oneof"`
}
type SessionMessage_Response ¶ added in v1.0.139
type SessionMessage_Response struct {
// Generic protocol messages (50-59)
Response *ProtocolResponse `protobuf:"bytes,50,opt,name=response,proto3,oneof"`
}
type SessionMessage_Resume ¶ added in v1.0.139
type SessionMessage_Resume struct {
Resume *ResumeRequest `protobuf:"bytes,41,opt,name=resume,proto3,oneof"`
}
type SessionMessage_RouteDeployment ¶ added in v1.0.139
type SessionMessage_RouteDeployment struct {
// Deployment management (20-29)
RouteDeployment *RouteDeploymentRequest `protobuf:"bytes,22,opt,name=route_deployment,json=routeDeployment,proto3,oneof"`
}
type SessionMessage_RouteDeploymentResponse ¶ added in v1.0.139
type SessionMessage_RouteDeploymentResponse struct {
RouteDeploymentResponse *RouteDeploymentResponse `protobuf:"bytes,23,opt,name=route_deployment_response,json=routeDeploymentResponse,proto3,oneof"`
}
type SessionMessage_RouteSandbox ¶ added in v1.0.139
type SessionMessage_RouteSandbox struct {
RouteSandbox *RouteSandboxRequest `protobuf:"bytes,26,opt,name=route_sandbox,json=routeSandbox,proto3,oneof"`
}
type SessionMessage_RouteSandboxResponse ¶ added in v1.0.139
type SessionMessage_RouteSandboxResponse struct {
RouteSandboxResponse *RouteSandboxResponse `protobuf:"bytes,27,opt,name=route_sandbox_response,json=routeSandboxResponse,proto3,oneof"`
}
type SessionMessage_SessionClose ¶ added in v1.0.139
type SessionMessage_SessionClose struct {
SessionClose *SessionCloseRequest `protobuf:"bytes,15,opt,name=session_close,json=sessionClose,proto3,oneof"`
}
type SessionMessage_SessionHello ¶ added in v1.0.139
type SessionMessage_SessionHello struct {
// Session lifecycle (10-19)
SessionHello *SessionHello `protobuf:"bytes,10,opt,name=session_hello,json=sessionHello,proto3,oneof"`
}
type SessionMessage_SessionHelloResponse ¶ added in v1.0.139
type SessionMessage_SessionHelloResponse struct {
SessionHelloResponse *SessionHelloResponse `protobuf:"bytes,11,opt,name=session_hello_response,json=sessionHelloResponse,proto3,oneof"`
}
type SessionMessage_Unprovision ¶ added in v1.0.139
type SessionMessage_Unprovision struct {
Unprovision *UnprovisionRequest `protobuf:"bytes,25,opt,name=unprovision,proto3,oneof"`
}
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 UnimplementedGravitySessionServiceServer ¶ added in v1.0.139
type UnimplementedGravitySessionServiceServer struct{}
UnimplementedGravitySessionServiceServer 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 (UnimplementedGravitySessionServiceServer) EstablishSession ¶ added in v1.0.139
func (UnimplementedGravitySessionServiceServer) EstablishSession(grpc.BidiStreamingServer[SessionMessage, SessionMessage]) error
func (UnimplementedGravitySessionServiceServer) GetDeploymentMetadata ¶ added in v1.0.139
func (UnimplementedGravitySessionServiceServer) GetDeploymentMetadata(context.Context, *DeploymentMetadataRequest) (*DeploymentMetadataResponse, error)
func (UnimplementedGravitySessionServiceServer) GetSandboxMetadata ¶ added in v1.0.139
func (UnimplementedGravitySessionServiceServer) GetSandboxMetadata(context.Context, *SandboxMetadataRequest) (*SandboxMetadataResponse, error)
func (UnimplementedGravitySessionServiceServer) Identify ¶ added in v1.0.139
func (UnimplementedGravitySessionServiceServer) Identify(context.Context, *IdentifyRequest) (*IdentifyResponse, error)
func (UnimplementedGravitySessionServiceServer) StreamSessionPackets ¶ added in v1.0.139
func (UnimplementedGravitySessionServiceServer) StreamSessionPackets(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 UnsafeGravitySessionServiceServer ¶ added in v1.0.139
type UnsafeGravitySessionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeGravitySessionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GravitySessionServiceServer will result in compilation errors.