encryptor

func GetDecryptorWithKey ¶

func GetDecryptorWithKey(name string, key []byte, encryptProps map[string]any) (message.Decryptor, error)

func GetDefaultDecryptor ¶

func GetDefaultDecryptor() (message.Decryptor, error)

GetDefaultDecryptor returns the singleton of the decryptor

func GetEncryptWriter ¶

func GetEncryptWriter(name string, output io.Writer, conf *model.KuiperConf) (io.Writer, error)

func GetEncryptor ¶

func GetEncryptor(name string, encryptProps map[string]any, conf *model.KuiperConf) (message.Encryptor, error)

GetEncryptor currently, decryptor and encryptor are the same instance

func InitConf ¶

func InitConf(enc *model.EncryptionConf, k []byte)

InitConf run in server start up