bulk

type AppDiffer interface {
	Diff(logger lager.Logger, cancel <-chan struct{}, fingerprints <-chan []cc_messages.CCDesiredAppFingerprint) <-chan error

	Stale() <-chan []cc_messages.CCDesiredAppFingerprint

	Missing() <-chan []cc_messages.CCDesiredAppFingerprint

	Deleted() <-chan []string
}

type CCFetcher struct {
	BaseURI   string
	BatchSize int
	Username  string
	Password  string
}

type CCTaskClient struct {
}

type Fetcher interface {
	FetchFingerprints(
		logger lager.Logger,
		cancel <-chan struct{},
		httpClient *http.Client,
	) (<-chan []cc_messages.CCDesiredAppFingerprint, <-chan error)

	FetchTaskStates(
		logger lager.Logger,
		cancel <-chan struct{},
		httpClient *http.Client,
	) (<-chan []cc_messages.CCTaskState, <-chan error)

	FetchDesiredApps(
		logger lager.Logger,
		cancel <-chan struct{},
		httpClient *http.Client,
		fingerprints <-chan []cc_messages.CCDesiredAppFingerprint,
	) (<-chan []cc_messages.DesireAppRequestFromCC, <-chan error)
}

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

type TaskClient interface {
	FailTask(logger lager.Logger, taskState *cc_messages.CCTaskState, httpClient *http.Client) error
}

type TaskDiffer interface {
	Diff(lager.Logger, <-chan []cc_messages.CCTaskState, <-chan struct{})
	TasksToFail() <-chan []cc_messages.CCTaskState
	TasksToCancel() <-chan []string
}

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