middleware

type MetricRole int

type MetricsObserver interface {
	OnUnaryRequest(role MetricRole, info psrpc.RPCInfo, duration time.Duration, err error)
	OnMultiRequest(role MetricRole, info psrpc.RPCInfo, duration time.Duration, responseCount int, errorCount int)
	OnStreamSend(role MetricRole, info psrpc.RPCInfo, duration time.Duration, err error)
	OnStreamRecv(role MetricRole, info psrpc.RPCInfo, err error)
	OnStreamOpen(role MetricRole, info psrpc.RPCInfo)
	OnStreamClose(role MetricRole, info psrpc.RPCInfo)
}

type RetryOptions struct {
	MaxAttempts   int
	Timeout       time.Duration
	Backoff       time.Duration
	IsRecoverable func(err error) bool
}