calc

type ActiveRulesCalculator struct {

	// Callback objects.
	RuleScanner         ruleScanner
	PolicyMatchListener PolicyMatchListener
	// contains filtered or unexported fields
}

type AsyncCalcGraph struct {
	Dispatcher *dispatcher.Dispatcher
	// contains filtered or unexported fields
}

type ConfigBatcher struct {
	// contains filtered or unexported fields
}

type DatastoreNotReady struct{}

type EventBuffer struct {
	Callback EventHandler
	// contains filtered or unexported fields
}

type EventHandler func(message interface{})

type FelixSender interface {
	SendUpdateToFelix(update model.KVPair)
}

type HostIPPassthru struct {
	// contains filtered or unexported fields
}

type IPAddRemoveCallbacks interface {
	OnIPAdded(ipSetID string, ip ip.Addr)
	OnIPRemoved(ipSetID string, ip ip.Addr)
}

type MemberCalculator struct {
	// contains filtered or unexported fields
}

type ParsedRule struct {
	Action string

	IPVersion *int

	Protocol *numorstring.Protocol

	SrcNet      *net.IPNet
	SrcPorts    []numorstring.Port
	DstNet      *net.IPNet
	DstPorts    []numorstring.Port
	ICMPType    *int
	ICMPCode    *int
	SrcIPSetIDs []string
	DstIPSetIDs []string

	NotProtocol    *numorstring.Protocol
	NotSrcNet      *net.IPNet
	NotSrcPorts    []numorstring.Port
	NotDstNet      *net.IPNet
	NotDstPorts    []numorstring.Port
	NotICMPType    *int
	NotICMPCode    *int
	NotSrcIPSetIDs []string
	NotDstIPSetIDs []string

	LogPrefix string
}

type ParsedRules struct {
	InboundRules  []*ParsedRule
	OutboundRules []*ParsedRule
}

type PipelineCallbacks interface {
	// contains filtered or unexported methods
}

type PolKV struct {
	Key   model.PolicyKey
	Value *model.Policy
}

type PolicyByOrder []PolKV

type PolicyMatchListener interface {
	OnPolicyMatch(policyKey model.PolicyKey, endpointKey interface{})
	OnPolicyMatchStopped(policyKey model.PolicyKey, endpointKey interface{})
}

type PolicyResolver struct {
	Callbacks PolicyResolverCallbacks
	InSync    bool
	// contains filtered or unexported fields
}

type PolicyResolverCallbacks interface {
	OnEndpointTierUpdate(endpointKey model.Key, endpoint interface{}, filteredTiers []tierInfo)
}

type PolicySorter struct {
	// contains filtered or unexported fields
}

type RuleScanner struct {
	OnSelectorActive   func(selector selector.Selector)
	OnSelectorInactive func(selector selector.Selector)
	OnTagActive        func(tag string)
	OnTagInactive      func(tag string)

	RulesUpdateCallbacks rulesUpdateCallbacks
	// contains filtered or unexported fields
}

type StatsCollector struct {
	Callback func(StatsUpdate) error
	// contains filtered or unexported fields
}

type StatsUpdate struct {
	NumHosts             int
	NumWorkloadEndpoints int
	NumHostEndpoints     int
}

type SyncerCallbacksDecoupler struct {
	// contains filtered or unexported fields
}

type ValidationFilter struct {
	// contains filtered or unexported fields
}