Documentation
¶
Index ¶
- func NewDeleteActualQuotaAction(kafkaConfig config.KafkaConfig, ...) chain.ReconcileAction[PromotionContext]
- func NewReserveDesiredQuotaAction(kafkaConfig config.KafkaConfig, ...) chain.ReconcileAction[PromotionContext]
- func NewUpdateKafkaRequestAction(kafkaService services.KafkaService) chain.ReconcileAction[PromotionContext]
- type DeleteActualQuotaAction
- type PromotionContext
- type ReserveDesiredQuotaAction
- type UpdateKafkaRequestAction
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDeleteActualQuotaAction ¶
func NewDeleteActualQuotaAction(kafkaConfig config.KafkaConfig, quotaServiceFactory services.QuotaServiceFactory) chain.ReconcileAction[PromotionContext]
func NewReserveDesiredQuotaAction ¶
func NewReserveDesiredQuotaAction(kafkaConfig config.KafkaConfig, quotaServiceFactory services.QuotaServiceFactory) chain.ReconcileAction[PromotionContext]
func NewUpdateKafkaRequestAction ¶
func NewUpdateKafkaRequestAction(kafkaService services.KafkaService) chain.ReconcileAction[PromotionContext]
Types ¶
type DeleteActualQuotaAction ¶
type DeleteActualQuotaAction struct {
// contains filtered or unexported fields
}
func (*DeleteActualQuotaAction) PerformJob ¶
func (d *DeleteActualQuotaAction) PerformJob(kafkaRequest *dbapi.KafkaRequest, currentResult chain.ActionResult[PromotionContext]) (chain.ActionResult[PromotionContext], bool, error)
type PromotionContext ¶
type PromotionContext struct {
SubscriptionID string
}
type ReserveDesiredQuotaAction ¶
type ReserveDesiredQuotaAction struct {
// contains filtered or unexported fields
}
func (*ReserveDesiredQuotaAction) PerformJob ¶
func (d *ReserveDesiredQuotaAction) PerformJob(kafkaRequest *dbapi.KafkaRequest, currentResult chain.ActionResult[PromotionContext]) (chain.ActionResult[PromotionContext], bool, error)
PerformJob reserves quota for the received kafkaRequest object. The quota is reserved only if it has not been already reserved (ie: running this action multiple times on the same kafkaRequest doesn't allocate multiple quotas) The type of quota to be allocated is inferred from the DesiredBillingModel attribute of the kafkaRequest object
type UpdateKafkaRequestAction ¶
type UpdateKafkaRequestAction struct {
// contains filtered or unexported fields
}
func (UpdateKafkaRequestAction) PerformJob ¶
func (u UpdateKafkaRequestAction) PerformJob(kafkaRequest *dbapi.KafkaRequest, currentResult chain.ActionResult[PromotionContext]) (chain.ActionResult[PromotionContext], bool, error)
Source Files
Click to show internal directories.
Click to hide internal directories.