Documentation
¶
Index ¶
- func GroupIntentsBySource(intents []TimestampedIntent) []model.ServiceIntents
- type IntentsConnectionCounter
- type IntentsHolder
- func (i *IntentsHolder) AddIntent(newTimestamp time.Time, intent model.Intent, sourcePorts []int64)
- func (i *IntentsHolder) GetIntents(namespaces []string, includeLabels []string, excludeServiceWithLabels []string, ...) ([]TimestampedIntent, error)
- func (i *IntentsHolder) GetNewIntentsSinceLastGet() []TimestampedIntent
- func (i *IntentsHolder) PeriodicIntentsUpload(ctx context.Context, interval time.Duration)
- func (i *IntentsHolder) RegisterNotifyIntents(callback func(context.Context, []TimestampedIntent))
- func (i *IntentsHolder) Reset()
- type IntentsStore
- type IntentsStoreKey
- type TimestampedIntent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GroupIntentsBySource ¶
func GroupIntentsBySource(intents []TimestampedIntent) []model.ServiceIntents
Types ¶
type IntentsConnectionCounter ¶
type IntentsConnectionCounter map[IntentsStoreKey]*concurrentconnectioncounter.ConnectionCounter[*concurrentconnectioncounter.CountableIntentIntent]
type IntentsHolder ¶
type IntentsHolder struct {
// contains filtered or unexported fields
}
func NewIntentsHolder ¶
func NewIntentsHolder() *IntentsHolder
func (*IntentsHolder) GetIntents ¶
func (i *IntentsHolder) GetIntents( namespaces []string, includeLabels []string, excludeServiceWithLabels []string, includeAllLabels bool, serverFilter *model.ServerFilter, ) ([]TimestampedIntent, error)
func (*IntentsHolder) GetNewIntentsSinceLastGet ¶
func (i *IntentsHolder) GetNewIntentsSinceLastGet() []TimestampedIntent
func (*IntentsHolder) PeriodicIntentsUpload ¶
func (i *IntentsHolder) PeriodicIntentsUpload(ctx context.Context, interval time.Duration)
func (*IntentsHolder) RegisterNotifyIntents ¶
func (i *IntentsHolder) RegisterNotifyIntents(callback func(context.Context, []TimestampedIntent))
func (*IntentsHolder) Reset ¶
func (i *IntentsHolder) Reset()
type IntentsStore ¶
type IntentsStore map[IntentsStoreKey]TimestampedIntent
type IntentsStoreKey ¶
type IntentsStoreKey struct {
Source types.NamespacedName
Destination types.NamespacedName
Type model.IntentType
}
type TimestampedIntent ¶
type TimestampedIntent struct {
Timestamp time.Time
ConnectionsCount *cloudclient.ConnectionsCount
Intent model.Intent
}
Source Files
Click to show internal directories.
Click to hide internal directories.