config

type AdapterConfig struct {
	OrderingCacheSize uint32 `yaml:"ordering-cache-size"`
}

type Config struct {
	Base            *config.Config
	ESHostPorts     []string      `yaml:"es-host-port"`
	ESAuth          ESAuth        `yaml:"es-auth"`
	Adapter         AdapterConfig `yaml:"adapter"`
	Labeler         LabelerConfig `yaml:"labeler"`
	Queue           QueueConfig   `yaml:"queue"`
	RpcTimeout      time.Duration `yaml:"rpc-timeout"`
	PCap            PCapConfig    `yaml:"pcap"`
	AgentLogToFile  bool          `yaml:"agent-log-to-file"`
	SyslogDirectory string        `yaml:"syslog-directory"`
	ESSyslog        bool          `yaml:"es-syslog"`
}

type ConfigSynchronizer interface {
	Start()
	Stop()
	Register(Handler)
}

type DropletConfig struct {
	Droplet Config `yaml:"ingester"`
}

type ESAuth struct {
	User     string `yaml:"user"`
	Password string `yaml:"password"`
}

type Handler func(*trident.SyncResponse, *RpcInfoVersions)

type LabelerConfig struct {
	FastPathDisable bool   `yaml:"fast-path-disable"`
	MapSizeLimit    uint32 `yaml:"map-size-limit"`
	Level           int    `yaml:"level"`
}

type PCapConfig struct {
	TCPIPChecksum         bool   `yaml:"tcpip-checksum"`
	BlockSizeKB           int    `yaml:"block-size-kb"`
	MaxConcurrentFiles    int    `yaml:"max-concurrent-files"`
	MaxFileSizeMB         int    `yaml:"max-file-size-mb"`
	MaxFilePeriodSecond   int    `yaml:"max-file-period-second"`
	MaxDirectorySizeGB    int    `yaml:"max-directory-size-gb"`
	DiskFreeSpaceMarginGB int    `yaml:"disk-free-space-margin-gb"`
	FileDirectory         string `yaml:"file-directory"`
}

type QueueConfig struct {
	PacketQueueCount    int `yaml:"packet-queue-count"`
	PacketQueueSize     int `yaml:"packet-queue-size"`
	SyslogQueueSize     int `yaml:"syslog-queue-size"`
	StatsdQueueSize     int `yaml:"statsd-queue-size"`
	CompressedQueueSize int `yaml:"compressed-queue-size"`
}

type RpcConfigSynchronizer struct {
	sync.Mutex
	PollingSession grpc.GrpcSession

	RpcInfoVersions
	// contains filtered or unexported fields
}

type RpcInfoVersions struct {
	VersionPlatformData uint64
	VersionAcls         uint64
	VersionGroups       uint64
}