transport

package

v0.0.21 Latest Latest Go to latest Published: Sep 4, 2022 License: AGPL-3.0 Imports: 13 Imported by: 2

Details

View Source

const (
	EmptyBody string = ""
)

View Source

const HeaderContentMD5 = "Content-MD5"

View Source

const HeaderGeneration = "x-goog-generation"

View Source

const HeaderGenerationIfMatch = "x-goog-if-generation-match"

View Source

var ErrNotFound = errors.New("not found")

View Source

var ErrWrongGeneration = errors.New("wrong generation")

View Source

var RmapiUserAGent = "rmapi"

View Source

var UnAuthorizedError = errors.New("401 Unauthorized Error")

This section is empty.

type AuthType int

const (
	EmptyBearer AuthType = iota
	DeviceBearer
	UserBearer
)

type BodyString struct {
	Content string
}

type HttpClientCtx struct {
	Client *http.Client
	Tokens model.AuthTokens
}

func CreateHttpClientCtx(tokens model.AuthTokens) HttpClientCtx

func (ctx HttpClientCtx) Delete(authType AuthType, url string, reqBody, resp interface{}) error

func (ctx HttpClientCtx) Get(authType AuthType, url string, body interface{}, target interface{}) error

func (ctx HttpClientCtx) GetBlobStream(url string) (io.ReadCloser, int64, error)

func (ctx HttpClientCtx) GetStream(authType AuthType, url string) (io.ReadCloser, error)

func (ctx HttpClientCtx) Post(authType AuthType, url string, reqBody, resp interface{}) error

func (ctx HttpClientCtx) Put(authType AuthType, url string, reqBody, resp interface{}) error

func (ctx HttpClientCtx) PutBlobStream(url string, gen int64, reader io.Reader) (int64, error)

func (ctx HttpClientCtx) PutStream(authType AuthType, url string, reqBody io.Reader) error

func (ctx HttpClientCtx) Request(authType AuthType, verb, url string, body io.Reader) (*http.Response, error)