net

package
v6.12.4+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 18, 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()

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.