utils

Documentation

Index

• Variables
• 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 DeptMsgIdFromContext(ctx context.Context) (int, string)
• func FileContent(path string) []byte
• func FileToUnstructured(path string) *unstructured.Unstructured
• func GetDialer() func(context.Context, string, string) (net.Conn, error)
• func GreaterOrEqualVersion(a string, b string) bool
• func IsBatchMessageSupported(version string) bool
• func NewBackOff() backoff.BackOff
• func NewClient() (dynamic.Interface, spdxv1beta1.SpdxV1beta1Interface, error)
• func NewMsgId() string
• func PulsarMessageIDtoString(msgID pulsar.MessageID) string
• func ServePprof()
• func StartLivenessProbe()
• func StringValueBigger(s1, s2 string) bool
• type CooldownQueue
  • func NewCooldownQueue() *CooldownQueue
  • func (q *CooldownQueue) Closed() bool
  • func (q *CooldownQueue) Enqueue(e watch.Event)
  • func (q *CooldownQueue) Stop()
• type CronTicker
  • func NewCronTicker(schedule string) (*CronTicker, error)
  • func (c *CronTicker) Chan() <-chan time.Time
  • func (c *CronTicker) Stop()
• type StdTicker
  • func NewStdTicker(d time.Duration) *StdTicker
  • func (g *StdTicker) Chan() <-chan time.Time
• type Ticker

Variables

var Direct = direct{}

Direct is a direct proxy: one that makes network connections directly.

Functions

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 DeptMsgIdFromContext

func DeptMsgIdFromContext(ctx context.Context) (int, string)

func FileContent

func FileContent(path string) []byte

func FileToUnstructured

func FileToUnstructured(path string) *unstructured.Unstructured

func GetDialer

func GetDialer() func(context.Context, string, string) (net.Conn, error)

GetDialer returns a net.DialContext function that uses a proxy if necessary. HTTP_PROXY and HTTPS_PROXY are used to determine the proxy to use. NO_PROXY is currently ignored.

func GreaterOrEqualVersion

func GreaterOrEqualVersion(a string, b string) bool

GreaterOrEqualVersion returns true if a version is greater or equal to b

func IsBatchMessageSupported

func IsBatchMessageSupported(version string) bool

func NewBackOff

func NewBackOff() backoff.BackOff

func NewClient

func NewClient() (dynamic.Interface, spdxv1beta1.SpdxV1beta1Interface, error)

func NewMsgId

func NewMsgId() string

func PulsarMessageIDtoString

func PulsarMessageIDtoString(msgID pulsar.MessageID) string

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

func ServePprof

func ServePprof()

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 waits for a cooldown period before the event is forwarded to the consumer. If and event for the same key is put into the queue again before the cooldown period is over, the event is overridden and the cooldown period is reset.

func NewCooldownQueue

func NewCooldownQueue() *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()

type CronTicker

type CronTicker struct {
	C chan time.Time
	// contains filtered or unexported fields
}

CronTicker is the struct returned to the user as a proxy to the ticker. The user can check the ticker channel for the next 'tick' via CronTicker.C (similar to the user of time.Timer).

func NewCronTicker

func NewCronTicker(schedule string) (*CronTicker, error)

NewCronTicker returns a CronTicker struct. You can check the ticker channel for the next tick by `CronTicker.Chan()`.

func (*CronTicker) Chan

func (c *CronTicker) Chan() <-chan time.Time

func (*CronTicker) Stop

func (c *CronTicker) Stop()

Stop sends the appropriate message on the control channel to kill the CronTicker goroutines. It's good practice to use `defer CronTicker.Stop()`.

type StdTicker

type StdTicker struct {
	*time.Ticker
}

func NewStdTicker

func NewStdTicker(d time.Duration) *StdTicker

func (*StdTicker) Chan

func (g *StdTicker) Chan() <-chan time.Time

type Ticker

type Ticker interface {
	Chan() <-chan time.Time
	Stop()
}