transport

Documentation

Index

• Constants
• Variables
• type AuthType
• type BodyString
• type HttpClientCtx
  • 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)

Constants

const (
	EmptyBody string = ""
)

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

const HeaderContentMD5 = "Content-MD5"

const HeaderGeneration = "x-goog-generation"

those headers are case sensitive

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

Variables

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

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

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

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

var RmapiUserAGent = "rmapi"

Types

type AuthType

type AuthType int

const (
	EmptyBearer AuthType = iota
	DeviceBearer
	UserBearer
)

type BodyString

type BodyString struct {
	Content string
}

type HttpClientCtx

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

func CreateHttpClientCtx

func CreateHttpClientCtx(tokens model.AuthTokens) HttpClientCtx

func (HttpClientCtx) Delete

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

func (HttpClientCtx) Get

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

func (HttpClientCtx) GetBlobStream

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

func (HttpClientCtx) GetStream

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

func (HttpClientCtx) Post

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

func (HttpClientCtx) Put

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

func (HttpClientCtx) PutBlobStream

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

func (HttpClientCtx) PutRootBlobStream

func (ctx HttpClientCtx) PutRootBlobStream(url string, gen, maxRequestSize int64, reader io.Reader) (newGeneration int64, err error)

func (HttpClientCtx) PutStream

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

func (HttpClientCtx) Request

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