hub

Documentation

Index

• Constants
• func CheckQuota(_ context.Context, tlr *hubv1.GetTokenLeaseRequest) (hubv1.Quota, string, error)
• func NewTokenLeaseRequest(ctx context.Context, gn string, fn *string, pb *int32, dw *float32, ...) (context.Context, *hubv1.GetTokenLeaseRequest)
• func ValidateTokens(_ context.Context, guard string, tokens []string) (hubv1.Token, error)

Constants

const (
	MAX_QUOTA_WAIT               = 1 * time.Second
	CACHED_LEASE_CHECK_INTERVAL  = 200 * time.Millisecond // TODO: what should this be set to?
	BATCH_TOKEN_CONSUME_INTERVAL = 200 * time.Millisecond // TODO: what should this be set to?
)

Functions

func CheckQuota

func CheckQuota(_ context.Context, tlr *hubv1.GetTokenLeaseRequest) (hubv1.Quota, string, error)

func NewTokenLeaseRequest

func NewTokenLeaseRequest(ctx context.Context, gn string, fn *string, pb *int32, dw *float32, tags *map[string]string) (context.Context, *hubv1.GetTokenLeaseRequest)

func ValidateTokens

func ValidateTokens(_ context.Context, guard string, tokens []string) (hubv1.Token, error)