models

package

Go to main page

Versions in this module

v1

v1.5.5

May 18, 2020

Changes in this version

+ const InternalKeyPrefix

+ const KeyRunnerIsBlock

+ const KeyRunnerMaxLineLen

+ const Lst

+ func CheckLogPath(logpath string) (dir string, path string)

+ func SetExtractMapValue(m map[string]interface{}, val interface{}, coercive bool, newKey string, ...) error

v1.5.4

Aug 20, 2019

Changes in this version

+ const CheckPattern

+ const CheckPatternKey

+ const DATE

+ const DROP

+ const DefaultEncodingWay

+ const DefaultInternalPrefix

+ const DefaultSelfRunnerName

+ const DefaultSendIntervalSeconds

+ const FLOAT

+ const KeyType

+ const LONG

+ const Local

+ const ProcessAt

+ const STRING

+ const Server

+ const TextPlain

+ var Encoding = []interface

+ var ModifierRe = regexp.MustCompile(`%{\w+:(\w+):(long|string|date|float|drop)}`)

+ var PatternOnlyRe = regexp.MustCompile(`%{(\w+)}`)

+ var SelfLogAutoCreateDescription = "由logkit收集自身日志创建"

+ func CheckPath(path string) (string, error)

+ func GetCmd(keyStr string) []string

+ func GetTime(timestamp string) (time.Time, error)

+ func IsFileModified(path string, interval time.Duration, compare time.Time) 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 MergeEnvTags(name string, tags map[string]interface{}) map[string]interface

+ func ParseTimeZoneOffset(zoneoffset string) (ret int)

+ func TrimInvalidSpace(pattern string) string

type Data

+ func AddTagsToData(tags map[string]interface{}, datas []Data, runnername string) []Data

+ type Deleteable interface

+ Delete func() error

+ type ErrorStatistic struct

+ ErrorSlice []equeue.ErrorInfo

+ Front int

+ MaxSize int

+ Rear int

+ func (e ErrorStatistic) GetMaxSize() int

+ func (e ErrorStatistic) IsNewVersion() bool

+ type GrokLabel struct

+ Name string

+ Value string

+ func GetGrokLabels(labelList []string, nameMap map[string]struct{}) (labels []GrokLabel)

+ func NewGrokLabel(name, dataValue string) GrokLabel

type Option

+ MultiDefault map[string]interface{}

+ MultiDefaultDepend string

+ MutiDefaultSource bool

+ type Pandora struct

+ AK string

+ LogDB string

+ Name string

+ Pipeline string

+ Region string

+ SK string

type StatsError

+ SendError *reqerr.SendError

v1.5.3

Sep 4, 2018

Changes in this version

+ const B

+ const DefaultTruncateMaxSize

+ const GB

+ const KB

+ const MB

+ const TypeIP

+ var ErrQueueClosed = errors.New("queue is closed")

+ var LogkitAutoCreateDescription = "由logkit日志收集自动创建"

+ var MaxProcs = 1

+ var MetricAutoCreateDescription = "由logkit监控收集自动创建"

+ var NumCPU = runtime.NumCPU()

+ func DecompressTarGzip(srcPath, dstPath, targetFile string) (targetDir string, _ error)

+ func TruncateStrSize(err string, size int) string

type Option

+ AdvanceDependValue interface{}

v1.5.2

Jul 30, 2018

Changes in this version

+ const DefaultErrorsListCap

+ const ErrRunnerErrorGet

+ const InputNumber

+ const PipeLineError

+ const TestPlain

+ var ErrNotExist = errors.New("runner does not exist")

+ var ErrNotSupport = errors.New("runner does not support")

+ func CheckErr(err error) error

+ func CheckPandoraKey(key string) bool

+ func DeepConvertKey(data map[string]interface{}) map[string]interface

+ func DeepConvertKeyWithCache(data map[string]interface{}, cache map[string]KeyInfo) map[string]interface

+ func IsNotExist(err error) bool

+ func IsNotSupport(err error) bool

+ func SetMapValueExistWithPrefix(m map[string]interface{}, val interface{}, prefix string, keys ...string) error

+ type ErrorInfo struct

+ Count int64

+ Error string

+ Timestamp int64

+ type ErrorQueue struct

+ ErrorSlice []ErrorInfo

+ Front int

+ MaxSize int

+ Rear int

+ func NewErrorQueue(maxSize int) *ErrorQueue

+ func (queue *ErrorQueue) Append(errors []ErrorInfo)

+ func (queue *ErrorQueue) Copy(e ErrorInfo)

+ func (queue *ErrorQueue) CopyQueue(src *ErrorQueue)

+ func (queue *ErrorQueue) EqualLast(e ErrorInfo) bool

+ func (queue *ErrorQueue) Get() ErrorInfo

+ func (queue *ErrorQueue) GetErrorSlice(front, rear int) []ErrorInfo

+ func (queue *ErrorQueue) GetMaxSize() int

+ func (queue *ErrorQueue) IsEmpty() bool

+ func (queue *ErrorQueue) Put(e ErrorInfo)

+ func (queue *ErrorQueue) Set(index int, e ErrorInfo)

+ func (queue *ErrorQueue) Size() int

+ func (queue *ErrorQueue) Sort() []ErrorInfo

+ type KeyInfo struct

+ NewKey string

+ Valid bool

type KeyValue

+ SortKey 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 Resetable interface

+ Reset func() error

v1.5.1

Jul 13, 2018

Changes in this version

+ const DefaultMaxBatchSize

+ const KeyPandoraSeparateId

+ func PickMapValue(m map[string]interface{}, pick map[string]interface{}, keys ...string)

type StatsError

+ RemainDatas []Data

+ func (se *StatsError) AddErrorsNum(n int)

+ func (se *StatsError) AddSuccessNum(n int)

v1.5.0

Jun 11, 2018

Changes in this version

+ func GetMapList(data string) map[string]string

+ func ModTimeLater(f1, f2 os.FileInfo) bool

+ func SetMapValueWithPrefix(m map[string]interface{}, val interface{}, prefix string, forceAdd bool, ...) error

+ 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 LagInfo

+ Total int64

v1.4.9

May 24, 2018

v1.4.8

May 23, 2018

Changes in this version

+ const Checkbox

+ const KeyPandoraLogDBAnalyzer

+ const Radio

+ const Text

+ func ConvertDate(layoutBefore, layoutAfter string, offset int, v interface{}) (interface{}, error)

+ func FormatWithUserOption(layoutAfter string, offset int, t time.Time) interface

+ func ReadFileContent(path string) (content []string, err error)

type Option

+ Element string

type StatsError

+ DatasourceSkipIndex []int

+ FtNotRetry bool

type StatsInfo

+ FtQueueLag int64

v1.4.7

Apr 17, 2018

Changes in this version

+ const KeyInsecureServer

+ const KeyNumberUseFloat

+ func Bool2String(i bool) string

+ func DecodeString(target string) (result string, err error)

+ func EncodeString(target string) (result string)

+ func PandoraKey(key string) string

type Option

+ ToolTip string

+ ToolTipActive bool

v1.4.6

Mar 28, 2018

Changes in this version

+ const ExtraInfo

+ const InnerUserAgent

+ const KeyFaultTolerant

+ const KeyFlowRateLimit

+ const KeyForceDataConvert

+ const KeyForceMicrosecond

+ const KeyIgnoreInvalidField

+ const KeyIsMetrics

+ const KeyLogkitSendTime

+ const KeyMetricTime

+ const KeyName

+ const KeyPandoraAk

+ const KeyPandoraAutoConvertDate

+ const KeyPandoraAutoCreate

+ const KeyPandoraEmail

+ const KeyPandoraEnableKodo

+ const KeyPandoraEnableLogDB

+ const KeyPandoraEnableTSDB

+ const KeyPandoraExtraInfo

+ const KeyPandoraGzip

+ const KeyPandoraHost

+ const KeyPandoraKodoBucketName

+ const KeyPandoraKodoCompressPrefix

+ const KeyPandoraKodoFilePrefix

+ const KeyPandoraLogDBHost

+ const KeyPandoraLogDBName

+ const KeyPandoraRegion

+ const KeyPandoraRepoName

+ const KeyPandoraSchema

+ const KeyPandoraSchemaFree

+ const KeyPandoraSchemaUpdateInterval

+ const KeyPandoraSk

+ const KeyPandoraTSDBHost

+ const KeyPandoraTSDBName

+ const KeyPandoraTSDBSeriesName

+ const KeyPandoraTSDBSeriesTags

+ const KeyPandoraTSDBTimeStamp

+ const KeyPandoraUUID

+ const KeyPandoraUnescape

+ const KeyPandoraWithIP

+ const KeyPandoraWorkflowName

+ const KeyRequestRateLimit

+ const KeyRunnerName

+ const KeySenderType

+ const PandoraUUID

+ const TimestampPrecision

+ const TypeDiscard

+ const TypeElastic

+ const TypeFile

+ const TypeHttp

+ const TypeInfluxdb

+ const TypeKafka

+ const TypeMock

+ const TypeMongodbAccumulate

+ const TypePandora

+ const UnderfinedRunnerName

+ func AddHttpProtocal(url string) string

+ func CheckFileMode(path string, fileMode os.FileMode) error

+ func CreateDirIfNotExist(dir string) (err error)

+ func DecompressGzip(packPath, dstDir string) (packDir string, err error)

+ func DecompressZip(packFilePath, dstDir string) (packDir string, err error)

+ func DeleteMapValue(m map[string]interface{}, keys ...string) (interface{}, bool)

+ func ExtractField(slice []string) ([]string, error)

+ func GetEnv(env string) string

+ func GetKeys(keyStr string) []string

+ func GetMapValue(m map[string]interface{}, keys ...string) (interface{}, error)

+ func GetRealPath(path string) (newPath string, fi os.FileInfo, err error)

+ func Hash(s string) string

+ func IsJsonString(s string) bool

+ func LogDirAndPattern(logpath string) (dir, pattern string, err error)

+ func ReadDirByTime(dir string) (files []os.FileInfo, err error)

+ func RemoveHttpProtocal(url string) (hostport, schema string)

+ func SetMapValue(m map[string]interface{}, val interface{}, coercive bool, keys ...string) error

+ func SortFilesByTime(files []os.FileInfo) (soredfiles []os.FileInfo)

+ func TrimeList(strs []string) (ret []string)

+ func TuoDecode(value []byte) (values [][]byte, err error)

+ func TuoEncode(values []sql.RawBytes) (ret []byte)

+ type ErrorResponse struct

+ Error error

+ func NewErrorResponse(err error) *ErrorResponse

+ type File struct

+ Info os.FileInfo

+ Path string

+ func GetLogFiles(doneFilePath string) (files []File)

+ 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 Int64Slice []int64

+ func (p Int64Slice) Len() int

+ func (p Int64Slice) Less(i, j int) bool

+ func (p Int64Slice) Sort()

+ func (p Int64Slice) Swap(i, j int)

+ type SchemaErr struct

+ Last time.Time

+ Number int64

+ func (s *SchemaErr) Output(count int64, err error)

+ type StatsError struct

+ ErrorDetail error

+ ErrorIndex []int

+ Ft bool

+ func (se *StatsError) AddErrors()

+ func (se *StatsError) AddSuccess()

+ func (se *StatsError) Error() string

+ func (se *StatsError) ErrorIndexIn(idx int) bool

+ type StatsInfo struct

+ Errors int64

+ Ftlag int64

+ LastError string

+ Speed float64

+ Success int64

+ Trend string

v1.4.5

Mar 14, 2018

Changes in this version

type Option

+ Placeholder string

+ Required bool

+ Style string

v1.4.4

Mar 5, 2018

Changes in this version

+ const DefaultDirPerm

+ const DefaultFilePerm

+ const KodoTokensPrefix

+ const LogDBTokensPrefix

+ const SchemaFreeTokensPrefix

+ const TsDBTokensPrefix

+ type AuthTokens struct

+ RunnerName string

+ SenderIndex int

+ SenderTokens conf.MapConf

+ type LagInfo struct

+ Ftlags int64

+ Size int64

+ SizeUnit string

type Option

+ Advance bool

+ AdvanceDepend string

v1.4.3

Feb 6, 2018

Changes in this version

+ const ApplicationGzip

+ const ApplicationJson

+ const ContentEncodingHeader

+ const ContentTypeHeader

+ 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 ErrRunnerReset

+ const ErrRunnerStart

+ const ErrRunnerStop

+ const ErrRunnerUpdate

+ const ErrSendSend

+ const ErrTransformTransform

+ const GlobalKeyName

+ const KeyCore

+ const KeyHostName

+ const KeyLocalIp

+ const KeyOsInfo

+ const KeyPandoraStash

+ var ErrorCodeHumanize = map[string]string

+ type Data map[string]interface

+ type KeyValue struct

+ Key string

+ Value string

+ type Option struct

+ CheckRegex string

+ ChooseOnly bool

+ ChooseOptions []interface{}

+ Default interface{}

+ DefaultNoUse bool

+ Description string

+ KeyName string

+ Secret bool

+ Type string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL