nodeclient

Documentation

Index

• type Config
  • func DefaultConfig(address string) Config
• type EnhancedNodeClient
  • func NewEnhancedNodeClient(config Config, logger *logger.Logger) (*EnhancedNodeClient, error)
  • func (c *EnhancedNodeClient) Close() error
  • func (c *EnhancedNodeClient) GetStats() map[string]interface{}
  • func (c *EnhancedNodeClient) Route(ctx context.Context, req *nodepb.Request, opts ...grpc.CallOption) (*nodepb.Response, error)

Types

type Config

type Config struct {
	// Connection settings
	Address           string
	MaxConnections    int
	ConnectionTimeout time.Duration
	RequestTimeout    time.Duration
	KeepAliveTime     time.Duration
	KeepAliveTimeout  time.Duration

	// Retry settings
	MaxRetries        int
	InitialBackoff    time.Duration
	MaxBackoff        time.Duration
	BackoffMultiplier float64

	// Circuit breaker settings
	CircuitBreakerConfig circuitbreaker.Config
}

Config holds configuration for the enhanced node client

func DefaultConfig

func DefaultConfig(address string) Config

DefaultConfig returns a default configuration

type EnhancedNodeClient

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

EnhancedNodeClient provides an enhanced client for node communication

func NewEnhancedNodeClient

func NewEnhancedNodeClient(config Config, logger *logger.Logger) (*EnhancedNodeClient, error)

NewEnhancedNodeClient creates a new enhanced node client

func (*EnhancedNodeClient) Close

func (c *EnhancedNodeClient) Close() error

Close closes the client and all connections

func (*EnhancedNodeClient) GetStats

func (c *EnhancedNodeClient) GetStats() map[string]interface{}

GetStats returns statistics about the client

func (*EnhancedNodeClient) Route

func (c *EnhancedNodeClient) Route(ctx context.Context, req *nodepb.Request, opts ...grpc.CallOption) (*nodepb.Response, error)

Route executes a node request with circuit breaker, retry logic, and connection pooling