expvar

Apr 2, 2018

Changes in this version

type Config

+ func (c *Config) Reader() (reader.DataReader, error)

Mar 31, 2018

Changes in this version

type Config

+ ConfInterval time.Duration

+ ConfTimeout time.Duration

+ EXPName string

+ func (c *Config) Mapper() datatype.Mapper

Mar 28, 2018

Changes in this version

+ type Conf func(*Config) error

+ func WithBackoff(backoff int) Conf

+ func WithEndpoint(endpoint string) Conf

+ func WithInterval(interval time.Duration) Conf

+ func WithLogger(log internal.FieldLogger) Conf

+ func WithMapFile(mapFile string) Conf

+ func WithName(name string) Conf

+ func WithTimeout(timeout time.Duration) Conf

+ func WithTypeName(typeName string) Conf

+ func WithViper(v unmarshaller, name, key string) Conf

Sep 24, 2017

Changes in this version

type Reader

+ func (r *Reader) Backoff() int

+ func (r *Reader) Endpoint() string

+ func (r *Reader) Logger() internal.FieldLogger

+ func (r *Reader) SetBackoff(backoff int)

+ func (r *Reader) SetEndpoint(endpoint string)

+ func (r *Reader) SetInterval(interval time.Duration)

+ func (r *Reader) SetLogger(log internal.FieldLogger)

+ func (r *Reader) SetMapper(mapper datatype.Mapper)

+ func (r *Reader) SetName(name string)

+ func (r *Reader) SetTimeout(timeout time.Duration)

+ func (r *Reader) SetTypeName(typeName string)

Sep 21, 2017

Changes in this version

type Reader

+ func New(log logrus.FieldLogger, endpoint string, mapper datatype.Mapper, name string, ...) (*Reader, error)

+ func (r *Reader) Ping() error

Jan 1, 2017

Changes in this version

type Reader

+ func (r *Reader) Read(job context.Context) (*reader.ReadJobResult, error)

Dec 27, 2016

Changes in this version

type Config

+ EXPBackoff int

+ EXPEndpoint string

+ EXPInterval string

+ EXPRoutePath string

+ EXPTimeout string

+ EXPTypeName string

Dec 24, 2016

Changes in this version

type Config

+ MapFile string

type Reader

+ func (r *Reader) Mapper() datatype.Mapper

Dec 22, 2016

Changes in this version

type Config

+ TypeName_ string

+ func (c *Config) TypeName() string

type Reader

+ func (r *Reader) TypeName() string

Dec 21, 2016

Changes in this version

type Reader

+ func (r *Reader) Interval() time.Duration

+ func (r *Reader) Timeout() time.Duration

Dec 20, 2016

Changes in this version

+ type Config struct

+ Backoff_ int

+ Endpoint_ string

+ Interval_ string

+ LogLevel_ string

+ RoutePath_ string

+ Timeout_ string

+ func FromViper(v *viper.Viper, name, key string) (*Config, error)

+ func NewConfig(name string, log logrus.FieldLogger, endpoint, routepath string, ...) (*Config, error)

+ func (c *Config) Backoff() int

+ func (c *Config) Endpoint() string

+ func (c *Config) Interval() time.Duration

+ func (c *Config) Logger() logrus.FieldLogger

+ func (c *Config) Name() string

+ func (c *Config) NewInstance(ctx context.Context) (reader.TargetReader, error)

+ func (c *Config) RoutePath() string

+ func (c *Config) Timeout() time.Duration

+ type Reader struct

+ func NewExpvarReader(logger logrus.FieldLogger, ctxReader reader.ContextReader, name string) (*Reader, error)

+ func (r *Reader) JobChan() chan context.Context

+ func (r *Reader) Name() string

+ func (r *Reader) ResultChan() chan *reader.ReadJobResult

+ func (r *Reader) Start() chan struct{}