common

func CryptoRandomHex ¶

func CryptoRandomHex(len int) (string, error)

CryptoRandomHex 生成16进制随机数

func GetEmailFromAccessToken ¶

func GetEmailFromAccessToken(token *string) (string, error)

func NewRedisClient ¶

func NewRedisClient() (*redis.Client, error)

func Pub ¶

func Pub(client *redis.Client, channel string, payload string) error

func ReadINI ¶

func ReadINI(iniPath string) (map[string]string, error)

Sample: vaultConf := "/login/vault/vault.conf" vaultProps, err := ReadINI(vaultConf) endpoint := vaultProps["endpoint"]

if os.IsNotExist(err) || strings.TrimSpace(endpoint) == "" {
	beego.Info("getVaultInstance ", err)
	panic("please check vault properties")
}

ReadINI read ini file into map

func Sub ¶

func Sub(pubsub *redis.PubSub, persist bool, f func(string)) error

func TriggerSlack ¶

func TriggerSlack(slackToken, channelName, text string, blocks []*Blocks) error

blocks sample:

titleBlock := &Blocks{
	Type: "section",
	Text: &TextPayload{
		Type: "mrkdwn",
		Text: "*Bastionhost bastionhost-sample installation complete*",
	},
}

bodyBlock := &Blocks{
	Type: "section",
	Text: &TextPayload{
		Type: "mrkdwn",
		Text: "ClusterID: bp59t7fd0ttl3j541hng\nClusterName: OSSTestDal13\nLogin URL: `tsh login --proxy osstestdal13-0278914c3cb0e2be944d47de59947e32-0039.us-south.containers.appdomain.cloud:443`",
	},
}

blocks := make([]*Blocks, 0) blocks = append(blocks, titleBlock) blocks = append(blocks, bodyBlock)

func TriggerSlackOutdated ¶

func TriggerSlackOutdated(slackToken string, legacySlackMsg *LegacySlackMsg) error