expvastic

Mar 31, 2018

Changes in this version

+ type JobError struct

+ Err error

+ ID token.ID

+ Name string

+ func (e JobError) Error() string

+ type PingError map[string]error

+ func (e PingError) Error() string

Mar 27, 2018

Changes in this version

+ func WithCtx(ctx context.Context) func(*Engine) error

+ func WithLogger(log internal.FieldLogger) func(*Engine) error

+ func WithReaders(reds ...reader.DataReader) func(*Engine) error

+ func WithRecorder(rec recorder.DataRecorder) func(*Engine) error

+ type ErrJob struct

+ Err error

+ ID token.ID

+ Name string

+ func (e ErrJob) Error() string

Sep 24, 2017

Changes in this version

+ var ErrNoCtx = fmt.Errorf("no ctx provided")

+ var ErrNoLogger = fmt.Errorf("no logger provided")

+ func SetCtx(ctx context.Context) func(*Engine) error

+ func SetLogger(log internal.FieldLogger) func(*Engine) error

+ func SetReaders(reds ...reader.DataReader) func(*Engine) error

+ func SetRecorder(rec recorder.DataRecorder) func(*Engine) error

Sep 22, 2017

Changes in this version

type Engine

+ func (e *Engine) String() string

Sep 21, 2017

Changes in this version

+ var ErrNoReader = fmt.Errorf("no reader provided")

type Engine

+ func New(ctx context.Context, log logrus.FieldLogger, rec recorder.DataRecorder, ...) (*Engine, error)

+ func WithConfig(ctx context.Context, log logrus.FieldLogger, recorderConf config.RecorderConf, ...) (*Engine, error)

+ type ErrPing map[string]error

+ func (ErrPing) Ping()

+ func (e ErrPing) Error() string

Dec 30, 2016

Changes in this version

+ var ErrDuplicateRecorderName = fmt.Errorf("recorder name cannot be reused")

Dec 27, 2016

Changes in this version

+ var ErrEmptyRedName = fmt.Errorf("reader name empty")

Dec 21, 2016

Changes in this version

+ var ErrDupRecName = fmt.Errorf("recorder name empty")

+ var ErrEmptyRecName = fmt.Errorf("recorder name empty")

Dec 21, 2016

Changes in this version

type Engine

+ func NewWithConfig(ctx context.Context, log logrus.FieldLogger, reader config.ReaderConf, ...) (*Engine, error)

+ func NewWithReadRecorder(ctx context.Context, log logrus.FieldLogger, red reader.TargetReader, ...) (*Engine, error)

Dec 20, 2016

Changes in this version

+ func StartEngines(ctx context.Context, log logrus.FieldLogger, confMap *config.ConfMap) (chan struct{}, error)

type Engine

+ func (c *Engine) Name() string

Dec 18, 2016

Changes in this version

type Container

+ func NewContainer(list []DataType) *Container

+ func (c *Container) String(timestamp time.Time) string

type ContextReader

+ Get func(ctx context.Context) (*http.Response, error)

type CtxReader

+ func (c *CtxReader) Get(ctx context.Context) (*http.Response, error)

type DataContainer

+ String func(timestamp time.Time) string

type DataRecorder

+ Start func() chan struct{}

type DataType

+ func DataTypeFromJason(key string, value jason.Value) (DataType, error)

type TargetReader

+ Start func() chan struct{}

Dec 17, 2016

Changes in this version

+ type Container struct

+ Err error

+ func (c *Container) Add(d ...DataType)

+ func (c *Container) Error() error

+ func (c *Container) Len() int

+ func (c *Container) List() []DataType

+ type DataContainer interface

+ Error func() error

+ Len func() int

+ List func() []DataType

+ type DataRecorder interface

+ PayloadChan func() chan *RecordJob

type ElasticSearch

+ func (e *ElasticSearch) PayloadChan() chan *RecordJob

+ func (e *ElasticSearch) Start() chan struct{}

+ type Engine struct

+ func NewEngine(ctx context.Context, c Conf) *Engine

+ func (c *Engine) Start()

+ func (c *Engine) Stop() error

+ type ReadJob struct

+ Ctx context.Context

+ Err chan error

+ type ReadJobResult struct

+ Err error

+ Res io.ReadCloser

+ Time time.Time

+ type RecordJob struct

+ Ctx context.Context

+ Err chan error

+ IndexName string

+ Payload DataContainer

+ Time time.Time

+ TypeName string

+ type TargetReader interface

+ JobChan func() chan context.Context

+ ResultChan func() chan ReadJobResult

Dec 17, 2016

Changes in this version

+ var ErrUnidentifiedJason = errors.New("unidentified jason value")

Dec 17, 2016

Changes in this version

+ const BYTE

+ const KILOBYTE

+ const MEGABYTE

+ type ByteType struct

+ Key string

+ Value float64

+ func (b ByteType) String() string

+ type Client struct

+ func NewClient(ctx context.Context, c Conf) *Client

+ func (c *Client) Start()

+ func (c *Client) Stop() error

+ type Conf struct

+ IndexName string

+ Interval time.Duration

+ Logger logrus.FieldLogger

+ Recorder Recorder

+ Target string

+ TargetReader targetReader

+ Timeout time.Duration

+ TypeName string

+ type ContextReader interface

+ ContextRead func(ctx context.Context) (*http.Response, error)

+ type CtxReader struct

+ func NewCtxReader(url string) *CtxReader

+ func (c *CtxReader) ContextRead(ctx context.Context) (*http.Response, error)

+ type DataType interface

+ type ElasticSearch struct

+ func NewElasticSearch(bgCtx context.Context, log logrus.FieldLogger, esURL, indexName string) (*ElasticSearch, error)

+ func (e *ElasticSearch) Record(ctx context.Context, typeName string, timestamp time.Time, kv []DataType) error

+ type ExpvarReader struct

+ func NewExpvarReader(log logrus.FieldLogger, ctxReader ContextReader) (*ExpvarReader, error)

+ func (e *ExpvarReader) JobChan() chan context.Context

+ func (e *ExpvarReader) ResultChan() chan JobResult

+ func (e *ExpvarReader) Start() chan struct{}

+ type FloatListType struct

+ Key string

+ Value []float64

+ func (fl FloatListType) String() string

+ type FloatType struct

+ Key string

+ Value float64

+ func (f FloatType) String() string

+ type GCListType struct

+ Key string

+ Value []uint64

+ func (flt GCListType) String() string

+ type Job struct

+ Err chan error

+ Payload context.Context

+ type JobResult struct

+ Err error

+ Res io.ReadCloser

+ Time time.Time

+ type Recorder interface

+ Record func(ctx context.Context, typeName string, timestamp time.Time, kv []DataType) error

+ type StringType struct

+ Key string

+ Value string

+ func (s StringType) String() string