net

Documentation

Index

• Constants
• func PrepareRedirect(req *http.Request, via []*http.Request) error
• func Sanitize(input string) (sanitized string)
• type ApiResponse
  • func NewApiResponse(message string, errorCode string, statusCode int) (apiResponse ApiResponse)
  • func NewApiResponseWithError(message string, err error) (apiResponse ApiResponse)
  • func NewApiResponseWithHttpError(message string, errorCode string, statusCode int, errorHeader string, ...) (apiResponse ApiResponse)
  • func NewApiResponseWithMessage(message string, a ...interface{}) (apiResponse ApiResponse)
  • func NewApiResponseWithStatusCode(statusCode int) (apiResponse ApiResponse)
  • func NewNotFoundApiResponse(message string, a ...interface{}) (apiResponse ApiResponse)
  • func NewSuccessfulApiResponse() (apiResponse ApiResponse)
  • func (apiResponse ApiResponse) IsError() bool
  • func (apiResponse ApiResponse) IsHttpError() bool
  • func (apiResponse ApiResponse) IsNotFound() bool
  • func (apiResponse ApiResponse) IsNotSuccessful() bool
  • func (apiResponse ApiResponse) IsSuccessful() bool
• type AsyncMetadata
• type AsyncResponse
• type Gateway
  • func NewCloudControllerGateway() Gateway
  • func NewUAAGateway() Gateway
  • func (gateway Gateway) CreateResource(url, accessToken string, body io.ReadSeeker) (apiResponse ApiResponse)
  • func (gateway Gateway) CreateResourceForResponse(url, accessToken string, body io.ReadSeeker, resource interface{}) (apiResponse ApiResponse)
  • func (gateway Gateway) DeleteResource(url, accessToken string) (apiResponse ApiResponse)
  • func (gateway Gateway) GetResource(url, accessToken string, resource interface{}) (apiResponse ApiResponse)
  • func (gateway Gateway) NewRequest(method, path, accessToken string, body io.ReadSeeker) (req *Request, apiResponse ApiResponse)
  • func (gateway Gateway) PerformPollingRequestForJSONResponse(request *Request, response interface{}) (headers http.Header, apiResponse ApiResponse)
  • func (gateway Gateway) PerformRequest(request *Request) (apiResponse ApiResponse)
  • func (gateway Gateway) PerformRequestForJSONResponse(request *Request, response interface{}) (headers http.Header, apiResponse ApiResponse)
  • func (gateway Gateway) PerformRequestForResponse(request *Request) (rawResponse *http.Response, apiResponse ApiResponse)
  • func (gateway Gateway) PerformRequestForResponseBytes(request *Request) (bytes []byte, headers http.Header, apiResponse ApiResponse)
  • func (gateway Gateway) PerformRequestForTextResponse(request *Request) (response string, headers http.Header, apiResponse ApiResponse)
  • func (gateway *Gateway) SetTokenRefresher(auth tokenRefresher)
  • func (gateway Gateway) UpdateResource(url, accessToken string, body io.ReadSeeker) (apiResponse ApiResponse)
  • func (gateway Gateway) UpdateResourceForResponse(url, accessToken string, body io.ReadSeeker, resource interface{}) (apiResponse ApiResponse)
• type JobEntity
• type JobResponse
• type Request

Constants

const (
	INVALID_TOKEN_CODE       = "GATEWAY INVALID TOKEN CODE"
	JOB_FINISHED             = "finished"
	JOB_FAILED               = "failed"
	DEFAULT_POLLING_THROTTLE = 5 * time.Second
)

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

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) 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{}) (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 Request

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