net

Documentation

Index

• Constants
• func NewTLSConfig(trustedCerts []tls.Certificate, disableSSL bool) (TLSConfig *tls.Config)
• func PrepareRedirect(req *http.Request, via []*http.Request) error
• func Sanitize(input string) (sanitized string)
• func WrapNetworkErrors(host string, err error) error
• type AsyncResource
• type Gateway
  • func NewCloudControllerGateway(config configuration.Reader) Gateway
  • func NewUAAGateway(config configuration.Reader) Gateway
  • func (gateway Gateway) CreateResource(url string, body io.ReadSeeker, resource ...interface{}) (apiErr error)
  • func (gateway Gateway) DeleteResource(url string) (apiErr error)
  • func (gateway Gateway) GetResource(url string, resource interface{}) (err error)
  • func (gateway Gateway) ListPaginatedResources(target string, path string, resource interface{}, cb func(interface{}) bool) (apiErr error)
  • func (gateway Gateway) NewRequest(method, path, accessToken string, body io.ReadSeeker) (req *Request, apiErr error)
  • func (gateway Gateway) PerformPollingRequestForJSONResponse(request *Request, response interface{}, timeout time.Duration) (headers http.Header, apiErr error)
  • func (gateway Gateway) PerformRequest(request *Request) (rawResponse *http.Response, apiErr error)
  • func (gateway Gateway) PerformRequestForJSONResponse(request *Request, response interface{}) (headers http.Header, apiErr error)
  • func (gateway Gateway) PerformRequestForTextResponse(request *Request) (response string, headers http.Header, apiErr error)
  • func (gateway *Gateway) SetTokenRefresher(auth tokenRefresher)
  • func (gateway *Gateway) SetTrustedCerts(certificates []tls.Certificate)
  • func (gateway Gateway) UpdateResource(url string, body io.ReadSeeker, resource ...interface{}) (apiErr error)
  • func (gateway Gateway) UpdateResourceSync(url string, body io.ReadSeeker, resource ...interface{}) (apiErr error)
• type JobResource
• type PaginatedResources
  • func NewPaginatedResources(exampleResource interface{}) PaginatedResources
  • func (this PaginatedResources) Resources() ([]interface{}, error)
• type Request

Constants

const (
	JOB_FINISHED             = "finished"
	JOB_FAILED               = "failed"
	DEFAULT_POLLING_THROTTLE = 5 * time.Second
	ASYNC_REQUEST_TIMEOUT    = 20 * time.Second
)

const (
	PRIVATE_DATA_PLACEHOLDER = "[PRIVATE DATA HIDDEN]"
)

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 Sanitize

func Sanitize(input string) (sanitized string)

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
	// contains filtered or unexported fields
}

func NewCloudControllerGateway

func NewCloudControllerGateway(config configuration.Reader) Gateway

func NewUAAGateway

func NewUAAGateway(config configuration.Reader) Gateway

func (Gateway) CreateResource

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

func (Gateway) DeleteResource

func (gateway Gateway) DeleteResource(url 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) PerformPollingRequestForJSONResponse

func (gateway Gateway) PerformPollingRequestForJSONResponse(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(url string, body io.ReadSeeker, resource ...interface{}) (apiErr error)

func (Gateway) UpdateResourceSync

func (gateway Gateway) UpdateResourceSync(url string, body io.ReadSeeker, resource ...interface{}) (apiErr 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 Request

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