testing

Apr 5, 2018

Changes in this version

type Reader

+ MockEndpoint string

+ MockInterval time.Duration

+ MockMapper datatype.Mapper

+ MockName string

+ MockTypeName string

Apr 2, 2018

Changes in this version

+ type BaseConstruct struct

+ func NewBaseConstruct() *BaseConstruct

+ func (b *BaseConstruct) SetBackoff(backoff int)

+ func (b *BaseConstruct) SetEndpoint(endpoint string)

+ func (b *BaseConstruct) SetInterval(interval time.Duration)

+ func (b *BaseConstruct) SetLogger(logger tools.FieldLogger)

+ func (b *BaseConstruct) SetMapper(mapper datatype.Mapper)

+ func (b *BaseConstruct) SetName(name string)

+ func (b *BaseConstruct) SetTimeout(timeout time.Duration)

+ func (b *BaseConstruct) SetTypeName(typeName string)

+ func (b *BaseConstruct) Setters() []func(reader.Constructor) error

type Config

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

Mar 31, 2018

Changes in this version

type Reader

+ PingFunc func() error

Mar 28, 2018

Changes in this version

+ type Conf func(*Config) error

+ func WithBackoff(backoff int) Conf

+ func WithEndpoint(endpoint string) Conf

+ func WithInterval(internal time.Duration) Conf

+ func WithLogger(log internal.FieldLogger) Conf

+ func WithName(name string) Conf

+ func WithTimeout(timeout time.Duration) Conf

+ func WithTypeName(typeName string) Conf

Sep 24, 2017

Changes in this version

+ func TestSuites() map[string]func(t *testing.T, cons Constructor)

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

+ func TestReader(t *testing.T, cons Constructor)

+ type Config struct

+ MockBackoff int

+ MockEndpoint string

+ MockInterval time.Duration

+ MockLogger logrus.FieldLogger

+ MockName string

+ MockRoutePath string

+ MockTimeout time.Duration

+ MockTypeName string

+ func NewConfig(name, typeName 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.DataReader, error)

+ func (c *Config) RoutePath() string

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

+ func (c *Config) TypeName() string

+ type Constructor interface

+ Object func() (reader.DataReader, error)

+ SetBackoff func(int)

+ SetEndpoint func(string)

+ SetInterval func(time.Duration)

+ SetName func(string)

+ SetTimeout func(time.Duration)

+ SetTypename func(string)

+ TestServer func() *httptest.Server

+ type Reader struct

+ Pinged bool

+ ReadFunc func(*token.Context) (*reader.Result, error)

+ func GetReader(url string) *Reader

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

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

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

+ func (s *Reader) Name() string

+ func (s *Reader) Ping() error

+ func (s *Reader) Read(job *token.Context) (*reader.Result, error)

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

+ func (s *Reader) TypeName() string

Jan 1, 2017

Changes in this version

+ const ReaderReceivesJobTestCase

+ const ReaderReturnsSameIDTestCase

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

Jan 1, 2017

Changes in this version

+ const GenericReaderReceivesJobTestCase

+ const ReaderBacksOffOnEndpointGoneTestCase

+ const ReaderErrorsOnEndpointDisapearsTestCase

+ const ReaderReadsOnBufferedChanTestCase

+ const ReaderSendsResultTestCase

+ const ReaderWithNoValidURLErrorsTestCase

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

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

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

+ type MockConfig struct

+ MockBackoff int

+ MockEndpoint string

+ MockInterval time.Duration

+ MockLogger logrus.FieldLogger

+ MockName string

+ MockRoutePath string

+ MockTimeout time.Duration

+ MockTypeName 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) (reader.DataReader, error)

+ func (c *MockConfig) RoutePath() string

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

+ func (c *MockConfig) TypeName() string

+ type SimpleReader struct

+ ReadFunc func(context.Context) (*reader.ReadJobResult, error)

+ func NewSimpleReader(log logrus.FieldLogger, endpoint string, name, typeName string, ...) (*SimpleReader, error)

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

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

+ func (m *SimpleReader) Name() string

+ func (m *SimpleReader) Read(job context.Context) (*reader.ReadJobResult, error)

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

+ func (m *SimpleReader) TypeName() string