Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RetryingStreamClientInterceptor ¶
func RetryingStreamClientInterceptor(duration time.Duration) func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)
RetryingStreamClientInterceptor returns a ClientStreamInterceptor that retries both requests and responses
Types ¶
type Logger ¶
type Logger interface { // Error logs an Error level message Error(message string, args ...interface{}) // Warn logs a Warn level message Warn(message string, args ...interface{}) // Info logs an Info level message Info(message string, args ...interface{}) // Debug logs a Debug level message Debug(message string, args ...interface{}) // Trace logs a Trace level message Trace(message string, args ...interface{}) // Send logs a sent message Send(messageType string, request interface{}) // Receive logs a received message Receive(messageType string, response interface{}) // SendTo logs a message send to a specific member SendTo(messageType string, request interface{}, member interface{}) // ReceiveFrom logs a message received from a specific member ReceiveFrom(messageType string, response interface{}, member interface{}) // ErrorFrom logs an error received from a specific member ErrorFrom(messageType string, err error, member interface{}) // Request logs a request Request(requestType string, request interface{}) // Response logs a response Response(responseType string, response interface{}, err error) error }
Logger provides logging for requests and responses
Click to show internal directories.
Click to hide internal directories.