rpc

Documentation

Index

• func ConvertErrorStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
• func ConvertErrorStreamServerInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• func ConvertErrorUnaryClientInterceptor(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, ...) error
• func ConvertErrorUnaryServerInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (any, error)
• func NewClientCredentials(caCertFile string, certFile string, keyFile string) (credentials.TransportCredentials, error)
• func NewInsecureCredentials() credentials.TransportCredentials
• func NewServerCredentials(caCertFile string, certFile string, keyFile string) (credentials.TransportCredentials, error)
• type RateLimiterInterceptor
  • func NewRateLimiterInterceptor(qps float64, burst int64) *RateLimiterInterceptor
  • func (r *RateLimiterInterceptor) Limit() bool

Functions

func ConvertErrorStreamClientInterceptor

func ConvertErrorStreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

ConvertErrorStreamClientInterceptor returns a new stream client interceptor that convert error when trigger custom error.

func ConvertErrorStreamServerInterceptor

func ConvertErrorStreamServerInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

ConvertErrorStreamServerInterceptor returns a new stream server interceptor that convert error when trigger custom error.

func ConvertErrorUnaryClientInterceptor

func ConvertErrorUnaryClientInterceptor(ctx context.Context, method string, req, reply any, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

ConvertErrorUnaryClientInterceptor returns a new unary client interceptor that convert error when trigger custom error.

func ConvertErrorUnaryServerInterceptor

func ConvertErrorUnaryServerInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (any, error)

ConvertErrorUnaryServerInterceptor returns a new unary server interceptor that convert error when trigger custom error.

func NewClientCredentials

func NewClientCredentials(caCertFile string, certFile string, keyFile string) (credentials.TransportCredentials, error)

NewClientCredentials creates a new client credentials with the given ca certificate, certificate and key.

func NewInsecureCredentials

func NewInsecureCredentials() credentials.TransportCredentials

NewInsecureCredentials creates a new insecure credentials.

func NewServerCredentials

func NewServerCredentials(caCertFile string, certFile string, keyFile string) (credentials.TransportCredentials, error)

NewServerCredentials creates a new server credentials with the given ca certificate, certificate and key.

Types

type RateLimiterInterceptor

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

RateLimiterInterceptor is the interface for ratelimit interceptor.

func NewRateLimiterInterceptor

func NewRateLimiterInterceptor(qps float64, burst int64) *RateLimiterInterceptor

NewRateLimiterInterceptor returns a RateLimiterInterceptor instance.

func (*RateLimiterInterceptor) Limit

func (r *RateLimiterInterceptor) Limit() bool

Limit is the predicate which limits the requests.