Documentation
¶
Index ¶
- Constants
- 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
- type EventGenerator
- type MeterType
Constants ¶
View Source
const ( NUM_EVENTS = 10000 BATCH_SIZE = 100 // Reduced batch size REQUESTS_PER_SEC = 50 // Rate limit: requests per second MAX_RETRIES = 1 // Maximum number of retries for failed requests INITIAL_BACKOFF = 100 // Initial backoff in milliseconds API_ENDPOINT = "https://api.cloud.flexprice.io/v1/events" TIMEOUT_SECONDS = 5 )
Variables ¶
This section is empty.
Functions ¶
func AssignTenantToUser ¶
func AssignTenantToUser() error
AssignTenantToUser assigns a tenant to a user
func MigrateEnvironments ¶
func MigrateEnvironments() error
MigrateEnvironments is the main function that migrates all entities to use environment_id
func OnboardNewTenant ¶
func OnboardNewTenant() error
func SeedEventsClickhouse ¶
func SeedEventsClickhouse() error
SeedEventsClickhouse seeds events data into Clickhouse
func SeedEventsFromMeters ¶
func SeedEventsFromMeters() error
SeedEventsFromMeters seeds events data based on existing meters
func TestKafkaConnection ¶
Types ¶
type BatchResult ¶
type EventGenerator ¶
type EventGenerator struct {
// contains filtered or unexported fields
}
EventGenerator holds the configuration for generating events
func NewEventGenerator ¶
func NewEventGenerator(meters []*meter.Meter, customers []*customer.Customer, logger *logger.Logger) *EventGenerator
NewEventGenerator creates a new event generator with the given meters
Source Files
Click to show internal directories.
Click to hide internal directories.