ratelimiter

Documentation

Index

• type Client
  • func (c *Client) AcquireResource(ctx context.Context, coordinationNodePath string, resourcePath string, ...) (err error)
  • func (c *Client) AlterResource(ctx context.Context, coordinationNodePath string, resource Resource) (err error)
  • func (c *Client) CreateResource(ctx context.Context, coordinationNodePath string, resource Resource) (err error)
  • func (c *Client) DescribeResource(ctx context.Context, coordinationNodePath string, resourcePath string) (*Resource, error)
  • func (c *Client) DropResource(ctx context.Context, coordinationNodePath string, resourcePath string) (err error)
  • func (c *Client) ListResource(ctx context.Context, coordinationNodePath string, resourcePath string, ...) ([]string, error)
• type HierarchicalDrrSettings
• type Resource

Types

type Client

type Client struct {
	Driver ydb.Driver
}

func (*Client) AcquireResource

func (c *Client) AcquireResource(ctx context.Context, coordinationNodePath string, resourcePath string, amount uint64, isUsedAmount bool) (err error)

func (*Client) AlterResource

func (c *Client) AlterResource(ctx context.Context, coordinationNodePath string, resource Resource) (err error)

func (*Client) CreateResource

func (c *Client) CreateResource(ctx context.Context, coordinationNodePath string, resource Resource) (err error)

func (*Client) DescribeResource

func (c *Client) DescribeResource(ctx context.Context, coordinationNodePath string, resourcePath string) (*Resource, error)

func (*Client) DropResource

func (c *Client) DropResource(ctx context.Context, coordinationNodePath string, resourcePath string) (err error)

func (*Client) ListResource

func (c *Client) ListResource(ctx context.Context, coordinationNodePath string, resourcePath string, recursive bool) ([]string, error)

type HierarchicalDrrSettings

type HierarchicalDrrSettings struct {
	MaxUnitsPerSecond       float64
	MaxBurstSizeCoefficient float64
	PrefetchCoefficient     float64
	PrefetchWatermark       float64
}

type Resource

type Resource struct {
	ResourcePath    string
	HierarchicalDrr HierarchicalDrrSettings
}