Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCESQLVerifyCorrelationIdFilter ¶
RegisterCESQLVerifyCorrelationIdFilter registers a new function with the CESQL runtime to verify correlation ids The function signature is KN_VERIFY_CORRELATION_ID(correlation_id, name, namespace, secret_name, pod_idx, replica_count)
func SetCorrelationId ¶
func SetCorrelationId(ce *cloudevents.Event, correlationIdName string, aesKey []byte, idx int) error
SetCorrelationId sets the correlationid for a cloudevent by encrypting the id and setting the correlationid attribute with the original and encrypted ids
Types ¶
type AESKeyStore ¶ added in v0.47.0
type AESKeyStore struct {
Logger *zap.SugaredLogger
// contains filtered or unexported fields
}
func (*AESKeyStore) GetAllKeys ¶ added in v0.47.0
func (ks *AESKeyStore) GetAllKeys(rrName types.NamespacedName) ([][]byte, bool)
func (*AESKeyStore) GetLatestKey ¶ added in v0.47.0
func (ks *AESKeyStore) GetLatestKey(rrName types.NamespacedName) ([]byte, bool)
func (*AESKeyStore) StopWatch ¶ added in v0.47.0
func (ks *AESKeyStore) StopWatch()
func (*AESKeyStore) WatchPath ¶ added in v0.47.0
func (ks *AESKeyStore) WatchPath(basePath string) error
type IngressHandler ¶ added in v0.47.0
type IngressHandler struct {
// contains filtered or unexported fields
}
func NewHandler ¶ added in v0.47.0
func NewHandler(logger *zap.Logger, requestReplyInformer eventingv1alpha1informers.RequestReplyInformer, trustBundleConfigMapLister corev1listers.ConfigMapNamespaceLister, keyStore *AESKeyStore, podIdx int) *IngressHandler
func (*IngressHandler) ServeHTTP ¶ added in v0.47.0
func (h *IngressHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.