notifiers

Documentation

Index

• Constants
• func NewSlackConfig(config *Config) (*slack.Config, error)
• type Client
  • func NewClient(config *Config, logger log.Logger) (Client, error)
• type Config
• type NotifyManager
  • func NewMultiClient(notifiers *[]Config, logger log.Logger) (*NotifyManager, error)
  • func (m *NotifyManager) Notify(ctx context.Context, notification []domain.Notification) []error
• type SlackConfig
  • func (c SlackConfig) Decode(v interface{}) error

Constants

const (
	ProviderTypeSlack = "slack"
	ProviderTypeLark  = "lark"
)

Functions

func NewSlackConfig

func NewSlackConfig(config *Config) (*slack.Config, error)

Types

type Client

type Client interface {
	Notify(context.Context, []domain.Notification) []error
}

func NewClient

func NewClient(config *Config, logger log.Logger) (Client, error)

type Config

type Config struct {
	Provider     string `mapstructure:"provider" validate:"omitempty,oneof=slack lark"`
	Name         string `mapstructure:"name"`
	ClientID     string `mapstructure:"client_id,omitempty"`
	ClientSecret string `mapstructure:"client_secret,omitempty"`
	Criteria     string `mapstructure:"criteria"`

	// slack
	AccessToken string      `mapstructure:"access_token" validate:"required_without=SlackConfig"`
	SlackConfig SlackConfig `mapstructure:"slack_config" validate:"required_without=AccessToken,dive"`
	// custom messages
	Messages domain.NotificationMessages
}

type NotifyManager

type NotifyManager struct {
	// contains filtered or unexported fields
}

func NewMultiClient

func NewMultiClient(notifiers *[]Config, logger log.Logger) (*NotifyManager, error)

func (*NotifyManager) Notify

func (m *NotifyManager) Notify(ctx context.Context, notification []domain.Notification) []error

type SlackConfig

type SlackConfig map[string]interface{}

SlackConfig is a map of workspace name to config

func (SlackConfig) Decode

func (c SlackConfig) Decode(v interface{}) error