reader

Apr 5, 2018

Changes in this version

+ var ErrInvalidJSON = fmt.Errorf("payload is invalid JSON object")

+ var ErrNillLogger = fmt.Errorf("nil logger")

Apr 2, 2018

Changes in this version

type DataReader

+ Backoff func() int

+ Endpoint func() string

Mar 31, 2018

Changes in this version

+ type EndpointNotAvailableError struct

+ Endpoint string

+ Err error

+ func (e EndpointNotAvailableError) Error() string

+ type InvalidEndpointError string

+ func (e InvalidEndpointError) Error() string

+ type LowBackoffValueError int64

+ func (e LowBackoffValueError) Error() string

+ type LowIntervalError time.Duration

+ func (e LowIntervalError) Error() string

+ type LowTimeoutError time.Duration

+ func (e LowTimeoutError) Error() string

Mar 27, 2018

Changes in this version

+ func WithBackoff(backoff int) func(Constructor) error

+ func WithEndpoint(endpoint string) func(Constructor) error

+ func WithInterval(interval time.Duration) func(Constructor) error

+ func WithLogger(log internal.FieldLogger) func(Constructor) error

+ func WithMapper(mapper datatype.Mapper) func(Constructor) error

+ func WithName(name string) func(Constructor) error

+ func WithTimeout(timeout time.Duration) func(Constructor) error

+ func WithTypeName(typeName string) func(Constructor) error

Sep 24, 2017

Changes in this version

+ func SetBackoff(backoff int) func(Constructor) error

+ func SetEndpoint(endpoint string) func(Constructor) error

+ func SetInterval(interval time.Duration) func(Constructor) error

+ func SetLogger(log internal.FieldLogger) func(Constructor) error

+ func SetMapper(mapper datatype.Mapper) func(Constructor) error

+ func SetName(name string) func(Constructor) error

+ func SetTimeout(timeout time.Duration) func(Constructor) error

+ func SetTypeName(typeName string) func(Constructor) error

+ type Constructor interface

+ SetBackoff func(backoff int)

+ SetEndpoint func(endpoint string)

+ SetInterval func(interval time.Duration)

+ SetLogger func(logger internal.FieldLogger)

+ SetMapper func(mapper datatype.Mapper)

+ SetName func(name string)

+ SetTimeout func(timeout time.Duration)

+ SetTypeName func(typeName string)

+ type ErrLowInterval time.Duration

+ func (e ErrLowInterval) Error() string

+ type ErrLowTimeout time.Duration

+ func (e ErrLowTimeout) Error() string

Sep 21, 2017

Changes in this version

+ var ErrPingNotCalled = fmt.Errorf("the caller forgot to ask me pinging")

type DataReader

+ Ping func() error

+ type Result struct

+ Content []byte

+ ID token.ID

+ Mapper datatype.Mapper

+ Time time.Time

+ TypeName string

Jan 1, 2017

Changes in this version

+ var ErrBackoffExceeded = fmt.Errorf("endpoint gone too long")

type DataReader

+ Interval func() time.Duration

+ Read func(context.Context) (*ReadJobResult, error)

+ Timeout func() time.Duration

+ type ErrLowBackoffValue int64

+ func (ErrLowBackoffValue) LowBackoffValue()

+ func (e ErrLowBackoffValue) Error() string

Dec 30, 2016

Changes in this version

+ const GenericReaderReceivesJobTestCase

+ const ReaderClosesTestCase

+ const ReaderClosesWithBufferedChansTestCase

+ const ReaderDrainsAfterClosingContextTestCase

+ const ReaderErrorsOnEndpointDisapearsTestCase

+ const ReaderReadsOnBufferedChanTestCase

+ const ReaderSendsResultTestCase

+ const ReaderWithNoValidURLErrorsTestCase

+ var ErrEmptyEndpoint = fmt.Errorf("endpoint cannot be empty")

+ var ErrEmptyName = fmt.Errorf("name cannot be empty")

+ var ErrEmptyTypeName = fmt.Errorf("type_name cannot be empty")

+ func TestReaderConstruction(t *testing.T, setup setupFunc)

+ func TestReaderEndpointManeuvers(t *testing.T, ...)

+ func TestReaderEssentials(t *testing.T, ...)

+ type ErrEndpointNotAvailable struct

+ Endpoint string

+ Err error

+ func (ErrEndpointNotAvailable) EndpointNotAvailable()

+ func (e ErrEndpointNotAvailable) Error() string

+ type ErrInvalidEndpoint string

+ func (ErrInvalidEndpoint) InvalidEndpoint()

+ func (e ErrInvalidEndpoint) Error() string

Dec 27, 2016

Changes in this version

type MockConfig

+ MockBackoff int

+ MockEndpoint string

+ MockInterval time.Duration

+ MockLogger logrus.FieldLogger

+ MockName string

+ MockRoutePath string

+ MockTimeout time.Duration

+ MockTypeName string

type ReadJobResult

+ Mapper datatype.Mapper

type SimpleReader

+ func (m *SimpleReader) ErrorChan() chan<- communication.ErrorMessage

Dec 24, 2016

Changes in this version

type ReadJobResult

+ ID communication.JobID

Dec 24, 2016

Changes in this version

type DataReader

+ Mapper func() datatype.Mapper

type SimpleReader

+ func (m *SimpleReader) Mapper() datatype.Mapper

Dec 22, 2016

Changes in this version

type DataReader

+ TypeName func() string

+ type MockConfig struct

+ Backoff_ int

+ Endpoint_ string

+ Interval_ time.Duration

+ Logger_ logrus.FieldLogger

+ Name_ string

+ RoutePath_ string

+ Timeout_ time.Duration

+ TypeName_ string

+ func NewMockConfig(name, typeName string, log logrus.FieldLogger, endpoint, routepath string, ...) (*MockConfig, error)

+ func (c *MockConfig) Backoff() int

+ func (c *MockConfig) Endpoint() string

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

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

+ func (c *MockConfig) Name() string

+ func (c *MockConfig) NewInstance(ctx context.Context, jobChan chan context.Context, ...) (DataReader, error)

+ func (c *MockConfig) RoutePath() string

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

+ func (c *MockConfig) TypeName() string

type ReadJobResult

+ TypeName string

type SimpleReader

+ func (m *SimpleReader) TypeName() string

Dec 21, 2016

Changes in this version

+ type DataReader interface

+ JobChan func() chan context.Context

+ Name func() string

+ ResultChan func() chan *ReadJobResult

+ Start func(ctx context.Context) chan struct{}

Dec 21, 2016

Changes in this version

+ type InterTimer interface

+ Interval func() time.Duration

+ Timeout func() time.Duration

+ type SimpleReader struct

+ StartFunc func() chan struct{}

+ func NewSimpleReader(logger logrus.FieldLogger, ctxReader ContextReader, name string, ...) (*SimpleReader, error)

+ func (m *SimpleReader) Interval() time.Duration

+ func (m *SimpleReader) JobChan() chan context.Context

+ func (m *SimpleReader) Name() string

+ func (m *SimpleReader) ResultChan() chan *ReadJobResult

+ func (m *SimpleReader) Start(ctx context.Context) chan struct{}

+ func (m *SimpleReader) Timeout() time.Duration

Dec 20, 2016

Changes in this version

+ type ContextReader interface

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

+ type CtxReader struct

+ func NewCtxReader(url string) *CtxReader

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

+ type MockCtxReader struct

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

+ func NewMockCtxReader(url string) *MockCtxReader

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

+ type MockExpvarReader struct

+ StartFunc func() chan struct{}

+ func NewMockExpvarReader(jobs chan context.Context, resCh chan *ReadJobResult, f func(context.Context)) *MockExpvarReader

+ func (m *MockExpvarReader) JobChan() chan context.Context

+ func (m *MockExpvarReader) ResultChan() chan *ReadJobResult

+ func (m *MockExpvarReader) Start() chan struct{}

+ type ReadJob struct

+ Ctx context.Context

+ Err chan error

+ type ReadJobResult struct

+ Err error

+ Res io.ReadCloser

+ Time time.Time

+ type TargetReader interface

+ JobChan func() chan context.Context

+ Name func() string

+ ResultChan func() chan *ReadJobResult

+ Start func() chan struct{}