mgr

package

Go to main page

Versions in this module

v1

v1.5.5

May 18, 2020

Changes in this version

+ const DefaultRawDataBatchLen

+ const DefaultRawDataSize

+ const MetaTmp

+ const RawDataMaxBatchLines

+ var RawDataTimeOut = 30 * time.Second

+ type CollectLog struct

+ CollectLogEnable bool

+ CollectLogPath string

+ EnvTag string

+ ReadFrom string

+ type CompatibleErrorResult struct

+ ParseErrors *ErrorStatistic

+ ReadErrors *ErrorStatistic

+ SendErrors map[string]*ErrorStatistic

+ TransformErrors map[string]*ErrorStatistic

+ type ErrorsList struct

+ ParseErrors *equeue.ErrorQueue

+ ReadErrors *equeue.ErrorQueue

+ SendErrors map[string]*equeue.ErrorQueue

+ TransformErrors map[string]*equeue.ErrorQueue

+ func NewErrorsList() *ErrorsList

+ func (list *ErrorsList) Clone() *ErrorsList

+ func (list *ErrorsList) Empty() bool

+ func (list *ErrorsList) HasParseErr() bool

+ func (list *ErrorsList) HasReadErr() bool

+ func (list *ErrorsList) HasSendErr() bool

+ func (list *ErrorsList) HasTransformErr() bool

+ func (list *ErrorsList) List() (dst ErrorsResult)

+ func (list *ErrorsList) Reset()

+ type ErrorsResult struct

+ ParseErrors []equeue.ErrorInfo

+ ReadErrors []equeue.ErrorInfo

+ SendErrors map[string][]equeue.ErrorInfo

+ TransformErrors map[string][]equeue.ErrorInfo

type LogExportRunner

+ func (r *LogExportRunner) Delete() (err error)

+ func (r *LogExportRunner) GetErrors() ErrorsResult

type Manager

+ CollectLogRunner *self.LogRunner

+ func (m *Manager) Error(name string) (rss ErrorsResult, err error)

+ func (m *Manager) Errors() (es map[string]ErrorsResult)

+ func (m *Manager) GetRunnerNames() []string

+ func (m *Manager) GetRunnerPath(name string) (string, bool)

+ func (m *Manager) IsRunning(confPath string) bool

+ func (m *Manager) StartRunnerWithFilename(filename string) (err error)

+ func (m *Manager) StatusAndConfig() (rs map[string]RunnerStatus, rc map[string]RunnerConfig)

+ func (m *Manager) StopRunnerWithFilename(filename string) error

+ func (m *Manager) UpdateReaderRegister()

+ func (m *Manager) UpdateSenderRegister()

type ManagerConfig

+ AuditDir string

type MetricRunner

+ func (mr *MetricRunner) Delete() error

type RestService

+ func (rs *RestService) GetCleanerKeyOptions() echo.HandlerFunc

+ func (rs *RestService) GetError() echo.HandlerFunc

+ func (rs *RestService) GetErrors() echo.HandlerFunc

+ func (rs *RestService) GetParserTooltips() echo.HandlerFunc

+ func (rs *RestService) GetReaderTooltips() echo.HandlerFunc

type RunnerConfig

+ AuditChan chan<- audit.Message

+ IsFromServer bool

+ SendersConfig []conf.MapConf

+ SourceData string

+ type RunnerErrors interface

+ GetErrors func() ErrorsResult

type RunnerInfo

+ ErrorsListCap int

+ InternalKeyPrefix string

+ IsBlock bool

+ LogAudit bool

+ MaxLineLen int64

+ MaxReaderCloseWaitTime int

+ Note string

+ ReadTime bool

+ SendRaw bool

+ SyncEvery int

type RunnerStatus

+ HistorySyncErrors CompatibleErrorResult

+ func (src *RunnerStatus) Clone() RunnerStatus

v1.4.7

Apr 17, 2018

Changes in this version

+ const DefaultMyTag

+ const DefaultTryTimes

+ const KeyMetricType

+ const KeyRouterConfig

+ const KeySendConfig

+ const PREFIX

+ const RunnerRunning

+ const RunnerStopped

+ const SpeedDown

+ const SpeedStable

+ const SpeedUp

+ const StatsShell

+ const StatusBad

+ const StatusLost

+ const StatusOK

+ var DEFAULT_LOGKIT_REST_DIR = "/.logkitconfs"

+ var DEFAULT_PORT = 3000

+ var DIR_NOT_EXIST_SLEEP_TIME = "300"

+ var KeySampleLog = "sampleLog"

+ func GetMySlaveUrl(address, schema string) (uri string, err error)

+ func MergeEnvTags(name string, tags map[string]interface{}) map[string]interface

+ func MergeExtraInfoTags(meta *reader.Meta, tags map[string]interface{}) map[string]interface

+ func NewMetric(tp string) (metric.Collector, error)

+ func ParseData(parserConfig conf.MapConf) (parsedData []Data, err error)

+ func RawData(readerConfig conf.MapConf) (rawData string, err error)

+ func Register(masters []string, myhost, tag string) error

+ func RespError(c echo.Context, respCode int, errCode, errMsg string) error

+ func RespSuccess(c echo.Context, data interface{}) error

+ func SendData(senderConfig map[string]interface{}) error

+ func TransformData(transformerConfig map[string]interface{}) ([]Data, error)

+ type CleanInfo struct

+ type Cluster struct

+ func NewCluster(cc *ClusterConfig) *Cluster

+ func (cc *Cluster) AddSlave(url, tag string)

+ func (cc *Cluster) RunRegisterLoop() error

+ func (cc *Cluster) UpdateSlaveStatus()

+ type ClusterConfig struct

+ Address string

+ Enable bool

+ IsMaster bool

+ MasterUrl []string

+ Tag string

+ type ClusterStatus struct

+ Err string

+ Status map[string]RunnerStatus

+ Tag string

+ type LogExportRunner struct

+ func NewLogExportRunner(rc RunnerConfig, cleanChan chan<- cleaner.CleanSignal, ...) (runner *LogExportRunner, err error)

+ func NewLogExportRunnerWithService(info RunnerInfo, reader reader.Reader, cleaner *cleaner.Cleaner, ...) (runner *LogExportRunner, err error)

+ func (r *LogExportRunner) Cleaner() CleanInfo

+ func (r *LogExportRunner) LagStats() (rl *LagInfo, err error)

+ func (r *LogExportRunner) Name() string

+ func (r *LogExportRunner) Reset() (err error)

+ func (r *LogExportRunner) Run()

+ func (r *LogExportRunner) Status() RunnerStatus

+ func (r *LogExportRunner) StatusBackup()

+ func (r *LogExportRunner) StatusRestore()

+ func (r *LogExportRunner) Stop()

+ func (r *LogExportRunner) TokenRefresh(tokens AuthTokens) error

+ type Manager struct

+ DefaultDir string

+ SystemInfo string

+ Version string

+ func NewCustomManager(conf ManagerConfig, rr *reader.ReaderRegistry, pr *parser.ParserRegistry, ...) (*Manager, error)

+ func NewManager(conf ManagerConfig) (*Manager, error)

+ func (m *Manager) Add(confPath string)

+ func (m *Manager) AddRunner(name string, conf RunnerConfig) (err error)

+ func (m *Manager) Configs() (rss map[string]RunnerConfig)

+ func (m *Manager) DeleteRunner(name string) (err error)

+ func (m *Manager) ForkRunner(confPath string, nconf RunnerConfig, errReturn bool) error

+ func (m *Manager) Remove(confPath string) (err error)

+ func (m *Manager) RemoveWithConfig(confPath string, isDelete bool) (err error)

+ func (m *Manager) ResetRunner(name string) (err error)

+ func (m *Manager) RestoreWebDir()

+ func (m *Manager) StartRunner(name string) (err error)

+ func (m *Manager) Status() (rss map[string]RunnerStatus)

+ func (m *Manager) Stop() error

+ func (m *Manager) StopRunner(name string) (err error)

+ func (m *Manager) UpdateRunner(name string, conf RunnerConfig) (err error)

+ func (m *Manager) UpdateToken(tokens []AuthTokens) (err error)

+ func (m *Manager) Watch(confsPath []string) (err error)

+ type ManagerConfig struct

+ BindHost string

+ Cluster ClusterConfig

+ DisableWeb bool

+ Idc string

+ RestDir string

+ ServerBackup bool

+ Zone string

+ type MetricConfig struct

+ Attributes map[string]bool

+ Config map[string]interface{}

+ MetricType string

+ type MetricRunner struct

+ RunnerName string

+ func NewMetricRunner(rc RunnerConfig, sr *sender.SenderRegistry) (runner *MetricRunner, err error)

+ func (_ *MetricRunner) Cleaner() CleanInfo

+ func (mr *MetricRunner) Name() string

+ func (mr *MetricRunner) Reset() (err error)

+ func (mr *MetricRunner) Status() RunnerStatus

+ func (mr *MetricRunner) StatusBackup()

+ func (mr *MetricRunner) StatusRestore()

+ func (mr *MetricRunner) Stop()

+ func (mr *MetricRunner) TokenRefresh(tokens AuthTokens) error

+ func (r *MetricRunner) Run()

+ type PostParseRet struct

+ SamplePoints []Data

+ type RegisterReq struct

+ Tag string

+ Url string

+ type Resetable interface

+ Reset func() error

+ type RestService struct

+ func NewRestService(mgr *Manager, router *echo.Echo) *RestService

+ func (rs *RestService) ClusterStatus() echo.HandlerFunc

+ func (rs *RestService) DeleteClusterConfig() echo.HandlerFunc

+ func (rs *RestService) DeleteConfig() echo.HandlerFunc

+ func (rs *RestService) DeleteSlaves() echo.HandlerFunc

+ func (rs *RestService) GetClusterConfig() echo.HandlerFunc

+ func (rs *RestService) GetClusterConfigs() echo.HandlerFunc

+ func (rs *RestService) GetClusterRunners() echo.HandlerFunc

+ func (rs *RestService) GetConfig() echo.HandlerFunc

+ func (rs *RestService) GetConfigs() echo.HandlerFunc

+ func (rs *RestService) GetErrorCodeHumanize() echo.HandlerFunc

+ func (rs *RestService) GetMetricKeys() echo.HandlerFunc

+ func (rs *RestService) GetMetricOptions() echo.HandlerFunc

+ func (rs *RestService) GetMetricUsages() echo.HandlerFunc

+ func (rs *RestService) GetParserKeyOptions() echo.HandlerFunc

+ func (rs *RestService) GetParserSampleLogs() echo.HandlerFunc

+ func (rs *RestService) GetParserUsages() echo.HandlerFunc

+ func (rs *RestService) GetReaderKeyOptions() echo.HandlerFunc

+ func (rs *RestService) GetReaderUsages() echo.HandlerFunc

+ func (rs *RestService) GetRunners() echo.HandlerFunc

+ func (rs *RestService) GetSenderKeyOptions() echo.HandlerFunc

+ func (rs *RestService) GetSenderRouterOption() echo.HandlerFunc

+ func (rs *RestService) GetSenderRouterUsage() echo.HandlerFunc

+ func (rs *RestService) GetSenderUsages() echo.HandlerFunc

+ func (rs *RestService) GetTransformerOptions() echo.HandlerFunc

+ func (rs *RestService) GetTransformerSampleConfigs() echo.HandlerFunc

+ func (rs *RestService) GetTransformerUsages() echo.HandlerFunc

+ func (rs *RestService) GetVersion() echo.HandlerFunc

+ func (rs *RestService) IsMaster() echo.HandlerFunc

+ func (rs *RestService) Ping() echo.HandlerFunc

+ func (rs *RestService) PostClusterConfig() echo.HandlerFunc

+ func (rs *RestService) PostClusterConfigReset() echo.HandlerFunc

+ func (rs *RestService) PostClusterConfigStart() echo.HandlerFunc

+ func (rs *RestService) PostClusterConfigStop() echo.HandlerFunc

+ func (rs *RestService) PostConfig() echo.HandlerFunc

+ func (rs *RestService) PostConfigReset() echo.HandlerFunc

+ func (rs *RestService) PostConfigStart() echo.HandlerFunc

+ func (rs *RestService) PostConfigStop() echo.HandlerFunc

+ func (rs *RestService) PostParse() echo.HandlerFunc

+ func (rs *RestService) PostParserCheck() echo.HandlerFunc

+ func (rs *RestService) PostRead() echo.HandlerFunc

+ func (rs *RestService) PostReaderCheck() echo.HandlerFunc

+ func (rs *RestService) PostRegister() echo.HandlerFunc

+ func (rs *RestService) PostSend() echo.HandlerFunc

+ func (rs *RestService) PostSenderCheck() echo.HandlerFunc

+ func (rs *RestService) PostSlaveTag() echo.HandlerFunc

+ func (rs *RestService) PostTag() echo.HandlerFunc

+ func (rs *RestService) PostTransform() echo.HandlerFunc

+ func (rs *RestService) PostTransformerCheck() echo.HandlerFunc

+ func (rs *RestService) PutClusterConfig() echo.HandlerFunc

+ func (rs *RestService) PutConfig() echo.HandlerFunc

+ func (rs *RestService) Register() error

+ func (rs *RestService) Slaves() echo.HandlerFunc

+ func (rs *RestService) Status() echo.HandlerFunc

+ func (rs *RestService) Stop()

+ type Runner interface

+ Cleaner func() CleanInfo

+ Name func() string

+ Run func()

+ Status func() RunnerStatus

+ Stop func()

+ func NewCustomRunner(rc RunnerConfig, cleanChan chan<- cleaner.CleanSignal, ...) (runner Runner, err error)

+ func NewRunner(rc RunnerConfig, cleanChan chan<- cleaner.CleanSignal) (runner Runner, err error)

+ func NewRunnerWithService(info RunnerInfo, reader reader.Reader, cleaner *cleaner.Cleaner, ...) (runner Runner, err error)

+ type RunnerConfig struct

+ CleanerConfig conf.MapConf

+ IsInWebFolder bool

+ IsStopped bool

+ MetricConfig []MetricConfig

+ ParserConf conf.MapConf

+ ReaderConfig conf.MapConf

+ Router router.RouterConfig

+ SenderConfig []conf.MapConf

+ Transforms []map[string]interface{}

+ func Compatible(rc RunnerConfig) RunnerConfig

+ func TrimSecretInfo(conf RunnerConfig) RunnerConfig

+ type RunnerInfo struct

+ CollectInterval int

+ CreateTime string

+ EnvTag string

+ ExtraInfo bool

+ MaxBatchInterval int

+ MaxBatchLen int

+ MaxBatchSize int

+ MaxBatchTryTimes int

+ RunnerName string

+ type RunnerStatus struct

+ Elaspedtime float64

+ Error string

+ Lag LagInfo

+ Logpath string

+ Name string

+ ParserStats StatsInfo

+ ReadDataCount int64

+ ReadDataSize int64

+ ReadSpeed float64

+ ReadSpeedKB float64

+ ReadSpeedTrend string

+ ReadSpeedTrendKb string

+ ReaderStats StatsInfo

+ RunningStatus string

+ SenderStats map[string]StatsInfo

+ Tag string

+ TransformStats map[string]StatsInfo

+ Url string

+ type Service struct

+ Prefix string

+ type Slave struct

+ LastTouch time.Time

+ Status string

+ Tag string

+ Url string

+ type SlaveConfig struct

+ Configs map[string]RunnerConfig

+ Err string

+ Tag string

+ type StatusPersistable interface

+ StatusBackup func()

+ StatusRestore func()

+ type TagReq struct

+ Tag string

+ type TokenRefreshable interface

+ TokenRefresh func(AuthTokens) error

+ type Version struct

+ Version string

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