net

package
v6.0.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2014 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	INVALID_TOKEN_CODE       = "GATEWAY INVALID TOKEN CODE"
	JOB_FINISHED             = "finished"
	JOB_FAILED               = "failed"
	DEFAULT_POLLING_THROTTLE = 5 * time.Second
	ASYNC_REQUEST_TIMEOUT    = 20 * time.Second
)
View Source
const (
	PRIVATE_DATA_PLACEHOLDER = "[PRIVATE DATA HIDDEN]"
)

Variables

This section is empty.

Functions

func PrepareRedirect

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

func Sanitize

func Sanitize(input string) (sanitized string)

Types

type ApiResponse

type ApiResponse struct {
	Message   string
	ErrorCode string

	StatusCode  int
	ErrorHeader string
	ErrorBody   string
	// contains filtered or unexported fields
}

func NewApiResponse

func NewApiResponse(message string, errorCode string, statusCode int) (apiResponse ApiResponse)

func NewApiResponseWithError

func NewApiResponseWithError(message string, err error) (apiResponse ApiResponse)

func NewApiResponseWithHttpError

func NewApiResponseWithHttpError(message string, errorCode string, statusCode int, errorHeader string, errorBody string) (apiResponse ApiResponse)

func NewApiResponseWithMessage

func NewApiResponseWithMessage(message string, a ...interface{}) (apiResponse ApiResponse)

func NewApiResponseWithStatusCode

func NewApiResponseWithStatusCode(statusCode int) (apiResponse ApiResponse)

func NewNotFoundApiResponse

func NewNotFoundApiResponse(message string, a ...interface{}) (apiResponse ApiResponse)

func NewSuccessfulApiResponse

func NewSuccessfulApiResponse() (apiResponse ApiResponse)

func (ApiResponse) IsError

func (apiResponse ApiResponse) IsError() bool

func (ApiResponse) IsHttpError

func (apiResponse ApiResponse) IsHttpError() bool

func (ApiResponse) IsNotFound

func (apiResponse ApiResponse) IsNotFound() bool

func (ApiResponse) IsNotSuccessful

func (apiResponse ApiResponse) IsNotSuccessful() bool

func (ApiResponse) IsSuccessful

func (apiResponse ApiResponse) IsSuccessful() bool

type AsyncMetadata

type AsyncMetadata struct {
	Url string
}

type AsyncResponse

type AsyncResponse struct {
	Metadata AsyncMetadata
}

type Gateway

type Gateway struct {
	PollingEnabled  bool
	PollingThrottle time.Duration
	// contains filtered or unexported fields
}

func NewCloudControllerGateway

func NewCloudControllerGateway() Gateway

func NewUAAGateway

func NewUAAGateway() Gateway

func (Gateway) CreateResource

func (gateway Gateway) CreateResource(url, accessToken string, body io.ReadSeeker) (apiResponse ApiResponse)

func (Gateway) CreateResourceForResponse

func (gateway Gateway) CreateResourceForResponse(url, accessToken string, body io.ReadSeeker, resource interface{}) (apiResponse ApiResponse)

func (Gateway) DeleteResource

func (gateway Gateway) DeleteResource(url, accessToken string) (apiResponse ApiResponse)

func (Gateway) GetResource

func (gateway Gateway) GetResource(url, accessToken string, resource interface{}) (apiResponse ApiResponse)

func (Gateway) ListPaginatedResources

func (gateway Gateway) ListPaginatedResources(
	target string,
	accessToken string,
	path string,
	resource interface{},
	cb func(interface{}) bool) (apiResponse ApiResponse)

func (Gateway) NewRequest

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

func (Gateway) PerformPollingRequestForJSONResponse

func (gateway Gateway) PerformPollingRequestForJSONResponse(request *Request, response interface{}, timeout time.Duration) (headers http.Header, apiResponse ApiResponse)

func (Gateway) PerformRequest

func (gateway Gateway) PerformRequest(request *Request) (apiResponse ApiResponse)

func (Gateway) PerformRequestForJSONResponse

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

func (Gateway) PerformRequestForResponse

func (gateway Gateway) PerformRequestForResponse(request *Request) (rawResponse *http.Response, apiResponse ApiResponse)

func (Gateway) PerformRequestForResponseBytes

func (gateway Gateway) PerformRequestForResponseBytes(request *Request) (bytes []byte, headers http.Header, apiResponse ApiResponse)

func (Gateway) PerformRequestForTextResponse

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

func (*Gateway) SetTokenRefresher

func (gateway *Gateway) SetTokenRefresher(auth tokenRefresher)

func (Gateway) UpdateResource

func (gateway Gateway) UpdateResource(url, accessToken string, body io.ReadSeeker) (apiResponse ApiResponse)

func (Gateway) UpdateResourceForResponse

func (gateway Gateway) UpdateResourceForResponse(url, accessToken string, body io.ReadSeeker, resource interface{}) (apiResponse ApiResponse)

type JobEntity

type JobEntity struct {
	Status string
}

type JobResponse

type JobResponse struct {
	Entity JobEntity
}

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
}

Jump to

Keyboard shortcuts

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