rpc

Documentation

Index

• func RPCServerStart()
• type RateLimiter
  • func NewRateLimiter(limit int) *RateLimiter
  • func (r *RateLimiter) UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Functions

func RPCServerStart

func RPCServerStart()

Types

type RateLimiter

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

func NewRateLimiter

func NewRateLimiter(limit int) *RateLimiter

func (*RateLimiter) UnaryInterceptor

func (r *RateLimiter) UnaryInterceptor(ctx context.Context, req interface{},
	info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)