filterstore

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

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

type BoolMapPromise interface {
	Result() (map[string]bool, error)
}

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

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

type Filter interface {
	Create(ctx context.Context, info *itemfilterRPC_pb.RedisFilterSetting) error
	Add(ctx context.Context, RefreshTTL bool, elements ...string) error
	CreateAndAdd(ctx context.Context, info *itemfilterRPC_pb.RedisFilterSetting, elements ...string) error
	Status(ctx context.Context) (*itemfilterRPC_pb.RedisFilterStatus, error)
	CheckIn(ctx context.Context, candidates ...string) (map[string]bool, error)
	Clean(ctx context.Context) error

	PipeCreateAndAdd(pipe redis.Pipeliner, ctx context.Context, info *itemfilterRPC_pb.RedisFilterSetting, expat string, elements ...string) error
	PipeCheckIn(pipe redis.Pipeliner, ctx context.Context, candidates ...string) (BoolMapPromise, error)
	PipeStatus(pipe redis.Pipeliner, ctx context.Context) FilterStatusPromise
}

type FilterPromise struct {
	Defaultsetting *itemfilterRPC_pb.RedisFilterSetting
	Expat          string
	// contains filtered or unexported fields
}

type FilterStatusPromise interface {
	Result() (*itemfilterRPC_pb.RedisFilterStatus, error)
}

type FilterStore interface {
	Init(opts ...optparams.Option[Options]) error

	//黑名单
	BlacklistKey(blacklistid string) string

	NewBlacklist(blacklistid string, setting *itemfilterRPC_pb.RedisFilterSetting, Content ...string) error
	BlacklistStatus(blacklistid string) (*itemfilterRPC_pb.RedisFilterStatus, error)
	DeleteBlacklist(id string) error
	UpdateBlacklistSource(id string, Content ...string) error
	CheckSourceInBlacklist(id string, Candidates ...string) (CandidateStatus map[string]bool, err error)
	FilterSourceInBlacklist(id string, Need, ChunkSize int32, Candidates ...string) (Survivor []string, err error)

	//range
	RangeKey(rangeid string) string

	NewRange(rangeid string, setting *itemfilterRPC_pb.RedisFilterSetting, Content ...string) error
	RangeStatus(rangeid string) (*itemfilterRPC_pb.RedisFilterStatus, error)
	DeleteRange(id string) error
	AddRangeSource(id string, Content ...string) error
	CheckSourceInRange(id string, Candidates ...string) (CandidateStatus map[string]bool, err error)
	FilterSourceNotInRange(id string, Need, ChunkSize int32, Candidates ...string) (Survivor []string, err error)

	//context
	ContextKeyTemplate() string
	ContextKey(EntitySourceType, ContextID string) string
	NewContext(EntitySourceType, ContextID string, setting *itemfilterRPC_pb.RedisFilterSetting, Content ...string) error
	ContextStatus(EntitySourceType, ContextID string) (*itemfilterRPC_pb.RedisFilterStatus, error)

	//picker
	PickerKeyTemplate() string
	PickerKey(EntitySourceType, PickerInterval, PickerID string) string
	NewPicker(EntitySourceType, PickerID string, settings map[string]*itemfilterRPC_pb.RedisFilterSetting, Content ...string) error
	PickerStatus(EntitySourceType, PickerID string) (map[string]*itemfilterRPC_pb.RedisFilterStatus, error)
	//opra
	SetEntitySourceUsed(*itemfilterRPC_pb.SetSourceUsedQuery) error
	CheckEntitySource(Condition *itemfilterRPC_pb.Condition, Candidates ...string) (CandidateStatus map[string]bool, err error)
	FilterEntitySource(Condition *itemfilterRPC_pb.Condition, Need, ChunkSize int32, Candidates ...string) (Survivor []string, err error)

	//pickercounter
	PickerCounterKeyTemplate() string
	PickerCounterKey(Date time.Time) string
	RangePickerCounterKeyTemplate() string
	RangePickerCounterKey(Date time.Time, RID string) string

	GetPickerCounterNumber(Days, Offset int32, mod itemfilterRPC_pb.UnionMod, Ranges ...string) (map[string]int64, error)
}

type Options struct {
	RedisURL                                      string
	RedisRouteMod                                 string
	ConnTimeout                                   int
	NamespaceBase                                 string
	BlacklistConfig_KeySubnamespace               string
	BlacklistConfig_DefaultTTLDays                int
	RangeConfig_KeySubnamespace                   string
	RangeConfig_FilterType                        string
	NamespaceConfig_EntitySourceTypeSubnamespace  string
	ContextConfig_KeySubnamespace                 string
	NamespaceConfig_PickerIntervalSubnamespace    string
	NamespaceConfig_PickerSubnamespace            string
	NamespaceConfig_PickerCounterSubnamespace     string
	NamespaceConfig_PickerCounterDateSubnamespace string

	PickerCounterOn                    bool
	PickerCounterConfig_TTLDays        int
	PickerCounterConfig_RangeCounterOn bool
	PickerCounterConfig_RangeTTLDays   int

	DefaultBlacklistFilterInfo *itemfilterRPC_pb.SetFilterSetting
	DefaultRangeFilterInfo     *itemfilterRPC_pb.RedisFilterSetting
	DefaultContextFilterInfo   *itemfilterRPC_pb.RedisFilterSetting
	DefaultPickerFilterInfos   map[string]*itemfilterRPC_pb.RedisFilterSetting
}

type RedisFilterStore struct {
	Opts Options
	// contains filtered or unexported fields
}

type SetBoolMapPlacehold struct {
	Cmd   *redis.BoolSliceCmd
	Items []string
}

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

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