mgr

package

Go to main page

Versions in this module

v1

v1.3.1

Sep 13, 2017

Changes in this version

+ const SpeedDown

+ const SpeedStable

+ const SpeedUp

type LogExportRunner

+ func (r *LogExportRunner) Reset() error

type Manager

+ Version string

+ type Resetable interface

+ Reset func() error

type RestService

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

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

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

type RunnerStatus

+ ReadSpeed float64

+ ReadSpeedKB float64

+ ReadSpeedTrend string

+ ReadSpeedTrendKb string

+ ReaderStats utils.StatsInfo

+ type Version struct

+ Version string

v1.3.0

Sep 5, 2017

Changes in this version

type RunnerStatus

+ Elaspedtime float64

+ ReadDataCount int64

+ ReadDataSize int64

+ TransformStats map[string]utils.StatsInfo

v1.2.4

Aug 29, 2017

Changes in this version

type RestService

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

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

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

type RunnerConfig

+ Transforms []map[string]interface{}

v1.2.3

Aug 16, 2017

Changes in this version

+ var DEFAULT_LOGKIT_REST_DIR = "/.logkitconfs"

+ var KeySampleLog = "sampleLog"

type Manager

+ DefaultDir string

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

+ func (m *Manager) RestoreWebDir()

type ManagerConfig

+ RestDir string

+ type PostParseRet struct

+ SamplePoints []sender.Data

type RestService

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

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

+ func (rs *RestService) GetConfigs() 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) GetSenderKeyOptions() echo.HandlerFunc

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

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

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

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

type RunnerConfig

+ IsInWebFolder bool

+ type Service struct

+ Prefix string

v1.2.2

Aug 1, 2017

v1.2.1

Jul 18, 2017

v1.1.0

Jun 27, 2017

Changes in this version

+ const KeyMetricType

+ const PREFIX

+ const StatsShell

+ var DEFAULT_PORT = 4000

+ var DIR_NOT_EXIST_SLEEP_TIME = 300

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

+ type CleanInfo struct

+ 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 RunnerLag, err error)

+ func (r *LogExportRunner) Name() string

+ func (r *LogExportRunner) Run()

+ func (r *LogExportRunner) Status() RunnerStatus

+ func (r *LogExportRunner) Stop()

+ type Manager struct

+ func NewCustomManager(conf ManagerConfig, pr *parser.ParserRegistry, sr *sender.SenderRegistry) (*Manager, error)

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

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

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

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

+ func (m *Manager) Stop() error

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

+ type ManagerConfig struct

+ BindHost string

+ Idc string

+ Zone 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) Status() RunnerStatus

+ func (mr *MetricRunner) Stop()

+ func (r *MetricRunner) Run()

+ type RestService struct

+ func NewRestService(mgr *Manager) *RestService

+ func (rs *RestService) GetStatus(rw http.ResponseWriter, req *http.Request)

+ 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

+ Metric []conf.MapConf

+ ParserConf conf.MapConf

+ ReaderConfig conf.MapConf

+ SenderConfig []conf.MapConf

+ func Compatible(rc RunnerConfig) RunnerConfig

+ type RunnerInfo struct

+ CollectInterval string

+ MaxBatchInteval int

+ MaxBatchLen int

+ MaxBatchSize int

+ MaxBatchTryTimes int

+ RunnerName string

+ type RunnerLag struct

+ Files int64

+ Ftlags int64

+ Size int64

+ type RunnerStatus struct

+ Error error

+ Lag RunnerLag

+ Logpath string

+ Name string

+ ParserStats utils.StatsInfo

+ SenderStats map[string]utils.StatsInfo

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