client

Documentation

Index

• Constants
• Variables
• type ApiClient
  • func NewApiClient(server string) *ApiClient
  • func (client *ApiClient) Request() *ApiRequest
• type ApiRequest
  • func (r *ApiRequest) Client() *ApiClient
  • func (r *ApiRequest) Do(req *http.Request) (*http.Response, error)
• type ApiRequester
• type ReportClient
  • func NewReportClient() *ReportClient
  • func (u *ReportClient) ReportState(api ApiRequester, packageUID string, previousState string, state string, ...) error
• type Reporter
• type UpdateClient
  • func NewUpdateClient() *UpdateClient
  • func (u *UpdateClient) DownloadUpdate(api ApiRequester, uri string, cr *httptoo.BytesContentRange) (io.ReadCloser, int64, error)
  • func (u *UpdateClient) GetUpdateContentRange(api ApiRequester, uri string, start int64) (*httptoo.BytesContentRange, error)
  • func (u *UpdateClient) ProbeUpdate(api ApiRequester, uri string, data interface{}) (interface{}, []byte, time.Duration, error)
• type Updater

Constants

const (
	UpgradesEndpoint    = "/upgrades"
	StateReportEndpoint = "/report"
)

Variables

var ErrMaxRedirect = errors.New("Exceeded max redirects")

Types

type ApiClient

type ApiClient struct {
	http.Client
	// contains filtered or unexported fields
}

func NewApiClient

func NewApiClient(server string) *ApiClient

func (*ApiClient) Request

func (client *ApiClient) Request() *ApiRequest

type ApiRequest

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

func (*ApiRequest) Client

func (r *ApiRequest) Client() *ApiClient

func (*ApiRequest) Do

func (r *ApiRequest) Do(req *http.Request) (*http.Response, error)

type ApiRequester

type ApiRequester interface {
	Client() *ApiClient
	Do(req *http.Request) (*http.Response, error)
}

type ReportClient

type ReportClient struct {
}

func NewReportClient

func NewReportClient() *ReportClient

func (*ReportClient) ReportState

func (u *ReportClient) ReportState(api ApiRequester, packageUID string, previousState string, state string, errorMessage string, fm metadata.FirmwareMetadata) error

type Reporter

type Reporter interface {
	ReportState(api ApiRequester, packageUID string, previousState string, state string, errorMessage string, fm metadata.FirmwareMetadata) error
}

type UpdateClient

type UpdateClient struct {
}

func NewUpdateClient

func NewUpdateClient() *UpdateClient

func (*UpdateClient) DownloadUpdate

func (u *UpdateClient) DownloadUpdate(api ApiRequester, uri string, cr *httptoo.BytesContentRange) (io.ReadCloser, int64, error)

func (*UpdateClient) GetUpdateContentRange

func (u *UpdateClient) GetUpdateContentRange(api ApiRequester, uri string, start int64) (*httptoo.BytesContentRange, error)

func (*UpdateClient) ProbeUpdate

func (u *UpdateClient) ProbeUpdate(api ApiRequester, uri string, data interface{}) (interface{}, []byte, time.Duration, error)

type Updater

type Updater interface {
	ProbeUpdate(api ApiRequester, uri string, data interface{}) (interface{}, []byte, time.Duration, error)
	DownloadUpdate(api ApiRequester, uri string, cr *httptoo.BytesContentRange) (io.ReadCloser, int64, error)
	GetUpdateContentRange(api ApiRequester, uri string, start int64) (*httptoo.BytesContentRange, error)
}