net

package
v6.12.2+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 15, 2015 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	JOB_FINISHED             = "finished"
	JOB_FAILED               = "failed"
	DEFAULT_POLLING_THROTTLE = 5 * time.Second
)

Variables

View Source
var NewHttpClient = func(tr *http.Transport) HttpClientInterface {
	return &http.Client{
		Transport:     tr,
		CheckRedirect: PrepareRedirect,
	}
}

Functions

func NewTLSConfig

func NewTLSConfig(trustedCerts []tls.Certificate, disableSSL bool) (TLSConfig *tls.Config)

func PrepareRedirect

func PrepareRedirect(req *http.Request, via []*http.Request) error

func WrapNetworkErrors

func WrapNetworkErrors(host string, err error) error

Types

type AsyncResource

type AsyncResource struct {
	Metadata struct {
		URL string
	}
}

type Gateway

type Gateway struct {
	PollingEnabled  bool
	PollingThrottle time.Duration

	Clock func() time.Time
	// contains filtered or unexported fields
}

func NewCloudControllerGateway

func NewCloudControllerGateway(config core_config.Reader, clock func() time.Time, ui terminal.UI) Gateway

func NewUAAGateway

func NewUAAGateway(config core_config.Reader, ui terminal.UI) Gateway

func (*Gateway) AsyncTimeout

func (gateway *Gateway) AsyncTimeout() time.Duration

func (Gateway) CreateResource

func (gateway Gateway) CreateResource(endpoint, apiUrl string, body io.ReadSeeker, resource ...interface{}) (apiErr error)

func (Gateway) CreateResourceFromStruct

func (gateway Gateway) CreateResourceFromStruct(endpoint, url string, resource interface{}) error

func (Gateway) DeleteResource

func (gateway Gateway) DeleteResource(endpoint, apiUrl string) (apiErr error)

func (Gateway) DeleteResourceSynchronously

func (gateway Gateway) DeleteResourceSynchronously(endpoint, apiUrl string) (apiErr error)

func (Gateway) GetResource

func (gateway Gateway) GetResource(url string, resource interface{}) (err error)

func (Gateway) ListPaginatedResources

func (gateway Gateway) ListPaginatedResources(target string,
	path string,
	resource interface{},
	cb func(interface{}) bool) (apiErr error)

func (Gateway) NewRequest

func (gateway Gateway) NewRequest(method, path, accessToken string, body io.ReadSeeker) (req *Request, apiErr error)

func (Gateway) NewRequestForFile

func (gateway Gateway) NewRequestForFile(method, fullUrl, accessToken string, body *os.File) (req *Request, apiErr error)

func (Gateway) PerformPollingRequestForJSONResponse

func (gateway Gateway) PerformPollingRequestForJSONResponse(endpoint string, request *Request, response interface{}, timeout time.Duration) (headers http.Header, apiErr error)

func (Gateway) PerformRequest

func (gateway Gateway) PerformRequest(request *Request) (rawResponse *http.Response, apiErr error)

func (Gateway) PerformRequestForJSONResponse

func (gateway Gateway) PerformRequestForJSONResponse(request *Request, response interface{}) (headers http.Header, apiErr error)

func (Gateway) PerformRequestForTextResponse

func (gateway Gateway) PerformRequestForTextResponse(request *Request) (response string, headers http.Header, apiErr error)

func (*Gateway) SetTokenRefresher

func (gateway *Gateway) SetTokenRefresher(auth tokenRefresher)

func (*Gateway) SetTrustedCerts

func (gateway *Gateway) SetTrustedCerts(certificates []tls.Certificate)

func (Gateway) UpdateResource

func (gateway Gateway) UpdateResource(endpoint, apiUrl string, body io.ReadSeeker, resource ...interface{}) (apiErr error)

func (Gateway) UpdateResourceFromStruct

func (gateway Gateway) UpdateResourceFromStruct(endpoint, apiUrl string, resource interface{}) error

func (Gateway) UpdateResourceSync

func (gateway Gateway) UpdateResourceSync(endpoint, apiUrl string, body io.ReadSeeker, resource ...interface{}) (apiErr error)

func (Gateway) Warnings

func (gateway Gateway) Warnings() []string

type HttpClientInterface

type HttpClientInterface interface {
	Do(req *http.Request) (resp *http.Response, err error)
}

type JobResource

type JobResource struct {
	Entity struct {
		Status       string
		ErrorDetails struct {
			Description string
		} `json:"error_details"`
	}
}

type PaginatedResources

type PaginatedResources struct {
	NextURL        string          `json:"next_url"`
	ResourcesBytes json.RawMessage `json:"resources"`
	// contains filtered or unexported fields
}

func NewPaginatedResources

func NewPaginatedResources(exampleResource interface{}) PaginatedResources

func (PaginatedResources) Resources

func (this PaginatedResources) Resources() ([]interface{}, error)

type ProgressReader

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

func NewProgressReader

func NewProgressReader(readSeeker io.ReadSeeker, ui terminal.UI, outputInterval time.Duration) *ProgressReader

func (*ProgressReader) Read

func (progressReader *ProgressReader) Read(p []byte) (int, error)

func (*ProgressReader) Seek

func (progressReader *ProgressReader) Seek(offset int64, whence int) (int64, error)

func (*ProgressReader) SetTotalSize

func (progressReader *ProgressReader) SetTotalSize(size int64)

type Request

type Request struct {
	HttpReq      *http.Request
	SeekableBody io.ReadSeeker
}

type WarningProducer

type WarningProducer interface {
	Warnings() []string
}

type WarningsCollector

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

func NewWarningsCollector

func NewWarningsCollector(ui terminal.UI, warning_producers ...WarningProducer) (warnings_collector WarningsCollector)

func (WarningsCollector) PrintWarnings

func (warnings_collector WarningsCollector) PrintWarnings()

Directories

Path Synopsis
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL