httpreceiver

Documentation

Index

• type AppConfig
• type NotificationConfig
  • func (c *NotificationConfig) AsMap() map[string]interface{}
• type PluginService
  • func NewPluginService(logger log.Logger, cfg AppConfig, opts ...ServiceOption) *PluginService
  • func (s *PluginService) Notify(ctx context.Context, apiURL string, body []byte) error
  • func (s *PluginService) PreHookDBTransformConfigs(ctx context.Context, receiverConfigMap map[string]interface{}) (map[string]interface{}, error)
  • func (s *PluginService) PreHookQueueTransformConfigs(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)
  • func (s *PluginService) Send(ctx context.Context, notificationMessage notification.Message) (bool, error)
• type ReceiverConfig
  • func (c *ReceiverConfig) AsMap() map[string]interface{}
  • func (c *ReceiverConfig) Validate() error
• type ServiceOption
  • func WithHTTPClient(httpClient *httpclient.Client) ServiceOption
  • func WithRetrier(runner retry.Runner) ServiceOption

Types

type AppConfig

type AppConfig struct {
	Retry      retry.Config      `mapstructure:"retry" yaml:"retry"`
	HTTPClient httpclient.Config `mapstructure:"http_client" yaml:"http_client"`
}

AppConfig is a config loaded when siren is started

type NotificationConfig

type NotificationConfig struct {
	ReceiverConfig `mapstructure:",squash"`
}

func (*NotificationConfig) AsMap

func (c *NotificationConfig) AsMap() map[string]interface{}

type PluginService

type PluginService struct {
	base.UnimplementedService
	// contains filtered or unexported fields
}

func NewPluginService

func NewPluginService(logger log.Logger, cfg AppConfig, opts ...ServiceOption) *PluginService

func (*PluginService) Notify

func (s *PluginService) Notify(ctx context.Context, apiURL string, body []byte) error

func (*PluginService) PreHookDBTransformConfigs

func (s *PluginService) PreHookDBTransformConfigs(ctx context.Context, receiverConfigMap map[string]interface{}) (map[string]interface{}, error)

func (*PluginService) PreHookQueueTransformConfigs

func (s *PluginService) PreHookQueueTransformConfigs(ctx context.Context, notificationConfigMap map[string]interface{}) (map[string]interface{}, error)

func (*PluginService) Send

func (s *PluginService) Send(ctx context.Context, notificationMessage notification.Message) (bool, error)

type ReceiverConfig

type ReceiverConfig struct {
	URL string `mapstructure:"url"`
}

func (*ReceiverConfig) AsMap

func (c *ReceiverConfig) AsMap() map[string]interface{}

func (*ReceiverConfig) Validate

func (c *ReceiverConfig) Validate() error

type ServiceOption

type ServiceOption func(*PluginService)

func WithHTTPClient

func WithHTTPClient(httpClient *httpclient.Client) ServiceOption

WithHTTPClient assigns custom http client when creating a service

func WithRetrier

func WithRetrier(runner retry.Runner) ServiceOption

WithRetrier wraps client call with retrier