Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + const ApplicationGzip + const ApplicationJson + const B + const CheckPattern + const CheckPatternKey + const Checkbox + const ContentEncodingHeader + const ContentTypeHeader + const DATE + const DROP + const DefaultDirPerm + const DefaultEncodingWay + const DefaultErrorsListCap + const DefaultFilePerm + const DefaultInternalPrefix + const DefaultMaxBatchSize + const DefaultSelfRunnerName + const DefaultSendIntervalSeconds + const DefaultTruncateMaxSize + const ErrClusterConfig + const ErrClusterConfigs + const ErrClusterRegister + const ErrClusterRunnerAdd + const ErrClusterRunnerDelete + const ErrClusterRunnerReset + const ErrClusterRunnerStart + const ErrClusterRunnerStop + const ErrClusterRunnerUpdate + const ErrClusterSlaves + const ErrClusterSlavesDelete + const ErrClusterSlavesTag + const ErrClusterStatus + const ErrClusterTag + const ErrConfigName + const ErrNothing + const ErrParseParse + const ErrReadRead + const ErrRunnerAdd + const ErrRunnerDelete + const ErrRunnerErrorGet + const ErrRunnerReset + const ErrRunnerStart + const ErrRunnerStop + const ErrRunnerUpdate + const ErrSendSend + const ErrTransformTransform + const ExtraInfo + const FLOAT + const GB + const GlobalKeyName + const InputNumber + const InternalKeyPrefix + const KB + const KeyCore + const KeyHostName + const KeyLocalIp + const KeyOsInfo + const KeyPandoraSeparateId + const KeyPandoraStash + const KeyRunnerIsBlock + const KeyRunnerMaxLineLen + const KeyRunnerName + const KeyType + const KodoTokensPrefix + const LONG + const Local + const LogDBTokensPrefix + const Lst + const MB + const PipeLineError + const ProcessAt + const Radio + const STRING + const SchemaFreeTokensPrefix + const Server + const Text + const TextPlain + const TsDBTokensPrefix + const TypeIP + var Encoding = []interface + var ErrNotExist = errors.New("runner does not exist") + var ErrNotSupport = errors.New("runner does not support") + var ErrQueueClosed = errors.New("queue is closed") + var ErrorCodeHumanize = map[string]string + var LogkitAutoCreateDescription = "由logkit日志收集自动创建" + var MaxProcs = 1 + var MetricAutoCreateDescription = "由logkit监控收集自动创建" + var ModifierRe = regexp.MustCompile(`%{\w+:(\w+):(long|string|date|float|drop)}`) + var NumCPU = runtime.NumCPU() + var PatternOnlyRe = regexp.MustCompile(`%{(\w+)}`) + var SelfLogAutoCreateDescription = "由logkit收集自身日志创建" + func AddHttpProtocal(url string) string + func Bool2String(i bool) string + func CheckErr(err error) error + func CheckFileMode(path string, fileMode os.FileMode) error + func CheckLogPath(logpath string) (dir string, path string) + func CheckPandoraKey(key string) bool + func CheckPath(path string) (string, error) + func ConvertDate(layoutBefore, layoutAfter string, offset int, loc *time.Location, ...) (interface{}, error) + func CreateDirIfNotExist(dir string) (err error) + func DecodeString(target string) (result string, err error) + func DecompressTarGzip(srcPath, dstPath, targetFile string) (targetDir string, _ error) + func DecompressZip(srcPath, dstPath, targetFile string) (targetDir string, _ error) + func DeepConvertKey(data map[string]interface{}) map[string]interface + func DeepConvertKeyWithCache(data map[string]interface{}, cache map[string]KeyInfo) map[string]interface + func DeleteMapValue(m map[string]interface{}, keys ...string) (interface{}, bool) + func EncodeString(target string) (result string) + func ExtractField(slice []string) ([]string, error) + func FormatWithUserOption(layoutAfter string, offset int, t time.Time) interface + func GetCmd(keyStr string) []string + func GetKeys(keyStr string) []string + func GetMapList(data string) map[string]string + func GetMapValue(m map[string]interface{}, keys ...string) (interface{}, error) + func GetRealPath(path string) (newPath string, fi os.FileInfo, err error) + func GetTime(timestamp string) (time.Time, error) + func Hash(s string) string + func IsFileModified(path string, interval time.Duration, compare time.Time) bool + func IsJsonString(s string) bool + func IsNotExist(err error) bool + func IsNotSupport(err error) bool + func IsSelfRunner(runnerName string) bool + func IsSpace(separator rune) bool + func IsSubMetaExpire(submetaExpire, expire time.Duration) bool + func IsSubmetaExpireValid(submetaExpire, expire time.Duration) bool + func KeyExist(m map[string]interface{}, val interface{}, keys ...string) (bool, error) + func LogDirAndPattern(logpath string) (dir, pattern string, err error) + func MergeEnvTags(name string, tags map[string]interface{}) map[string]interface + func ModTimeLater(f1, f2 os.FileInfo) bool + func ParseTimeZoneOffset(zoneoffset string) (ret int) + func PickMapValue(m map[string]interface{}, pick map[string]interface{}, keys ...string) + func ReadDirByTime(dir string) (files []os.FileInfo, err error) + func ReadFileContent(path string) (content []string, err error) + func RemoveHttpProtocal(url string) (hostport, schema string) + func SetExtractMapValue(m map[string]interface{}, val interface{}, coercive bool, newKey string, ...) error + func SetMapValue(m map[string]interface{}, val interface{}, coercive bool, keys ...string) error + func SetMapValueExistWithPrefix(m map[string]interface{}, val interface{}, prefix string, keys ...string) error + func SortFilesByTime(files FileInfos) (soredfiles []os.FileInfo) + func TrimInvalidSpace(pattern string) string + func TrimeList(strs []string) (ret []string) + func TruncateStrSize(err string, size int) string + func TuoDecode(value []byte) (values [][]byte, err error) + func TuoEncode(values []sql.RawBytes) (ret []byte) + type AuthTokens struct + RunnerName string + SenderIndex int + SenderTokens conf.MapConf + type Data map[string]interface + func AddTagsToData(tags map[string]interface{}, datas []Data, runnername string) []Data + type Deleteable interface + Delete func() error + type ErrorResponse struct + Error error + func NewErrorResponse(err error) *ErrorResponse + type ErrorStatistic struct + ErrorSlice []equeue.ErrorInfo + Front int + MaxSize int + Rear int + func (e ErrorStatistic) GetMaxSize() int + func (e ErrorStatistic) IsNewVersion() bool + type File struct + Info os.FileInfo + Path string + func GetLogFiles(doneFilePath string) (files []File) + type FileInfos []os.FileInfo + func (p FileInfos) Len() int + func (p FileInfos) Less(i, j int) bool + func (p FileInfos) Sort() + func (p FileInfos) Swap(i, j int) + type GrokLabel struct + Name string + Value string + func GetGrokLabels(labelList []string, nameMap map[string]struct{}) (labels []GrokLabel) + func NewGrokLabel(name, dataValue string) GrokLabel + type HashSet struct + func NewHashSet() *HashSet + func (s *HashSet) Add(ele interface{}) + func (s *HashSet) AddStringArray(ele []string) + func (s *HashSet) Clear() + func (s *HashSet) Elements() []interface{} + func (s *HashSet) IsEmpty() bool + func (s *HashSet) IsIn(ele interface{}) bool + func (s *HashSet) Len() int + func (s *HashSet) Remove(ele interface{}) + type KeyInfo struct + NewKey string + Valid bool + type KeyValue struct + Key string + SortKey string + Value string + type KeyValueSlice []KeyValue + func (slice KeyValueSlice) Len() int + func (slice KeyValueSlice) Less(i, j int) bool + func (slice KeyValueSlice) Swap(i, j int) + type LagInfo struct + Ftlags int64 + Size int64 + SizeUnit string + Total int64 + type Option struct + Advance bool + AdvanceDepend string + AdvanceDependValue interface{} + CheckRegex string + ChooseOnly bool + ChooseOptions []interface{} + Default interface{} + DefaultNoUse bool + Description string + Element string + KeyName string + MultiDefault map[string]interface{} + MultiDefaultDepend string + MutiDefaultSource bool + Placeholder string + Required bool + Secret bool + Style string + ToolTip string + Type string + type Pandora struct + AK string + LogDB string + Name string + Pipeline string + Region string + SK string + type Resetable interface + Reset func() error + type SchemaErr struct + Last time.Time + Number int64 + func (s *SchemaErr) Output(count int64, err error) + type StatsError struct + DatasourceSkipIndex []int + Ft bool + FtNotRetry bool + RemainDatas []Data + SendError *reqerr.SendError + func (se *StatsError) AddErrors() + func (se *StatsError) AddErrorsNum(n int) + func (se *StatsError) AddSuccess() + func (se *StatsError) AddSuccessNum(n int) + func (se *StatsError) Error() string + func (se *StatsError) ErrorIndexIn(idx int) bool + type StatsInfo struct + Errors int64 + FtQueueLag int64 + LastError string + Speed int64 + Success int64 + Trend string