common

type Address struct {
	AddressID  int         `json:"addressID"`
	OwnerID    int         `json:"ownerID"`
	TypeID     interface{} `json:"typeID"`
	Address2   string      `json:"address2"`
	Address    string      `json:"address"`
	Street     string      `json:"street"`
	PostalCode string      `json:"postalCode"`
	City       string      `json:"city"`
	State      string      `json:"state"`
	Country    string      `json:"country"`
}

type Addresses []Address

type Cursor struct {
	Limit  int
	Offset int
}

type DataProvider interface {
	Count(ctx context.Context, filters map[string]interface{}) (int, error)
	Read(ctx context.Context, bulkFilters []map[string]interface{}, callback func(item interface{})) error
}

type Item struct {
	Err        error
	TotalCount int
	Payload    interface{}
}

type ItemsStream chan Item

type ItemsStreamGrouped chan []Item

type Lister struct {
	// contains filtered or unexported fields
}

type ListingSettings struct {
	MaxRequestsCountPerSecond int
	StreamBufferLength        int
	MaxFetchersCount          int
	MaxItemsPerRequest        int
}

type ObjAttribute struct {
	AttributeName  string `json:"attributeName"`
	AttributeType  string `json:"attributeType"`
	AttributeValue string `json:"attributeValue"`
}

type SleepThrottler struct {
	LimitPerSecond int
	LastTimestamp  int64
	Count          int
	// contains filtered or unexported fields
}

type Sleeper func(sleepTime time.Duration)

type Status struct {
	Request           string          `json:"request"`
	RequestUnixTime   int             `json:"requestUnixTime"`
	ResponseStatus    string          `json:"responseStatus"`
	ErrorCode         errors.ApiError `json:"errorCode"`
	ErrorField        string          `json:"errorField"`
	GenerationTime    float64         `json:"generationTime"`
	RecordsTotal      int             `json:"recordsTotal"`
	RecordsInResponse int             `json:"recordsInResponse"`
}

type StatusBulk struct {
	RequestName string `json:"requestName"`
	RequestID   string `json:"requestID"`
	Status
}

type Throttler interface {
	Throttle()
}

type ThrottlerMock struct {
	WasTriggered bool
}