premium

May 13, 2024

Changes in this version

+ const BatchLimitHeader

+ const MaximumUpdateIntervalHeader

+ const MinimumUpdateIntervalHeader

May 9, 2024

Changes in this version

type NoOpUsageClient

+ func (NoOpUsageClient) IncreaseForTable(_ string, _ uint32) error

type UsageClient

+ IncreaseForTable func(string, uint32) error

May 9, 2024

Changes in this version

+ const UsageIncreaseMethodBreakdown

+ const UsageIncreaseMethodTotal

+ const UsageIncreaseMethodUnset

type BatchUpdater

+ func (u *BatchUpdater) IncreaseForTable(table string, rows uint32) error

Jan 2, 2024

Changes in this version

+ var ErrLicenseNotApplicable = errors.New("license not applicable to this plugin")

type License

+ Plugins []string

Dec 29, 2023

Changes in this version

+ var ErrInvalidLicenseSignature = errors.New("invalid license signature")

+ var ErrLicenseExpired = errors.New("license expired")

+ var ErrLicenseNotValidYet = errors.New("license not valid yet")

+ func ValidateLicense(logger zerolog.Logger, licenseFile string) error

+ type License struct

+ ExpiresAt time.Time

+ IssuedAt time.Time

+ LicensedTo string

+ ValidFrom time.Time

+ func UnpackLicense(lic []byte) (*License, error)

+ func (l *License) IsValid(logger zerolog.Logger) error

+ type LicenseWrapper struct

+ LicenseBytes []byte

+ Signature string

+ type NoOpUsageClient struct

+ TeamNameValue string

+ func (NoOpUsageClient) Close() error

+ func (NoOpUsageClient) HasQuota(_ context.Context) (bool, error)

+ func (NoOpUsageClient) Increase(_ uint32) error

+ func (n *NoOpUsageClient) TeamName() string

Dec 14, 2023

Changes in this version

type BatchUpdater

+ func (u *BatchUpdater) TeamName() string

type ErrNoQuota

+ func (e ErrNoQuota) Error() string

type QuotaMonitor

+ TeamName func() string

Dec 4, 2023

Changes in this version

+ type TokenClient interface

+ GetToken func() (auth.Token, error)

+ GetTokenType func() auth.TokenType

Oct 30, 2023

Changes in this version

+ const DefaultMaxQuotaFailures

+ const DefaultQuotaCheckInterval

+ var ErrNoQuota = errors.New(...)

+ func ContainsPaidTables(tables schema.Tables) bool

+ func MakeAllTablesPaid(tables schema.Tables) schema.Tables

+ func MakeTablePaid(table *schema.Table) *schema.Table

+ func WithCancelOnQuotaExceeded(ctx context.Context, qm QuotaMonitor, ops ...QuotaCheckOption) (context.Context, error)

+ func WithPluginKind(pluginKind string) cqapi.PluginKind

+ func WithPluginName(pluginName string) cqapi.PluginName

+ func WithPluginTeam(pluginTeam string) cqapi.PluginTeam

+ type BatchUpdater struct

+ func NewUsageClient(pluginTeam cqapi.PluginTeam, pluginKind cqapi.PluginKind, ...) (*BatchUpdater, error)

+ func (u *BatchUpdater) Close() error

+ func (u *BatchUpdater) HasQuota(ctx context.Context) (bool, error)

+ func (u *BatchUpdater) Increase(rows uint32) error

+ type QuotaCheckOption func(*quotaChecker)

+ func WithQuotaCheckPeriod(duration time.Duration) QuotaCheckOption

+ func WithQuotaMaxConsecutiveFailures(n int) QuotaCheckOption

+ type QuotaMonitor interface

+ HasQuota func(context.Context) (bool, error)

+ type UsageClient interface

+ Close func() error

+ Increase func(uint32) error

+ type UsageClientOptions func(updater *BatchUpdater)

+ func WithAPIClient(apiClient *cqapi.ClientWithResponses) UsageClientOptions

+ func WithBatchLimit(batchLimit uint32) UsageClientOptions

+ func WithLogger(logger zerolog.Logger) UsageClientOptions

+ func WithMaxRetries(maxRetries int) UsageClientOptions

+ func WithMaxTimeBetweenFlushes(maxTimeBetweenFlushes time.Duration) UsageClientOptions

+ func WithMaxWaitTime(maxWaitTime time.Duration) UsageClientOptions

+ func WithMinTimeBetweenFlushes(minTimeBetweenFlushes time.Duration) UsageClientOptions

+ func WithURL(url string) UsageClientOptions