proxy

type Config struct {
	Version              primitive.ProtocolVersion
	MaxVersion           primitive.ProtocolVersion
	Auth                 proxycore.Authenticator
	Resolver             proxycore.EndpointResolver
	ReconnectPolicy      proxycore.ReconnectPolicy
	RetryPolicy          RetryPolicy
	IdempotentGraph      bool
	NumConns             int
	Logger               *zap.Logger
	HeartBeatInterval    time.Duration
	IdleTimeout          time.Duration
	RPCAddr              string
	DC                   string
	Tokens               []string
	Peers                []PeerConfig
	TrackUsage           bool
	UsageTrackSystem     bool
	UsageKeyspace        string
	UsageWruBytes        int
	UsageRruBytes        int
	UsageTable           string
	UsageFlushSeconds    int
	UsageHistogramsTable string
	// PreparedCache a cache that stores prepared queries. If not set it uses the default implementation with a max
	// capacity of ~100MB.
	PreparedCache proxycore.PreparedCache
}

type PeerConfig struct {
	RPCAddr string   `yaml:"rpc-address"`
	DC      string   `yaml:"data-center,omitempty"`
	Tokens  []string `yaml:"tokens,omitempty"`
}

type ProducerService struct {
}

type Proxy struct {
	StreamingManager *streamingManager
	// contains filtered or unexported fields
}

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

type RetryDecision int

type RetryPolicy interface {
	// OnReadTimeout handles the retry decision for a server-side read timeout error (Read_timeout = 0x1200).
	// This occurs when a replica read request times out during a read query.
	OnReadTimeout(msg *message.ReadTimeout, retryCount int) RetryDecision

	// OnWriteTimeout handles the retry decision for a server-side write timeout error (Write_timeout = 0x1100).
	// This occurs when a replica write request times out during a write query.
	OnWriteTimeout(msg *message.WriteTimeout, retryCount int) RetryDecision

	// OnUnavailable handles the retry decision for a server-side unavailable exception (Unavailable = 0x1000).
	// This occurs when a coordinator determines that there are not enough replicas to handle a query at the requested
	// consistency level.
	OnUnavailable(msg *message.Unavailable, retryCount int) RetryDecision

	// OnErrorResponse handles the retry decision for other potentially recoverable errors.
	// This can be called for the following error types: server error (ServerError = 0x0000),
	// overloaded (Overloaded = 0x1001), truncate error (Truncate_error = 0x1003), read failure (Read_failure = 0x1300),
	// and write failure (Write_failure = 0x1500).
	OnErrorResponse(msg message.Error, retryCount int) RetryDecision
}