requestreply

Oct 29, 2025

Changes in this version

+ type AESKeyStore struct

+ Logger *zap.SugaredLogger

+ func (ks *AESKeyStore) GetAllKeys(rrName types.NamespacedName) ([][]byte, bool)

+ func (ks *AESKeyStore) GetLatestKey(rrName types.NamespacedName) ([]byte, bool)

+ func (ks *AESKeyStore) StopWatch()

+ func (ks *AESKeyStore) WatchPath(basePath string) error

+ type IngressHandler struct

+ func NewHandler(logger *zap.Logger, ...) *IngressHandler

+ func (h *IngressHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

Jul 22, 2025

Changes in this version

+ func RegisterCESQLVerifyCorrelationIdFilter(ctx context.Context) error

+ func SetCorrelationId(ce *cloudevents.Event, correlationIdName string, aesKey []byte) error

+ func VerifyReplyId(replyId string, aesKey []byte) (bool, error)