Documentation
¶
Index ¶
- Constants
- func AddStats(m map[string]string)
- func FlushAcknowlegedOffsetsMap() error
- func Heartbeat(buildVersion, buildCommit string, configTs int32, configHash string, ...)
- func Init(c Config)
- func InternalLog(typ, table string, volume int64, message, content string)
- func UpdateDestinationsConfig(m destination.Map)
- func Write(table string, data []byte, rowBinary bool) error
- type Config
Constants ¶
View Source
const ( ErrCodeFileOpen = 100 ErrCodeFileWrite = 101 )
Variables ¶
This section is empty.
Functions ¶
func FlushAcknowlegedOffsetsMap ¶
func FlushAcknowlegedOffsetsMap() error
FlushAcknowlegedOffsetsMap saves current offsets map. It is made public so that offsets can be saved right before SIGTERM.
func Heartbeat ¶
func Heartbeat(buildVersion, buildCommit string, configTs int32, configHash string, memoryUsedBytes uint64, cpuUserAvg, cpuSysAvg float32)
Heartbeat adds entry to daemon_heartbeat_buffer table.
func Init ¶
func Init(c Config)
Init initializes config variables and checks that configuration is valid.
func InternalLog ¶
InternalLog adds entry to internal log table. Be careful to avoid infinite recursion when using inside of persist package itself.
func UpdateDestinationsConfig ¶
func UpdateDestinationsConfig(m destination.Map)
UpdateDestinationsConfig accepts destination.Map and restarts all senders
Types ¶
type Config ¶
type Config struct {
Dir string
Port uint // for debug purposes
MaxSendSize int64
MaxFileSize int64
RotateInterval time.Duration
MarkAsDone bool // rename files to ".done" instead of deleting files that are delivered successfully
// contains filtered or unexported fields
}
Config for package
Source Files
Click to show internal directories.
Click to hide internal directories.