channels

Documentation

Index

• Variables
• func EmailSecretKey(receverName, from string) string
• type ChannelConfig
  • func (ChannelConfig) GormDBDataType(db *gorm.DB, field *schema.Field) string
  • func (m ChannelConfig) GormDataType() string
  • func (m ChannelConfig) MarshalJSON() ([]byte, error)
  • func (m *ChannelConfig) Scan(val interface{}) error
  • func (m *ChannelConfig) UnmarshalJSON(b []byte) error
  • func (m ChannelConfig) Value() (driver.Value, error)
• type ChannelGetter
• type ChannelIf
• type ChannelMapper
  • func (m *ChannelMapper) FindChannel(id uint) (ChannelIf, error)
• type ChannelType
• type Email
  • func (e *Email) Check() error
  • func (e *Email) Test(alert prometheus.WebhookAlert) error
  • func (e *Email) ToReceiver(name string) v1alpha1.Receiver
• type Feishu
  • func (f *Feishu) Check() error
  • func (f *Feishu) Test(alert prometheus.WebhookAlert) error
  • func (f *Feishu) ToReceiver(name string) v1alpha1.Receiver
• type Webhook
  • func (w *Webhook) Check() error
  • func (w *Webhook) Test(alert prometheus.WebhookAlert) error
  • func (w *Webhook) ToReceiver(name string) v1alpha1.Receiver

Variables

var (
	EmailSecretName                    = "gemscloud-email-password"
	EmailSecretLabel map[string]string = map[string]string{
		"gemcloud": "email-secret",
	}
)

var (
	KubegemsWebhookURL = fmt.Sprintf("https://kubegems-local-agent.%s:8041/alert", gems.NamespaceLocal)
)

Functions

func EmailSecretKey

func EmailSecretKey(receverName, from string) string

Types

type ChannelConfig

type ChannelConfig struct {
	ChannelIf
}

func (ChannelConfig) GormDBDataType

func (ChannelConfig) GormDBDataType(db *gorm.DB, field *schema.Field) string

GormDBDataType gorm db data type

func (ChannelConfig) GormDataType

func (m ChannelConfig) GormDataType() string

GormDataType gorm common data type

func (ChannelConfig) MarshalJSON

func (m ChannelConfig) MarshalJSON() ([]byte, error)

MarshalJSON to output non base64 encoded []byte

func (*ChannelConfig) Scan

func (m *ChannelConfig) Scan(val interface{}) error

Scan scan value into Jsonb, implements sql.Scanner interface

func (*ChannelConfig) UnmarshalJSON

func (m *ChannelConfig) UnmarshalJSON(b []byte) error

UnmarshalJSON to deserialize []byte

func (ChannelConfig) Value

func (m ChannelConfig) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type ChannelGetter

type ChannelGetter func(id uint) (ChannelIf, error)

type ChannelIf

type ChannelIf interface {
	ToReceiver(name string) v1alpha1.Receiver
	Check() error
	Test(alert prometheus.WebhookAlert) error
}

type ChannelMapper

type ChannelMapper struct {
	M   map[uint]ChannelIf
	Err error
}

func (*ChannelMapper) FindChannel

func (m *ChannelMapper) FindChannel(id uint) (ChannelIf, error)

type ChannelType

type ChannelType string

const (
	TypeWebhook ChannelType = "webhook"
	TypeEmail   ChannelType = "email"
	TypeFeishu  ChannelType = "feishu"
)

type Email

type Email struct {
	ChannelType  `json:"channelType"`
	SMTPServer   string `json:"smtpServer"`
	RequireTLS   bool   `json:"requireTLS"`
	From         string `json:"from"`
	To           string `json:"to"`
	AuthPassword string `json:"authPassword"`
}

func (*Email) Check

func (e *Email) Check() error

func (*Email) Test

func (e *Email) Test(alert prometheus.WebhookAlert) error

func (*Email) ToReceiver

func (e *Email) ToReceiver(name string) v1alpha1.Receiver

type Feishu

type Feishu struct {
	ChannelType `json:"channelType"`
	URL         string `json:"url"`        // feishu robot webhook url
	At          string `json:"at"`         // 要@的用户id，所有人则是 all
	SignSecret  string `json:"signSecret"` // 签名校验key
}

func (*Feishu) Check

func (f *Feishu) Check() error

func (*Feishu) Test

func (f *Feishu) Test(alert prometheus.WebhookAlert) error

func (*Feishu) ToReceiver

func (f *Feishu) ToReceiver(name string) v1alpha1.Receiver

type Webhook

type Webhook struct {
	ChannelType        `json:"channelType"`
	URL                string `json:"url"`
	InsecureSkipVerify bool   `json:"insecureSkipVerify"`
}

func (*Webhook) Check

func (w *Webhook) Check() error

func (*Webhook) Test

func (w *Webhook) Test(alert prometheus.WebhookAlert) error

func (*Webhook) ToReceiver

func (w *Webhook) ToReceiver(name string) v1alpha1.Receiver