MCPcopy
hub / github.com/keploy/keploy / FilterConfigMocksTierAware

Function FilterConfigMocksTierAware

pkg/util.go:2962–2974  ·  view source on GitHub ↗

FilterConfigMocksTierAware is the tier-aware variant of FilterConfigMocks. Identical to FilterConfigMocks except it threads firstWindowStart through to filterByTimeStampTierAware. Used by the agent's UpdateMockParams so startup-init entries in the unfiltered (config) pool are kept in the filtered re

(ctx context.Context, logger *zap.Logger, m []*models.Mock, afterTime time.Time, beforeTime time.Time, strict bool, firstWindowStart time.Time)

Source from the content-addressed store, hash-verified

2960// tier-aware strict branch) and reach MockManager.SetMocksWithWindow
2961// where the startup-tier partition sorts them correctly.
2962func FilterConfigMocksTierAware(ctx context.Context, logger *zap.Logger, m []*models.Mock, afterTime time.Time, beforeTime time.Time, strict bool, firstWindowStart time.Time) []*models.Mock {
2963 filteredMocks, unfilteredMocks := filterByTimeStampTierAware(ctx, logger, m, afterTime, beforeTime, strict, firstWindowStart)
2964
2965 sort.SliceStable(filteredMocks, func(i, j int) bool {
2966 return filteredMocks[i].Spec.ReqTimestampMock.Before(filteredMocks[j].Spec.ReqTimestampMock)
2967 })
2968
2969 sort.SliceStable(unfilteredMocks, func(i, j int) bool {
2970 return unfilteredMocks[i].Spec.ReqTimestampMock.Before(unfilteredMocks[j].Spec.ReqTimestampMock)
2971 })
2972
2973 return append(filteredMocks, unfilteredMocks...)
2974}
2975
2976func FilterTcsMocksMapping(ctx context.Context, logger *zap.Logger, m []*models.Mock, mocksPresentInMapping []string) []*models.Mock {
2977 filteredMocks, _ := filterByMapping(ctx, logger, m, mocksPresentInMapping)

Callers 2

UpdateMockParamsMethod · 0.92
FilterConfigMocksFunction · 0.85

Calls 1

Tested by

no test coverage detected