crdbqm

Documentation

Overview

Package crdbqm defines a CockroachDB-based quota.Manager implementation.

Index

• Constants
• Variables
• type QuotaManager
  • func (m *QuotaManager) GetTokens(ctx context.Context, numTokens int, specs []quota.Spec) error
  • func (m *QuotaManager) PutTokens(ctx context.Context, numTokens int, specs []quota.Spec) error
  • func (m *QuotaManager) ResetQuota(ctx context.Context, specs []quota.Spec) error

Constants

const (
	// DefaultMaxUnsequenced is a suggested value for MaxUnsequencedRows.
	// Note that this is a Global/Write quota suggestion, so it applies across trees.
	DefaultMaxUnsequenced = 500000 // About 2h of non-stop signing at 70QPS.

)

const QuotaManagerName = "crdb"

QuotaManagerName identifies the CockroachDB quota implementation.

Variables

var ErrTooManyUnsequencedRows = errors.New("too many unsequenced rows")

ErrTooManyUnsequencedRows is returned when tokens are requested but Unsequenced has grown beyond the configured limit.

Types

type QuotaManager

type QuotaManager struct {
	DB                 *sql.DB
	MaxUnsequencedRows int
}

QuotaManager is a CockroachDB-based quota.Manager implementation.

QuotaManager only implements Global/Write quotas, which is based on the number of Unsequenced rows (to be exact, tokens = MaxUnsequencedRows - actualUnsequencedRows). Other quotas are considered infinite.

func (*QuotaManager) GetTokens

func (m *QuotaManager) GetTokens(ctx context.Context, numTokens int, specs []quota.Spec) error

GetTokens implements quota.Manager.GetTokens. It doesn't actually reserve or retrieve tokens, instead it allows access based on the number of rows in the Unsequenced table.

func (*QuotaManager) PutTokens

func (m *QuotaManager) PutTokens(ctx context.Context, numTokens int, specs []quota.Spec) error

PutTokens implements quota.Manager.PutTokens. It's a noop for QuotaManager.

func (*QuotaManager) ResetQuota

func (m *QuotaManager) ResetQuota(ctx context.Context, specs []quota.Spec) error

ResetQuota implements quota.Manager.ResetQuota. It's a noop for QuotaManager.