webhookrelay

package module

Go to main page

Versions in this module

v0

v0.3.1

Sep 23, 2020

v0.3.0

Sep 23, 2020

Changes in this version

+ const AnyResponseFromOutput

type API

+ func (api *API) DeleteFunctionConfigurationVariable(options *FunctionConfigurationVariableDeleteOptions) error

+ func (api *API) GetWebhookLog(id string) (*Log, error)

+ func (api *API) ListFunctionConfigurationVariables(options *FunctionConfigurationVariablesListOptions) ([]*Variable, error)

+ func (api *API) ListWebhookLogs(options *WebhookLogsListOptions) (*WebhookLogsResponse, error)

+ func (api *API) SetFunctionConfigurationVariable(options *SetFunctionConfigRequest) (*Variable, error)

+ func (api *API) UpdateWebhookLog(updateRequest *WebhookLogsUpdateRequest) error

+ type FunctionConfigurationVariableDeleteOptions struct

+ ID string

+ Key string

+ type FunctionConfigurationVariablesListOptions struct

+ ID string

+ type Headers map[string]interface

+ type ListConfigResponse = reactor_v1.ListConfigResponse

+ type Log struct

+ AccountID string

+ Body string

+ BucketID string

+ CreatedAt time.Time

+ Ephemeral bool

+ ExtraPath string

+ Headers Headers

+ ID string

+ InputID string

+ Internal bool

+ Method string

+ OutputID string

+ RawQuery string

+ ResponseBody []byte

+ ResponseHeaders Headers

+ Retries int

+ Status RequestStatus

+ StatusCode int

+ UpdatedAt time.Time

+ func (l *Log) MarshalJSON() ([]byte, error)

+ func (l *Log) UnmarshalJSON(data []byte) error

type Output

+ Disabled bool

+ LockPath bool

+ type RequestStatus int

+ const RequestStatusFailed

+ const RequestStatusPreparing

+ const RequestStatusReceived

+ const RequestStatusRejected

+ const RequestStatusSent

+ const RequestStatusStalled

+ func (r *RequestStatus) UnmarshalJSON(data []byte) error

+ func (r RequestStatus) MarshalJSON() ([]byte, error)

+ func (s RequestStatus) String() string

+ type SetFunctionConfigRequest struct

+ ID string

+ Key string

+ Value string

+ type Variable = reactor_v1.Variable

+ type WebhookLogsListOptions struct

+ BucketID string

+ From time.Time

+ Limit int

+ Offset int

+ Status RequestStatus

+ To time.Time

+ type WebhookLogsResponse struct

+ Data []*Log

+ Limit int

+ Offset int

+ Total int

+ type WebhookLogsUpdateRequest struct

+ ID string

+ ResponseBody []byte

+ ResponseHeaders Headers

+ Retries int

+ Status RequestStatus

+ StatusCode int

v0.2.0

Jun 14, 2020

Changes in this version

type API

+ func (api *API) UpdateAccessToken(options *AccessToken) (*AccessToken, error)

type AccessToken

+ APIAccess AccessTokenAPIAccess

+ Scopes AccessTokenScopes

+ type AccessTokenAPIAccess string

+ const AccessTokenAPIAccessDisabled

+ const AccessTokenAPIAccessEnabled

type AccessTokenCreateOptions

+ APIAccess AccessTokenAPIAccess

+ Description string

+ Scopes AccessTokenScopes

+ type AccessTokenScopes struct

+ Buckets []string

+ Tunnels []string

v0.1.0

Jun 10, 2020

Changes in this version

+ const AuthToken

+ const CryptoFlexible

+ const CryptoFull

+ const CryptoFullStrict

+ const CryptoOff

+ const CryptoTLSPassThrough

+ const IDFormat

+ const NameFormat

+ var ErrEmptyCredentials = errors.New("invalid credentials: key & secret must not be empty")

+ var ErrNoRef = errors.New("no ref provided or incorrect format")

+ var ErrNoSuchInput = errors.New("no such input")

+ var ErrNoSuchOutput = errors.New("no such output")

+ var IDPattern = regexp.MustCompile(`^` + IDFormat + `$`)

+ var NamePattern = regexp.MustCompile(`^` + NameFormat + `$`)

+ func IsName(s string) bool

+ func IsUUID(s string) bool

+ type API struct

+ APIKey string

+ APISecret string

+ BaseURL string

+ UserAgent string

+ func New(key, secret string, opts ...Option) (*API, error)

+ func (api *API) CreateAccessToken(options *AccessTokenCreateOptions) (*AccessTokenCreateResponse, error)

+ func (api *API) CreateBucket(options *BucketCreateOptions) (*Bucket, error)

+ func (api *API) CreateFunction(opts *CreateFunctionRequest) (*Function, error)

+ func (api *API) CreateInput(options *Input) (*Input, error)

+ func (api *API) CreateOutput(options *Output) (*Output, error)

+ func (api *API) CreateTunnel(options *Tunnel) (*Tunnel, error)

+ func (api *API) DeleteAccessToken(options *AccessTokenDeleteOptions) error

+ func (api *API) DeleteBucket(options *BucketDeleteOptions) error

+ func (api *API) DeleteDomainReservation(options *DomainDeleteOptions) error

+ func (api *API) DeleteFunction(options *FunctionDeleteOptions) error

+ func (api *API) DeleteInput(options *InputDeleteOptions) error

+ func (api *API) DeleteOutput(options *OutputDeleteOptions) error

+ func (api *API) DeleteTunnel(options *TunnelDeleteOptions) error

+ func (api *API) GetBucket(ref string) (*Bucket, error)

+ func (api *API) GetFunction(ref string) (*Function, error)

+ func (api *API) GetTunnel(ref string) (*Tunnel, error)

+ func (api *API) InvokeFunction(options *InvokeOpts) (*ExecuteResponse, error)

+ func (api *API) ListAccessTokens(options *AccessTokenListOptions) ([]*AccessToken, error)

+ func (api *API) ListBuckets(options *BucketListOptions) ([]*Bucket, error)

+ func (api *API) ListDomainReservations(options *DomainListOptions) ([]*Domain, error)

+ func (api *API) ListFunctions(options *FunctionListOptions) ([]*Function, error)

+ func (api *API) ListInputs(options *InputListOptions) ([]*Input, error)

+ func (api *API) ListOutputs(options *OutputListOptions) ([]*Output, error)

+ func (api *API) ListRegions(options *RegionListOptions) ([]*Region, error)

+ func (api *API) ListTunnels(options *TunnelListOptions) ([]*Tunnel, error)

+ func (api *API) ReserveDomain(options *Domain) (*Domain, error)

+ func (api *API) ServerVersion(ctx context.Context) (*VersionInfo, error)

+ func (api *API) UpdateBucket(options *Bucket) (*Bucket, error)

+ func (api *API) UpdateFunction(options *UpdateFunctionRequest) (*Function, error)

+ func (api *API) UpdateInput(options *Input) (*Input, error)

+ func (api *API) UpdateOutput(options *Output) (*Output, error)

+ func (api *API) UpdateTunnel(options *Tunnel) (*Tunnel, error)

+ type AccessToken struct

+ Active bool

+ CreatedAt time.Time

+ Description string

+ ID string

+ LastLogin string

+ UpdatedAt time.Time

+ func (t *AccessToken) MarshalJSON() ([]byte, error)

+ func (t *AccessToken) UnmarshalJSON(data []byte) error

+ type AccessTokenCreateOptions struct

+ type AccessTokenCreateResponse struct

+ Key string

+ Secret string

+ type AccessTokenDeleteOptions struct

+ ID string

+ type AccessTokenListOptions struct

+ type AuthType int

+ const AuthTypeBasic

+ const AuthTypeNone

+ const AuthTypeToken

+ func (r *AuthType) UnmarshalJSON(data []byte) error

+ func (r AuthType) MarshalJSON() ([]byte, error)

+ func (s AuthType) String() string

+ type Bucket struct

+ Auth BucketAuth

+ CreatedAt time.Time

+ Description string

+ Ephemeral bool

+ ID string

+ Inputs []Input

+ Name string

+ Outputs []Output

+ Stream bool

+ UpdatedAt time.Time

+ func (b *Bucket) MarshalJSON() ([]byte, error)

+ func (b *Bucket) UnmarshalJSON(data []byte) error

+ type BucketAuth struct

+ Password string

+ Token string

+ Type AuthType

+ Username string

+ type BucketCreateOptions struct

+ Description string

+ Name string

+ type BucketDeleteOptions struct

+ Force bool

+ Ref string

+ type BucketListOptions struct

+ type CreateFunctionRequest struct

+ Driver string

+ Name string

+ Payload io.Reader

+ type Domain struct

+ CreatedAt time.Time

+ Domain string

+ ID string

+ UpdatedAt time.Time

+ func (d *Domain) MarshalJSON() ([]byte, error)

+ func (d *Domain) UnmarshalJSON(data []byte) error

+ type DomainDeleteOptions struct

+ Ref string

+ type DomainListOptions struct

+ type Endpoint struct

+ Address string

+ type ExecuteResponse = reactor_v1.ExecuteResponse

+ type Features struct

+ RewriteHostHeader string

+ type Function = reactor_v1.Function

+ type FunctionDeleteOptions struct

+ ID string

+ type FunctionListOptions struct

+ type FunctionRequest struct

+ Driver string

+ ID string

+ Name string

+ Payload string

+ type IngressRule struct

+ Endpoints []*Endpoint

+ Name string

+ Path string

+ type IngressRules struct

+ Rules []*IngressRule

+ type Input struct

+ Body string

+ BucketID string

+ CreatedAt time.Time

+ CustomDomain string

+ Description string

+ FunctionID string

+ Headers map[string][]string

+ ID string

+ Name string

+ PathPrefix string

+ ResponseFromOutput string

+ StatusCode int

+ UpdatedAt time.Time

+ func (i *Input) EndpointURL() string

+ func (i *Input) MarshalJSON() ([]byte, error)

+ func (i *Input) String() string

+ func (i *Input) UnmarshalJSON(data []byte) error

+ type InputDeleteOptions struct

+ Bucket string

+ Input string

+ type InputListOptions struct

+ Bucket string

+ type InvokeFunctionRequest struct

+ Headers map[string][]string

+ Method string

+ RawQuery string

+ RequestBody string

+ type InvokeOpts struct

+ ID string

+ InvokeFunctionRequest InvokeFunctionRequest

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ type Option func(*API) error

+ func WithHTTPClient(client *http.Client) Option

+ func WithHeaders(headers http.Header) Option

+ func WithLogger(logger Logger) Option

+ func WithRetryPolicy(maxRetries int, minRetryDelaySecs int, maxRetryDelaySecs int) Option

+ func WithUserAgent(userAgent string) Option

+ type Output struct

+ BucketID string

+ CreatedAt time.Time

+ Description string

+ Destination string

+ FunctionID string

+ Headers map[string][]string

+ ID string

+ Internal bool

+ Name string

+ Timeout int

+ UpdatedAt time.Time

+ func (o *Output) MarshalJSON() ([]byte, error)

+ func (o *Output) UnmarshalJSON(data []byte) error

+ type OutputDeleteOptions struct

+ Bucket string

+ Output string

+ type OutputListOptions struct

+ Bucket string

+ type Region struct

+ CreatedAt time.Time

+ DomainSuffix string

+ ID string

+ Name string

+ ServerAddress string

+ UpdatedAt time.Time

+ func (r *Region) MarshalJSON() ([]byte, error)

+ func (r *Region) UnmarshalJSON(data []byte) error

+ type RegionListOptions struct

+ type RetryPolicy struct

+ MaxRetries int

+ MaxRetryDelay time.Duration

+ MinRetryDelay time.Duration

+ type Tunnel struct

+ AccountID string

+ Addr string

+ Auth TunnelAuth

+ CreatedAt time.Time

+ Crypto string

+ Description string

+ Destination string

+ Features Features

+ Group string

+ Host string

+ ID string

+ IngressRules IngressRules

+ Mode TunnelMode

+ Name string

+ Protocol string

+ Region string

+ UpdatedAt time.Time

+ func (t *Tunnel) GetURL() string

+ func (t *Tunnel) MarshalJSON() ([]byte, error)

+ func (t *Tunnel) UnmarshalJSON(data []byte) error

+ type TunnelAuth struct

+ Password string

+ Token string

+ Type AuthType

+ Username string

+ type TunnelDeleteOptions struct

+ ID string

+ Name string

+ type TunnelListOptions struct

+ type TunnelMode int

+ const TunnelModeActive

+ const TunnelModeInactive

+ func ParseTunnelMode(mode string) TunnelMode

+ func (r *TunnelMode) UnmarshalJSON(data []byte) error

+ func (r TunnelMode) MarshalJSON() ([]byte, error)

+ func (s TunnelMode) String() string

+ type UpdateFunctionRequest struct

+ Driver string

+ ID string

+ Name string

+ Payload io.Reader

+ type VersionInfo struct

+ APIVersion string

+ Arch string

+ BuildDate string

+ Experimental bool

+ GoVersion string

+ KernelVersion string

+ Name string

+ OS string

+ Revision string

+ Version string

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