transport

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

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

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

type GRPCTransportConfig struct {
	NodeID               string
	Address              string
	Port                 int
	BufferSize           int
	MaxConnections       int
	ConnectionTimeout    time.Duration
	RequestTimeout       time.Duration
	KeepAliveTime        time.Duration
	KeepAliveTimeout     time.Duration
	MaxConcurrentStreams uint32
	TLSConfig            *tls.Config
}

type GobSerializer struct{}

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

type HTTPTransportConfig struct {
	NodeID              string
	Address             string
	Port                int
	BufferSize          int
	RequestTimeout      time.Duration
	IdleConnTimeout     time.Duration
	MaxIdleConns        int
	MaxIdleConnsPerHost int
}

type JSONSerializer struct{}

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

type LocalTransportConfig struct {
	NodeID     string
	Address    string
	BufferSize int
}

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

type MessageEnvelope struct {
	Type           internal.MessageType
	From           string
	To             string
	Data           []byte
	Timestamp      int64
	SerializerType SerializerType
}

type MetricsCollector interface {
	RecordMessage(msg *internal.Message, duration time.Duration, success bool)
}

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

type PoolConfig struct {
	MaxConnections      int
	MaxIdleTime         time.Duration
	MaxConnectionAge    time.Duration
	HealthCheckInterval time.Duration
	ConnectTimeout      time.Duration
}

type PoolStatistics struct {
	TotalConnections   int64
	ActiveConnections  int64
	IdleConnections    int64
	CreatedConnections int64
	ClosedConnections  int64
	FailedConnections  int64
	TotalUses          int64
}

type PooledConnection struct {
	PeerID     string
	Connection any
	Created    time.Time
	LastUsed   time.Time
	UseCount   int64
	InUse      bool
	Healthy    bool
	// contains filtered or unexported fields
}

type ProtobufSerializer struct{}

type Serializer interface {
	Serialize(msg any) ([]byte, error)
	Deserialize(data []byte, msg any) error
	Type() SerializerType
}

type SerializerType string

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

type TCPTransportConfig struct {
	NodeID            string
	Address           string
	Port              int
	BufferSize        int
	ConnectionTimeout time.Duration
	ReadTimeout       time.Duration
	WriteTimeout      time.Duration
	KeepAlive         time.Duration
	MaxRetries        int
}

type TLSConfig struct {
	// Enable TLS
	Enabled bool

	// Certificate and key paths
	CertFile string
	KeyFile  string
	CAFile   string

	// mTLS configuration
	RequireClientCert bool
	ClientCAFile      string

	// TLS version
	MinVersion uint16
	MaxVersion uint16

	// Cipher suites
	CipherSuites []uint16

	// Server name for SNI
	ServerName string

	// Skip verification (for testing only)
	InsecureSkipVerify bool
}

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

type TransportHandler func(ctx context.Context, msg *internal.Message) error

type TransportMiddleware func(next TransportHandler) TransportHandler