transport

package

v0.0.25 Latest Latest Go to latest Published: Jan 1, 2023 License: AGPL-3.0 Imports: 13 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	EmptyBody string = ""
)

View Source

const HeaderContentLengthRange = "x-goog-content-length-range"

View Source

const HeaderContentMD5 = "Content-MD5"

View Source

const HeaderGeneration = "x-goog-generation"

those headers are case sensitive

View Source

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

View Source

var ErrConflict = errors.New("409 Conflict")

View Source

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

View Source

var ErrUnauthorized = errors.New("401 Unauthorized")

View Source

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

View Source

var RmapiUserAGent = "rmapi"

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, reader io.Reader, maxRequestSize int64) (err error)

func (ctx HttpClientCtx) PutRootBlobStream(url string, gen, maxRequestSize int64, reader io.Reader) (newGeneration int64, err 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)