utils

Documentation

Index

• Constants
• func CanonicalHash(in []byte) (string, error)
• func ClientIdentifierFromContext(ctx context.Context) domain.ClientIdentifier
• func CompareJson(a, b []byte) bool
• func ContextFromGeneric(parent context.Context, generic domain.Generic) context.Context
• func ContextFromIdentifiers(parent context.Context, id domain.ClientIdentifier) context.Context
• func FilterAndMarshal(d *unstructured.Unstructured) ([]byte, error)
• func NewClient() (dynamic.Interface, error)
• func PulsarMessageIDtoString(msgID pulsar.MessageID) string
• func StartLivenessProbe()
• func StringValueBigger(s1, s2 string) bool
• type CooldownQueue
  • func NewCooldownQueue(size int, cooldown time.Duration) *CooldownQueue
  • func (q *CooldownQueue) Closed() bool
  • func (q *CooldownQueue) Enqueue(e watch.Event)
  • func (q *CooldownQueue) Stop()

Constants

const (
	// Default size for the cooldown queue
	DefaultQueueSize = 512
	// Default TTL for events put in the queue
	DefaultTTL = 5 * time.Second
)

Functions

func CanonicalHash

func CanonicalHash(in []byte) (string, error)

func ClientIdentifierFromContext

func ClientIdentifierFromContext(ctx context.Context) domain.ClientIdentifier

func CompareJson

func CompareJson(a, b []byte) bool

func ContextFromGeneric

func ContextFromGeneric(parent context.Context, generic domain.Generic) context.Context

func ContextFromIdentifiers

func ContextFromIdentifiers(parent context.Context, id domain.ClientIdentifier) context.Context

func FilterAndMarshal

func FilterAndMarshal(d *unstructured.Unstructured) ([]byte, error)

func NewClient

func NewClient() (dynamic.Interface, error)

func PulsarMessageIDtoString

func PulsarMessageIDtoString(msgID pulsar.MessageID) string

PulsarMessageIDtoString is taken from github.com/kubescape/event-ingester-service/utils/common.go:func PulsarMessageIDtoString

func StartLivenessProbe

func StartLivenessProbe()

func StringValueBigger

func StringValueBigger(s1, s2 string) bool

Types

type CooldownQueue

type CooldownQueue struct {

	// public channel for reading events
	ResultChan <-chan watch.Event
	// contains filtered or unexported fields
}

CooldownQueue is a queue that lets clients put events into it with a cooldown

When a client puts an event into a queue, it forwards the event to its output channel and starts a cooldown for this event. If a client attempts to put the same event into the queue while the cooldown is running, the queue will silently drop the event. When the cooldown resets and a client puts the same event into the queue, it will be forwarded to the output channel

func NewCooldownQueue

func NewCooldownQueue(size int, cooldown time.Duration) *CooldownQueue

NewCooldownQueue returns a new Cooldown Queue

func (*CooldownQueue) Closed

func (q *CooldownQueue) Closed() bool

func (*CooldownQueue) Enqueue

func (q *CooldownQueue) Enqueue(e watch.Event)

Enqueue enqueues an event in the Cooldown Queue

func (*CooldownQueue) Stop

func (q *CooldownQueue) Stop()