pkg

Documentation

Index

• func AMQPHandler(msg *message.Message) ([]*message.Message, error)
• func GithubWebhookHandler(msg *message.Message) ([]*message.Message, error)
• func GrafanaHandler(msg *message.Message) ([]*message.Message, error)
• func GrafanaMarshaller(credentials string) http.MarshalMessageFunc
• func SetupRouter(router *message.Router, c Config, logger watermill.LoggerAdapter) error
• func SlackHandler(msg *message.Message) ([]*message.Message, error)
• func SlackMarshaller(url string, msg *message.Message) (*http.Request, error)
• type Config
  • func LoadConfig() Config
• type DeploySimulator
  • func (d DeploySimulator) Handle(msg *message.Message) ([]*message.Message, error)

Functions

func AMQPHandler

func AMQPHandler(msg *message.Message) ([]*message.Message, error)

AMQPHandler receives a deployment message over AMQP and translates it into a commitDeployed event.

func GithubWebhookHandler

func GithubWebhookHandler(msg *message.Message) ([]*message.Message, error)

GithubWebhookHandler receives GitHub webhooks and translates each commit details into a commitPushed event.

func GrafanaHandler

func GrafanaHandler(msg *message.Message) ([]*message.Message, error)

GrafanaHandler receives an event and translates it into an annotation payload compatible with Grafana REST API.

func GrafanaMarshaller

func GrafanaMarshaller(credentials string) http.MarshalMessageFunc

func SetupRouter

func SetupRouter(router *message.Router, c Config, logger watermill.LoggerAdapter) error

func SlackHandler

func SlackHandler(msg *message.Message) ([]*message.Message, error)

SlackHandler receives an event and translates it into a message payload compatible with Slack REST API.

func SlackMarshaller

func SlackMarshaller(url string, msg *message.Message) (*http.Request, error)

Types

type Config

type Config struct {
	BindAddr        string
	MetricsBindAddr string

	AMQPURI   string
	AMQPQueue string

	KafkaBrokers []string
	KafkaTopic   string

	GrafanaURL         string
	GrafanaCredentials string

	SlackWebhookURL string
}

func LoadConfig

func LoadConfig() Config

type DeploySimulator

type DeploySimulator struct {
	Env   string
	Delay time.Duration
}

DeploySimulator simulates deployment messages for each commitPushed event.

func (DeploySimulator) Handle

func (d DeploySimulator) Handle(msg *message.Message) ([]*message.Message, error)

Handle receives a commitPushed event, waits for chosen duration and produces a commitDeployed event.