ratelimit

Documentation

Index

• func New(cfg Config) (*service, error)
• type Config
• type Middleware
• type Service
  • func WithTracing(svc Service) Service

Functions

func New

func New(cfg Config) (*service, error)

Types

type Config

type Config struct {
	Logger  logging.Logger
	Metrics metrics.Metrics
	Cluster cluster.Cluster
}

type Middleware

type Middleware func(Service) Service

type Service

type Service interface {
	Ratelimit(context.Context, *ratelimitv1.RatelimitRequest) (*ratelimitv1.RatelimitResponse, error)
	MultiRatelimit(context.Context, *ratelimitv1.RatelimitMultiRequest) (*ratelimitv1.RatelimitMultiResponse, error)
	PushPull(context.Context, *ratelimitv1.PushPullRequest) (*ratelimitv1.PushPullResponse, error)
	CommitLease(context.Context, *ratelimitv1.CommitLeaseRequest) (*ratelimitv1.CommitLeaseResponse, error)
	Mitigate(context.Context, *ratelimitv1.MitigateRequest) (*ratelimitv1.MitigateResponse, error)
}

func WithTracing

func WithTracing(svc Service) Service