net

package
v6.8.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2014 License: Apache-2.0 Imports: 26 Imported by: 602

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) 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()

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.