nuclio

package module
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: May 10, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

README

Go SDK for nuclio

To get started with nuclio, see https://github.com/nuclio/nuclio.

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrAccepted = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrAccepted is a StatusAccepted Error

View Source
var ErrAlreadyReported = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrAlreadyReported is a StatusAlreadyReported Error

View Source
var ErrBadGateway = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrBadGateway is a StatusBadGateway Error

View Source
var ErrBadRequest = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrBadRequest is a StatusBadRequest Error

View Source
var ErrConflict = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrConflict is a StatusConflict Error

View Source
var ErrContinue = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrContinue is a StatusContinue Error

View Source
var ErrCreated = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrCreated is a StatusCreated Error

View Source
var ErrExpectationFailed = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrExpectationFailed is a StatusExpectationFailed Error

View Source
var ErrFailedDependency = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrFailedDependency is a StatusFailedDependency Error

View Source
var ErrForbidden = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrForbidden is a StatusForbidden Error

View Source
var ErrFound = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrFound is a StatusFound Error

View Source
var ErrGatewayTimeout = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrGatewayTimeout is a StatusGatewayTimeout Error

View Source
var ErrGone = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrGone is a StatusGone Error

View Source
var ErrHTTPVersionNotSupported = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrHTTPVersionNotSupported is a StatusHTTPVersionNotSupported Error

View Source
var ErrIMUsed = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrIMUsed is a StatusIMUsed Error

View Source
var ErrInsufficientStorage = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrInsufficientStorage is a StatusInsufficientStorage Error

View Source
var ErrInternalServerError = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrInternalServerError is a StatusInternalServerError Error

View Source
var ErrLengthRequired = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrLengthRequired is a StatusLengthRequired Error

View Source
var ErrLocked = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrLocked is a StatusLocked Error

View Source
var ErrLoopDetected = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrLoopDetected is a StatusLoopDetected Error

View Source
var ErrMethodNotAllowed = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrMethodNotAllowed is a StatusMethodNotAllowed Error

View Source
var ErrMovedPermanently = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrMovedPermanently is a StatusMovedPermanently Error

View Source
var ErrMultiStatus = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrMultiStatus is a StatusMultiStatus Error

View Source
var ErrMultipleChoices = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrMultipleChoices is a StatusMultipleChoices Error

View Source
var ErrNetworkAuthenticationRequired = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNetworkAuthenticationRequired is a StatusNetworkAuthenticationRequired Error

View Source
var ErrNoContent = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNoContent is a StatusNoContent Error

View Source
var ErrNonAuthoritativeInfo = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNonAuthoritativeInfo is a StatusNonAuthoritativeInfo Error

View Source
var ErrNotAcceptable = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNotAcceptable is a StatusNotAcceptable Error

View Source
var ErrNotExtended = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNotExtended is a StatusNotExtended Error

View Source
var ErrNotFound = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNotFound is a StatusNotFound Error

View Source
var ErrNotImplemented = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNotImplemented is a StatusNotImplemented Error

View Source
var ErrNotModified = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrNotModified is a StatusNotModified Error

View Source
var ErrPartialContent = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrPartialContent is a StatusPartialContent Error

View Source
var ErrPaymentRequired = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrPaymentRequired is a StatusPaymentRequired Error

View Source
var ErrPermanentRedirect = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrPermanentRedirect is a StatusPermanentRedirect Error

View Source
var ErrPreconditionFailed = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrPreconditionFailed is a StatusPreconditionFailed Error

View Source
var ErrPreconditionRequired = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrPreconditionRequired is a StatusPreconditionRequired Error

View Source
var ErrProcessing = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrProcessing is a StatusProcessing Error

View Source
var ErrProxyAuthRequired = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrProxyAuthRequired is a StatusProxyAuthRequired Error

View Source
var ErrRequestEntityTooLarge = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrRequestEntityTooLarge is a StatusRequestEntityTooLarge Error

View Source
var ErrRequestHeaderFieldsTooLarge = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrRequestHeaderFieldsTooLarge is a StatusRequestHeaderFieldsTooLarge Error

View Source
var ErrRequestTimeout = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrRequestTimeout is a StatusRequestTimeout Error

View Source
var ErrRequestURITooLong = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrRequestURITooLong is a StatusRequestURITooLong Error

View Source
var ErrRequestedRangeNotSatisfiable = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrRequestedRangeNotSatisfiable is a StatusRequestedRangeNotSatisfiable Error

View Source
var ErrResetContent = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrResetContent is a StatusResetContent Error

View Source
var ErrSeeOther = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrSeeOther is a StatusSeeOther Error

View Source
var ErrServiceUnavailable = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrServiceUnavailable is a StatusServiceUnavailable Error

View Source
var ErrSwitchingProtocols = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrSwitchingProtocols is a StatusSwitchingProtocols Error

View Source
var ErrTeapot = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrTeapot is a StatusTeapot Error

View Source
var ErrTemporaryRedirect = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrTemporaryRedirect is a StatusTemporaryRedirect Error

View Source
var ErrTooManyRequests = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrTooManyRequests is a StatusTooManyRequests Error

View Source
var ErrTypeConversion = errors.New("Cannot convert to this type")

ErrTypeConversion is returned when a type conversion for headers / fields fails

View Source
var ErrUnauthorized = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrUnauthorized is a StatusUnauthorized Error

View Source
var ErrUnavailableForLegalReasons = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrUnavailableForLegalReasons is a StatusUnavailableForLegalReasons Error

View Source
var ErrUnprocessableEntity = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrUnprocessableEntity is a StatusUnprocessableEntity Error

View Source
var ErrUnsupported = errors.New("Event does not support this interface")

ErrUnsupported is returned when an unsupported interface on the event is called

View Source
var ErrUnsupportedMediaType = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrUnsupportedMediaType is a StatusUnsupportedMediaType Error

View Source
var ErrUpgradeRequired = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrUpgradeRequired is a StatusUpgradeRequired Error

View Source
var ErrUseProxy = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrUseProxy is a StatusUseProxy Error

View Source
var ErrVariantAlsoNegotiates = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrVariantAlsoNegotiates is a StatusVariantAlsoNegotiates Error

Functions

func NewErrAccepted

func NewErrAccepted(message string) error

NewErrAccepted returns a new ErrAccepted with custom error message

func NewErrAlreadyReported

func NewErrAlreadyReported(message string) error

NewErrAlreadyReported returns a new ErrAlreadyReported with custom error message

func NewErrBadGateway

func NewErrBadGateway(message string) error

NewErrBadGateway returns a new ErrBadGateway with custom error message

func NewErrBadRequest

func NewErrBadRequest(message string) error

NewErrBadRequest returns a new ErrBadRequest with custom error message

func NewErrConflict

func NewErrConflict(message string) error

NewErrConflict returns a new ErrConflict with custom error message

func NewErrContinue

func NewErrContinue(message string) error

NewErrContinue returns a new ErrContinue with custom error message

func NewErrCreated

func NewErrCreated(message string) error

NewErrCreated returns a new ErrCreated with custom error message

func NewErrExpectationFailed

func NewErrExpectationFailed(message string) error

NewErrExpectationFailed returns a new ErrExpectationFailed with custom error message

func NewErrFailedDependency

func NewErrFailedDependency(message string) error

NewErrFailedDependency returns a new ErrFailedDependency with custom error message

func NewErrForbidden

func NewErrForbidden(message string) error

NewErrForbidden returns a new ErrForbidden with custom error message

func NewErrFound

func NewErrFound(message string) error

NewErrFound returns a new ErrFound with custom error message

func NewErrGatewayTimeout

func NewErrGatewayTimeout(message string) error

NewErrGatewayTimeout returns a new ErrGatewayTimeout with custom error message

func NewErrGone

func NewErrGone(message string) error

NewErrGone returns a new ErrGone with custom error message

func NewErrHTTPVersionNotSupported

func NewErrHTTPVersionNotSupported(message string) error

NewErrHTTPVersionNotSupported returns a new ErrHTTPVersionNotSupported with custom error message

func NewErrIMUsed

func NewErrIMUsed(message string) error

NewErrIMUsed returns a new ErrIMUsed with custom error message

func NewErrInsufficientStorage

func NewErrInsufficientStorage(message string) error

NewErrInsufficientStorage returns a new ErrInsufficientStorage with custom error message

func NewErrInternalServerError

func NewErrInternalServerError(message string) error

NewErrInternalServerError returns a new ErrInternalServerError with custom error message

func NewErrLengthRequired

func NewErrLengthRequired(message string) error

NewErrLengthRequired returns a new ErrLengthRequired with custom error message

func NewErrLocked

func NewErrLocked(message string) error

NewErrLocked returns a new ErrLocked with custom error message

func NewErrLoopDetected

func NewErrLoopDetected(message string) error

NewErrLoopDetected returns a new ErrLoopDetected with custom error message

func NewErrMethodNotAllowed

func NewErrMethodNotAllowed(message string) error

NewErrMethodNotAllowed returns a new ErrMethodNotAllowed with custom error message

func NewErrMovedPermanently

func NewErrMovedPermanently(message string) error

NewErrMovedPermanently returns a new ErrMovedPermanently with custom error message

func NewErrMultiStatus

func NewErrMultiStatus(message string) error

NewErrMultiStatus returns a new ErrMultiStatus with custom error message

func NewErrMultipleChoices

func NewErrMultipleChoices(message string) error

NewErrMultipleChoices returns a new ErrMultipleChoices with custom error message

func NewErrNetworkAuthenticationRequired

func NewErrNetworkAuthenticationRequired(message string) error

NewErrNetworkAuthenticationRequired returns a new ErrNetworkAuthenticationRequired with custom error message

func NewErrNoContent

func NewErrNoContent(message string) error

NewErrNoContent returns a new ErrNoContent with custom error message

func NewErrNonAuthoritativeInfo

func NewErrNonAuthoritativeInfo(message string) error

NewErrNonAuthoritativeInfo returns a new ErrNonAuthoritativeInfo with custom error message

func NewErrNotAcceptable

func NewErrNotAcceptable(message string) error

NewErrNotAcceptable returns a new ErrNotAcceptable with custom error message

func NewErrNotExtended

func NewErrNotExtended(message string) error

NewErrNotExtended returns a new ErrNotExtended with custom error message

func NewErrNotFound

func NewErrNotFound(message string) error

NewErrNotFound returns a new ErrNotFound with custom error message

func NewErrNotImplemented

func NewErrNotImplemented(message string) error

NewErrNotImplemented returns a new ErrNotImplemented with custom error message

func NewErrNotModified

func NewErrNotModified(message string) error

NewErrNotModified returns a new ErrNotModified with custom error message

func NewErrPartialContent

func NewErrPartialContent(message string) error

NewErrPartialContent returns a new ErrPartialContent with custom error message

func NewErrPaymentRequired

func NewErrPaymentRequired(message string) error

NewErrPaymentRequired returns a new ErrPaymentRequired with custom error message

func NewErrPermanentRedirect

func NewErrPermanentRedirect(message string) error

NewErrPermanentRedirect returns a new ErrPermanentRedirect with custom error message

func NewErrPreconditionFailed

func NewErrPreconditionFailed(message string) error

NewErrPreconditionFailed returns a new ErrPreconditionFailed with custom error message

func NewErrPreconditionRequired

func NewErrPreconditionRequired(message string) error

NewErrPreconditionRequired returns a new ErrPreconditionRequired with custom error message

func NewErrProcessing

func NewErrProcessing(message string) error

NewErrProcessing returns a new ErrProcessing with custom error message

func NewErrProxyAuthRequired

func NewErrProxyAuthRequired(message string) error

NewErrProxyAuthRequired returns a new ErrProxyAuthRequired with custom error message

func NewErrRequestEntityTooLarge

func NewErrRequestEntityTooLarge(message string) error

NewErrRequestEntityTooLarge returns a new ErrRequestEntityTooLarge with custom error message

func NewErrRequestHeaderFieldsTooLarge

func NewErrRequestHeaderFieldsTooLarge(message string) error

NewErrRequestHeaderFieldsTooLarge returns a new ErrRequestHeaderFieldsTooLarge with custom error message

func NewErrRequestTimeout

func NewErrRequestTimeout(message string) error

NewErrRequestTimeout returns a new ErrRequestTimeout with custom error message

func NewErrRequestURITooLong

func NewErrRequestURITooLong(message string) error

NewErrRequestURITooLong returns a new ErrRequestURITooLong with custom error message

func NewErrRequestedRangeNotSatisfiable

func NewErrRequestedRangeNotSatisfiable(message string) error

NewErrRequestedRangeNotSatisfiable returns a new ErrRequestedRangeNotSatisfiable with custom error message

func NewErrResetContent

func NewErrResetContent(message string) error

NewErrResetContent returns a new ErrResetContent with custom error message

func NewErrSeeOther

func NewErrSeeOther(message string) error

NewErrSeeOther returns a new ErrSeeOther with custom error message

func NewErrServiceUnavailable

func NewErrServiceUnavailable(message string) error

NewErrServiceUnavailable returns a new ErrServiceUnavailable with custom error message

func NewErrSwitchingProtocols

func NewErrSwitchingProtocols(message string) error

NewErrSwitchingProtocols returns a new ErrSwitchingProtocols with custom error message

func NewErrTeapot

func NewErrTeapot(message string) error

NewErrTeapot returns a new ErrTeapot with custom error message

func NewErrTemporaryRedirect

func NewErrTemporaryRedirect(message string) error

NewErrTemporaryRedirect returns a new ErrTemporaryRedirect with custom error message

func NewErrTooManyRequests

func NewErrTooManyRequests(message string) error

NewErrTooManyRequests returns a new ErrTooManyRequests with custom error message

func NewErrUnauthorized

func NewErrUnauthorized(message string) error

NewErrUnauthorized returns a new ErrUnauthorized with custom error message

func NewErrUnavailableForLegalReasons

func NewErrUnavailableForLegalReasons(message string) error

NewErrUnavailableForLegalReasons returns a new ErrUnavailableForLegalReasons with custom error message

func NewErrUnprocessableEntity

func NewErrUnprocessableEntity(message string) error

NewErrUnprocessableEntity returns a new ErrUnprocessableEntity with custom error message

func NewErrUnsupportedMediaType

func NewErrUnsupportedMediaType(message string) error

NewErrUnsupportedMediaType returns a new ErrUnsupportedMediaType with custom error message

func NewErrUpgradeRequired

func NewErrUpgradeRequired(message string) error

NewErrUpgradeRequired returns a new ErrUpgradeRequired with custom error message

func NewErrUseProxy

func NewErrUseProxy(message string) error

NewErrUseProxy returns a new ErrUseProxy with custom error message

func NewErrVariantAlsoNegotiates

func NewErrVariantAlsoNegotiates(message string) error

NewErrVariantAlsoNegotiates returns a new ErrVariantAlsoNegotiates with custom error message

func WrapErrAccepted

func WrapErrAccepted(err error) error

WrapErrAccepted returns a new ErrAccepted, wrapping an existing error

func WrapErrAlreadyReported

func WrapErrAlreadyReported(err error) error

WrapErrAlreadyReported returns a new ErrAlreadyReported, wrapping an existing error

func WrapErrBadGateway

func WrapErrBadGateway(err error) error

WrapErrBadGateway returns a new ErrBadGateway, wrapping an existing error

func WrapErrBadRequest

func WrapErrBadRequest(err error) error

WrapErrBadRequest returns a new ErrBadRequest, wrapping an existing error

func WrapErrConflict

func WrapErrConflict(err error) error

WrapErrConflict returns a new ErrConflict, wrapping an existing error

func WrapErrContinue

func WrapErrContinue(err error) error

WrapErrContinue returns a new ErrContinue, wrapping an existing error

func WrapErrCreated

func WrapErrCreated(err error) error

WrapErrCreated returns a new ErrCreated, wrapping an existing error

func WrapErrExpectationFailed

func WrapErrExpectationFailed(err error) error

WrapErrExpectationFailed returns a new ErrExpectationFailed, wrapping an existing error

func WrapErrFailedDependency

func WrapErrFailedDependency(err error) error

WrapErrFailedDependency returns a new ErrFailedDependency, wrapping an existing error

func WrapErrForbidden

func WrapErrForbidden(err error) error

WrapErrForbidden returns a new ErrForbidden, wrapping an existing error

func WrapErrFound

func WrapErrFound(err error) error

WrapErrFound returns a new ErrFound, wrapping an existing error

func WrapErrGatewayTimeout

func WrapErrGatewayTimeout(err error) error

WrapErrGatewayTimeout returns a new ErrGatewayTimeout, wrapping an existing error

func WrapErrGone

func WrapErrGone(err error) error

WrapErrGone returns a new ErrGone, wrapping an existing error

func WrapErrHTTPVersionNotSupported

func WrapErrHTTPVersionNotSupported(err error) error

WrapErrHTTPVersionNotSupported returns a new ErrHTTPVersionNotSupported, wrapping an existing error

func WrapErrIMUsed

func WrapErrIMUsed(err error) error

WrapErrIMUsed returns a new ErrIMUsed, wrapping an existing error

func WrapErrInsufficientStorage

func WrapErrInsufficientStorage(err error) error

WrapErrInsufficientStorage returns a new ErrInsufficientStorage, wrapping an existing error

func WrapErrInternalServerError

func WrapErrInternalServerError(err error) error

WrapErrInternalServerError returns a new ErrInternalServerError, wrapping an existing error

func WrapErrLengthRequired

func WrapErrLengthRequired(err error) error

WrapErrLengthRequired returns a new ErrLengthRequired, wrapping an existing error

func WrapErrLocked

func WrapErrLocked(err error) error

WrapErrLocked returns a new ErrLocked, wrapping an existing error

func WrapErrLoopDetected

func WrapErrLoopDetected(err error) error

WrapErrLoopDetected returns a new ErrLoopDetected, wrapping an existing error

func WrapErrMethodNotAllowed

func WrapErrMethodNotAllowed(err error) error

WrapErrMethodNotAllowed returns a new ErrMethodNotAllowed, wrapping an existing error

func WrapErrMovedPermanently

func WrapErrMovedPermanently(err error) error

WrapErrMovedPermanently returns a new ErrMovedPermanently, wrapping an existing error

func WrapErrMultiStatus

func WrapErrMultiStatus(err error) error

WrapErrMultiStatus returns a new ErrMultiStatus, wrapping an existing error

func WrapErrMultipleChoices

func WrapErrMultipleChoices(err error) error

WrapErrMultipleChoices returns a new ErrMultipleChoices, wrapping an existing error

func WrapErrNetworkAuthenticationRequired

func WrapErrNetworkAuthenticationRequired(err error) error

WrapErrNetworkAuthenticationRequired returns a new ErrNetworkAuthenticationRequired, wrapping an existing error

func WrapErrNoContent

func WrapErrNoContent(err error) error

WrapErrNoContent returns a new ErrNoContent, wrapping an existing error

func WrapErrNonAuthoritativeInfo

func WrapErrNonAuthoritativeInfo(err error) error

WrapErrNonAuthoritativeInfo returns a new ErrNonAuthoritativeInfo, wrapping an existing error

func WrapErrNotAcceptable

func WrapErrNotAcceptable(err error) error

WrapErrNotAcceptable returns a new ErrNotAcceptable, wrapping an existing error

func WrapErrNotExtended

func WrapErrNotExtended(err error) error

WrapErrNotExtended returns a new ErrNotExtended, wrapping an existing error

func WrapErrNotFound

func WrapErrNotFound(err error) error

WrapErrNotFound returns a new ErrNotFound, wrapping an existing error

func WrapErrNotImplemented

func WrapErrNotImplemented(err error) error

WrapErrNotImplemented returns a new ErrNotImplemented, wrapping an existing error

func WrapErrNotModified

func WrapErrNotModified(err error) error

WrapErrNotModified returns a new ErrNotModified, wrapping an existing error

func WrapErrPartialContent

func WrapErrPartialContent(err error) error

WrapErrPartialContent returns a new ErrPartialContent, wrapping an existing error

func WrapErrPaymentRequired

func WrapErrPaymentRequired(err error) error

WrapErrPaymentRequired returns a new ErrPaymentRequired, wrapping an existing error

func WrapErrPermanentRedirect

func WrapErrPermanentRedirect(err error) error

WrapErrPermanentRedirect returns a new ErrPermanentRedirect, wrapping an existing error

func WrapErrPreconditionFailed

func WrapErrPreconditionFailed(err error) error

WrapErrPreconditionFailed returns a new ErrPreconditionFailed, wrapping an existing error

func WrapErrPreconditionRequired

func WrapErrPreconditionRequired(err error) error

WrapErrPreconditionRequired returns a new ErrPreconditionRequired, wrapping an existing error

func WrapErrProcessing

func WrapErrProcessing(err error) error

WrapErrProcessing returns a new ErrProcessing, wrapping an existing error

func WrapErrProxyAuthRequired

func WrapErrProxyAuthRequired(err error) error

WrapErrProxyAuthRequired returns a new ErrProxyAuthRequired, wrapping an existing error

func WrapErrRequestEntityTooLarge

func WrapErrRequestEntityTooLarge(err error) error

WrapErrRequestEntityTooLarge returns a new ErrRequestEntityTooLarge, wrapping an existing error

func WrapErrRequestHeaderFieldsTooLarge

func WrapErrRequestHeaderFieldsTooLarge(err error) error

WrapErrRequestHeaderFieldsTooLarge returns a new ErrRequestHeaderFieldsTooLarge, wrapping an existing error

func WrapErrRequestTimeout

func WrapErrRequestTimeout(err error) error

WrapErrRequestTimeout returns a new ErrRequestTimeout, wrapping an existing error

func WrapErrRequestURITooLong

func WrapErrRequestURITooLong(err error) error

WrapErrRequestURITooLong returns a new ErrRequestURITooLong, wrapping an existing error

func WrapErrRequestedRangeNotSatisfiable

func WrapErrRequestedRangeNotSatisfiable(err error) error

WrapErrRequestedRangeNotSatisfiable returns a new ErrRequestedRangeNotSatisfiable, wrapping an existing error

func WrapErrResetContent

func WrapErrResetContent(err error) error

WrapErrResetContent returns a new ErrResetContent, wrapping an existing error

func WrapErrSeeOther

func WrapErrSeeOther(err error) error

WrapErrSeeOther returns a new ErrSeeOther, wrapping an existing error

func WrapErrServiceUnavailable

func WrapErrServiceUnavailable(err error) error

WrapErrServiceUnavailable returns a new ErrServiceUnavailable, wrapping an existing error

func WrapErrSwitchingProtocols

func WrapErrSwitchingProtocols(err error) error

WrapErrSwitchingProtocols returns a new ErrSwitchingProtocols, wrapping an existing error

func WrapErrTeapot

func WrapErrTeapot(err error) error

WrapErrTeapot returns a new ErrTeapot, wrapping an existing error

func WrapErrTemporaryRedirect

func WrapErrTemporaryRedirect(err error) error

WrapErrTemporaryRedirect returns a new ErrTemporaryRedirect, wrapping an existing error

func WrapErrTooManyRequests

func WrapErrTooManyRequests(err error) error

WrapErrTooManyRequests returns a new ErrTooManyRequests, wrapping an existing error

func WrapErrUnauthorized

func WrapErrUnauthorized(err error) error

WrapErrUnauthorized returns a new ErrUnauthorized, wrapping an existing error

func WrapErrUnavailableForLegalReasons

func WrapErrUnavailableForLegalReasons(err error) error

WrapErrUnavailableForLegalReasons returns a new ErrUnavailableForLegalReasons, wrapping an existing error

func WrapErrUnprocessableEntity

func WrapErrUnprocessableEntity(err error) error

WrapErrUnprocessableEntity returns a new ErrUnprocessableEntity, wrapping an existing error

func WrapErrUnsupportedMediaType

func WrapErrUnsupportedMediaType(err error) error

WrapErrUnsupportedMediaType returns a new ErrUnsupportedMediaType, wrapping an existing error

func WrapErrUpgradeRequired

func WrapErrUpgradeRequired(err error) error

WrapErrUpgradeRequired returns a new ErrUpgradeRequired, wrapping an existing error

func WrapErrUseProxy

func WrapErrUseProxy(err error) error

WrapErrUseProxy returns a new ErrUseProxy, wrapping an existing error

func WrapErrVariantAlsoNegotiates

func WrapErrVariantAlsoNegotiates(err error) error

WrapErrVariantAlsoNegotiates returns a new ErrVariantAlsoNegotiates, wrapping an existing error

Types

type AbstractEvent

type AbstractEvent struct {
	// contains filtered or unexported fields
}

AbstractEvent provides a base implementation of an event

func (*AbstractEvent) GetBody

func (ae *AbstractEvent) GetBody() []byte

GetBody returns the body of the event

func (*AbstractEvent) GetBodyObject

func (ae *AbstractEvent) GetBodyObject() interface{}

GetBodyObject returns the body of the event as an object

func (*AbstractEvent) GetContentType

func (ae *AbstractEvent) GetContentType() string

GetContentType returns the content type of the body

func (*AbstractEvent) GetField

func (ae *AbstractEvent) GetField(key string) interface{}

GetField returns the field by name as an interface{}

func (*AbstractEvent) GetFieldByteSlice

func (ae *AbstractEvent) GetFieldByteSlice(key string) []byte

GetFieldByteSlice returns the field by name as a byte slice

func (*AbstractEvent) GetFieldInt

func (ae *AbstractEvent) GetFieldInt(key string) (int, error)

GetFieldInt returns the field by name as an integer

func (*AbstractEvent) GetFieldString

func (ae *AbstractEvent) GetFieldString(key string) string

GetFieldString returns the field by name as a string

func (*AbstractEvent) GetFields

func (ae *AbstractEvent) GetFields() map[string]interface{}

GetFields loads all fields into a map of string / interface{}

func (*AbstractEvent) GetHeader

func (ae *AbstractEvent) GetHeader(key string) interface{}

GetHeader returns the header by name as an interface{}

func (*AbstractEvent) GetHeaderByteSlice

func (ae *AbstractEvent) GetHeaderByteSlice(key string) []byte

GetHeaderByteSlice returns the header by name as a byte slice

func (*AbstractEvent) GetHeaderInt

func (ae *AbstractEvent) GetHeaderInt(key string) (int, error)

GetHeaderInt returns the field by name as an integer

func (*AbstractEvent) GetHeaderString

func (ae *AbstractEvent) GetHeaderString(key string) string

GetHeaderString returns the header by name as a string

func (*AbstractEvent) GetHeaders

func (ae *AbstractEvent) GetHeaders() map[string]interface{}

GetHeaders loads all headers into a map of string / interface{}

func (*AbstractEvent) GetID

func (ae *AbstractEvent) GetID() ID

GetID returns the ID of the event

func (*AbstractEvent) GetLastInBatch added in v0.1.0

func (ae *AbstractEvent) GetLastInBatch() bool

GetLastInBatch returns whether the event is the last event in a trigger specific batch

func (*AbstractEvent) GetMethod

func (ae *AbstractEvent) GetMethod() string

GetPath returns the method of the event, if applicable

func (*AbstractEvent) GetOffset added in v0.1.0

func (ae *AbstractEvent) GetOffset() int

GetOffset returns the offset of the event

func (*AbstractEvent) GetPath

func (ae *AbstractEvent) GetPath() string

GetPath returns the path of the event

func (*AbstractEvent) GetShardID

func (ae *AbstractEvent) GetShardID() int

GetShardID returns the ID of the shard from which this event arrived, if applicable

func (*AbstractEvent) GetTimestamp

func (ae *AbstractEvent) GetTimestamp() time.Time

GetTimestamp returns when the event originated

func (*AbstractEvent) GetTotalNumShards

func (ae *AbstractEvent) GetTotalNumShards() int

GetTotalNumShards returns the total number of shards, if applicable

func (*AbstractEvent) GetTriggerInfo

func (ae *AbstractEvent) GetTriggerInfo() TriggerInfoProvider

GetTriggerInfo returns a trigger info provider

func (*AbstractEvent) GetType

func (ae *AbstractEvent) GetType() string

GetType returns the type of event

func (*AbstractEvent) GetTypeVersion

func (ae *AbstractEvent) GetTypeVersion() string

GetTypeVersion returns the version of the type

func (*AbstractEvent) GetURL

func (ae *AbstractEvent) GetURL() string

GetURL returns the URL of the event

func (*AbstractEvent) GetVersion

func (ae *AbstractEvent) GetVersion() string

GetVersion returns the version of the event

func (*AbstractEvent) SetID

func (ae *AbstractEvent) SetID(id ID)

SetID sets the ID of the event

func (*AbstractEvent) SetTriggerInfoProvider

func (ae *AbstractEvent) SetTriggerInfoProvider(triggerInfoProvider TriggerInfoProvider)

SetTriggerInfoProvider sets the information about the trigger who triggered this event

type Context

type Context struct {

	// Logger allows submitting information to logger sinks configured in the platform
	Logger logger.Logger

	// DataBinding holds a map of <data binding name> <data binding object>. For example, if the user
	// configured the function to bind to an Azure Event Hub, it will hold an instance of an Event Hub
	// client. The user can type cast this to the client type
	DataBinding map[string]DataBinding

	// Platform is set of platform-specific functions like "invoking other function"
	Platform *Platform

	// WorkerID holds the unique identifier of the worker currently handling the event. It can be used
	// to key into shared datasets to prevent locking
	WorkerID int

	// UserData is nil by default. This holds information set by the user should he need access to long
	// living data. The lifetime of this pointer is that of the _worker_ and workers can come and go.
	// Treat this like cache - always check if it's nil prior to access and re-populate if necessary
	UserData interface{}

	// FunctionName holds the name of the function currently running
	FunctionName string

	// FunctionVersion holds the version of the function currently running
	FunctionVersion int

	// TriggerKind holds the information about the invoking trigger in this context
	TriggerKind string

	// TriggerName holds the information about the invoking trigger in this context
	TriggerName string

	// WorkerAllocatorName holds the name of the worker allocator
	WorkerAllocatorName string
}

Context holds objects whose lifetime is that of the function instance

type DataBinding

type DataBinding interface{}

DataBinding defines a generic interface to data sources configured in the function. For the time being there is no "abstract" data interface and user will cast this to the specific data source client

type ErrorWithStatusCode

type ErrorWithStatusCode struct {
	// contains filtered or unexported fields
}

ErrorWithStatusCode implements both error and WithStatusCode

func (ErrorWithStatusCode) Error

func (e ErrorWithStatusCode) Error() string

Error returns the error message

func (*ErrorWithStatusCode) GetError

func (e *ErrorWithStatusCode) GetError() error

GetError returns the underlying error

func (*ErrorWithStatusCode) StatusCode

func (e *ErrorWithStatusCode) StatusCode() int

StatusCode returns the status code

type Event

type Event interface {

	// GetID returns the ID of the event
	GetID() ID

	// SetID sets the ID of the event
	SetID(ID)

	// SetTriggerInfoProvider sets the information about the trigger who triggered this event
	SetTriggerInfoProvider(TriggerInfoProvider)

	// GetTriggerInfo retruns a trigger info provider
	GetTriggerInfo() TriggerInfoProvider

	// GetContentType returns the content type of the body
	GetContentType() string

	// GetBody returns the body of the event
	GetBody() []byte

	// GetBodyObject returns the body of the event as an object
	GetBodyObject() interface{}

	// GetHeader returns the header by name as an interface{}
	GetHeader(string) interface{}

	// GetHeaderByteSlice returns the header by name as a byte slice
	GetHeaderByteSlice(string) []byte

	// GetHeaderString returns the header by name as a string
	GetHeaderString(string) string

	// GetHeaderInt returns the field by name as an integer
	GetHeaderInt(string) (int, error)

	// GetHeaders loads all headers into a map of string / interface{}
	GetHeaders() map[string]interface{}

	// GetField returns the field by name as an interface{}
	GetField(string) interface{}

	// GetFieldByteSlice returns the field by name as a byte slice
	GetFieldByteSlice(string) []byte

	// GetFieldString returns the field by name as a string
	GetFieldString(string) string

	// GetFieldInt returns the field by name as an integer
	GetFieldInt(string) (int, error)

	// GetFields loads all fields into a map of string / interface{}
	GetFields() map[string]interface{}

	// GetTimestamp returns when the event originated
	GetTimestamp() time.Time

	// GetPath returns the path of the event
	GetPath() string

	// GetURL returns the URL of the event
	GetURL() string

	// GetPath returns the method of the event, if applicable
	GetMethod() string

	// GetShardID returns the ID of the shard from which this event arrived, if applicable
	GetShardID() int

	// GetTotalNumShards returns the total number of shards, if applicable
	GetTotalNumShards() int

	// GetType returns the type of event
	GetType() string

	// GetTypeVersion returns the version of the type
	GetTypeVersion() string

	// GetVersion returns the version of the event
	GetVersion() string

	// GetLastInBatch returns whether the event is the last event in a trigger specific batch
	GetLastInBatch() bool

	// GetOffset returns the offset of the event
	GetOffset() int
}

Event allows access to the concrete event

type ID

type ID string

ID is event ID

type MemoryEvent

type MemoryEvent struct {
	AbstractEvent
	Method      string
	ContentType string
	Body        []byte
	Headers     map[string]interface{}
	Path        string
}

func (*MemoryEvent) GetBody

func (me *MemoryEvent) GetBody() []byte

func (*MemoryEvent) GetContentType

func (me *MemoryEvent) GetContentType() string

func (*MemoryEvent) GetHeader

func (me *MemoryEvent) GetHeader(key string) interface{}

func (*MemoryEvent) GetHeaders

func (me *MemoryEvent) GetHeaders() map[string]interface{}

func (*MemoryEvent) GetMethod

func (me *MemoryEvent) GetMethod() string

func (*MemoryEvent) GetPath

func (me *MemoryEvent) GetPath() string

type Platform

type Platform struct {
	// contains filtered or unexported fields
}

func NewPlatform

func NewPlatform(parentLogger logger.Logger, kind string, namespace string) (*Platform, error)

func (*Platform) CallFunction

func (p *Platform) CallFunction(functionName string, event Event) (Response, error)

type Response

type Response struct {
	StatusCode  int
	ContentType string
	Headers     map[string]interface{}
	Body        []byte
}

Response can be returned from functions, allowing the user to specify various fields

type TriggerInfoProvider

type TriggerInfoProvider interface {

	// get the class of source (sync, async, etc)
	GetClass() string

	// get specific kind of source (http, rabbit mq, etc)
	GetKind() string

	// get given name of trigger
	GetName() string
}

TriggerInfoProvider provides information about the trigger in which this event originated

type WithStatusCode

type WithStatusCode interface {
	StatusCode() int
}

WithStatusCode is an error with status code

Jump to

Keyboard shortcuts

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