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 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) 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 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) Enqueue

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

Enqueue enqueues an event in the Cooldown Queue

func (*CooldownQueue) Stop

func (q *CooldownQueue) Stop()