conf

type BrokerClientType int

type BrokerConfig struct {
	ClientType BrokerClientType  `json:"client-type,omitempty"`
	Properties map[string]string `json:"properties,omitempty"`
}

type BrokerConfigs map[string]BrokerConfig // Key is broker name which is referred to in the source descriptor

type Config struct {
	NodeID                           int
	ClusterID                        uint64 // All nodes in a Prana cluster must share the same ClusterID
	RaftAddresses                    []string
	NotifListenAddresses             []string
	NumShards                        int
	ReplicationFactor                int
	DataDir                          string
	TestServer                       bool
	KafkaBrokers                     BrokerConfigs
	DataSnapshotEntries              int
	DataCompactionOverhead           int
	SequenceSnapshotEntries          int
	SequenceCompactionOverhead       int
	LocksSnapshotEntries             int
	LocksCompactionOverhead          int
	EnableAPIServer                  bool
	APIServerListenAddresses         []string
	EnableSourceStats                bool
	ProtobufDescriptorDir            string `` /* 164-byte string literal not displayed */
	EnableLifecycleEndpoint          bool
	LifeCycleListenAddress           string
	StartupEndpointPath              string
	ReadyEndpointPath                string
	LiveEndpointPath                 string
	MetricsBind                      string `help:"Bind address for Prometheus metrics." default:"localhost:9102" env:"METRICS_BIND"`
	EnableMetrics                    bool
	EnableFailureInjector            bool
	ScreenDragonLogSpam              bool
	DisableShardPlacementSanityCheck bool
	RaftRTTMs                        int
	RaftElectionRTT                  int
	RaftHeartbeatRTT                 int
	DisableFsync                     bool
	DDProfilerTypes                  string
	DDProfilerHostEnvVarName         string
	DDProfilerPort                   int
	DDProfilerServiceName            string
	DDProfilerEnvironmentName        string
	DDProfilerVersionName            string
	AggregationCacheSizeRows         int // The maximum number of rows for an aggregation to cache in memory
	MaxProcessBatchSize              int
	MaxForwardWriteBatchSize         int
}