gravity

Jan 13, 2026

Changes in this version

type GravityClient

+ func (g *GravityClient) GetSandboxMetadata(ctx context.Context, sandboxID, orgID string, generateCertificate bool) (*pb.SandboxMetadataResponse, error)

Jan 5, 2026

Changes in this version

type GravityClient

+ func (g *GravityClient) SendRouteSandboxRequest(sandboxID, virtualIP string, timeout time.Duration) (*pb.RouteSandboxResponse, error)

Oct 9, 2025

Changes in this version

type GravityClient

+ func (g *GravityClient) Disconnected(ctx context.Context)

type GravityConfig

+ SkipAutoReconnect bool

Sep 20, 2025

Changes in this version

+ func Provision(request ProvisionRequest) (*pb.ProvisionResponse, error)

+ type ProvisionRequest struct

+ AvailabilityZone string

+ Capabilities *pb.ClientCapabilities

+ Context context.Context

+ Ephemeral bool

+ ErrorMessage string

+ GravityURL string

+ Hostname string

+ InstanceID string

+ PrivateIP string

+ Provider string

+ PublicKey string

+ Region string

+ Token string

Sep 17, 2025

Changes in this version

+ var ErrCircuitBreakerOpen = errors.New("circuit breaker is open")

+ var ErrCircuitBreakerTimeout = errors.New("circuit breaker operation timeout")

+ var ErrConnectionClosed = errors.New("gravity connection closed")

+ var ErrTooManyFailures = errors.New("too many consecutive failures")

+ func DefaultRetryableErrors(err error) bool

+ func ExponentialBackoff(ctx context.Context, maxRetries int, initialBackoff time.Duration, ...) error

+ func LinearBackoff(ctx context.Context, maxRetries int, backoffDuration time.Duration, ...) error

+ func ProvisionMachine(...) (*pb.ProvisionResponse, error)

+ func Retry(ctx context.Context, config RetryConfig, fn RetryableFunc) error

+ func RetryWithCircuitBreaker(ctx context.Context, retryConfig RetryConfig, circuitBreaker *CircuitBreaker, ...) error

+ type CircuitBreaker struct

+ func NewCircuitBreaker(config CircuitBreakerConfig) *CircuitBreaker

+ func (cb *CircuitBreaker) Execute(ctx context.Context, fn func() error) error

+ func (cb *CircuitBreaker) Failures() int

+ func (cb *CircuitBreaker) Reset()

+ func (cb *CircuitBreaker) State() CircuitBreakerState

+ func (cb *CircuitBreaker) Stats() CircuitBreakerStats

+ func (cb *CircuitBreaker) Successes() int

+ func (cb *CircuitBreaker) TransitionToHalfOpen()

+ type CircuitBreakerConfig struct

+ MaxConcurrentRequests int

+ MaxFailures int

+ RequestTimeout time.Duration

+ SuccessThreshold int

+ Timeout time.Duration

+ func DefaultCircuitBreakerConfig() CircuitBreakerConfig

+ type CircuitBreakerState int32

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ func (s CircuitBreakerState) String() string

+ type CircuitBreakerStats struct

+ Failures int

+ Requests int

+ State CircuitBreakerState

+ Successes int

+ type ConnectionPoolConfig struct

+ AllocationStrategy StreamAllocationStrategy

+ FailoverTimeout time.Duration

+ HealthCheckInterval time.Duration

+ PoolSize int

+ StreamsPerConnection int

+ type ErrorRateSample = pb.ErrorRateSample

+ type GRPCConnectionMetrics = pb.GRPCConnectionMetrics

+ type GravityClient struct

+ func New(config GravityConfig) (*GravityClient, error)

+ func (g *GravityClient) Close() error

+ func (g *GravityClient) GetAPIURL() string

+ func (g *GravityClient) GetConnectionPoolStats() map[string]interface{}

+ func (g *GravityClient) GetDeploymentMetadata(ctx context.Context, deploymentID, orgID string) (*pb.DeploymentMetadataResponse, error)

+ func (g *GravityClient) GetHealthScore() float64

+ func (g *GravityClient) GetIPv6Address() string

+ func (g *GravityClient) GetInboundPackets() <-chan *PooledBuffer

+ func (g *GravityClient) GetSecret() string

+ func (g *GravityClient) GetServerMetrics(reset bool) *pb.ServerMetrics

+ func (g *GravityClient) GetTLSConfig() *tls.Config

+ func (g *GravityClient) GetTextMessages() <-chan *PooledBuffer

+ func (g *GravityClient) IsConnected() bool

+ func (g *GravityClient) Pause(reason string) error

+ func (g *GravityClient) Resume(reason string) error

+ func (g *GravityClient) SendPacket(data []byte) error

+ func (g *GravityClient) SendRouteDeploymentRequest(deploymentID, hostname, virtualIP string, timeout time.Duration) (*pb.RouteDeploymentResponse, error)

+ func (g *GravityClient) Start() error

+ func (g *GravityClient) Unprovision(deploymentID string) error

+ func (g *GravityClient) WritePacket(payload []byte) error

+ type GravityConfig struct

+ AuthToken string

+ CACert string

+ Capabilities *pb.ClientCapabilities

+ Cert string

+ ClientName string

+ ClientVersion string

+ ConnectionPoolConfig *ConnectionPoolConfig

+ Context context.Context

+ IP4Address string

+ IP6Address string

+ InstanceID string

+ Key string

+ Logger logger.Logger

+ NetworkInterface network.NetworkInterface

+ PingInterval time.Duration

+ Provider provider.Provider

+ ReportInterval time.Duration

+ ReportStats bool

+ TraceLogPackets bool

+ URL string

+ WorkingDir string

+ type HealthSample = pb.HealthSample

+ type HistoricalMetrics = pb.HistoricalMetrics

+ type LatencySample = pb.LatencySample

+ type MessageStatistics = pb.MessageStatistics

+ type PooledBuffer struct

+ Buffer []byte

+ Length int

+ type RetryConfig struct

+ BackoffMultiplier float64

+ InitialBackoff time.Duration

+ Jitter bool

+ MaxBackoff time.Duration

+ MaxRetries int

+ RetryableErrors func(error) bool

+ func DefaultRetryConfig() RetryConfig

+ type RetryStats struct

+ AverageBackoff time.Duration

+ FailedCalls int

+ LastError error

+ SuccessfulCalls int

+ TotalAttempts int

+ TotalRetries int

+ func RetryWithStats(ctx context.Context, config RetryConfig, fn RetryableFunc) (RetryStats, error)

+ type RetryableFunc func() error

+ type ServerMetrics struct

+ func NewServerMetrics() *ServerMetrics

+ func (sm *ServerMetrics) AddHistoricalSample()

+ func (sm *ServerMetrics) GetHealthScore() float64

+ func (sm *ServerMetrics) GetSnapshot() *pb.ServerMetrics

+ func (sm *ServerMetrics) RecordMessage(messageType string, bytes int64, sent bool)

+ func (sm *ServerMetrics) Reset()

+ func (sm *ServerMetrics) UpdateConnection(connected bool)

+ func (sm *ServerMetrics) UpdateGRPCMetrics(grpcMetrics *GRPCConnectionMetrics)

+ func (sm *ServerMetrics) UpdatePerformanceMetrics(perfMetrics *pb.PerformanceMetrics)

+ func (sm *ServerMetrics) UpdateSystemMetrics()

+ type ServerMetricsSnapshot = pb.ServerMetrics

+ type StreamAllocationStrategy int

+ const HashBased

+ const LeastConnections

+ const RoundRobin

+ const WeightedRoundRobin

+ func (s StreamAllocationStrategy) String() string

+ type StreamInfo struct

+ type StreamManager struct

+ type StreamMetrics struct

+ ErrorCount int64

+ LastError time.Time

+ LastLatency time.Duration

+ PacketsReceived int64

+ PacketsSent int64

+ type SystemResourceMetrics = pb.SystemResourceMetrics

+ type ThroughputSample = pb.ThroughputSample