client

Documentation

Index

• type Client
  • func NewClient(cfg conf.ClientConfig, poolSize int) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) List(ctx context.Context, ret *pb.LimiterList) error
  • func (c *Client) NewLimiter(ctx context.Context, name string, rate int, interval time.Duration) error
  • func (c *Client) RemoveLimiter(ctx context.Context, name string) error
  • func (c *Client) Take(ctx context.Context, req *pb.Limiter) (time.Duration, error)
  • func (c *Client) TakeAsync(ctx context.Context, req *pb.Limiter, ch chan<- Result) error
• type Result

Types

type Client

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

func NewClient

func NewClient(cfg conf.ClientConfig, poolSize int) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) List

func (c *Client) List(ctx context.Context, ret *pb.LimiterList) error

func (*Client) NewLimiter

func (c *Client) NewLimiter(ctx context.Context, name string, rate int, interval time.Duration) error

func (*Client) RemoveLimiter

func (c *Client) RemoveLimiter(ctx context.Context, name string) error

func (*Client) Take

func (c *Client) Take(ctx context.Context, req *pb.Limiter) (time.Duration, error)

func (*Client) TakeAsync

func (c *Client) TakeAsync(ctx context.Context, req *pb.Limiter, ch chan<- Result) error

type Result

type Result struct {
	Duration time.Duration
	Error    error
}