proto

package
v1.0.127 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2025 License: MIT Imports: 11 Imported by: 0

README

Gravity Protocol Buffers

This directory contains the Protocol Buffer definitions for the Gravity control and tunnel protocols.

Module Path

Generated Go code uses the import path: github.com/agentuity/go-common/gravity/proto

Files

  • gravity.proto - Main protocol definitions
  • gravity.pb.go - Generated Go message types
  • gravity_grpc.pb.go - Generated gRPC service stubs

Regenerating Code

Use the same toolchain as the original graviton project:

# Install dependencies
make install-tools

# Generate code
make gen

The generated code should be committed to version control.

Documentation

Index

Constants

View Source
const (
	GravityControl_Provision_FullMethodName             = "/gravity.GravityControl/Provision"
	GravityControl_GetDeploymentMetadata_FullMethodName = "/gravity.GravityControl/GetDeploymentMetadata"
)
View Source
const (
	GravityTunnel_EstablishTunnel_FullMethodName = "/gravity.GravityTunnel/EstablishTunnel"
	GravityTunnel_StreamPackets_FullMethodName   = "/gravity.GravityTunnel/StreamPackets"
)

Variables

View Source
var File_gravity_proto protoreflect.FileDescriptor
View Source
var GravityControl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gravity.GravityControl",
	HandlerType: (*GravityControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Provision",
			Handler:    _GravityControl_Provision_Handler,
		},
		{
			MethodName: "GetDeploymentMetadata",
			Handler:    _GravityControl_GetDeploymentMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gravity.proto",
}

GravityControl_ServiceDesc is the grpc.ServiceDesc for GravityControl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var GravityTunnel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gravity.GravityTunnel",
	HandlerType: (*GravityTunnelServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EstablishTunnel",
			Handler:       _GravityTunnel_EstablishTunnel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamPackets",
			Handler:       _GravityTunnel_StreamPackets_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "gravity.proto",
}

GravityTunnel_ServiceDesc is the grpc.ServiceDesc for GravityTunnel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGravityControlServer

func RegisterGravityControlServer(s grpc.ServiceRegistrar, srv GravityControlServer)

func RegisterGravityTunnelServer

func RegisterGravityTunnelServer(s grpc.ServiceRegistrar, srv GravityTunnelServer)

Types

type ClientCapabilities

type ClientCapabilities struct {
	ProvisionDeployments   bool `protobuf:"varint,1,opt,name=provision_deployments,json=provisionDeployments,proto3" json:"provision_deployments,omitempty"` // Can handle provision deployment requests
	UnprovisionDeployments bool ``                                                                                                                           // Can handle unprovision deployment requests
	/* 128-byte string literal not displayed */
	DynamicProjectRouting string `` // Project ID for dynamic routing (empty = no routing)
	/* 126-byte string literal not displayed */
	DynamicHostname bool `protobuf:"varint,4,opt,name=dynamic_hostname,json=dynamicHostname,proto3" json:"dynamic_hostname,omitempty"` // Request dynamic hostname generation and routing
	// contains filtered or unexported fields
}

ClientCapabilities defines what capabilities a client supports

func (*ClientCapabilities) Descriptor deprecated

func (*ClientCapabilities) Descriptor() ([]byte, []int)

Deprecated: Use ClientCapabilities.ProtoReflect.Descriptor instead.

func (*ClientCapabilities) GetDynamicHostname

func (x *ClientCapabilities) GetDynamicHostname() bool

func (*ClientCapabilities) GetDynamicProjectRouting

func (x *ClientCapabilities) GetDynamicProjectRouting() string

func (*ClientCapabilities) GetProvisionDeployments

func (x *ClientCapabilities) GetProvisionDeployments() bool

func (*ClientCapabilities) GetUnprovisionDeployments

func (x *ClientCapabilities) GetUnprovisionDeployments() bool

func (*ClientCapabilities) ProtoMessage

func (*ClientCapabilities) ProtoMessage()

func (*ClientCapabilities) ProtoReflect

func (x *ClientCapabilities) ProtoReflect() protoreflect.Message

func (*ClientCapabilities) Reset

func (x *ClientCapabilities) Reset()

func (*ClientCapabilities) String

func (x *ClientCapabilities) String() string

type CloseRequest

type CloseRequest struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for closing the connection
	// contains filtered or unexported fields
}

Close request

func (*CloseRequest) Descriptor deprecated

func (*CloseRequest) Descriptor() ([]byte, []int)

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetReason

func (x *CloseRequest) GetReason() string

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect

func (x *CloseRequest) ProtoReflect() protoreflect.Message

func (*CloseRequest) Reset

func (x *CloseRequest) Reset()

func (*CloseRequest) String

func (x *CloseRequest) String() string

type CodeMetadata

type CodeMetadata struct {
	Env     []string `protobuf:"bytes,1,rep,name=env,proto3" json:"env,omitempty"`         // Environment variable names
	Secrets []string `protobuf:"bytes,2,rep,name=secrets,proto3" json:"secrets,omitempty"` // Secret names required by the code
	// contains filtered or unexported fields
}

func (*CodeMetadata) Descriptor deprecated

func (*CodeMetadata) Descriptor() ([]byte, []int)

Deprecated: Use CodeMetadata.ProtoReflect.Descriptor instead.

func (*CodeMetadata) GetEnv

func (x *CodeMetadata) GetEnv() []string

func (*CodeMetadata) GetSecrets

func (x *CodeMetadata) GetSecrets() []string

func (*CodeMetadata) ProtoMessage

func (*CodeMetadata) ProtoMessage()

func (*CodeMetadata) ProtoReflect

func (x *CodeMetadata) ProtoReflect() protoreflect.Message

func (*CodeMetadata) Reset

func (x *CodeMetadata) Reset()

func (*CodeMetadata) String

func (x *CodeMetadata) String() string

type ConfigItem

type ConfigItem struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`     // Configuration key name
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Configuration value
	// contains filtered or unexported fields
}

func (*ConfigItem) Descriptor deprecated

func (*ConfigItem) Descriptor() ([]byte, []int)

Deprecated: Use ConfigItem.ProtoReflect.Descriptor instead.

func (*ConfigItem) GetKey

func (x *ConfigItem) GetKey() string

func (*ConfigItem) GetValue

func (x *ConfigItem) GetValue() string

func (*ConfigItem) ProtoMessage

func (*ConfigItem) ProtoMessage()

func (*ConfigItem) ProtoReflect

func (x *ConfigItem) ProtoReflect() protoreflect.Message

func (*ConfigItem) Reset

func (x *ConfigItem) Reset()

func (*ConfigItem) String

func (x *ConfigItem) String() string

type ConfigurationUpdate

type ConfigurationUpdate struct {
	Id     string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`         // Unique identifier for tracking this update
	Config []*ConfigItem `protobuf:"bytes,2,rep,name=config,proto3" json:"config,omitempty"` // List of configuration items to set
	// contains filtered or unexported fields
}

Configuration update from server to client

func (*ConfigurationUpdate) Descriptor deprecated

func (*ConfigurationUpdate) Descriptor() ([]byte, []int)

Deprecated: Use ConfigurationUpdate.ProtoReflect.Descriptor instead.

func (*ConfigurationUpdate) GetConfig

func (x *ConfigurationUpdate) GetConfig() []*ConfigItem

func (*ConfigurationUpdate) GetId

func (x *ConfigurationUpdate) GetId() string

func (*ConfigurationUpdate) ProtoMessage

func (*ConfigurationUpdate) ProtoMessage()

func (*ConfigurationUpdate) ProtoReflect

func (x *ConfigurationUpdate) ProtoReflect() protoreflect.Message

func (*ConfigurationUpdate) Reset

func (x *ConfigurationUpdate) Reset()

func (*ConfigurationUpdate) String

func (x *ConfigurationUpdate) String() string

type ConfigurationUpdateResponse

type ConfigurationUpdateResponse struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`            // Identifier matching the ConfigurationUpdate
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` // Whether the configuration was successful
	Error   string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`      // Error message if configuration failed
	// contains filtered or unexported fields
}

Configuration update response from client to server

func (*ConfigurationUpdateResponse) Descriptor deprecated

func (*ConfigurationUpdateResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConfigurationUpdateResponse.ProtoReflect.Descriptor instead.

func (*ConfigurationUpdateResponse) GetError

func (x *ConfigurationUpdateResponse) GetError() string

func (*ConfigurationUpdateResponse) GetId

func (*ConfigurationUpdateResponse) GetSuccess

func (x *ConfigurationUpdateResponse) GetSuccess() bool

func (*ConfigurationUpdateResponse) ProtoMessage

func (*ConfigurationUpdateResponse) ProtoMessage()

func (*ConfigurationUpdateResponse) ProtoReflect

func (*ConfigurationUpdateResponse) Reset

func (x *ConfigurationUpdateResponse) Reset()

func (*ConfigurationUpdateResponse) String

func (x *ConfigurationUpdateResponse) String() string

type ConnectRequest

type ConnectRequest struct {
	ProtocolVersion int32                 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` // Protocol version number for compatibility
	ClientVersion   string                `protobuf:"bytes,2,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`        // Version string of the client (e.g., SHA, semver)
	ClientName      string                `protobuf:"bytes,3,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"`                 // Name of the client application (e.g., "hadron")
	Deployments     []*ExistingDeployment `protobuf:"bytes,4,rep,name=deployments,proto3" json:"deployments,omitempty"`                                 // List of existing deployments to restore
	HostInfo        *HostInfo             `protobuf:"bytes,5,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"`                       // Information about the host system
	Capabilities    *ClientCapabilities   `protobuf:"bytes,6,opt,name=capabilities,proto3" json:"capabilities,omitempty"`                               // Client capabilities for this connection
	// contains filtered or unexported fields
}

Connect request from client to Gravity

func (*ConnectRequest) Descriptor deprecated

func (*ConnectRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetCapabilities

func (x *ConnectRequest) GetCapabilities() *ClientCapabilities

func (*ConnectRequest) GetClientName

func (x *ConnectRequest) GetClientName() string

func (*ConnectRequest) GetClientVersion

func (x *ConnectRequest) GetClientVersion() string

func (*ConnectRequest) GetDeployments

func (x *ConnectRequest) GetDeployments() []*ExistingDeployment

func (*ConnectRequest) GetHostInfo

func (x *ConnectRequest) GetHostInfo() *HostInfo

func (*ConnectRequest) GetProtocolVersion

func (x *ConnectRequest) GetProtocolVersion() int32

func (*ConnectRequest) ProtoMessage

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect

func (x *ConnectRequest) ProtoReflect() protoreflect.Message

func (*ConnectRequest) Reset

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String

func (x *ConnectRequest) String() string

type ConnectResponse

type ConnectResponse struct {
	OtlpUrl       string         `protobuf:"bytes,1,opt,name=otlp_url,json=otlpUrl,proto3" json:"otlp_url,omitempty"`             // OpenTelemetry endpoint URL for metrics
	ApiUrl        string         `protobuf:"bytes,3,opt,name=api_url,json=apiUrl,proto3" json:"api_url,omitempty"`                // Base URL for API operations
	Environment   []string       `protobuf:"bytes,4,rep,name=environment,proto3" json:"environment,omitempty"`                    // Environment variables to set
	HostMapping   []*HostMapping `protobuf:"bytes,5,rep,name=host_mapping,json=hostMapping,proto3" json:"host_mapping,omitempty"` // Host to IP address mappings
	SubnetRoutes  []string       `protobuf:"bytes,6,rep,name=subnet_routes,json=subnetRoutes,proto3" json:"subnet_routes,omitempty"`
	GravityServer string         `protobuf:"bytes,7,opt,name=gravity_server,json=gravityServer,proto3" json:"gravity_server,omitempty"` // the gravity server that we're connected to
	Hostname      string         `protobuf:"bytes,8,opt,name=hostname,proto3" json:"hostname,omitempty"`                                // this hostname if dynamic hostname is requested
	OtlpKey       string         `protobuf:"bytes,9,opt,name=otlp_key,json=otlpKey,proto3" json:"otlp_key,omitempty"`                   // OpenTelemetry API key for authentication (if needed)
	OrgId         string         `protobuf:"bytes,10,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`                        // Organization ID for authentication
	SshPublicKey  []byte         `protobuf:"bytes,11,opt,name=ssh_public_key,json=sshPublicKey,proto3" json:"ssh_public_key,omitempty"` // SSH public key for internal trusted connections (SSH wire format)
	// contains filtered or unexported fields
}

Connect response from Gravity to client

func (*ConnectResponse) Descriptor deprecated

func (*ConnectResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetApiUrl

func (x *ConnectResponse) GetApiUrl() string

func (*ConnectResponse) GetEnvironment

func (x *ConnectResponse) GetEnvironment() []string

func (*ConnectResponse) GetGravityServer

func (x *ConnectResponse) GetGravityServer() string

func (*ConnectResponse) GetHostMapping

func (x *ConnectResponse) GetHostMapping() []*HostMapping

func (*ConnectResponse) GetHostname added in v1.0.94

func (x *ConnectResponse) GetHostname() string

func (*ConnectResponse) GetOrgId added in v1.0.95

func (x *ConnectResponse) GetOrgId() string

func (*ConnectResponse) GetOtlpKey added in v1.0.94

func (x *ConnectResponse) GetOtlpKey() string

func (*ConnectResponse) GetOtlpUrl

func (x *ConnectResponse) GetOtlpUrl() string

func (*ConnectResponse) GetSshPublicKey added in v1.0.123

func (x *ConnectResponse) GetSshPublicKey() []byte

func (*ConnectResponse) GetSubnetRoutes

func (x *ConnectResponse) GetSubnetRoutes() []string

func (*ConnectResponse) ProtoMessage

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect

func (x *ConnectResponse) ProtoReflect() protoreflect.Message

func (*ConnectResponse) Reset

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String

func (x *ConnectResponse) String() string

type ControlMessage

type ControlMessage struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` // Logical stream identifier for multiplexing
	// Types that are valid to be assigned to MessageType:
	//
	//	*ControlMessage_Connect
	//	*ControlMessage_ConnectResponse
	//	*ControlMessage_Close
	//	*ControlMessage_RouteDeployment
	//	*ControlMessage_RouteDeploymentResponse
	//	*ControlMessage_Unprovision
	//	*ControlMessage_Ping
	//	*ControlMessage_Pong
	//	*ControlMessage_Report
	//	*ControlMessage_Pause
	//	*ControlMessage_Resume
	//	*ControlMessage_ConfigUpdate
	//	*ControlMessage_ConfigUpdateResponse
	//	*ControlMessage_Response
	//	*ControlMessage_Event
	MessageType isControlMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

ControlMessage represents all control plane communications

func (*ControlMessage) Descriptor deprecated

func (*ControlMessage) Descriptor() ([]byte, []int)

Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage) GetClose

func (x *ControlMessage) GetClose() *CloseRequest

func (*ControlMessage) GetConfigUpdate

func (x *ControlMessage) GetConfigUpdate() *ConfigurationUpdate

func (*ControlMessage) GetConfigUpdateResponse

func (x *ControlMessage) GetConfigUpdateResponse() *ConfigurationUpdateResponse

func (*ControlMessage) GetConnect

func (x *ControlMessage) GetConnect() *ConnectRequest

func (*ControlMessage) GetConnectResponse

func (x *ControlMessage) GetConnectResponse() *ConnectResponse

func (*ControlMessage) GetEvent

func (x *ControlMessage) GetEvent() *ProtocolEvent

func (*ControlMessage) GetId

func (x *ControlMessage) GetId() string

func (*ControlMessage) GetMessageType

func (x *ControlMessage) GetMessageType() isControlMessage_MessageType

func (*ControlMessage) GetPause

func (x *ControlMessage) GetPause() *PauseRequest

func (*ControlMessage) GetPing

func (x *ControlMessage) GetPing() *PingRequest

func (*ControlMessage) GetPong

func (x *ControlMessage) GetPong() *PongResponse

func (*ControlMessage) GetReport

func (x *ControlMessage) GetReport() *ReportRequest

func (*ControlMessage) GetResponse

func (x *ControlMessage) GetResponse() *ProtocolResponse

func (*ControlMessage) GetResume

func (x *ControlMessage) GetResume() *ResumeRequest

func (*ControlMessage) GetRouteDeployment

func (x *ControlMessage) GetRouteDeployment() *RouteDeploymentRequest

func (*ControlMessage) GetRouteDeploymentResponse

func (x *ControlMessage) GetRouteDeploymentResponse() *RouteDeploymentResponse

func (*ControlMessage) GetStreamId

func (x *ControlMessage) GetStreamId() string

func (*ControlMessage) GetUnprovision

func (x *ControlMessage) GetUnprovision() *UnprovisionRequest

func (*ControlMessage) ProtoMessage

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) ProtoReflect

func (x *ControlMessage) ProtoReflect() protoreflect.Message

func (*ControlMessage) Reset

func (x *ControlMessage) Reset()

func (*ControlMessage) String

func (x *ControlMessage) String() string

type ControlMessage_Close

type ControlMessage_Close struct {
	Close *CloseRequest `protobuf:"bytes,15,opt,name=close,proto3,oneof"`
}

type ControlMessage_ConfigUpdate

type ControlMessage_ConfigUpdate struct {
	// Configuration management (45-49)
	ConfigUpdate *ConfigurationUpdate `protobuf:"bytes,45,opt,name=config_update,json=configUpdate,proto3,oneof"`
}

type ControlMessage_ConfigUpdateResponse

type ControlMessage_ConfigUpdateResponse struct {
	ConfigUpdateResponse *ConfigurationUpdateResponse `protobuf:"bytes,46,opt,name=config_update_response,json=configUpdateResponse,proto3,oneof"`
}

type ControlMessage_Connect

type ControlMessage_Connect struct {
	// Connection lifecycle (10-19)
	Connect *ConnectRequest `protobuf:"bytes,10,opt,name=connect,proto3,oneof"`
}

type ControlMessage_ConnectResponse

type ControlMessage_ConnectResponse struct {
	ConnectResponse *ConnectResponse `protobuf:"bytes,11,opt,name=connect_response,json=connectResponse,proto3,oneof"`
}

type ControlMessage_Event

type ControlMessage_Event struct {
	Event *ProtocolEvent `protobuf:"bytes,51,opt,name=event,proto3,oneof"`
}

type ControlMessage_Pause

type ControlMessage_Pause struct {
	// Session control (40-49)
	Pause *PauseRequest `protobuf:"bytes,40,opt,name=pause,proto3,oneof"`
}

type ControlMessage_Ping

type ControlMessage_Ping struct {
	// Health and monitoring (30-39)
	Ping *PingRequest `protobuf:"bytes,30,opt,name=ping,proto3,oneof"`
}

type ControlMessage_Pong

type ControlMessage_Pong struct {
	Pong *PongResponse `protobuf:"bytes,31,opt,name=pong,proto3,oneof"`
}

type ControlMessage_Report

type ControlMessage_Report struct {
	Report *ReportRequest `protobuf:"bytes,32,opt,name=report,proto3,oneof"`
}

type ControlMessage_Response

type ControlMessage_Response struct {
	// Generic protocol messages (50-59)
	Response *ProtocolResponse `protobuf:"bytes,50,opt,name=response,proto3,oneof"`
}

type ControlMessage_Resume

type ControlMessage_Resume struct {
	Resume *ResumeRequest `protobuf:"bytes,41,opt,name=resume,proto3,oneof"`
}

type ControlMessage_RouteDeployment

type ControlMessage_RouteDeployment struct {
	// Deployment management (20-29)
	RouteDeployment *RouteDeploymentRequest `protobuf:"bytes,22,opt,name=route_deployment,json=routeDeployment,proto3,oneof"`
}

type ControlMessage_RouteDeploymentResponse

type ControlMessage_RouteDeploymentResponse struct {
	RouteDeploymentResponse *RouteDeploymentResponse `protobuf:"bytes,23,opt,name=route_deployment_response,json=routeDeploymentResponse,proto3,oneof"`
}

type ControlMessage_Unprovision

type ControlMessage_Unprovision struct {
	Unprovision *UnprovisionRequest `protobuf:"bytes,25,opt,name=unprovision,proto3,oneof"`
}

type DeploymentCert

type DeploymentCert struct {
	Cert    string `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"`       // TLS certificate in PEM format
	Key     string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`         // TLS private key in PEM format
	Ca      string `protobuf:"bytes,3,opt,name=ca,proto3" json:"ca,omitempty"`           // Certificate Authority certificate
	Dnsname string `protobuf:"bytes,4,opt,name=dnsname,proto3" json:"dnsname,omitempty"` // DNS name for the certificate
	// contains filtered or unexported fields
}

func (*DeploymentCert) Descriptor deprecated

func (*DeploymentCert) Descriptor() ([]byte, []int)

Deprecated: Use DeploymentCert.ProtoReflect.Descriptor instead.

func (*DeploymentCert) GetCa

func (x *DeploymentCert) GetCa() string

func (*DeploymentCert) GetCert

func (x *DeploymentCert) GetCert() string

func (*DeploymentCert) GetDnsname

func (x *DeploymentCert) GetDnsname() string

func (*DeploymentCert) GetKey

func (x *DeploymentCert) GetKey() string

func (*DeploymentCert) ProtoMessage

func (*DeploymentCert) ProtoMessage()

func (*DeploymentCert) ProtoReflect

func (x *DeploymentCert) ProtoReflect() protoreflect.Message

func (*DeploymentCert) Reset

func (x *DeploymentCert) Reset()

func (*DeploymentCert) String

func (x *DeploymentCert) String() string

type DeploymentMetadataRequest

type DeploymentMetadataRequest struct {
	DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Unique identifier for the deployment
	OrgId        string `protobuf:"bytes,2,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`                      // Organization identifier
	// contains filtered or unexported fields
}

Deployment metadata request

func (*DeploymentMetadataRequest) Descriptor deprecated

func (*DeploymentMetadataRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeploymentMetadataRequest.ProtoReflect.Descriptor instead.

func (*DeploymentMetadataRequest) GetDeploymentId

func (x *DeploymentMetadataRequest) GetDeploymentId() string

func (*DeploymentMetadataRequest) GetOrgId

func (x *DeploymentMetadataRequest) GetOrgId() string

func (*DeploymentMetadataRequest) ProtoMessage

func (*DeploymentMetadataRequest) ProtoMessage()

func (*DeploymentMetadataRequest) ProtoReflect

func (*DeploymentMetadataRequest) Reset

func (x *DeploymentMetadataRequest) Reset()

func (*DeploymentMetadataRequest) String

func (x *DeploymentMetadataRequest) String() string

type DeploymentMetadataResponse

type DeploymentMetadataResponse struct {
	Success        bool            `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`                                    // Whether the request was successful
	Error          string          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`                                         // Error message if request failed
	CodeMetadata   *CodeMetadata   `protobuf:"bytes,3,opt,name=code_metadata,json=codeMetadata,proto3" json:"code_metadata,omitempty"`       // Code metadata from FetchEnv
	DeploymentCert *DeploymentCert `protobuf:"bytes,4,opt,name=deployment_cert,json=deploymentCert,proto3" json:"deployment_cert,omitempty"` // Generated deployment certificate
	OtlpToken      string          `protobuf:"bytes,5,opt,name=otlp_token,json=otlpToken,proto3" json:"otlp_token,omitempty"`                // OpenTelemetry token for metrics
	AuthToken      string          `protobuf:"bytes,6,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`                // Authentication token
	ExtraHosts     []string        `protobuf:"bytes,7,rep,name=extra_hosts,json=extraHosts,proto3" json:"extra_hosts,omitempty"`             // Extra /etc/hosts entries for the deployment
	// contains filtered or unexported fields
}

Deployment metadata response

func (*DeploymentMetadataResponse) Descriptor deprecated

func (*DeploymentMetadataResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeploymentMetadataResponse.ProtoReflect.Descriptor instead.

func (*DeploymentMetadataResponse) GetAuthToken

func (x *DeploymentMetadataResponse) GetAuthToken() string

func (*DeploymentMetadataResponse) GetCodeMetadata

func (x *DeploymentMetadataResponse) GetCodeMetadata() *CodeMetadata

func (*DeploymentMetadataResponse) GetDeploymentCert

func (x *DeploymentMetadataResponse) GetDeploymentCert() *DeploymentCert

func (*DeploymentMetadataResponse) GetError

func (x *DeploymentMetadataResponse) GetError() string

func (*DeploymentMetadataResponse) GetExtraHosts added in v1.0.125

func (x *DeploymentMetadataResponse) GetExtraHosts() []string

func (*DeploymentMetadataResponse) GetOtlpToken

func (x *DeploymentMetadataResponse) GetOtlpToken() string

func (*DeploymentMetadataResponse) GetSuccess

func (x *DeploymentMetadataResponse) GetSuccess() bool

func (*DeploymentMetadataResponse) ProtoMessage

func (*DeploymentMetadataResponse) ProtoMessage()

func (*DeploymentMetadataResponse) ProtoReflect

func (*DeploymentMetadataResponse) Reset

func (x *DeploymentMetadataResponse) Reset()

func (*DeploymentMetadataResponse) String

func (x *DeploymentMetadataResponse) String() string

type DeploymentSpec deprecated

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

Deprecated: Marked as deprecated in gravity.proto.

func (*DeploymentSpec) Descriptor deprecated

func (*DeploymentSpec) Descriptor() ([]byte, []int)

Deprecated: Use DeploymentSpec.ProtoReflect.Descriptor instead.

func (*DeploymentSpec) ProtoMessage

func (*DeploymentSpec) ProtoMessage()

func (*DeploymentSpec) ProtoReflect

func (x *DeploymentSpec) ProtoReflect() protoreflect.Message

func (*DeploymentSpec) Reset

func (x *DeploymentSpec) Reset()

func (*DeploymentSpec) String

func (x *DeploymentSpec) String() string

type ErrorRateSample

type ErrorRateSample struct {
	Timestamp   int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                   // epoch milliseconds
	ErrorRate   float64 `protobuf:"fixed64,2,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"` // percentage
	TotalErrors int64   `protobuf:"varint,3,opt,name=total_errors,json=totalErrors,proto3" json:"total_errors,omitempty"`
	// contains filtered or unexported fields
}

ErrorRateSample represents error rate at a point in time

func (*ErrorRateSample) Descriptor deprecated

func (*ErrorRateSample) Descriptor() ([]byte, []int)

Deprecated: Use ErrorRateSample.ProtoReflect.Descriptor instead.

func (*ErrorRateSample) GetErrorRate

func (x *ErrorRateSample) GetErrorRate() float64

func (*ErrorRateSample) GetTimestamp

func (x *ErrorRateSample) GetTimestamp() int64

func (*ErrorRateSample) GetTotalErrors

func (x *ErrorRateSample) GetTotalErrors() int64

func (*ErrorRateSample) ProtoMessage

func (*ErrorRateSample) ProtoMessage()

func (*ErrorRateSample) ProtoReflect

func (x *ErrorRateSample) ProtoReflect() protoreflect.Message

func (*ErrorRateSample) Reset

func (x *ErrorRateSample) Reset()

func (*ErrorRateSample) String

func (x *ErrorRateSample) String() string

type ExistingDeployment

type ExistingDeployment struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique identifier for the deployment
	Started        *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"`                            // When the deployment was started
	Ipv6Address    string                 `protobuf:"bytes,4,opt,name=ipv6_address,json=ipv6Address,proto3" json:"ipv6_address,omitempty"` // Assigned IPv6 address for the deployment
	OrgId          string                 `protobuf:"bytes,5,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	Resources      *ResourceRequirements  `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"` // CPU and memory requirements
	DeploymentCert *DeploymentCert        `protobuf:"bytes,7,opt,name=deployment_cert,json=deploymentCert,proto3" json:"deployment_cert,omitempty"`
	UsedPrivateKey bool                   `protobuf:"varint,8,opt,name=used_private_key,json=usedPrivateKey,proto3" json:"used_private_key,omitempty"` // Deployment used private key
	Paused         bool                   `protobuf:"varint,9,opt,name=paused,proto3" json:"paused,omitempty"`
	PausedDuration *durationpb.Duration   `protobuf:"bytes,10,opt,name=pausedDuration,proto3" json:"pausedDuration,omitempty"`
	OnDemand       bool                   `protobuf:"varint,11,opt,name=on_demand,json=onDemand,proto3" json:"on_demand,omitempty"`
	// contains filtered or unexported fields
}

func (*ExistingDeployment) Descriptor deprecated

func (*ExistingDeployment) Descriptor() ([]byte, []int)

Deprecated: Use ExistingDeployment.ProtoReflect.Descriptor instead.

func (*ExistingDeployment) GetDeploymentCert added in v1.0.111

func (x *ExistingDeployment) GetDeploymentCert() *DeploymentCert

func (*ExistingDeployment) GetId

func (x *ExistingDeployment) GetId() string

func (*ExistingDeployment) GetIpv6Address

func (x *ExistingDeployment) GetIpv6Address() string

func (*ExistingDeployment) GetOnDemand added in v1.0.114

func (x *ExistingDeployment) GetOnDemand() bool

func (*ExistingDeployment) GetOrgId added in v1.0.111

func (x *ExistingDeployment) GetOrgId() string

func (*ExistingDeployment) GetPaused added in v1.0.111

func (x *ExistingDeployment) GetPaused() bool

func (*ExistingDeployment) GetPausedDuration added in v1.0.111

func (x *ExistingDeployment) GetPausedDuration() *durationpb.Duration

func (*ExistingDeployment) GetResources added in v1.0.111

func (x *ExistingDeployment) GetResources() *ResourceRequirements

func (*ExistingDeployment) GetStarted

func (x *ExistingDeployment) GetStarted() *timestamppb.Timestamp

func (*ExistingDeployment) GetUsedPrivateKey added in v1.0.111

func (x *ExistingDeployment) GetUsedPrivateKey() bool

func (*ExistingDeployment) ProtoMessage

func (*ExistingDeployment) ProtoMessage()

func (*ExistingDeployment) ProtoReflect

func (x *ExistingDeployment) ProtoReflect() protoreflect.Message

func (*ExistingDeployment) Reset

func (x *ExistingDeployment) Reset()

func (*ExistingDeployment) String

func (x *ExistingDeployment) String() string

type GRPCConnectionMetrics

type GRPCConnectionMetrics struct {

	// Connection pool information (1-10)
	PoolSize          int32    `protobuf:"varint,1,opt,name=pool_size,json=poolSize,proto3" json:"pool_size,omitempty"`
	ActiveConnections int32    `protobuf:"varint,2,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
	IdleConnections   int32    `protobuf:"varint,3,opt,name=idle_connections,json=idleConnections,proto3" json:"idle_connections,omitempty"`
	FailedConnections int32    `protobuf:"varint,4,opt,name=failed_connections,json=failedConnections,proto3" json:"failed_connections,omitempty"`
	ConnectionStates  []string `protobuf:"bytes,5,rep,name=connection_states,json=connectionStates,proto3" json:"connection_states,omitempty"`
	// Stream information (11-20)
	TotalStreams     int32  `protobuf:"varint,11,opt,name=total_streams,json=totalStreams,proto3" json:"total_streams,omitempty"`
	ControlStreams   int32  `protobuf:"varint,12,opt,name=control_streams,json=controlStreams,proto3" json:"control_streams,omitempty"`
	TunnelStreams    int32  `protobuf:"varint,13,opt,name=tunnel_streams,json=tunnelStreams,proto3" json:"tunnel_streams,omitempty"`
	HealthyStreams   int32  `protobuf:"varint,14,opt,name=healthy_streams,json=healthyStreams,proto3" json:"healthy_streams,omitempty"`
	ActiveStreams    int32  `protobuf:"varint,15,opt,name=active_streams,json=activeStreams,proto3" json:"active_streams,omitempty"`
	StreamAllocation string `protobuf:"bytes,16,opt,name=stream_allocation,json=streamAllocation,proto3" json:"stream_allocation,omitempty"` // allocation strategy
	// Protocol information (21-30)
	ProtocolVersion    string `protobuf:"bytes,21,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	CompressionEnabled bool   `protobuf:"varint,22,opt,name=compression_enabled,json=compressionEnabled,proto3" json:"compression_enabled,omitempty"`
	TlsVersion         string `protobuf:"bytes,23,opt,name=tls_version,json=tlsVersion,proto3" json:"tls_version,omitempty"`
	// Health monitoring (31-40)
	LastHealthCheck       int64 `protobuf:"varint,31,opt,name=last_health_check,json=lastHealthCheck,proto3" json:"last_health_check,omitempty"` // epoch milliseconds
	HealthCheckIntervalNs int64 ``                                                                                                               // nanoseconds
	/* 130-byte string literal not displayed */
	UnhealthyStreams []string `protobuf:"bytes,33,rep,name=unhealthy_streams,json=unhealthyStreams,proto3" json:"unhealthy_streams,omitempty"`
	// contains filtered or unexported fields
}

GRPCConnectionMetrics contains gRPC-specific connection metrics

func (*GRPCConnectionMetrics) Descriptor deprecated

func (*GRPCConnectionMetrics) Descriptor() ([]byte, []int)

Deprecated: Use GRPCConnectionMetrics.ProtoReflect.Descriptor instead.

func (*GRPCConnectionMetrics) GetActiveConnections

func (x *GRPCConnectionMetrics) GetActiveConnections() int32

func (*GRPCConnectionMetrics) GetActiveStreams

func (x *GRPCConnectionMetrics) GetActiveStreams() int32

func (*GRPCConnectionMetrics) GetCompressionEnabled

func (x *GRPCConnectionMetrics) GetCompressionEnabled() bool

func (*GRPCConnectionMetrics) GetConnectionStates

func (x *GRPCConnectionMetrics) GetConnectionStates() []string

func (*GRPCConnectionMetrics) GetControlStreams

func (x *GRPCConnectionMetrics) GetControlStreams() int32

func (*GRPCConnectionMetrics) GetFailedConnections

func (x *GRPCConnectionMetrics) GetFailedConnections() int32

func (*GRPCConnectionMetrics) GetHealthCheckIntervalNs

func (x *GRPCConnectionMetrics) GetHealthCheckIntervalNs() int64

func (*GRPCConnectionMetrics) GetHealthyStreams

func (x *GRPCConnectionMetrics) GetHealthyStreams() int32

func (*GRPCConnectionMetrics) GetIdleConnections

func (x *GRPCConnectionMetrics) GetIdleConnections() int32

func (*GRPCConnectionMetrics) GetLastHealthCheck

func (x *GRPCConnectionMetrics) GetLastHealthCheck() int64

func (*GRPCConnectionMetrics) GetPoolSize

func (x *GRPCConnectionMetrics) GetPoolSize() int32

func (*GRPCConnectionMetrics) GetProtocolVersion

func (x *GRPCConnectionMetrics) GetProtocolVersion() string

func (*GRPCConnectionMetrics) GetStreamAllocation

func (x *GRPCConnectionMetrics) GetStreamAllocation() string

func (*GRPCConnectionMetrics) GetTlsVersion

func (x *GRPCConnectionMetrics) GetTlsVersion() string

func (*GRPCConnectionMetrics) GetTotalStreams

func (x *GRPCConnectionMetrics) GetTotalStreams() int32

func (*GRPCConnectionMetrics) GetTunnelStreams

func (x *GRPCConnectionMetrics) GetTunnelStreams() int32

func (*GRPCConnectionMetrics) GetUnhealthyStreams

func (x *GRPCConnectionMetrics) GetUnhealthyStreams() []string

func (*GRPCConnectionMetrics) ProtoMessage

func (*GRPCConnectionMetrics) ProtoMessage()

func (*GRPCConnectionMetrics) ProtoReflect

func (x *GRPCConnectionMetrics) ProtoReflect() protoreflect.Message

func (*GRPCConnectionMetrics) Reset

func (x *GRPCConnectionMetrics) Reset()

func (*GRPCConnectionMetrics) String

func (x *GRPCConnectionMetrics) String() string

type GravityControlClient

type GravityControlClient interface {
	// provision is called on startup to get certificates and configuration
	Provision(ctx context.Context, in *ProvisionRequest, opts ...grpc.CallOption) (*ProvisionResponse, error)
	// get deployment metadata for provisioning
	GetDeploymentMetadata(ctx context.Context, in *DeploymentMetadataRequest, opts ...grpc.CallOption) (*DeploymentMetadataResponse, error)
}

GravityControlClient is the client API for GravityControl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

GravityControl service handles client provisioning and metadata

type GravityControlServer

type GravityControlServer interface {
	// provision is called on startup to get certificates and configuration
	Provision(context.Context, *ProvisionRequest) (*ProvisionResponse, error)
	// get deployment metadata for provisioning
	GetDeploymentMetadata(context.Context, *DeploymentMetadataRequest) (*DeploymentMetadataResponse, error)
	// contains filtered or unexported methods
}

GravityControlServer is the server API for GravityControl service. All implementations must embed UnimplementedGravityControlServer for forward compatibility.

GravityControl service handles client provisioning and metadata

type GravityTunnelClient

type GravityTunnelClient interface {
	// establish a tunnel for the client to send and receive control messages
	// after it has been provisioned
	EstablishTunnel(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ControlMessage, ControlMessage], error)
	// stream packet data with multiplexing
	StreamPackets(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[TunnelPacket, TunnelPacket], error)
}

GravityTunnelClient is the client API for GravityTunnel service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

GravityTunnel service handles bidirectional streaming for packet data and control messages

type GravityTunnelServer

type GravityTunnelServer interface {
	// establish a tunnel for the client to send and receive control messages
	// after it has been provisioned
	EstablishTunnel(grpc.BidiStreamingServer[ControlMessage, ControlMessage]) error
	// stream packet data with multiplexing
	StreamPackets(grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]) error
	// contains filtered or unexported methods
}

GravityTunnelServer is the server API for GravityTunnel service. All implementations must embed UnimplementedGravityTunnelServer for forward compatibility.

GravityTunnel service handles bidirectional streaming for packet data and control messages

type GravityTunnel_EstablishTunnelClient

type GravityTunnel_EstablishTunnelClient = grpc.BidiStreamingClient[ControlMessage, ControlMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GravityTunnel_EstablishTunnelServer

type GravityTunnel_EstablishTunnelServer = grpc.BidiStreamingServer[ControlMessage, ControlMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GravityTunnel_StreamPacketsClient

type GravityTunnel_StreamPacketsClient = grpc.BidiStreamingClient[TunnelPacket, TunnelPacket]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GravityTunnel_StreamPacketsServer

type GravityTunnel_StreamPacketsServer = grpc.BidiStreamingServer[TunnelPacket, TunnelPacket]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HealthSample

type HealthSample struct {
	Timestamp         int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
	HealthyStreams    int32   `protobuf:"varint,2,opt,name=healthy_streams,json=healthyStreams,proto3" json:"healthy_streams,omitempty"`
	TotalStreams      int32   `protobuf:"varint,3,opt,name=total_streams,json=totalStreams,proto3" json:"total_streams,omitempty"`
	ActiveConnections int32   `protobuf:"varint,4,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
	HealthScore       float64 `protobuf:"fixed64,5,opt,name=health_score,json=healthScore,proto3" json:"health_score,omitempty"` // percentage
	// contains filtered or unexported fields
}

HealthSample represents system health at a point in time

func (*HealthSample) Descriptor deprecated

func (*HealthSample) Descriptor() ([]byte, []int)

Deprecated: Use HealthSample.ProtoReflect.Descriptor instead.

func (*HealthSample) GetActiveConnections

func (x *HealthSample) GetActiveConnections() int32

func (*HealthSample) GetHealthScore

func (x *HealthSample) GetHealthScore() float64

func (*HealthSample) GetHealthyStreams

func (x *HealthSample) GetHealthyStreams() int32

func (*HealthSample) GetTimestamp

func (x *HealthSample) GetTimestamp() int64

func (*HealthSample) GetTotalStreams

func (x *HealthSample) GetTotalStreams() int32

func (*HealthSample) ProtoMessage

func (*HealthSample) ProtoMessage()

func (*HealthSample) ProtoReflect

func (x *HealthSample) ProtoReflect() protoreflect.Message

func (*HealthSample) Reset

func (x *HealthSample) Reset()

func (*HealthSample) String

func (x *HealthSample) String() string

type HistoricalMetrics

type HistoricalMetrics struct {

	// Recent throughput samples (last 60 samples, 1 per minute)
	ThroughputHistory []*ThroughputSample `protobuf:"bytes,1,rep,name=throughput_history,json=throughputHistory,proto3" json:"throughput_history,omitempty"`
	// Recent latency samples
	LatencyHistory []*LatencySample `protobuf:"bytes,2,rep,name=latency_history,json=latencyHistory,proto3" json:"latency_history,omitempty"`
	// Error rate samples
	ErrorRateHistory []*ErrorRateSample `protobuf:"bytes,3,rep,name=error_rate_history,json=errorRateHistory,proto3" json:"error_rate_history,omitempty"`
	// Connection health samples
	HealthHistory []*HealthSample `protobuf:"bytes,4,rep,name=health_history,json=healthHistory,proto3" json:"health_history,omitempty"`
	// Maximum history length
	MaxHistoryLength int32 `protobuf:"varint,5,opt,name=max_history_length,json=maxHistoryLength,proto3" json:"max_history_length,omitempty"`
	// contains filtered or unexported fields
}

HistoricalMetrics contains time-series data for trend analysis

func (*HistoricalMetrics) Descriptor deprecated

func (*HistoricalMetrics) Descriptor() ([]byte, []int)

Deprecated: Use HistoricalMetrics.ProtoReflect.Descriptor instead.

func (*HistoricalMetrics) GetErrorRateHistory

func (x *HistoricalMetrics) GetErrorRateHistory() []*ErrorRateSample

func (*HistoricalMetrics) GetHealthHistory

func (x *HistoricalMetrics) GetHealthHistory() []*HealthSample

func (*HistoricalMetrics) GetLatencyHistory

func (x *HistoricalMetrics) GetLatencyHistory() []*LatencySample

func (*HistoricalMetrics) GetMaxHistoryLength

func (x *HistoricalMetrics) GetMaxHistoryLength() int32

func (*HistoricalMetrics) GetThroughputHistory

func (x *HistoricalMetrics) GetThroughputHistory() []*ThroughputSample

func (*HistoricalMetrics) ProtoMessage

func (*HistoricalMetrics) ProtoMessage()

func (*HistoricalMetrics) ProtoReflect

func (x *HistoricalMetrics) ProtoReflect() protoreflect.Message

func (*HistoricalMetrics) Reset

func (x *HistoricalMetrics) Reset()

func (*HistoricalMetrics) String

func (x *HistoricalMetrics) String() string

type HostInfo

type HostInfo struct {
	Started     uint64 `protobuf:"varint,1,opt,name=started,proto3" json:"started,omitempty"`                           // epoch time in milliseconds since server started
	Cpu         uint32 `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"`                                   // number of CPUs
	Memory      uint64 `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"`                             // memory in bytes
	Disk        uint64 `protobuf:"varint,4,opt,name=disk,proto3" json:"disk,omitempty"`                                 // disk free space in bytes
	Ipv4Address string `protobuf:"bytes,5,opt,name=ipv4_address,json=ipv4Address,proto3" json:"ipv4_address,omitempty"` // IPv4 address
	Ipv6Address string `protobuf:"bytes,6,opt,name=ipv6_address,json=ipv6Address,proto3" json:"ipv6_address,omitempty"` // IPv6 address
	Hostname    string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"`                          // hostname
	InstanceId  string `protobuf:"bytes,8,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`    // instance id of the client
	// contains filtered or unexported fields
}

Supporting data structures

func (*HostInfo) Descriptor deprecated

func (*HostInfo) Descriptor() ([]byte, []int)

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetCpu

func (x *HostInfo) GetCpu() uint32

func (*HostInfo) GetDisk

func (x *HostInfo) GetDisk() uint64

func (*HostInfo) GetHostname

func (x *HostInfo) GetHostname() string

func (*HostInfo) GetInstanceId

func (x *HostInfo) GetInstanceId() string

func (*HostInfo) GetIpv4Address

func (x *HostInfo) GetIpv4Address() string

func (*HostInfo) GetIpv6Address

func (x *HostInfo) GetIpv6Address() string

func (*HostInfo) GetMemory

func (x *HostInfo) GetMemory() uint64

func (*HostInfo) GetStarted

func (x *HostInfo) GetStarted() uint64

func (*HostInfo) ProtoMessage

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect

func (x *HostInfo) ProtoReflect() protoreflect.Message

func (*HostInfo) Reset

func (x *HostInfo) Reset()

func (*HostInfo) String

func (x *HostInfo) String() string

type HostMapping

type HostMapping struct {
	Hostname  string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`                    // Hostname to map
	IpAddress string `protobuf:"bytes,2,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"` // IP address to map the hostname to
	// contains filtered or unexported fields
}

func (*HostMapping) Descriptor deprecated

func (*HostMapping) Descriptor() ([]byte, []int)

Deprecated: Use HostMapping.ProtoReflect.Descriptor instead.

func (*HostMapping) GetHostname

func (x *HostMapping) GetHostname() string

func (*HostMapping) GetIpAddress

func (x *HostMapping) GetIpAddress() string

func (*HostMapping) ProtoMessage

func (*HostMapping) ProtoMessage()

func (*HostMapping) ProtoReflect

func (x *HostMapping) ProtoReflect() protoreflect.Message

func (*HostMapping) Reset

func (x *HostMapping) Reset()

func (*HostMapping) String

func (x *HostMapping) String() string

type LatencySample

type LatencySample struct {
	Timestamp    int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
	AvgLatencyNs int64 `protobuf:"varint,2,opt,name=avg_latency_ns,json=avgLatencyNs,proto3" json:"avg_latency_ns,omitempty"`
	P95LatencyNs int64 `protobuf:"varint,3,opt,name=p95_latency_ns,json=p95LatencyNs,proto3" json:"p95_latency_ns,omitempty"`
	P99LatencyNs int64 `protobuf:"varint,4,opt,name=p99_latency_ns,json=p99LatencyNs,proto3" json:"p99_latency_ns,omitempty"`
	MaxLatencyNs int64 `protobuf:"varint,5,opt,name=max_latency_ns,json=maxLatencyNs,proto3" json:"max_latency_ns,omitempty"`
	// contains filtered or unexported fields
}

LatencySample represents latency measurements at a point in time

func (*LatencySample) Descriptor deprecated

func (*LatencySample) Descriptor() ([]byte, []int)

Deprecated: Use LatencySample.ProtoReflect.Descriptor instead.

func (*LatencySample) GetAvgLatencyNs

func (x *LatencySample) GetAvgLatencyNs() int64

func (*LatencySample) GetMaxLatencyNs

func (x *LatencySample) GetMaxLatencyNs() int64

func (*LatencySample) GetP95LatencyNs

func (x *LatencySample) GetP95LatencyNs() int64

func (*LatencySample) GetP99LatencyNs

func (x *LatencySample) GetP99LatencyNs() int64

func (*LatencySample) GetTimestamp

func (x *LatencySample) GetTimestamp() int64

func (*LatencySample) ProtoMessage

func (*LatencySample) ProtoMessage()

func (*LatencySample) ProtoReflect

func (x *LatencySample) ProtoReflect() protoreflect.Message

func (*LatencySample) Reset

func (x *LatencySample) Reset()

func (*LatencySample) String

func (x *LatencySample) String() string

type MessageStatistics

type MessageStatistics struct {

	// Packet statistics (1-10)
	PacketsSent     int64   `protobuf:"varint,1,opt,name=packets_sent,json=packetsSent,proto3" json:"packets_sent,omitempty"`
	PacketsReceived int64   `protobuf:"varint,2,opt,name=packets_received,json=packetsReceived,proto3" json:"packets_received,omitempty"`
	PacketsDropped  int64   `protobuf:"varint,3,opt,name=packets_dropped,json=packetsDropped,proto3" json:"packets_dropped,omitempty"`
	PacketBytes     int64   `protobuf:"varint,4,opt,name=packet_bytes,json=packetBytes,proto3" json:"packet_bytes,omitempty"`
	AvgPacketSize   float64 `protobuf:"fixed64,5,opt,name=avg_packet_size,json=avgPacketSize,proto3" json:"avg_packet_size,omitempty"` // bytes
	// Control message statistics (11-20)
	ControlMessagesSent     int64 `protobuf:"varint,11,opt,name=control_messages_sent,json=controlMessagesSent,proto3" json:"control_messages_sent,omitempty"`
	ControlMessagesReceived int64 `` /* 134-byte string literal not displayed */
	ControlMessageBytes     int64 `protobuf:"varint,13,opt,name=control_message_bytes,json=controlMessageBytes,proto3" json:"control_message_bytes,omitempty"`
	// Message breakdown (21-30)
	MessagesByType map[string]int64 `` /* 181-byte string literal not displayed */
	// Throughput metrics (31-40)
	PacketsPerSecond float64 `protobuf:"fixed64,31,opt,name=packets_per_second,json=packetsPerSecond,proto3" json:"packets_per_second,omitempty"`
	BytesPerSecond   float64 `protobuf:"fixed64,32,opt,name=bytes_per_second,json=bytesPerSecond,proto3" json:"bytes_per_second,omitempty"`
	// Quality metrics (41-50)
	PacketLossRate      float64 `protobuf:"fixed64,41,opt,name=packet_loss_rate,json=packetLossRate,proto3" json:"packet_loss_rate,omitempty"`                // percentage
	MessageDeliveryRate float64 `protobuf:"fixed64,42,opt,name=message_delivery_rate,json=messageDeliveryRate,proto3" json:"message_delivery_rate,omitempty"` // percentage
	// contains filtered or unexported fields
}

MessageStatistics contains detailed message flow statistics

func (*MessageStatistics) Descriptor deprecated

func (*MessageStatistics) Descriptor() ([]byte, []int)

Deprecated: Use MessageStatistics.ProtoReflect.Descriptor instead.

func (*MessageStatistics) GetAvgPacketSize

func (x *MessageStatistics) GetAvgPacketSize() float64

func (*MessageStatistics) GetBytesPerSecond

func (x *MessageStatistics) GetBytesPerSecond() float64

func (*MessageStatistics) GetControlMessageBytes

func (x *MessageStatistics) GetControlMessageBytes() int64

func (*MessageStatistics) GetControlMessagesReceived

func (x *MessageStatistics) GetControlMessagesReceived() int64

func (*MessageStatistics) GetControlMessagesSent

func (x *MessageStatistics) GetControlMessagesSent() int64

func (*MessageStatistics) GetMessageDeliveryRate

func (x *MessageStatistics) GetMessageDeliveryRate() float64

func (*MessageStatistics) GetMessagesByType

func (x *MessageStatistics) GetMessagesByType() map[string]int64

func (*MessageStatistics) GetPacketBytes

func (x *MessageStatistics) GetPacketBytes() int64

func (*MessageStatistics) GetPacketLossRate

func (x *MessageStatistics) GetPacketLossRate() float64

func (*MessageStatistics) GetPacketsDropped

func (x *MessageStatistics) GetPacketsDropped() int64

func (*MessageStatistics) GetPacketsPerSecond

func (x *MessageStatistics) GetPacketsPerSecond() float64

func (*MessageStatistics) GetPacketsReceived

func (x *MessageStatistics) GetPacketsReceived() int64

func (*MessageStatistics) GetPacketsSent

func (x *MessageStatistics) GetPacketsSent() int64

func (*MessageStatistics) ProtoMessage

func (*MessageStatistics) ProtoMessage()

func (*MessageStatistics) ProtoReflect

func (x *MessageStatistics) ProtoReflect() protoreflect.Message

func (*MessageStatistics) Reset

func (x *MessageStatistics) Reset()

func (*MessageStatistics) String

func (x *MessageStatistics) String() string

type PauseRequest

type PauseRequest struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for pausing the session
	// contains filtered or unexported fields
}

Pause request

func (*PauseRequest) Descriptor deprecated

func (*PauseRequest) Descriptor() ([]byte, []int)

Deprecated: Use PauseRequest.ProtoReflect.Descriptor instead.

func (*PauseRequest) GetReason

func (x *PauseRequest) GetReason() string

func (*PauseRequest) ProtoMessage

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) ProtoReflect

func (x *PauseRequest) ProtoReflect() protoreflect.Message

func (*PauseRequest) Reset

func (x *PauseRequest) Reset()

func (*PauseRequest) String

func (x *PauseRequest) String() string

type PerformanceMetrics

type PerformanceMetrics struct {

	// Latency metrics (1-10) - all in nanoseconds
	AvgPacketLatencyNs  int64 `protobuf:"varint,1,opt,name=avg_packet_latency_ns,json=avgPacketLatencyNs,proto3" json:"avg_packet_latency_ns,omitempty"`
	P95PacketLatencyNs  int64 `protobuf:"varint,2,opt,name=p95_packet_latency_ns,json=p95PacketLatencyNs,proto3" json:"p95_packet_latency_ns,omitempty"`
	P99PacketLatencyNs  int64 `protobuf:"varint,3,opt,name=p99_packet_latency_ns,json=p99PacketLatencyNs,proto3" json:"p99_packet_latency_ns,omitempty"`
	MaxPacketLatencyNs  int64 `protobuf:"varint,4,opt,name=max_packet_latency_ns,json=maxPacketLatencyNs,proto3" json:"max_packet_latency_ns,omitempty"`
	AvgControlLatencyNs int64 `protobuf:"varint,5,opt,name=avg_control_latency_ns,json=avgControlLatencyNs,proto3" json:"avg_control_latency_ns,omitempty"`
	P95ControlLatencyNs int64 `protobuf:"varint,6,opt,name=p95_control_latency_ns,json=p95ControlLatencyNs,proto3" json:"p95_control_latency_ns,omitempty"`
	// Throughput metrics (11-20)
	PacketsPerSecond      float64 `protobuf:"fixed64,11,opt,name=packets_per_second,json=packetsPerSecond,proto3" json:"packets_per_second,omitempty"`
	BytesPerSecond        float64 `protobuf:"fixed64,12,opt,name=bytes_per_second,json=bytesPerSecond,proto3" json:"bytes_per_second,omitempty"`
	ControlMessagesPerSec float64 `` /* 131-byte string literal not displayed */
	// Error metrics (21-30)
	ErrorRate        float64 `protobuf:"fixed64,21,opt,name=error_rate,json=errorRate,proto3" json:"error_rate,omitempty"` // percentage
	PacketDrops      int64   `protobuf:"varint,22,opt,name=packet_drops,json=packetDrops,proto3" json:"packet_drops,omitempty"`
	StreamErrors     int64   `protobuf:"varint,23,opt,name=stream_errors,json=streamErrors,proto3" json:"stream_errors,omitempty"`
	ConnectionErrors int64   `protobuf:"varint,24,opt,name=connection_errors,json=connectionErrors,proto3" json:"connection_errors,omitempty"`
	// Stream health (31-40)
	HealthyStreams    int64   `protobuf:"varint,31,opt,name=healthy_streams,json=healthyStreams,proto3" json:"healthy_streams,omitempty"`
	TotalStreams      int64   `protobuf:"varint,32,opt,name=total_streams,json=totalStreams,proto3" json:"total_streams,omitempty"`
	ActiveConnections int64   `protobuf:"varint,33,opt,name=active_connections,json=activeConnections,proto3" json:"active_connections,omitempty"`
	UnhealthyStreams  int64   `protobuf:"varint,34,opt,name=unhealthy_streams,json=unhealthyStreams,proto3" json:"unhealthy_streams,omitempty"`
	StreamUtilization float64 `protobuf:"fixed64,35,opt,name=stream_utilization,json=streamUtilization,proto3" json:"stream_utilization,omitempty"` // percentage
	// Circuit breaker metrics (41-50)
	CircuitBreakerStates []string `protobuf:"bytes,41,rep,name=circuit_breaker_states,json=circuitBreakerStates,proto3" json:"circuit_breaker_states,omitempty"`
	TotalCircuitBreaks   int64    `protobuf:"varint,42,opt,name=total_circuit_breaks,json=totalCircuitBreaks,proto3" json:"total_circuit_breaks,omitempty"`
	AvgRecoveryTimeNs    int64    `protobuf:"varint,43,opt,name=avg_recovery_time_ns,json=avgRecoveryTimeNs,proto3" json:"avg_recovery_time_ns,omitempty"`
	// Compression metrics (51-60)
	CompressionRatio    float64 `protobuf:"fixed64,51,opt,name=compression_ratio,json=compressionRatio,proto3" json:"compression_ratio,omitempty"` // percentage
	BytesSaved          int64   `protobuf:"varint,52,opt,name=bytes_saved,json=bytesSaved,proto3" json:"bytes_saved,omitempty"`
	CompressionTimeNs   int64   `protobuf:"varint,53,opt,name=compression_time_ns,json=compressionTimeNs,proto3" json:"compression_time_ns,omitempty"`
	DecompressionTimeNs int64   `protobuf:"varint,54,opt,name=decompression_time_ns,json=decompressionTimeNs,proto3" json:"decompression_time_ns,omitempty"`
	// Retry metrics (61-70)
	TotalRetryAttempts int64   `protobuf:"varint,61,opt,name=total_retry_attempts,json=totalRetryAttempts,proto3" json:"total_retry_attempts,omitempty"`
	SuccessfulRetries  int64   `protobuf:"varint,62,opt,name=successful_retries,json=successfulRetries,proto3" json:"successful_retries,omitempty"`
	FailedRetries      int64   `protobuf:"varint,63,opt,name=failed_retries,json=failedRetries,proto3" json:"failed_retries,omitempty"`
	RetrySuccessRate   float64 `protobuf:"fixed64,64,opt,name=retry_success_rate,json=retrySuccessRate,proto3" json:"retry_success_rate,omitempty"` // percentage
	// Connection pool metrics (71-80)
	PoolUtilization  float64 `protobuf:"fixed64,71,opt,name=pool_utilization,json=poolUtilization,proto3" json:"pool_utilization,omitempty"` // percentage
	IdleConnections  int64   `protobuf:"varint,72,opt,name=idle_connections,json=idleConnections,proto3" json:"idle_connections,omitempty"`
	ConnectionResets int64   `protobuf:"varint,73,opt,name=connection_resets,json=connectionResets,proto3" json:"connection_resets,omitempty"`
	// Resource utilization (81-90)
	MemoryUsageBytes int64 `protobuf:"varint,81,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
	BufferPoolSize   int64 `protobuf:"varint,82,opt,name=buffer_pool_size,json=bufferPoolSize,proto3" json:"buffer_pool_size,omitempty"`
	BufferPoolHits   int64 `protobuf:"varint,83,opt,name=buffer_pool_hits,json=bufferPoolHits,proto3" json:"buffer_pool_hits,omitempty"`
	BufferPoolMisses int64 `protobuf:"varint,84,opt,name=buffer_pool_misses,json=bufferPoolMisses,proto3" json:"buffer_pool_misses,omitempty"`
	// Metadata and timing (91-100)
	LastUpdated          int64 `protobuf:"varint,91,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`                              // epoch milliseconds
	CollectionIntervalNs int64 `protobuf:"varint,92,opt,name=collection_interval_ns,json=collectionIntervalNs,proto3" json:"collection_interval_ns,omitempty"` // nanoseconds
	// Runtime metrics (101-110)
	RuntimeStats map[string]*ProjectRuntimeStats `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

PerformanceMetrics contains performance data from MetricsCollector

func (*PerformanceMetrics) Descriptor deprecated

func (*PerformanceMetrics) Descriptor() ([]byte, []int)

Deprecated: Use PerformanceMetrics.ProtoReflect.Descriptor instead.

func (*PerformanceMetrics) GetActiveConnections

func (x *PerformanceMetrics) GetActiveConnections() int64

func (*PerformanceMetrics) GetAvgControlLatencyNs

func (x *PerformanceMetrics) GetAvgControlLatencyNs() int64

func (*PerformanceMetrics) GetAvgPacketLatencyNs

func (x *PerformanceMetrics) GetAvgPacketLatencyNs() int64

func (*PerformanceMetrics) GetAvgRecoveryTimeNs

func (x *PerformanceMetrics) GetAvgRecoveryTimeNs() int64

func (*PerformanceMetrics) GetBufferPoolHits

func (x *PerformanceMetrics) GetBufferPoolHits() int64

func (*PerformanceMetrics) GetBufferPoolMisses

func (x *PerformanceMetrics) GetBufferPoolMisses() int64

func (*PerformanceMetrics) GetBufferPoolSize

func (x *PerformanceMetrics) GetBufferPoolSize() int64

func (*PerformanceMetrics) GetBytesPerSecond

func (x *PerformanceMetrics) GetBytesPerSecond() float64

func (*PerformanceMetrics) GetBytesSaved

func (x *PerformanceMetrics) GetBytesSaved() int64

func (*PerformanceMetrics) GetCircuitBreakerStates

func (x *PerformanceMetrics) GetCircuitBreakerStates() []string

func (*PerformanceMetrics) GetCollectionIntervalNs

func (x *PerformanceMetrics) GetCollectionIntervalNs() int64

func (*PerformanceMetrics) GetCompressionRatio

func (x *PerformanceMetrics) GetCompressionRatio() float64

func (*PerformanceMetrics) GetCompressionTimeNs

func (x *PerformanceMetrics) GetCompressionTimeNs() int64

func (*PerformanceMetrics) GetConnectionErrors

func (x *PerformanceMetrics) GetConnectionErrors() int64

func (*PerformanceMetrics) GetConnectionResets

func (x *PerformanceMetrics) GetConnectionResets() int64

func (*PerformanceMetrics) GetControlMessagesPerSec

func (x *PerformanceMetrics) GetControlMessagesPerSec() float64

func (*PerformanceMetrics) GetDecompressionTimeNs

func (x *PerformanceMetrics) GetDecompressionTimeNs() int64

func (*PerformanceMetrics) GetErrorRate

func (x *PerformanceMetrics) GetErrorRate() float64

func (*PerformanceMetrics) GetFailedRetries

func (x *PerformanceMetrics) GetFailedRetries() int64

func (*PerformanceMetrics) GetHealthyStreams

func (x *PerformanceMetrics) GetHealthyStreams() int64

func (*PerformanceMetrics) GetIdleConnections

func (x *PerformanceMetrics) GetIdleConnections() int64

func (*PerformanceMetrics) GetLastUpdated

func (x *PerformanceMetrics) GetLastUpdated() int64

func (*PerformanceMetrics) GetMaxPacketLatencyNs

func (x *PerformanceMetrics) GetMaxPacketLatencyNs() int64

func (*PerformanceMetrics) GetMemoryUsageBytes

func (x *PerformanceMetrics) GetMemoryUsageBytes() int64

func (*PerformanceMetrics) GetP95ControlLatencyNs

func (x *PerformanceMetrics) GetP95ControlLatencyNs() int64

func (*PerformanceMetrics) GetP95PacketLatencyNs

func (x *PerformanceMetrics) GetP95PacketLatencyNs() int64

func (*PerformanceMetrics) GetP99PacketLatencyNs

func (x *PerformanceMetrics) GetP99PacketLatencyNs() int64

func (*PerformanceMetrics) GetPacketDrops

func (x *PerformanceMetrics) GetPacketDrops() int64

func (*PerformanceMetrics) GetPacketsPerSecond

func (x *PerformanceMetrics) GetPacketsPerSecond() float64

func (*PerformanceMetrics) GetPoolUtilization

func (x *PerformanceMetrics) GetPoolUtilization() float64

func (*PerformanceMetrics) GetRetrySuccessRate

func (x *PerformanceMetrics) GetRetrySuccessRate() float64

func (*PerformanceMetrics) GetRuntimeStats

func (x *PerformanceMetrics) GetRuntimeStats() map[string]*ProjectRuntimeStats

func (*PerformanceMetrics) GetStreamErrors

func (x *PerformanceMetrics) GetStreamErrors() int64

func (*PerformanceMetrics) GetStreamUtilization

func (x *PerformanceMetrics) GetStreamUtilization() float64

func (*PerformanceMetrics) GetSuccessfulRetries

func (x *PerformanceMetrics) GetSuccessfulRetries() int64

func (*PerformanceMetrics) GetTotalCircuitBreaks

func (x *PerformanceMetrics) GetTotalCircuitBreaks() int64

func (*PerformanceMetrics) GetTotalRetryAttempts

func (x *PerformanceMetrics) GetTotalRetryAttempts() int64

func (*PerformanceMetrics) GetTotalStreams

func (x *PerformanceMetrics) GetTotalStreams() int64

func (*PerformanceMetrics) GetUnhealthyStreams

func (x *PerformanceMetrics) GetUnhealthyStreams() int64

func (*PerformanceMetrics) ProtoMessage

func (*PerformanceMetrics) ProtoMessage()

func (*PerformanceMetrics) ProtoReflect

func (x *PerformanceMetrics) ProtoReflect() protoreflect.Message

func (*PerformanceMetrics) Reset

func (x *PerformanceMetrics) Reset()

func (*PerformanceMetrics) String

func (x *PerformanceMetrics) String() string

type PingRequest

type PingRequest struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Ping request for health checking

func (*PingRequest) Descriptor deprecated

func (*PingRequest) Descriptor() ([]byte, []int)

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetTimestamp

func (x *PingRequest) GetTimestamp() *timestamppb.Timestamp

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PongResponse

type PongResponse struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Pong response

func (*PongResponse) Descriptor deprecated

func (*PongResponse) Descriptor() ([]byte, []int)

Deprecated: Use PongResponse.ProtoReflect.Descriptor instead.

func (*PongResponse) GetTimestamp

func (x *PongResponse) GetTimestamp() *timestamppb.Timestamp

func (*PongResponse) ProtoMessage

func (*PongResponse) ProtoMessage()

func (*PongResponse) ProtoReflect

func (x *PongResponse) ProtoReflect() protoreflect.Message

func (*PongResponse) Reset

func (x *PongResponse) Reset()

func (*PongResponse) String

func (x *PongResponse) String() string

type ProjectRuntimeStats

type ProjectRuntimeStats struct {

	// Runtime identity (1-10)
	RuntimeId    string `protobuf:"bytes,1,opt,name=runtime_id,json=runtimeId,proto3" json:"runtime_id,omitempty"`
	RuntimeName  string `protobuf:"bytes,2,opt,name=runtime_name,json=runtimeName,proto3" json:"runtime_name,omitempty"`
	Image        string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	DeploymentId string `protobuf:"bytes,4,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	// Runtime state (11-20)
	Status       string `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	Paused       bool   `protobuf:"varint,12,opt,name=paused,proto3" json:"paused,omitempty"`
	PausedTime   int64  `protobuf:"varint,13,opt,name=paused_time,json=pausedTime,proto3" json:"paused_time,omitempty"`    // epoch milliseconds, 0 if not paused
	StartedTime  int64  `protobuf:"varint,14,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"` // epoch milliseconds
	RestartCount int64  `protobuf:"varint,15,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	// CPU metrics (21-30)
	CpuUsagePercent     float64 `protobuf:"fixed64,21,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"`
	CpuUsageTotalNs     uint64  `protobuf:"varint,22,opt,name=cpu_usage_total_ns,json=cpuUsageTotalNs,proto3" json:"cpu_usage_total_ns,omitempty"`
	CpuUsageKernelNs    uint64  `protobuf:"varint,23,opt,name=cpu_usage_kernel_ns,json=cpuUsageKernelNs,proto3" json:"cpu_usage_kernel_ns,omitempty"`
	CpuUsageUserNs      uint64  `protobuf:"varint,24,opt,name=cpu_usage_user_ns,json=cpuUsageUserNs,proto3" json:"cpu_usage_user_ns,omitempty"`
	CpuThrottledPeriods uint64  `protobuf:"varint,25,opt,name=cpu_throttled_periods,json=cpuThrottledPeriods,proto3" json:"cpu_throttled_periods,omitempty"`
	CpuThrottledTimeNs  uint64  `protobuf:"varint,26,opt,name=cpu_throttled_time_ns,json=cpuThrottledTimeNs,proto3" json:"cpu_throttled_time_ns,omitempty"`
	CpuLimit            float64 `protobuf:"fixed64,27,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
	// Memory metrics (31-40)
	MemoryUsageBytes     uint64  `protobuf:"varint,31,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
	MemoryLimitBytes     uint64  `protobuf:"varint,32,opt,name=memory_limit_bytes,json=memoryLimitBytes,proto3" json:"memory_limit_bytes,omitempty"`
	MemoryUsagePercent   float64 `protobuf:"fixed64,33,opt,name=memory_usage_percent,json=memoryUsagePercent,proto3" json:"memory_usage_percent,omitempty"`
	MemoryMaxUsageBytes  uint64  `protobuf:"varint,34,opt,name=memory_max_usage_bytes,json=memoryMaxUsageBytes,proto3" json:"memory_max_usage_bytes,omitempty"`
	MemoryCacheBytes     uint64  `protobuf:"varint,35,opt,name=memory_cache_bytes,json=memoryCacheBytes,proto3" json:"memory_cache_bytes,omitempty"`
	MemoryRssBytes       uint64  `protobuf:"varint,36,opt,name=memory_rss_bytes,json=memoryRssBytes,proto3" json:"memory_rss_bytes,omitempty"`
	MemorySwapBytes      uint64  `protobuf:"varint,37,opt,name=memory_swap_bytes,json=memorySwapBytes,proto3" json:"memory_swap_bytes,omitempty"`
	MemorySwapLimitBytes uint64  `` /* 127-byte string literal not displayed */
	OomKills             uint64  `protobuf:"varint,39,opt,name=oom_kills,json=oomKills,proto3" json:"oom_kills,omitempty"`
	// Network metrics (41-50)
	NetworkRxBytes   uint64 `protobuf:"varint,41,opt,name=network_rx_bytes,json=networkRxBytes,proto3" json:"network_rx_bytes,omitempty"`
	NetworkTxBytes   uint64 `protobuf:"varint,42,opt,name=network_tx_bytes,json=networkTxBytes,proto3" json:"network_tx_bytes,omitempty"`
	NetworkRxPackets uint64 `protobuf:"varint,43,opt,name=network_rx_packets,json=networkRxPackets,proto3" json:"network_rx_packets,omitempty"`
	NetworkTxPackets uint64 `protobuf:"varint,44,opt,name=network_tx_packets,json=networkTxPackets,proto3" json:"network_tx_packets,omitempty"`
	NetworkRxErrors  uint64 `protobuf:"varint,45,opt,name=network_rx_errors,json=networkRxErrors,proto3" json:"network_rx_errors,omitempty"`
	NetworkTxErrors  uint64 `protobuf:"varint,46,opt,name=network_tx_errors,json=networkTxErrors,proto3" json:"network_tx_errors,omitempty"`
	NetworkRxDropped uint64 `protobuf:"varint,47,opt,name=network_rx_dropped,json=networkRxDropped,proto3" json:"network_rx_dropped,omitempty"`
	NetworkTxDropped uint64 `protobuf:"varint,48,opt,name=network_tx_dropped,json=networkTxDropped,proto3" json:"network_tx_dropped,omitempty"`
	// Disk I/O metrics (51-60)
	BlockIoReadBytes  uint64 `protobuf:"varint,51,opt,name=block_io_read_bytes,json=blockIoReadBytes,proto3" json:"block_io_read_bytes,omitempty"`
	BlockIoWriteBytes uint64 `protobuf:"varint,52,opt,name=block_io_write_bytes,json=blockIoWriteBytes,proto3" json:"block_io_write_bytes,omitempty"`
	BlockIoReadOps    uint64 `protobuf:"varint,53,opt,name=block_io_read_ops,json=blockIoReadOps,proto3" json:"block_io_read_ops,omitempty"`
	BlockIoWriteOps   uint64 `protobuf:"varint,54,opt,name=block_io_write_ops,json=blockIoWriteOps,proto3" json:"block_io_write_ops,omitempty"`
	// Process metrics (61-70)
	PidsCurrent uint64 `protobuf:"varint,61,opt,name=pids_current,json=pidsCurrent,proto3" json:"pids_current,omitempty"`
	PidsLimit   uint64 `protobuf:"varint,62,opt,name=pids_limit,json=pidsLimit,proto3" json:"pids_limit,omitempty"`
	// Network interface information (71-80)
	Ipv4Address string `protobuf:"bytes,71,opt,name=ipv4_address,json=ipv4Address,proto3" json:"ipv4_address,omitempty"`
	Ipv6Address string `protobuf:"bytes,72,opt,name=ipv6_address,json=ipv6Address,proto3" json:"ipv6_address,omitempty"`
	Hostname    string `protobuf:"bytes,73,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Runtime metrics (81-90)
	InflightRequests int64 `protobuf:"varint,81,opt,name=inflight_requests,json=inflightRequests,proto3" json:"inflight_requests,omitempty"`
	// Health and timing (91-100)
	Healthy     bool  `protobuf:"varint,91,opt,name=healthy,proto3" json:"healthy,omitempty"`
	LastUpdated int64 `protobuf:"varint,92,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"` // epoch milliseconds
	// contains filtered or unexported fields
}

ProjectRuntimeStats contains real-time project runtime statistics

func (*ProjectRuntimeStats) Descriptor deprecated

func (*ProjectRuntimeStats) Descriptor() ([]byte, []int)

Deprecated: Use ProjectRuntimeStats.ProtoReflect.Descriptor instead.

func (*ProjectRuntimeStats) GetBlockIoReadBytes

func (x *ProjectRuntimeStats) GetBlockIoReadBytes() uint64

func (*ProjectRuntimeStats) GetBlockIoReadOps

func (x *ProjectRuntimeStats) GetBlockIoReadOps() uint64

func (*ProjectRuntimeStats) GetBlockIoWriteBytes

func (x *ProjectRuntimeStats) GetBlockIoWriteBytes() uint64

func (*ProjectRuntimeStats) GetBlockIoWriteOps

func (x *ProjectRuntimeStats) GetBlockIoWriteOps() uint64

func (*ProjectRuntimeStats) GetCpuLimit

func (x *ProjectRuntimeStats) GetCpuLimit() float64

func (*ProjectRuntimeStats) GetCpuThrottledPeriods

func (x *ProjectRuntimeStats) GetCpuThrottledPeriods() uint64

func (*ProjectRuntimeStats) GetCpuThrottledTimeNs

func (x *ProjectRuntimeStats) GetCpuThrottledTimeNs() uint64

func (*ProjectRuntimeStats) GetCpuUsageKernelNs

func (x *ProjectRuntimeStats) GetCpuUsageKernelNs() uint64

func (*ProjectRuntimeStats) GetCpuUsagePercent

func (x *ProjectRuntimeStats) GetCpuUsagePercent() float64

func (*ProjectRuntimeStats) GetCpuUsageTotalNs

func (x *ProjectRuntimeStats) GetCpuUsageTotalNs() uint64

func (*ProjectRuntimeStats) GetCpuUsageUserNs

func (x *ProjectRuntimeStats) GetCpuUsageUserNs() uint64

func (*ProjectRuntimeStats) GetDeploymentId

func (x *ProjectRuntimeStats) GetDeploymentId() string

func (*ProjectRuntimeStats) GetHealthy

func (x *ProjectRuntimeStats) GetHealthy() bool

func (*ProjectRuntimeStats) GetHostname

func (x *ProjectRuntimeStats) GetHostname() string

func (*ProjectRuntimeStats) GetImage

func (x *ProjectRuntimeStats) GetImage() string

func (*ProjectRuntimeStats) GetInflightRequests

func (x *ProjectRuntimeStats) GetInflightRequests() int64

func (*ProjectRuntimeStats) GetIpv4Address

func (x *ProjectRuntimeStats) GetIpv4Address() string

func (*ProjectRuntimeStats) GetIpv6Address

func (x *ProjectRuntimeStats) GetIpv6Address() string

func (*ProjectRuntimeStats) GetLastUpdated

func (x *ProjectRuntimeStats) GetLastUpdated() int64

func (*ProjectRuntimeStats) GetMemoryCacheBytes

func (x *ProjectRuntimeStats) GetMemoryCacheBytes() uint64

func (*ProjectRuntimeStats) GetMemoryLimitBytes

func (x *ProjectRuntimeStats) GetMemoryLimitBytes() uint64

func (*ProjectRuntimeStats) GetMemoryMaxUsageBytes

func (x *ProjectRuntimeStats) GetMemoryMaxUsageBytes() uint64

func (*ProjectRuntimeStats) GetMemoryRssBytes

func (x *ProjectRuntimeStats) GetMemoryRssBytes() uint64

func (*ProjectRuntimeStats) GetMemorySwapBytes

func (x *ProjectRuntimeStats) GetMemorySwapBytes() uint64

func (*ProjectRuntimeStats) GetMemorySwapLimitBytes

func (x *ProjectRuntimeStats) GetMemorySwapLimitBytes() uint64

func (*ProjectRuntimeStats) GetMemoryUsageBytes

func (x *ProjectRuntimeStats) GetMemoryUsageBytes() uint64

func (*ProjectRuntimeStats) GetMemoryUsagePercent

func (x *ProjectRuntimeStats) GetMemoryUsagePercent() float64

func (*ProjectRuntimeStats) GetNetworkRxBytes

func (x *ProjectRuntimeStats) GetNetworkRxBytes() uint64

func (*ProjectRuntimeStats) GetNetworkRxDropped

func (x *ProjectRuntimeStats) GetNetworkRxDropped() uint64

func (*ProjectRuntimeStats) GetNetworkRxErrors

func (x *ProjectRuntimeStats) GetNetworkRxErrors() uint64

func (*ProjectRuntimeStats) GetNetworkRxPackets

func (x *ProjectRuntimeStats) GetNetworkRxPackets() uint64

func (*ProjectRuntimeStats) GetNetworkTxBytes

func (x *ProjectRuntimeStats) GetNetworkTxBytes() uint64

func (*ProjectRuntimeStats) GetNetworkTxDropped

func (x *ProjectRuntimeStats) GetNetworkTxDropped() uint64

func (*ProjectRuntimeStats) GetNetworkTxErrors

func (x *ProjectRuntimeStats) GetNetworkTxErrors() uint64

func (*ProjectRuntimeStats) GetNetworkTxPackets

func (x *ProjectRuntimeStats) GetNetworkTxPackets() uint64

func (*ProjectRuntimeStats) GetOomKills

func (x *ProjectRuntimeStats) GetOomKills() uint64

func (*ProjectRuntimeStats) GetPaused

func (x *ProjectRuntimeStats) GetPaused() bool

func (*ProjectRuntimeStats) GetPausedTime

func (x *ProjectRuntimeStats) GetPausedTime() int64

func (*ProjectRuntimeStats) GetPidsCurrent

func (x *ProjectRuntimeStats) GetPidsCurrent() uint64

func (*ProjectRuntimeStats) GetPidsLimit

func (x *ProjectRuntimeStats) GetPidsLimit() uint64

func (*ProjectRuntimeStats) GetRestartCount

func (x *ProjectRuntimeStats) GetRestartCount() int64

func (*ProjectRuntimeStats) GetRuntimeId

func (x *ProjectRuntimeStats) GetRuntimeId() string

func (*ProjectRuntimeStats) GetRuntimeName

func (x *ProjectRuntimeStats) GetRuntimeName() string

func (*ProjectRuntimeStats) GetStartedTime

func (x *ProjectRuntimeStats) GetStartedTime() int64

func (*ProjectRuntimeStats) GetStatus

func (x *ProjectRuntimeStats) GetStatus() string

func (*ProjectRuntimeStats) ProtoMessage

func (*ProjectRuntimeStats) ProtoMessage()

func (*ProjectRuntimeStats) ProtoReflect

func (x *ProjectRuntimeStats) ProtoReflect() protoreflect.Message

func (*ProjectRuntimeStats) Reset

func (x *ProjectRuntimeStats) Reset()

func (*ProjectRuntimeStats) String

func (x *ProjectRuntimeStats) String() string

type ProtocolEvent

type ProtocolEvent struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`           // Unique identifier for the event
	Event   string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`     // Event type being sent
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // Event payload data
	// contains filtered or unexported fields
}

Generic protocol event (server-initiated)

func (*ProtocolEvent) Descriptor deprecated

func (*ProtocolEvent) Descriptor() ([]byte, []int)

Deprecated: Use ProtocolEvent.ProtoReflect.Descriptor instead.

func (*ProtocolEvent) GetEvent

func (x *ProtocolEvent) GetEvent() string

func (*ProtocolEvent) GetId

func (x *ProtocolEvent) GetId() string

func (*ProtocolEvent) GetPayload

func (x *ProtocolEvent) GetPayload() []byte

func (*ProtocolEvent) ProtoMessage

func (*ProtocolEvent) ProtoMessage()

func (*ProtocolEvent) ProtoReflect

func (x *ProtocolEvent) ProtoReflect() protoreflect.Message

func (*ProtocolEvent) Reset

func (x *ProtocolEvent) Reset()

func (*ProtocolEvent) String

func (x *ProtocolEvent) String() string

type ProtocolResponse

type ProtocolResponse struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`            // Unique identifier for the response
	Event   string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`      // Event type this response is for
	Success bool   `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"` // Whether the operation was successful
	Error   string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`      // Error message if operation failed
	Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`  // Optional response payload data
	// contains filtered or unexported fields
}

Generic protocol response

func (*ProtocolResponse) Descriptor deprecated

func (*ProtocolResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProtocolResponse.ProtoReflect.Descriptor instead.

func (*ProtocolResponse) GetError

func (x *ProtocolResponse) GetError() string

func (*ProtocolResponse) GetEvent

func (x *ProtocolResponse) GetEvent() string

func (*ProtocolResponse) GetId

func (x *ProtocolResponse) GetId() string

func (*ProtocolResponse) GetPayload

func (x *ProtocolResponse) GetPayload() []byte

func (*ProtocolResponse) GetSuccess

func (x *ProtocolResponse) GetSuccess() bool

func (*ProtocolResponse) ProtoMessage

func (*ProtocolResponse) ProtoMessage()

func (*ProtocolResponse) ProtoReflect

func (x *ProtocolResponse) ProtoReflect() protoreflect.Message

func (*ProtocolResponse) Reset

func (x *ProtocolResponse) Reset()

func (*ProtocolResponse) String

func (x *ProtocolResponse) String() string

type ProvisionRequest

type ProvisionRequest struct {
	Region           string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`                                             // the region for the client
	AvailabilityZone string `protobuf:"bytes,2,opt,name=availability_zone,json=availabilityZone,proto3" json:"availability_zone,omitempty"` // the availability zone for the client
	Provider         string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`                                         // the provider for the client
	InstanceId       string `protobuf:"bytes,4,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`                   // the unique client id for the server
	PrivateIpv4      string `protobuf:"bytes,5,opt,name=private_ipv4,json=privateIpv4,proto3" json:"private_ipv4,omitempty"`                // the ip v4 address to use for the server
	PublicKey        string `protobuf:"bytes,6,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`                      // the public key to use for the server
	Hostname         string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"`                                         // the hostname of the server
	ErrorMessage     string `protobuf:"bytes,8,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`             // the error message if the client has an error
	// during boot or provisioning
	Ephemeral    bool                `protobuf:"varint,9,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`       // if the client is ephemeral
	Capabilities *ClientCapabilities `protobuf:"bytes,10,opt,name=capabilities,proto3" json:"capabilities,omitempty"` // the client capabilities requested
	// contains filtered or unexported fields
}

func (*ProvisionRequest) Descriptor deprecated

func (*ProvisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProvisionRequest.ProtoReflect.Descriptor instead.

func (*ProvisionRequest) GetAvailabilityZone

func (x *ProvisionRequest) GetAvailabilityZone() string

func (*ProvisionRequest) GetCapabilities added in v1.0.96

func (x *ProvisionRequest) GetCapabilities() *ClientCapabilities

func (*ProvisionRequest) GetEphemeral

func (x *ProvisionRequest) GetEphemeral() bool

func (*ProvisionRequest) GetErrorMessage

func (x *ProvisionRequest) GetErrorMessage() string

func (*ProvisionRequest) GetHostname

func (x *ProvisionRequest) GetHostname() string

func (*ProvisionRequest) GetInstanceId

func (x *ProvisionRequest) GetInstanceId() string

func (*ProvisionRequest) GetPrivateIpv4

func (x *ProvisionRequest) GetPrivateIpv4() string

func (*ProvisionRequest) GetProvider

func (x *ProvisionRequest) GetProvider() string

func (*ProvisionRequest) GetPublicKey

func (x *ProvisionRequest) GetPublicKey() string

func (*ProvisionRequest) GetRegion

func (x *ProvisionRequest) GetRegion() string

func (*ProvisionRequest) ProtoMessage

func (*ProvisionRequest) ProtoMessage()

func (*ProvisionRequest) ProtoReflect

func (x *ProvisionRequest) ProtoReflect() protoreflect.Message

func (*ProvisionRequest) Reset

func (x *ProvisionRequest) Reset()

func (*ProvisionRequest) String

func (x *ProvisionRequest) String() string

type ProvisionResponse

type ProvisionResponse struct {
	CaCertificate        []byte                 `protobuf:"bytes,1,opt,name=ca_certificate,json=caCertificate,proto3" json:"ca_certificate,omitempty"`                        // the CA certificate to trust for self-signed server certificates
	Certificate          []byte                 `protobuf:"bytes,2,opt,name=certificate,proto3" json:"certificate,omitempty"`                                                 // the cert to use for the server
	PrivateKey           []byte                 `protobuf:"bytes,3,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`                                 // the key to use for the server
	Expires              *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`                                                         // the expiration time of the certificates
	ClientToken          string                 `protobuf:"bytes,5,opt,name=client_token,json=clientToken,proto3" json:"client_token,omitempty"`                              // the client token to use for communication with APIs
	OrgId                string                 `protobuf:"bytes,6,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`                                                // the organization id for the client
	ClusterId            string                 `protobuf:"bytes,7,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`                                    // the cluster id for the client
	DeploymentPrivateKey []byte                 `protobuf:"bytes,8,opt,name=deployment_private_key,json=deploymentPrivateKey,proto3" json:"deployment_private_key,omitempty"` // the sourcecode private key for the organization, usually nil unless
	// contains filtered or unexported fields
}

func (*ProvisionResponse) Descriptor deprecated

func (*ProvisionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProvisionResponse.ProtoReflect.Descriptor instead.

func (*ProvisionResponse) GetCaCertificate

func (x *ProvisionResponse) GetCaCertificate() []byte

func (*ProvisionResponse) GetCertificate

func (x *ProvisionResponse) GetCertificate() []byte

func (*ProvisionResponse) GetClientToken added in v1.0.94

func (x *ProvisionResponse) GetClientToken() string

func (*ProvisionResponse) GetClusterId

func (x *ProvisionResponse) GetClusterId() string

func (*ProvisionResponse) GetDeploymentPrivateKey

func (x *ProvisionResponse) GetDeploymentPrivateKey() []byte

func (*ProvisionResponse) GetExpires

func (x *ProvisionResponse) GetExpires() *timestamppb.Timestamp

func (*ProvisionResponse) GetOrgId

func (x *ProvisionResponse) GetOrgId() string

func (*ProvisionResponse) GetPrivateKey

func (x *ProvisionResponse) GetPrivateKey() []byte

func (*ProvisionResponse) ProtoMessage

func (*ProvisionResponse) ProtoMessage()

func (*ProvisionResponse) ProtoReflect

func (x *ProvisionResponse) ProtoReflect() protoreflect.Message

func (*ProvisionResponse) Reset

func (x *ProvisionResponse) Reset()

func (*ProvisionResponse) String

func (x *ProvisionResponse) String() string

type ReportRequest

type ReportRequest struct {
	Metrics *ServerMetrics `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` // Comprehensive server metrics and performance data
	// contains filtered or unexported fields
}

Report request for metrics

func (*ReportRequest) Descriptor deprecated

func (*ReportRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReportRequest.ProtoReflect.Descriptor instead.

func (*ReportRequest) GetMetrics

func (x *ReportRequest) GetMetrics() *ServerMetrics

func (*ReportRequest) ProtoMessage

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) ProtoReflect

func (x *ReportRequest) ProtoReflect() protoreflect.Message

func (*ReportRequest) Reset

func (x *ReportRequest) Reset()

func (*ReportRequest) String

func (x *ReportRequest) String() string

type ResourceRequirements

type ResourceRequirements struct {
	MemoryLimit   int64 `protobuf:"varint,1,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`       // Maximum memory in bytes
	CpuLimit      int64 `protobuf:"varint,2,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`                // Maximum CPU in millicores (1000 = 1 core)
	MemoryRequest int64 `protobuf:"varint,3,opt,name=memory_request,json=memoryRequest,proto3" json:"memory_request,omitempty"` // Requested memory in bytes
	CpuRequest    int64 `protobuf:"varint,4,opt,name=cpu_request,json=cpuRequest,proto3" json:"cpu_request,omitempty"`          // Requested CPU in millicores
	DiskLimit     int64 `protobuf:"varint,5,opt,name=disk_limit,json=diskLimit,proto3" json:"disk_limit,omitempty"`             // Maximum storage in bytes
	DiskRequest   int64 `protobuf:"varint,6,opt,name=disk_request,json=diskRequest,proto3" json:"disk_request,omitempty"`       // Requested storage in bytes
	// contains filtered or unexported fields
}

func (*ResourceRequirements) Descriptor deprecated

func (*ResourceRequirements) Descriptor() ([]byte, []int)

Deprecated: Use ResourceRequirements.ProtoReflect.Descriptor instead.

func (*ResourceRequirements) GetCpuLimit

func (x *ResourceRequirements) GetCpuLimit() int64

func (*ResourceRequirements) GetCpuRequest

func (x *ResourceRequirements) GetCpuRequest() int64

func (*ResourceRequirements) GetDiskLimit added in v1.0.113

func (x *ResourceRequirements) GetDiskLimit() int64

func (*ResourceRequirements) GetDiskRequest added in v1.0.113

func (x *ResourceRequirements) GetDiskRequest() int64

func (*ResourceRequirements) GetMemoryLimit

func (x *ResourceRequirements) GetMemoryLimit() int64

func (*ResourceRequirements) GetMemoryRequest

func (x *ResourceRequirements) GetMemoryRequest() int64

func (*ResourceRequirements) ProtoMessage

func (*ResourceRequirements) ProtoMessage()

func (*ResourceRequirements) ProtoReflect

func (x *ResourceRequirements) ProtoReflect() protoreflect.Message

func (*ResourceRequirements) Reset

func (x *ResourceRequirements) Reset()

func (*ResourceRequirements) String

func (x *ResourceRequirements) String() string

type ResumeRequest

type ResumeRequest struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // Reason for resuming the session
	// contains filtered or unexported fields
}

Resume request

func (*ResumeRequest) Descriptor deprecated

func (*ResumeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetReason

func (x *ResumeRequest) GetReason() string

func (*ResumeRequest) ProtoMessage

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect

func (x *ResumeRequest) ProtoReflect() protoreflect.Message

func (*ResumeRequest) Reset

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String

func (x *ResumeRequest) String() string

type RouteDeploymentRequest

type RouteDeploymentRequest struct {
	DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Unique identifier for the deployment
	Hostname     string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`                             // Hostname for the deployment
	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 ServerMetrics

type ServerMetrics struct {

	// Basic server metrics (1-10)
	StartTime       int64  `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`                     // epoch milliseconds
	Uptime          uint64 `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty"`                                            // milliseconds since start
	ConnectedTime   int64  `protobuf:"varint,3,opt,name=connected_time,json=connectedTime,proto3" json:"connected_time,omitempty"`         // epoch milliseconds (optional)
	LastMessageTime int64  `protobuf:"varint,4,opt,name=last_message_time,json=lastMessageTime,proto3" json:"last_message_time,omitempty"` // epoch milliseconds (optional)
	// Connection metrics (11-20)
	IsConnected      bool  `protobuf:"varint,11,opt,name=is_connected,json=isConnected,proto3" json:"is_connected,omitempty"`
	ReconnectCount   int64 `protobuf:"varint,12,opt,name=reconnect_count,json=reconnectCount,proto3" json:"reconnect_count,omitempty"`
	TotalConnections int64 `protobuf:"varint,13,opt,name=total_connections,json=totalConnections,proto3" json:"total_connections,omitempty"`
	// Component metrics (21-40)
	GrpcMetrics   *GRPCConnectionMetrics `protobuf:"bytes,21,opt,name=grpc_metrics,json=grpcMetrics,proto3" json:"grpc_metrics,omitempty"`
	Performance   *PerformanceMetrics    `protobuf:"bytes,22,opt,name=performance,proto3" json:"performance,omitempty"`
	MessageStats  *MessageStatistics     `protobuf:"bytes,23,opt,name=message_stats,json=messageStats,proto3" json:"message_stats,omitempty"`
	SystemMetrics *SystemResourceMetrics `protobuf:"bytes,24,opt,name=system_metrics,json=systemMetrics,proto3" json:"system_metrics,omitempty"`
	// Historical data (41-50)
	HistoricalData *HistoricalMetrics `protobuf:"bytes,41,opt,name=historical_data,json=historicalData,proto3" json:"historical_data,omitempty"`
	// contains filtered or unexported fields
}

Enhanced ServerMetrics with comprehensive performance and health data

func (*ServerMetrics) Descriptor deprecated

func (*ServerMetrics) Descriptor() ([]byte, []int)

Deprecated: Use ServerMetrics.ProtoReflect.Descriptor instead.

func (*ServerMetrics) GetConnectedTime

func (x *ServerMetrics) GetConnectedTime() int64

func (*ServerMetrics) GetGrpcMetrics

func (x *ServerMetrics) GetGrpcMetrics() *GRPCConnectionMetrics

func (*ServerMetrics) GetHistoricalData

func (x *ServerMetrics) GetHistoricalData() *HistoricalMetrics

func (*ServerMetrics) GetIsConnected

func (x *ServerMetrics) GetIsConnected() bool

func (*ServerMetrics) GetLastMessageTime

func (x *ServerMetrics) GetLastMessageTime() int64

func (*ServerMetrics) GetMessageStats

func (x *ServerMetrics) GetMessageStats() *MessageStatistics

func (*ServerMetrics) GetPerformance

func (x *ServerMetrics) GetPerformance() *PerformanceMetrics

func (*ServerMetrics) GetReconnectCount

func (x *ServerMetrics) GetReconnectCount() int64

func (*ServerMetrics) GetStartTime

func (x *ServerMetrics) GetStartTime() int64

func (*ServerMetrics) GetSystemMetrics

func (x *ServerMetrics) GetSystemMetrics() *SystemResourceMetrics

func (*ServerMetrics) GetTotalConnections

func (x *ServerMetrics) GetTotalConnections() int64

func (*ServerMetrics) GetUptime

func (x *ServerMetrics) GetUptime() uint64

func (*ServerMetrics) ProtoMessage

func (*ServerMetrics) ProtoMessage()

func (*ServerMetrics) ProtoReflect

func (x *ServerMetrics) ProtoReflect() protoreflect.Message

func (*ServerMetrics) Reset

func (x *ServerMetrics) Reset()

func (*ServerMetrics) String

func (x *ServerMetrics) String() string

type SystemResourceMetrics

type SystemResourceMetrics struct {

	// Memory metrics (1-10)
	MemoryUsageBytes int64   `protobuf:"varint,1,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
	MemoryUsageMb    float64 `protobuf:"fixed64,2,opt,name=memory_usage_mb,json=memoryUsageMb,proto3" json:"memory_usage_mb,omitempty"`
	AllocatedMemory  int64   `protobuf:"varint,3,opt,name=allocated_memory,json=allocatedMemory,proto3" json:"allocated_memory,omitempty"`
	GcPauseTimeNs    int64   `protobuf:"varint,4,opt,name=gc_pause_time_ns,json=gcPauseTimeNs,proto3" json:"gc_pause_time_ns,omitempty"`
	NumGoroutines    int32   `protobuf:"varint,5,opt,name=num_goroutines,json=numGoroutines,proto3" json:"num_goroutines,omitempty"`
	// CPU metrics (11-20)
	CpuUsagePercent float64 `protobuf:"fixed64,11,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"`
	// Buffer pool metrics (21-30)
	BufferPoolSize    int64   `protobuf:"varint,21,opt,name=buffer_pool_size,json=bufferPoolSize,proto3" json:"buffer_pool_size,omitempty"`
	BufferPoolHits    int64   `protobuf:"varint,22,opt,name=buffer_pool_hits,json=bufferPoolHits,proto3" json:"buffer_pool_hits,omitempty"`
	BufferPoolMisses  int64   `protobuf:"varint,23,opt,name=buffer_pool_misses,json=bufferPoolMisses,proto3" json:"buffer_pool_misses,omitempty"`
	BufferPoolHitRate float64 `protobuf:"fixed64,24,opt,name=buffer_pool_hit_rate,json=bufferPoolHitRate,proto3" json:"buffer_pool_hit_rate,omitempty"` // percentage
	// File descriptor metrics (31-40)
	OpenFileDescriptors int32 `protobuf:"varint,31,opt,name=open_file_descriptors,json=openFileDescriptors,proto3" json:"open_file_descriptors,omitempty"`
	// contains filtered or unexported fields
}

SystemResourceMetrics contains system resource utilization

func (*SystemResourceMetrics) Descriptor deprecated

func (*SystemResourceMetrics) Descriptor() ([]byte, []int)

Deprecated: Use SystemResourceMetrics.ProtoReflect.Descriptor instead.

func (*SystemResourceMetrics) GetAllocatedMemory

func (x *SystemResourceMetrics) GetAllocatedMemory() int64

func (*SystemResourceMetrics) GetBufferPoolHitRate

func (x *SystemResourceMetrics) GetBufferPoolHitRate() float64

func (*SystemResourceMetrics) GetBufferPoolHits

func (x *SystemResourceMetrics) GetBufferPoolHits() int64

func (*SystemResourceMetrics) GetBufferPoolMisses

func (x *SystemResourceMetrics) GetBufferPoolMisses() int64

func (*SystemResourceMetrics) GetBufferPoolSize

func (x *SystemResourceMetrics) GetBufferPoolSize() int64

func (*SystemResourceMetrics) GetCpuUsagePercent

func (x *SystemResourceMetrics) GetCpuUsagePercent() float64

func (*SystemResourceMetrics) GetGcPauseTimeNs

func (x *SystemResourceMetrics) GetGcPauseTimeNs() int64

func (*SystemResourceMetrics) GetMemoryUsageBytes

func (x *SystemResourceMetrics) GetMemoryUsageBytes() int64

func (*SystemResourceMetrics) GetMemoryUsageMb

func (x *SystemResourceMetrics) GetMemoryUsageMb() float64

func (*SystemResourceMetrics) GetNumGoroutines

func (x *SystemResourceMetrics) GetNumGoroutines() int32

func (*SystemResourceMetrics) GetOpenFileDescriptors

func (x *SystemResourceMetrics) GetOpenFileDescriptors() int32

func (*SystemResourceMetrics) ProtoMessage

func (*SystemResourceMetrics) ProtoMessage()

func (*SystemResourceMetrics) ProtoReflect

func (x *SystemResourceMetrics) ProtoReflect() protoreflect.Message

func (*SystemResourceMetrics) Reset

func (x *SystemResourceMetrics) Reset()

func (*SystemResourceMetrics) String

func (x *SystemResourceMetrics) String() string

type ThroughputSample

type ThroughputSample struct {
	Timestamp      int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // epoch milliseconds
	PacketsPerSec  float64 `protobuf:"fixed64,2,opt,name=packets_per_sec,json=packetsPerSec,proto3" json:"packets_per_sec,omitempty"`
	BytesPerSec    float64 `protobuf:"fixed64,3,opt,name=bytes_per_sec,json=bytesPerSec,proto3" json:"bytes_per_sec,omitempty"`
	MessagesPerSec float64 `protobuf:"fixed64,4,opt,name=messages_per_sec,json=messagesPerSec,proto3" json:"messages_per_sec,omitempty"`
	// contains filtered or unexported fields
}

ThroughputSample represents a throughput measurement at a point in time

func (*ThroughputSample) Descriptor deprecated

func (*ThroughputSample) Descriptor() ([]byte, []int)

Deprecated: Use ThroughputSample.ProtoReflect.Descriptor instead.

func (*ThroughputSample) GetBytesPerSec

func (x *ThroughputSample) GetBytesPerSec() float64

func (*ThroughputSample) GetMessagesPerSec

func (x *ThroughputSample) GetMessagesPerSec() float64

func (*ThroughputSample) GetPacketsPerSec

func (x *ThroughputSample) GetPacketsPerSec() float64

func (*ThroughputSample) GetTimestamp

func (x *ThroughputSample) GetTimestamp() int64

func (*ThroughputSample) ProtoMessage

func (*ThroughputSample) ProtoMessage()

func (*ThroughputSample) ProtoReflect

func (x *ThroughputSample) ProtoReflect() protoreflect.Message

func (*ThroughputSample) Reset

func (x *ThroughputSample) Reset()

func (*ThroughputSample) String

func (x *ThroughputSample) String() string

type TunnelPacket

type TunnelPacket struct {
	Data     []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`                         // Raw IP packet data
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` // Logical stream identifier for multiplexing
	// contains filtered or unexported fields
}

TunnelPacket represents network packet data for the tunnel

func (*TunnelPacket) Descriptor deprecated

func (*TunnelPacket) Descriptor() ([]byte, []int)

Deprecated: Use TunnelPacket.ProtoReflect.Descriptor instead.

func (*TunnelPacket) GetData

func (x *TunnelPacket) GetData() []byte

func (*TunnelPacket) GetStreamId

func (x *TunnelPacket) GetStreamId() string

func (*TunnelPacket) ProtoMessage

func (*TunnelPacket) ProtoMessage()

func (*TunnelPacket) ProtoReflect

func (x *TunnelPacket) ProtoReflect() protoreflect.Message

func (*TunnelPacket) Reset

func (x *TunnelPacket) Reset()

func (*TunnelPacket) String

func (x *TunnelPacket) String() string

type UnimplementedGravityControlServer

type UnimplementedGravityControlServer struct{}

UnimplementedGravityControlServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedGravityControlServer) GetDeploymentMetadata

func (UnimplementedGravityControlServer) Provision

type UnimplementedGravityTunnelServer

type UnimplementedGravityTunnelServer struct{}

UnimplementedGravityTunnelServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedGravityTunnelServer) EstablishTunnel

func (UnimplementedGravityTunnelServer) StreamPackets

type UnprovisionRequest

type UnprovisionRequest struct {
	DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Unique identifier of deployment to remove
	// contains filtered or unexported fields
}

Unprovision request

func (*UnprovisionRequest) Descriptor deprecated

func (*UnprovisionRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnprovisionRequest.ProtoReflect.Descriptor instead.

func (*UnprovisionRequest) GetDeploymentId

func (x *UnprovisionRequest) GetDeploymentId() string

func (*UnprovisionRequest) ProtoMessage

func (*UnprovisionRequest) ProtoMessage()

func (*UnprovisionRequest) ProtoReflect

func (x *UnprovisionRequest) ProtoReflect() protoreflect.Message

func (*UnprovisionRequest) Reset

func (x *UnprovisionRequest) Reset()

func (*UnprovisionRequest) String

func (x *UnprovisionRequest) String() string

type UnsafeGravityControlServer

type UnsafeGravityControlServer interface {
	// contains filtered or unexported methods
}

UnsafeGravityControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GravityControlServer will result in compilation errors.

type UnsafeGravityTunnelServer

type UnsafeGravityTunnelServer interface {
	// contains filtered or unexported methods
}

UnsafeGravityTunnelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GravityTunnelServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL