config

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2021 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ChannelCapacity = 1000
)

Functions

This section is empty.

Types

type Config 

type Config struct {
	ReceiverOpts *v2beta1.Options
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context, logger log.Logger) (*Config, error)

func (*Config) GetSecretData 

func (c *Config) GetSecretData(selector *v2beta1.SecretKeySelector) (string, error)

func (*Config) OutputReceiver 

func (c *Config) OutputReceiver(tenant, receiver string) interface{}

func (*Config) RcvsFromNs 

func (c *Config) RcvsFromNs(namespace *string) []Receiver

func (*Config) Run 

func (c *Config) Run() error

type DingTalk 

type DingTalk struct {
	ChatIDs        []string
	ChatBot        *DingTalkChatBot
	DingTalkConfig *DingTalkConfig
	Selector       *metav1.LabelSelector
	// contains filtered or unexported fields
}

func (DingTalk) Enabled added in v1.0.0 

func (c DingTalk) Enabled() bool

func (*DingTalk) GetConfig 

func (d *DingTalk) GetConfig() interface{}

func (*DingTalk) SetConfig 

func (d *DingTalk) SetConfig(obj interface{}) error

func (DingTalk) SetUseDefault 

func (c DingTalk) SetUseDefault(b bool)

func (DingTalk) UseDefault 

func (c DingTalk) UseDefault() bool

type DingTalkChatBot 

type DingTalkChatBot struct {
	Webhook  *v2beta1.SecretKeySelector
	Keywords []string
	Secret   *v2beta1.SecretKeySelector
}

Configuration of ChatBot

type DingTalkConfig 

type DingTalkConfig struct {
	AppKey    *v2beta1.SecretKeySelector
	AppSecret *v2beta1.SecretKeySelector
}

type Email 

type Email struct {
	To          []string
	EmailConfig *EmailConfig
	Selector    *metav1.LabelSelector
	// contains filtered or unexported fields
}

func NewEmail 

func NewEmail(to []string) *Email

func (Email) Enabled added in v1.0.0 

func (c Email) Enabled() bool

func (*Email) GetConfig 

func (e *Email) GetConfig() interface{}

func (*Email) SetConfig 

func (e *Email) SetConfig(obj interface{}) error

func (Email) SetUseDefault 

func (c Email) SetUseDefault(b bool)

func (Email) UseDefault 

func (c Email) UseDefault() bool

type EmailConfig 

type EmailConfig struct {
	From         string
	SmartHost    v2beta1.HostPort
	Hello        string
	AuthUsername string
	AuthIdentify string
	AuthPassword *v2beta1.SecretKeySelector
	AuthSecret   *v2beta1.SecretKeySelector
	RequireTLS   bool
	TLS          *v2beta1.TLSConfig
}

type Receiver 

type Receiver interface {
	Enabled() bool
	UseDefault() bool
	SetUseDefault(b bool)
	GetConfig() interface{}
	SetConfig(c interface{}) error
}

func NewDingTalkConfig added in v1.0.0 

func NewDingTalkConfig(dc *v2beta1.DingTalkConfig) Receiver

func NewDingTalkReceiver 

func NewDingTalkReceiver(c *Config, dr *v2beta1.DingTalkReceiver) Receiver

func NewEmailConfig added in v1.0.0 

func NewEmailConfig(ec *v2beta1.EmailConfig) Receiver

func NewEmailReceiver 

func NewEmailReceiver(c *Config, er *v2beta1.EmailReceiver) Receiver

func NewReceiver added in v1.0.0 

func NewReceiver(c *Config, obj interface{}) Receiver

func NewSlackConfig added in v1.0.0 

func NewSlackConfig(sc *v2beta1.SlackConfig) Receiver

func NewSlackReceiver 

func NewSlackReceiver(c *Config, sr *v2beta1.SlackReceiver) Receiver

func NewWebhookConfig added in v1.0.0 

func NewWebhookConfig(_ *v2beta1.WebhookConfig) Receiver

func NewWebhookReceiver 

func NewWebhookReceiver(_ *Config, wr *v2beta1.WebhookReceiver) Receiver

func NewWechatConfig added in v1.0.0 

func NewWechatConfig(wc *v2beta1.WechatConfig) Receiver

func NewWechatReceiver 

func NewWechatReceiver(c *Config, wr *v2beta1.WechatReceiver) Receiver

type Slack 

type Slack struct {
	// The channel or user to send notifications to.
	Channels    []string
	SlackConfig *SlackConfig
	Selector    *metav1.LabelSelector
	// contains filtered or unexported fields
}

func (Slack) Enabled added in v1.0.0 

func (c Slack) Enabled() bool

func (*Slack) GetConfig 

func (s *Slack) GetConfig() interface{}

func (*Slack) SetConfig 

func (s *Slack) SetConfig(obj interface{}) error

func (Slack) SetUseDefault 

func (c Slack) SetUseDefault(b bool)

func (Slack) UseDefault 

func (c Slack) UseDefault() bool

type SlackConfig 

type SlackConfig struct {
	// The token of user or bot.
	Token *v2beta1.SecretKeySelector
}

type Webhook 

type Webhook struct {
	// `url` gives the location of the webhook, in standard URL form.
	URL           string
	HttpConfig    *v2beta1.HTTPClientConfig
	WebhookConfig *WebhookConfig
	Selector      *metav1.LabelSelector
	// contains filtered or unexported fields
}

func (Webhook) Enabled added in v1.0.0 

func (c Webhook) Enabled() bool

func (*Webhook) GetConfig 

func (w *Webhook) GetConfig() interface{}

func (*Webhook) SetConfig 

func (w *Webhook) SetConfig(obj interface{}) error

func (Webhook) SetUseDefault 

func (c Webhook) SetUseDefault(b bool)

func (Webhook) UseDefault 

func (c Webhook) UseDefault() bool

type WebhookConfig 

type WebhookConfig struct {
}

type Wechat 

type Wechat struct {
	ToUser       []string
	ToParty      []string
	ToTag        []string
	WechatConfig *WechatConfig
	Selector     *metav1.LabelSelector
	// contains filtered or unexported fields
}

func (*Wechat) Clone 

func (w *Wechat) Clone() *Wechat

func (Wechat) Enabled added in v1.0.0 

func (c Wechat) Enabled() bool

func (*Wechat) GetConfig 

func (w *Wechat) GetConfig() interface{}

func (*Wechat) SetConfig 

func (w *Wechat) SetConfig(obj interface{}) error

func (Wechat) SetUseDefault 

func (c Wechat) SetUseDefault(b bool)

func (Wechat) UseDefault 

func (c Wechat) UseDefault() bool

type WechatConfig 

type WechatConfig struct {
	APISecret *v2beta1.SecretKeySelector
	CorpID    string
	APIURL    string
	AgentID   string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.