conf

type AggregateSchedulesConfig struct {
	BufferSize  int // Channel buffer size
	Routines    int // Number of workers aggregating schedules
	BatchSize   int // Batchsize of schedules for bulk update
	FlushPeriod int // Flush period in seconds after which schedule batches are pushed to db (even if they are not full)
}

type AppLevelConfiguration struct {
	// Requests are rejected if the schedule time is beyond specified FutureScheduleCreationPeriod (in days) from current time
	FutureScheduleCreationPeriod int

	// Period in days for which schedules are kept in DB after the schedules are fired
	FiredScheduleRetentionPeriod int

	// Maximum Payload size in bytes allowed
	PayloadSize int

	// Http Retries for requests
	HttpRetries int

	// HTTP Timeout in milliseconds for requests
	HttpTimeout int
}

type BulkActionConfig struct {
	BufferSize int // Channel buffer size
	Routines   int // Number of workers aggregating schedules
}

type CassandraConfig struct {
	Hosts          string            // Comma-separated list of Cassandra hosts
	Consistency    gocql.Consistency // Consistency level for Cassandra operations
	DataCenter     string            // Name of the data center to connect to
	ConnectionPool ConnectionPool    // Connection pool configuration
}

type ClusterConfig struct {
	ClusterName      string   // Name of the cluster
	Address          string   // Address of the cluster
	TChannelPort     string   // TChannel port for inter-node communication
	BootStrapServers []string // List of bootstrap servers for cluster formation
	JoinSize         int      // Number of nodes required to form a cluster
	Log              Log      // Logging configuration

	//TODO: move it to DB config
	PageSize      int // Page size for pagination
	NumRetry      int // Number of retries for failed operations
	ReplicaPoints int // Number of replica points for data replication
}

type ClusterDBConfig struct {
	ClusterKeySpace   string          // Keyspace for the cluster
	DBConfig          CassandraConfig // Cassandra configuration for the cluster
	EntityHistorySize int             // Size of the entity history
}

type Configuration struct {
	HttpPort                 string                   // Port for the HTTP server
	ConfigFile               string                   `json:"-"` // Configuration file path
	SchemaPath               string                   // Configuration options for Cassandra Schema path
	Cluster                  ClusterConfig            // Configuration options for the cluster
	ClusterDB                ClusterDBConfig          // Configuration options for the cluster database
	ScheduleDB               ScheduleDBConfig         // Configuration options for the schedule database
	Poller                   PollerConfig             // Configuration options for the poller
	MonitoringConfig         MonitoringConfig         // Configuration options for monitoring
	HttpConnector            HttpConnectorConfig      // Configuration options for the HTTP connector
	CronConfig               CronConfig               // Configuration options for the cron scheduler
	StatusUpdateConfig       StatusUpdateConfig       // Configuration options for status updates
	AggregateSchedulesConfig AggregateSchedulesConfig // Configuration options for schedule aggregation
	NodeCrashReconcile       NodeCrashReconcile       // Configuration options for node crash reconciliation
	BulkActionConfig         BulkActionConfig         // Configuration options for bulk actions
	AppLevelConfiguration    AppLevelConfiguration    // Configuration options for app level configuration
	DCConfig                 DCConfig                 // Configuration options for DC configuration
}

type ConnectionPool struct {
	InitialConnectTimeout int // Initial connection timeout in milliseconds
	ConnectTimeout        int // Connection timeout in milliseconds
	MaxNumConnections     int // Maximum number of connections in the pool
}

type CronConfig struct {
	App string // Name of the special app which converts the recurring schedules to one time schedules.
	// A special schedule retriever will be used by this app pollers.
	Window   time.Duration // The time window within which new future one time schedules for the recurring schedules will be created.
	Routines int           // Number of worker routines converting the schedules to one time.
}

type DCConfig struct {
	// used to prefix appIds
	Prefix string

	// location of the DC
	Location string
}

type EventListener struct {
	AppName             string // Name of the application associated with the listener
	EventName           string // Name of the event the listener is listening for
	ConcurrentListeners int    // Number of concurrent listeners
	ConsumerCount       int    // Number of consumers for each listener
}

type HttpConnectorConfig struct {
	Routines      int           // Number of concurrent routines for processing
	MaxRetry      int           // Maximum number of retries for failed requests
	TimeoutMillis time.Duration // Timeout for HTTP requests in milliseconds
}

type Log struct {
	Enable bool // Indicates if logging is enabled
}

type MonitoringConfig struct {
	Statsd *StatsdConfig // Configuration options for Statsd
}

type NewrelicConfig struct {
	LicenseKey string // License key for the New Relic agent
	AppName    string // Name of the application being monitored
	Enable     bool   // Indicates if the New Relic agent is enabled
}

type NodeCrashReconcile struct {
	NeedsReconcile  bool
	ReconcileOffset int
}

type Option func(*Configuration)

type PollerConfig struct {
	Interval     int    // Polling interval in seconds
	DefaultCount uint32 // Default number of items to be polled
}

type RingPopConfig struct {
	Host string // Hostname or IP address of the RingPop instance
	Port int    // Port number on which the RingPop instance is listening
}

type ScheduleDBConfig struct {
	ScheduleKeySpace  string          // Keyspace for the schedule
	ScheduleTableName string          // Table name for the schedule
	DBConfig          CassandraConfig // Cassandra configuration for the schedule
}

type StatsdConfig struct {
	Enabled bool   // Indicates if the StatsD client is enabled
	Address string // Address of the StatsD server, in the format "host:port"
	Prefix  string // Optional prefix for metric names
}

type StatusUpdateConfig struct {
	Routines int // Number of workers updating status of schedules
}