conf

Documentation

Index

• Constants
• type BrokerClientType
• type BrokerConfig
• type BrokerConfigs
• type Config
  • func NewDefaultConfig() *Config
  • func NewTestConfig(fakeKafkaID int64) *Config
  • func (c *Config) ApplyDefaults()
  • func (c *Config) Validate() error

Constants

const (
	DefaultDataSnapshotEntries        = 50000
	DefaultDataCompactionOverhead     = 5000
	DefaultSequenceSnapshotEntries    = 1000
	DefaultSequenceCompactionOverhead = 50
	DefaultLocksSnapshotEntries       = 1000
	DefaultLocksCompactionOverhead    = 50
	DefaultRaftRTTMs                  = 50
	DefaultRaftHeartbeatRTT           = 30
	DefaultRaftElectionRTT            = 300
	DefaultAggregationCacheSizeRows   = 20000
	DefaultMaxProcessBatchSize        = 2000
	DefaultMaxForwardWriteBatchSize   = 500
)

const (
	BrokerClientTypeUnknown                  = 0
	BrokerClientFake        BrokerClientType = 1
	BrokerClientDefault                      = 2
	BrokerClientGenerator                    = 3
)

Types

type BrokerClientType

type BrokerClientType int

type BrokerConfig

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

type BrokerConfigs

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

type Config

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
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func NewTestConfig

func NewTestConfig(fakeKafkaID int64) *Config

func (*Config) ApplyDefaults

func (c *Config) ApplyDefaults()

func (*Config) Validate

func (c *Config) Validate() error