nuclio

package module
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2024 License: Apache-2.0 Imports: 7 Imported by: 183

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 ErrEarlyHints = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrEarlyHints is a StatusEarlyHints 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 ErrMisdirectedRequest = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrMisdirectedRequest is a StatusMisdirectedRequest 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 ErrTooEarly = ErrorWithStatusCode{/* contains filtered or unexported fields */}

ErrTooEarly is a StatusTooEarly 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 GetByStatusCode added in v0.3.0 

func GetByStatusCode(statusCode int) func(string) error

func GetWrapByStatusCode added in v0.3.0 

func GetWrapByStatusCode(statusCode int) func(error) error

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 NewErrEarlyHints added in v0.3.0 

func NewErrEarlyHints(message string) error

NewErrEarlyHints returns a new ErrEarlyHints 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 NewErrMisdirectedRequest added in v0.3.0 

func NewErrMisdirectedRequest(message string) error

NewErrMisdirectedRequest returns a new ErrMisdirectedRequest 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 NewErrTooEarly added in v0.3.0 

func NewErrTooEarly(message string) error

NewErrTooEarly returns a new ErrTooEarly 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 WrapErrEarlyHints added in v0.3.0 

func WrapErrEarlyHints(err error) error

WrapErrEarlyHints returns a new ErrEarlyHints, 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 WrapErrMisdirectedRequest added in v0.3.0 

func WrapErrMisdirectedRequest(err error) error

WrapErrMisdirectedRequest returns a new ErrMisdirectedRequest, 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 WrapErrTooEarly added in v0.3.0 

func WrapErrTooEarly(err error) error

WrapErrTooEarly returns a new ErrTooEarly, 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

GetMethod 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) GetTopic added in v0.5.1 

func (ae *AbstractEvent) GetTopic() string

GetTopic returns the topic of the event

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

	// GetMethod 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

	// GetTopic returns the topic of the event
	GetTopic() string
}

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 {

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

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

	// GetName 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

Source Files

View all Source files

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.