desiredstatefetcher

Documentation

Index

• type BulkToken
• type DesiredStateFetcher
  • func New(config *config.Config, store store.Store, ...) *DesiredStateFetcher
  • func (fetcher *DesiredStateFetcher) Fetch(resultChan chan DesiredStateFetcherResult)
• type DesiredStateFetcherResult
• type DesiredStateServerResponse
  • func NewDesiredStateServerResponse(jsonMessage []byte) (DesiredStateServerResponse, error)
  • func (response DesiredStateServerResponse) BulkTokenRepresentation() string
  • func (response DesiredStateServerResponse) ToJSON() []byte

Types

type BulkToken

type BulkToken struct {
	Id int `json:"id"`
}

type DesiredStateFetcher

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

func New

func New(config *config.Config,
	store store.Store,
	metricsAccountant metricsaccountant.MetricsAccountant,
	httpClient httpclient.HttpClient,
	timeProvider timeprovider.TimeProvider,
	logger logger.Logger) *DesiredStateFetcher

func (*DesiredStateFetcher) Fetch

func (fetcher *DesiredStateFetcher) Fetch(resultChan chan DesiredStateFetcherResult)

type DesiredStateFetcherResult

type DesiredStateFetcherResult struct {
	Success    bool
	Message    string
	Error      error
	NumResults int
}

type DesiredStateServerResponse

type DesiredStateServerResponse struct {
	Results   map[string]models.DesiredAppState `json:"results"`
	BulkToken BulkToken                         `json:"bulk_token"`
}

func NewDesiredStateServerResponse

func NewDesiredStateServerResponse(jsonMessage []byte) (DesiredStateServerResponse, error)

func (DesiredStateServerResponse) BulkTokenRepresentation

func (response DesiredStateServerResponse) BulkTokenRepresentation() string

func (DesiredStateServerResponse) ToJSON

func (response DesiredStateServerResponse) ToJSON() []byte