internal

Jan 30, 2026

Changes in this version

+ func SyncPriceToSubscriptions() error

Jan 5, 2026

Changes in this version

+ func ImportFeatures() error

+ func MigrateCGA() error

+ type FeatureImportSummary struct

+ Errors []string

+ FeaturesCreated int

+ FeaturesSkipped int

+ PricesCreated int

+ PricesSkipped int

+ TotalRows int

+ type FeatureRow struct

+ AggregationField string

+ AggregationType string

+ EventName string

+ FeatureName string

+ PricePerUnit decimal.Decimal

Dec 24, 2025

Changes in this version

type BulkReprocessEventsParams

+ ExternalCustomerID string

Dec 9, 2025

Changes in this version

+ func GenerateCreditUsageReport() error

+ type CreditUsageReportData struct

+ CurrentBalance decimal.Decimal

+ CustomerExternalID string

+ CustomerID string

+ CustomerName string

+ RealtimeBalance decimal.Decimal

Sep 25, 2025

Changes in this version

+ func ProcessCSVFeatures() error

+ type CSVFeatureProcessor struct

+ type CSVFeatureRecord struct

+ Aggregation string

+ Amount string

+ Currency string

+ EventName string

+ FeatureName string

+ PlanName string

+ type ProcessingSummary struct

+ Errors []string

+ FeaturesCreated int

+ MetersCreated int

+ PricesCreated int

+ TotalRows int

Sep 22, 2025

Changes in this version

+ func MigrateBillingCycle() error

+ type MigrateBillingCycleParams struct

+ DryRun bool

+ EnvironmentID string

+ TenantID string

Sep 11, 2025

Changes in this version

+ func CopyPlanChargesToAddons() error

Aug 13, 2025

Changes in this version

+ func MigrateInvoiceSequences() error

+ type DryRunResult struct

+ AlreadyExists bool

+ Environment string

+ LastValue int64

+ TenantID string

+ WouldCreate bool

+ YearMonth string

Jul 2, 2025

Changes in this version

+ func AddNewUserToTenant() error

+ func AssignPlanToCustomers() error

+ func BulkReprocessEvents(params BulkReprocessEventsParams) error

+ func ReprocessEventsFromEnv() error

+ type BulkReprocessEventsParams struct

+ BatchSize int

+ EnvironmentID string

+ EventName string

+ TenantID string

+ type BulkReprocessEventsScript struct

+ type ReprocessEventsScriptParams struct

+ BatchSize int

+ EndTime time.Time

+ EnvironmentID string

+ EventName string

+ ExternalCustomerID string

+ StartTime time.Time

+ TenantID string

May 23, 2025

Changes in this version

+ func ImportPricing() error

+ func ReprocessEvents() error

+ func SyncPlanPrices() error

+ type PricingImportSummary struct

+ Errors []string

+ FeaturesDeleted int

+ FeaturesUpdated int

+ MetersDeleted int

+ MetersUpdated int

+ PricesCreated int

+ PricesDeleted int

+ PricesUpdated int

+ TotalRows int

+ type PricingRow struct

+ Aggregation string

+ Delete string

+ EventName string

+ FeatureID string

+ FeatureName string

+ Filters string

+ MeterID string

+ PerUnitPrice float64

+ PlanID string

+ PlanName string

+ PriceID string

+ type ReprocessEventsScript struct

Apr 17, 2025

Changes in this version

+ func SyncBillingCustomers() error

Mar 4, 2025

Changes in this version

+ const API_ENDPOINT

+ const BATCH_SIZE

+ const INITIAL_BACKOFF

+ const MAX_RETRIES

+ const NUM_EVENTS

+ const REQUESTS_PER_SEC

+ const TIMEOUT_SECONDS

+ func AssignTenantToUser() error

+ func GenerateNewAPIKey() error

+ func MigrateEnvironments() error

+ func OnboardNewTenant() error

+ func SeedEventsClickhouse() error

+ func SeedEventsFromMeters() error

+ func TestKafkaConnection(brokers []string, username, password string) error

+ type BatchResult struct

+ BatchNumber int

+ EndTime time.Time

+ EventCount int

+ LastEventID string

+ StartTime time.Time

+ type EventGenerator struct

+ func NewEventGenerator(meters []*meter.Meter, customers []*customer.Customer, logger *logger.Logger) *EventGenerator

+ type MeterType struct

+ Code string

+ Description string

+ MaxValue int64

+ MinValue int64