Documentation
¶
Index ¶
- Constants
- type Item
- type RetryLogger
- type TrackerClient
- func (that *TrackerClient) ItemDone(item string) error
- func (that *TrackerClient) ItemDoneContext(ctx context.Context, item string) error
- func (that *TrackerClient) ItemsDone(items []string, bytes map[string]uint64) error
- func (that *TrackerClient) ItemsDoneContext(ctx context.Context, items []string, bytes map[string]uint64) error
- func (that *TrackerClient) RequestItem() (item string, err error)
- func (that *TrackerClient) RequestItemContext(ctx context.Context) (item string, err error)
- func (that *TrackerClient) RequestItems(limit uint64) ([]string, error)
- func (that *TrackerClient) RequestItemsContext(ctx context.Context, limit uint64) ([]string, error)
- type TrackerConfig
- type TrackerError
Constants ¶
View Source
const ErrInvalidTrackerResponse = TrackerError("invalid tracker response")
View Source
const ErrNoSuchProject = TrackerError("this project doesn't exist")
View Source
const ErrNoTasksAvailable = TrackerError("no tasks available")
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RetryLogger ¶
type RetryLogger struct {
retryablehttp.LeveledLogger
}
func (*RetryLogger) Debug ¶
func (that *RetryLogger) Debug(_ string, _ ...interface{})
func (*RetryLogger) Error ¶
func (that *RetryLogger) Error(msg string, keysAndValues ...interface{})
func (*RetryLogger) Info ¶
func (that *RetryLogger) Info(msg string, keysAndValues ...interface{})
func (*RetryLogger) Warn ¶
func (that *RetryLogger) Warn(msg string, keysAndValues ...interface{})
type TrackerClient ¶
type TrackerClient struct {
// contains filtered or unexported fields
}
func NewTrackerConfig ¶
func NewTrackerConfig(trackerConfig *TrackerConfig) (*TrackerClient, error)
func (*TrackerClient) ItemDone ¶
func (that *TrackerClient) ItemDone(item string) error
func (*TrackerClient) ItemDoneContext ¶
func (that *TrackerClient) ItemDoneContext(ctx context.Context, item string) error
func (*TrackerClient) ItemsDone ¶
func (that *TrackerClient) ItemsDone(items []string, bytes map[string]uint64) error
func (*TrackerClient) ItemsDoneContext ¶
func (*TrackerClient) RequestItem ¶
func (that *TrackerClient) RequestItem() (item string, err error)
func (*TrackerClient) RequestItemContext ¶
func (that *TrackerClient) RequestItemContext(ctx context.Context) (item string, err error)
func (*TrackerClient) RequestItems ¶
func (that *TrackerClient) RequestItems(limit uint64) ([]string, error)
func (*TrackerClient) RequestItemsContext ¶
type TrackerConfig ¶
type TrackerError ¶
type TrackerError string
func (TrackerError) Error ¶
func (e TrackerError) Error() string
Click to show internal directories.
Click to hide internal directories.