provider

Documentation

Index

• Variables
• func DecodeJSONResponse(r io.Reader, retval interface{}) error
• func JSONWithoutSecrets(obj interface{}) ([]byte, error)
• func RemoveSecretsFromJSON(in []byte) []byte
• func SendWithRetry(maxRetries int, send func() (statusCode int, _ error)) error
• type IRequest
• type Pipe
  • func NewPipe(write func(io.Writer) error) *Pipe
  • func (p *Pipe) Close() error
  • func (p *Pipe) Read(out []byte) (n int, err error)

Variables

var (
	ErrInternalServerError = errors.New("remote push server: internal error")
	ErrServiceUnavailable  = errors.New("remote push server: service unavailable")
)

Functions

func DecodeJSONResponse

func DecodeJSONResponse(r io.Reader, retval interface{}) error

DecodeJSONResponse unmarshal response in json format to the object. If server returns invalid json data, the method represents a response body as an error

func JSONWithoutSecrets

func JSONWithoutSecrets(obj interface{}) ([]byte, error)

func RemoveSecretsFromJSON

func RemoveSecretsFromJSON(in []byte) []byte

func SendWithRetry

func SendWithRetry(maxRetries int, send func() (statusCode int, _ error)) error

Types

type IRequest

type IRequest interface {
	SetToken(token string)
	ShouldIgnore() bool
}

type Pipe

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

func NewPipe

func NewPipe(write func(io.Writer) error) *Pipe

func (*Pipe) Close

func (p *Pipe) Close() error

func (*Pipe) Read

func (p *Pipe) Read(out []byte) (n int, err error)