dispatchers

package
v0.1.4-0...-f970457 Latest Latest
Warning

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

Go to latest
Published: Dec 17, 2019 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

Types

type ForwarderDispatcher

type ForwarderDispatcher struct {
	webhookd.WebhookDispatcher
	DestinationURL string
}

func NewForwarderDispatcher

func NewForwarderDispatcher(destinationURL string) (*ForwarderDispatcher, error)

func (*ForwarderDispatcher) Dispatch

func (fdr *ForwarderDispatcher) Dispatch(body []byte) *webhookd.WebhookError

type LambdaDispatcher

type LambdaDispatcher struct {
	webhookd.WebhookDispatcher
	LambdaFunction string
	LambdaService  *lambda.Lambda
}

func NewLambdaDispatcher

func NewLambdaDispatcher(lambda_dsn string, lambda_function string) (*LambdaDispatcher, error)

func (*LambdaDispatcher) Dispatch

func (d *LambdaDispatcher) Dispatch(body []byte) *webhookd.WebhookError

type LogDispatcher

type LogDispatcher struct {
	webhookd.WebhookDispatcher
}

func NewLogDispatcher

func NewLogDispatcher() (*LogDispatcher, error)

func (*LogDispatcher) Dispatch

func (n *LogDispatcher) Dispatch(body []byte) *webhookd.WebhookError

type NullDispatcher

type NullDispatcher struct {
	webhookd.WebhookDispatcher
}

func NewNullDispatcher

func NewNullDispatcher() (*NullDispatcher, error)

func (*NullDispatcher) Dispatch

func (n *NullDispatcher) Dispatch(body []byte) *webhookd.WebhookError

type PubSubDispatcher

type PubSubDispatcher struct {
	webhookd.WebhookDispatcher
	// contains filtered or unexported fields
}

func NewPubSubDispatcher

func NewPubSubDispatcher(host string, port string, channel string) (*PubSubDispatcher, error)

func (*PubSubDispatcher) Dispatch

func (dispatcher *PubSubDispatcher) Dispatch(body []byte) *webhookd.WebhookError

type SlackDispatcher

type SlackDispatcher struct {
	webhookd.WebhookDispatcher
	// contains filtered or unexported fields
}

func NewSlackDispatcher

func NewSlackDispatcher(slackcat_config string) (*SlackDispatcher, error)

func (*SlackDispatcher) Dispatch

func (sl *SlackDispatcher) Dispatch(body []byte) *webhookd.WebhookError

Jump to

Keyboard shortcuts

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