itemfilterRPC_pb

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 7, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Package itemfilterRPC_pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	MetaDataStoreType_name = map[int32]string{
		0: "SELF",
		1: "REDIS",
		2: "ETCD",
	}
	MetaDataStoreType_value = map[string]int32{
		"SELF":  0,
		"REDIS": 1,
		"ETCD":  2,
	}
)

Enum value maps for MetaDataStoreType.

View Source 
var (
	UnionMod_name = map[int32]string{
		0: "UnionByDayAndRange",
		1: "UnionByRange",
		2: "UnionByDay",
	}
	UnionMod_value = map[string]int32{
		"UnionByDayAndRange": 0,
		"UnionByRange":       1,
		"UnionByDay":         2,
	}
)

Enum value maps for UnionMod.

View Source 
var (
	RedisFilterType_name = map[int32]string{
		0: "SET",
		1: "BLOOM",
		2: "CUCKOO",
	}
	RedisFilterType_value = map[string]int32{
		"SET":    0,
		"BLOOM":  1,
		"CUCKOO": 2,
	}
)

Enum value maps for RedisFilterType.

View Source 
var File_pbschema_itemfilterRPC_blacklistdatamodel_proto protoreflect.FileDescriptor
View Source 
var File_pbschema_itemfilterRPC_metadatamodel_proto protoreflect.FileDescriptor
View Source 
var File_pbschema_itemfilterRPC_rangedatamodel_proto protoreflect.FileDescriptor
View Source 
var File_pbschema_itemfilterRPC_service_proto protoreflect.FileDescriptor
View Source 
var File_pbschema_itemfilterRPC_universal_proto protoreflect.FileDescriptor
View Source 
var ITEMFILTERRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "itemfilterRPC.ITEMFILTERRPC",
	HandlerType: (*ITEMFILTERRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMeta",
			Handler:    _ITEMFILTERRPC_GetMeta_Handler,
		},
		{
			MethodName: "GetBlacklistList",
			Handler:    _ITEMFILTERRPC_GetBlacklistList_Handler,
		},
		{
			MethodName: "NewBlacklist",
			Handler:    _ITEMFILTERRPC_NewBlacklist_Handler,
		},
		{
			MethodName: "GetBlacklistInfo",
			Handler:    _ITEMFILTERRPC_GetBlacklistInfo_Handler,
		},
		{
			MethodName: "DeleteBlacklist",
			Handler:    _ITEMFILTERRPC_DeleteBlacklist_Handler,
		},
		{
			MethodName: "UpdateBlacklistSource",
			Handler:    _ITEMFILTERRPC_UpdateBlacklistSource_Handler,
		},
		{
			MethodName: "CheckSourceInBlacklist",
			Handler:    _ITEMFILTERRPC_CheckSourceInBlacklist_Handler,
		},
		{
			MethodName: "FilterSourceInBlacklist",
			Handler:    _ITEMFILTERRPC_FilterSourceInBlacklist_Handler,
		},
		{
			MethodName: "GetRangeList",
			Handler:    _ITEMFILTERRPC_GetRangeList_Handler,
		},
		{
			MethodName: "NewRange",
			Handler:    _ITEMFILTERRPC_NewRange_Handler,
		},
		{
			MethodName: "GetRangeInfo",
			Handler:    _ITEMFILTERRPC_GetRangeInfo_Handler,
		},
		{
			MethodName: "DeleteRange",
			Handler:    _ITEMFILTERRPC_DeleteRange_Handler,
		},
		{
			MethodName: "AddRangeSource",
			Handler:    _ITEMFILTERRPC_AddRangeSource_Handler,
		},
		{
			MethodName: "CheckSourceInRange",
			Handler:    _ITEMFILTERRPC_CheckSourceInRange_Handler,
		},
		{
			MethodName: "FilterSourceNotInRange",
			Handler:    _ITEMFILTERRPC_FilterSourceNotInRange_Handler,
		},
		{
			MethodName: "GetContextStatus",
			Handler:    _ITEMFILTERRPC_GetContextStatus_Handler,
		},
		{
			MethodName: "NewContexts",
			Handler:    _ITEMFILTERRPC_NewContexts_Handler,
		},
		{
			MethodName: "GetPickerStatus",
			Handler:    _ITEMFILTERRPC_GetPickerStatus_Handler,
		},
		{
			MethodName: "NewPickers",
			Handler:    _ITEMFILTERRPC_NewPickers_Handler,
		},
		{
			MethodName: "SetEntitySourceUsed",
			Handler:    _ITEMFILTERRPC_SetEntitySourceUsed_Handler,
		},
		{
			MethodName: "CheckEntitySource",
			Handler:    _ITEMFILTERRPC_CheckEntitySource_Handler,
		},
		{
			MethodName: "FilterEntitySource",
			Handler:    _ITEMFILTERRPC_FilterEntitySource_Handler,
		},
		{
			MethodName: "GetPickerCounterNumber",
			Handler:    _ITEMFILTERRPC_GetPickerCounterNumber_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BatchAddRangeSource",
			Handler:       _ITEMFILTERRPC_BatchAddRangeSource_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "BatchSetEntitySourceUsed",
			Handler:       _ITEMFILTERRPC_BatchSetEntitySourceUsed_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pbschema/itemfilterRPC/service.proto",
}

ITEMFILTERRPC_ServiceDesc is the grpc.ServiceDesc for ITEMFILTERRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterITEMFILTERRPCHandler 

func RegisterITEMFILTERRPCHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterITEMFILTERRPCHandler registers the http handlers for service ITEMFILTERRPC to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterITEMFILTERRPCHandlerClient 

func RegisterITEMFILTERRPCHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ITEMFILTERRPCClient) error

RegisterITEMFILTERRPCHandlerClient registers the http handlers for service ITEMFILTERRPC to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ITEMFILTERRPCClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ITEMFILTERRPCClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ITEMFILTERRPCClient" to call the correct interceptors.

func RegisterITEMFILTERRPCHandlerFromEndpoint 

func RegisterITEMFILTERRPCHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterITEMFILTERRPCHandlerFromEndpoint is same as RegisterITEMFILTERRPCHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterITEMFILTERRPCHandlerServer 

func RegisterITEMFILTERRPCHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ITEMFILTERRPCServer) error

RegisterITEMFILTERRPCHandlerServer registers the http handlers for service ITEMFILTERRPC to "mux". UnaryRPC :call ITEMFILTERRPCServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterITEMFILTERRPCHandlerFromEndpoint instead.

func RegisterITEMFILTERRPCServer 

func RegisterITEMFILTERRPCServer(s grpc.ServiceRegistrar, srv ITEMFILTERRPCServer)

Types

type AddRangeSourceQuery 

type AddRangeSourceQuery struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Content []string `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRangeSourceQuery) Descriptor deprecated 

func (*AddRangeSourceQuery) Descriptor() ([]byte, []int)

Deprecated: Use AddRangeSourceQuery.ProtoReflect.Descriptor instead.

func (*AddRangeSourceQuery) GetContent 

func (x *AddRangeSourceQuery) GetContent() []string

func (*AddRangeSourceQuery) GetId 

func (x *AddRangeSourceQuery) GetId() string

func (*AddRangeSourceQuery) ProtoMessage 

func (*AddRangeSourceQuery) ProtoMessage()

func (*AddRangeSourceQuery) ProtoReflect 

func (x *AddRangeSourceQuery) ProtoReflect() protoreflect.Message

func (*AddRangeSourceQuery) Reset 

func (x *AddRangeSourceQuery) Reset()

func (*AddRangeSourceQuery) String 

func (x *AddRangeSourceQuery) String() string

type BlacklistInfo 

type BlacklistInfo struct {
	Meta       *RedisFilterMeta    `protobuf:"bytes,1,opt,name=Meta,proto3" json:"Meta,omitempty"`
	FilterType RedisFilterType     `protobuf:"varint,2,opt,name=FilterType,proto3,enum=itemfilterRPC.RedisFilterType" json:"FilterType,omitempty"`
	Status     *RedisFilterStatus  `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	Setting    *RedisFilterSetting `protobuf:"bytes,4,opt,name=Setting,proto3" json:"Setting,omitempty"`
	// contains filtered or unexported fields
}

func (*BlacklistInfo) Descriptor deprecated 

func (*BlacklistInfo) Descriptor() ([]byte, []int)

Deprecated: Use BlacklistInfo.ProtoReflect.Descriptor instead.

func (*BlacklistInfo) GetFilterType 

func (x *BlacklistInfo) GetFilterType() RedisFilterType

func (*BlacklistInfo) GetMeta 

func (x *BlacklistInfo) GetMeta() *RedisFilterMeta

func (*BlacklistInfo) GetSetting 

func (x *BlacklistInfo) GetSetting() *RedisFilterSetting

func (*BlacklistInfo) GetStatus 

func (x *BlacklistInfo) GetStatus() *RedisFilterStatus

func (*BlacklistInfo) ProtoMessage 

func (*BlacklistInfo) ProtoMessage()

func (*BlacklistInfo) ProtoReflect 

func (x *BlacklistInfo) ProtoReflect() protoreflect.Message

func (*BlacklistInfo) Reset 

func (x *BlacklistInfo) Reset()

func (*BlacklistInfo) String 

func (x *BlacklistInfo) String() string

type BlacklistInfoResponse 

type BlacklistInfoResponse struct {
	Info *BlacklistInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

blacklist

func (*BlacklistInfoResponse) Descriptor deprecated 

func (*BlacklistInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use BlacklistInfoResponse.ProtoReflect.Descriptor instead.

func (*BlacklistInfoResponse) GetInfo 

func (x *BlacklistInfoResponse) GetInfo() *BlacklistInfo

func (*BlacklistInfoResponse) ProtoMessage 

func (*BlacklistInfoResponse) ProtoMessage()

func (*BlacklistInfoResponse) ProtoReflect 

func (x *BlacklistInfoResponse) ProtoReflect() protoreflect.Message

func (*BlacklistInfoResponse) Reset 

func (x *BlacklistInfoResponse) Reset()

func (*BlacklistInfoResponse) String 

func (x *BlacklistInfoResponse) String() string

type BloomFilterSetting 

type BloomFilterSetting struct {
	Capacity      int64   `protobuf:"varint,1,opt,name=Capacity,proto3" json:"Capacity,omitempty"`
	ErrorRate     float64 `protobuf:"fixed64,2,opt,name=ErrorRate,proto3" json:"ErrorRate,omitempty"`
	Expansion     int64   `protobuf:"varint,3,opt,name=Expansion,proto3" json:"Expansion,omitempty"`
	NonScaling    bool    `protobuf:"varint,4,opt,name=NonScaling,proto3" json:"NonScaling,omitempty"`
	MaxTTLSeconds int64   `protobuf:"varint,5,opt,name=MaxTTLSeconds,proto3" json:"MaxTTLSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*BloomFilterSetting) Descriptor deprecated 

func (*BloomFilterSetting) Descriptor() ([]byte, []int)

Deprecated: Use BloomFilterSetting.ProtoReflect.Descriptor instead.

func (*BloomFilterSetting) GetCapacity 

func (x *BloomFilterSetting) GetCapacity() int64

func (*BloomFilterSetting) GetErrorRate 

func (x *BloomFilterSetting) GetErrorRate() float64

func (*BloomFilterSetting) GetExpansion 

func (x *BloomFilterSetting) GetExpansion() int64

func (*BloomFilterSetting) GetMaxTTLSeconds 

func (x *BloomFilterSetting) GetMaxTTLSeconds() int64

func (*BloomFilterSetting) GetNonScaling 

func (x *BloomFilterSetting) GetNonScaling() bool

func (*BloomFilterSetting) ProtoMessage 

func (*BloomFilterSetting) ProtoMessage()

func (*BloomFilterSetting) ProtoReflect 

func (x *BloomFilterSetting) ProtoReflect() protoreflect.Message

func (*BloomFilterSetting) Reset 

func (x *BloomFilterSetting) Reset()

func (*BloomFilterSetting) String 

func (x *BloomFilterSetting) String() string

type CandidateStatusResponse 

type CandidateStatusResponse struct {
	EntitySourceType string          `protobuf:"bytes,1,opt,name=entity_source_type,json=entitySourceType,proto3" json:"entity_source_type,omitempty"`
	CandidateStatus  map[string]bool `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CandidateStatusResponse) Descriptor deprecated 

func (*CandidateStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use CandidateStatusResponse.ProtoReflect.Descriptor instead.

func (*CandidateStatusResponse) GetCandidateStatus 

func (x *CandidateStatusResponse) GetCandidateStatus() map[string]bool

func (*CandidateStatusResponse) GetEntitySourceType 

func (x *CandidateStatusResponse) GetEntitySourceType() string

func (*CandidateStatusResponse) ProtoMessage 

func (*CandidateStatusResponse) ProtoMessage()

func (*CandidateStatusResponse) ProtoReflect 

func (x *CandidateStatusResponse) ProtoReflect() protoreflect.Message

func (*CandidateStatusResponse) Reset 

func (x *CandidateStatusResponse) Reset()

func (*CandidateStatusResponse) String 

func (x *CandidateStatusResponse) String() string

type CheckQuery 

type CheckQuery struct {
	Conditions *Condition `protobuf:"bytes,1,opt,name=conditions,proto3" json:"conditions,omitempty"`
	Candidates []string   `protobuf:"bytes,2,rep,name=candidates,proto3" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckQuery) Descriptor deprecated 

func (*CheckQuery) Descriptor() ([]byte, []int)

Deprecated: Use CheckQuery.ProtoReflect.Descriptor instead.

func (*CheckQuery) GetCandidates 

func (x *CheckQuery) GetCandidates() []string

func (*CheckQuery) GetConditions 

func (x *CheckQuery) GetConditions() *Condition

func (*CheckQuery) ProtoMessage 

func (*CheckQuery) ProtoMessage()

func (*CheckQuery) ProtoReflect 

func (x *CheckQuery) ProtoReflect() protoreflect.Message

func (*CheckQuery) Reset 

func (x *CheckQuery) Reset()

func (*CheckQuery) String 

func (x *CheckQuery) String() string

type CheckSourceQuery 

type CheckSourceQuery struct {
	Id         string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Candidates []string `protobuf:"bytes,2,rep,name=candidates,proto3" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSourceQuery) Descriptor deprecated 

func (*CheckSourceQuery) Descriptor() ([]byte, []int)

Deprecated: Use CheckSourceQuery.ProtoReflect.Descriptor instead.

func (*CheckSourceQuery) GetCandidates 

func (x *CheckSourceQuery) GetCandidates() []string

func (*CheckSourceQuery) GetId 

func (x *CheckSourceQuery) GetId() string

func (*CheckSourceQuery) ProtoMessage 

func (*CheckSourceQuery) ProtoMessage()

func (*CheckSourceQuery) ProtoReflect 

func (x *CheckSourceQuery) ProtoReflect() protoreflect.Message

func (*CheckSourceQuery) Reset 

func (x *CheckSourceQuery) Reset()

func (*CheckSourceQuery) String 

func (x *CheckSourceQuery) String() string

type Condition 

type Condition struct {
	PickerId         string   `protobuf:"bytes,1,opt,name=picker_id,json=pickerId,proto3" json:"picker_id,omitempty"`
	EntitySourceType string   `protobuf:"bytes,2,opt,name=entity_source_type,json=entitySourceType,proto3" json:"entity_source_type,omitempty"`
	RangeId          string   `protobuf:"bytes,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	ContextIds       []string `protobuf:"bytes,4,rep,name=context_ids,json=contextIds,proto3" json:"context_ids,omitempty"`
	BlacklistIds     []string `protobuf:"bytes,5,rep,name=blacklist_ids,json=blacklistIds,proto3" json:"blacklist_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Condition) Descriptor deprecated 

func (*Condition) Descriptor() ([]byte, []int)

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetBlacklistIds 

func (x *Condition) GetBlacklistIds() []string

func (*Condition) GetContextIds 

func (x *Condition) GetContextIds() []string

func (*Condition) GetEntitySourceType 

func (x *Condition) GetEntitySourceType() string

func (*Condition) GetPickerId 

func (x *Condition) GetPickerId() string

func (*Condition) GetRangeId 

func (x *Condition) GetRangeId() string

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect 

func (x *Condition) ProtoReflect() protoreflect.Message

func (*Condition) Reset 

func (x *Condition) Reset()

func (*Condition) String 

func (x *Condition) String() string

type CuckooFilterSetting 

type CuckooFilterSetting struct {
	Capacity      int64 `protobuf:"varint,1,opt,name=Capacity,proto3" json:"Capacity,omitempty"`
	Expansion     int64 `protobuf:"varint,2,opt,name=Expansion,proto3" json:"Expansion,omitempty"`
	NonScaling    bool  `protobuf:"varint,3,opt,name=NonScaling,proto3" json:"NonScaling,omitempty"`
	BucketSize    int64 `protobuf:"varint,4,opt,name=BucketSize,proto3" json:"BucketSize,omitempty"`
	MaxIterations int64 `protobuf:"varint,5,opt,name=MaxIterations,proto3" json:"MaxIterations,omitempty"`
	MaxTTLSeconds int64 `protobuf:"varint,6,opt,name=MaxTTLSeconds,proto3" json:"MaxTTLSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*CuckooFilterSetting) Descriptor deprecated 

func (*CuckooFilterSetting) Descriptor() ([]byte, []int)

Deprecated: Use CuckooFilterSetting.ProtoReflect.Descriptor instead.

func (*CuckooFilterSetting) GetBucketSize 

func (x *CuckooFilterSetting) GetBucketSize() int64

func (*CuckooFilterSetting) GetCapacity 

func (x *CuckooFilterSetting) GetCapacity() int64

func (*CuckooFilterSetting) GetExpansion 

func (x *CuckooFilterSetting) GetExpansion() int64

func (*CuckooFilterSetting) GetMaxIterations 

func (x *CuckooFilterSetting) GetMaxIterations() int64

func (*CuckooFilterSetting) GetMaxTTLSeconds 

func (x *CuckooFilterSetting) GetMaxTTLSeconds() int64

func (*CuckooFilterSetting) GetNonScaling 

func (x *CuckooFilterSetting) GetNonScaling() bool

func (*CuckooFilterSetting) ProtoMessage 

func (*CuckooFilterSetting) ProtoMessage()

func (*CuckooFilterSetting) ProtoReflect 

func (x *CuckooFilterSetting) ProtoReflect() protoreflect.Message

func (*CuckooFilterSetting) Reset 

func (x *CuckooFilterSetting) Reset()

func (*CuckooFilterSetting) String 

func (x *CuckooFilterSetting) String() string

type FilterQuery 

type FilterQuery struct {
	Conditions *Condition `protobuf:"bytes,1,opt,name=conditions,proto3" json:"conditions,omitempty"`
	Need       int32      `protobuf:"varint,2,opt,name=need,proto3" json:"need,omitempty"`
	ChunkSize  int32      `protobuf:"varint,3,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	Candidates []string   `protobuf:"bytes,4,rep,name=candidates,proto3" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterQuery) Descriptor deprecated 

func (*FilterQuery) Descriptor() ([]byte, []int)

Deprecated: Use FilterQuery.ProtoReflect.Descriptor instead.

func (*FilterQuery) GetCandidates 

func (x *FilterQuery) GetCandidates() []string

func (*FilterQuery) GetChunkSize 

func (x *FilterQuery) GetChunkSize() int32

func (*FilterQuery) GetConditions 

func (x *FilterQuery) GetConditions() *Condition

func (*FilterQuery) GetNeed 

func (x *FilterQuery) GetNeed() int32

func (*FilterQuery) ProtoMessage 

func (*FilterQuery) ProtoMessage()

func (*FilterQuery) ProtoReflect 

func (x *FilterQuery) ProtoReflect() protoreflect.Message

func (*FilterQuery) Reset 

func (x *FilterQuery) Reset()

func (*FilterQuery) String 

func (x *FilterQuery) String() string

type FilterSourceQuery 

type FilterSourceQuery struct {
	Id         string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Need       int32    `protobuf:"varint,2,opt,name=need,proto3" json:"need,omitempty"`
	ChunkSize  int32    `protobuf:"varint,3,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	Candidates []string `protobuf:"bytes,4,rep,name=candidates,proto3" json:"candidates,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterSourceQuery) Descriptor deprecated 

func (*FilterSourceQuery) Descriptor() ([]byte, []int)

Deprecated: Use FilterSourceQuery.ProtoReflect.Descriptor instead.

func (*FilterSourceQuery) GetCandidates 

func (x *FilterSourceQuery) GetCandidates() []string

func (*FilterSourceQuery) GetChunkSize 

func (x *FilterSourceQuery) GetChunkSize() int32

func (*FilterSourceQuery) GetId 

func (x *FilterSourceQuery) GetId() string

func (*FilterSourceQuery) GetNeed 

func (x *FilterSourceQuery) GetNeed() int32

func (*FilterSourceQuery) ProtoMessage 

func (*FilterSourceQuery) ProtoMessage()

func (*FilterSourceQuery) ProtoReflect 

func (x *FilterSourceQuery) ProtoReflect() protoreflect.Message

func (*FilterSourceQuery) Reset 

func (x *FilterSourceQuery) Reset()

func (*FilterSourceQuery) String 

func (x *FilterSourceQuery) String() string

type GetContextStatusResponse 

type GetContextStatusResponse struct {
	FilterStatus *RedisFilterStatus `protobuf:"bytes,1,opt,name=filter_status,json=filterStatus,proto3" json:"filter_status,omitempty"`
	// contains filtered or unexported fields
}

操作

func (*GetContextStatusResponse) Descriptor deprecated 

func (*GetContextStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetContextStatusResponse.ProtoReflect.Descriptor instead.

func (*GetContextStatusResponse) GetFilterStatus 

func (x *GetContextStatusResponse) GetFilterStatus() *RedisFilterStatus

func (*GetContextStatusResponse) ProtoMessage 

func (*GetContextStatusResponse) ProtoMessage()

func (*GetContextStatusResponse) ProtoReflect 

func (x *GetContextStatusResponse) ProtoReflect() protoreflect.Message

func (*GetContextStatusResponse) Reset 

func (x *GetContextStatusResponse) Reset()

func (*GetContextStatusResponse) String 

func (x *GetContextStatusResponse) String() string

type GetPickerCounterNumberQuery 

type GetPickerCounterNumberQuery struct {
	Days   int32    `protobuf:"varint,1,opt,name=days,proto3" json:"days,omitempty"`
	Offset int32    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Mod    UnionMod `protobuf:"varint,3,opt,name=mod,proto3,enum=itemfilterRPC.UnionMod" json:"mod,omitempty"`
	Ranges []string `protobuf:"bytes,4,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

PickerCounter

func (*GetPickerCounterNumberQuery) Descriptor deprecated 

func (*GetPickerCounterNumberQuery) Descriptor() ([]byte, []int)

Deprecated: Use GetPickerCounterNumberQuery.ProtoReflect.Descriptor instead.

func (*GetPickerCounterNumberQuery) GetDays 

func (x *GetPickerCounterNumberQuery) GetDays() int32

func (*GetPickerCounterNumberQuery) GetMod 

func (x *GetPickerCounterNumberQuery) GetMod() UnionMod

func (*GetPickerCounterNumberQuery) GetOffset 

func (x *GetPickerCounterNumberQuery) GetOffset() int32

func (*GetPickerCounterNumberQuery) GetRanges 

func (x *GetPickerCounterNumberQuery) GetRanges() []string

func (*GetPickerCounterNumberQuery) ProtoMessage 

func (*GetPickerCounterNumberQuery) ProtoMessage()

func (*GetPickerCounterNumberQuery) ProtoReflect 

func (x *GetPickerCounterNumberQuery) ProtoReflect() protoreflect.Message

func (*GetPickerCounterNumberQuery) Reset 

func (x *GetPickerCounterNumberQuery) Reset()

func (*GetPickerCounterNumberQuery) String 

func (x *GetPickerCounterNumberQuery) String() string

type GetPickerCounterNumberResponse 

type GetPickerCounterNumberResponse struct {
	Result map[string]int64 `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetPickerCounterNumberResponse) Descriptor deprecated 

func (*GetPickerCounterNumberResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPickerCounterNumberResponse.ProtoReflect.Descriptor instead.

func (*GetPickerCounterNumberResponse) GetResult 

func (x *GetPickerCounterNumberResponse) GetResult() map[string]int64

func (*GetPickerCounterNumberResponse) ProtoMessage 

func (*GetPickerCounterNumberResponse) ProtoMessage()

func (*GetPickerCounterNumberResponse) ProtoReflect 

func (x *GetPickerCounterNumberResponse) ProtoReflect() protoreflect.Message

func (*GetPickerCounterNumberResponse) Reset 

func (x *GetPickerCounterNumberResponse) Reset()

func (*GetPickerCounterNumberResponse) String 

func (x *GetPickerCounterNumberResponse) String() string

type GetPickerStatusResponse 

type GetPickerStatusResponse struct {
	FilterStatus map[string]*RedisFilterStatus `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetPickerStatusResponse) Descriptor deprecated 

func (*GetPickerStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPickerStatusResponse.ProtoReflect.Descriptor instead.

func (*GetPickerStatusResponse) GetFilterStatus 

func (x *GetPickerStatusResponse) GetFilterStatus() map[string]*RedisFilterStatus

func (*GetPickerStatusResponse) ProtoMessage 

func (*GetPickerStatusResponse) ProtoMessage()

func (*GetPickerStatusResponse) ProtoReflect 

func (x *GetPickerStatusResponse) ProtoReflect() protoreflect.Message

func (*GetPickerStatusResponse) Reset 

func (x *GetPickerStatusResponse) Reset()

func (*GetPickerStatusResponse) String 

func (x *GetPickerStatusResponse) String() string

type IDEntitySourceTypeQuery 

type IDEntitySourceTypeQuery struct {
	Id               string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	EntitySourceType string `protobuf:"bytes,2,opt,name=entity_source_type,json=entitySourceType,proto3" json:"entity_source_type,omitempty"`
	// contains filtered or unexported fields
}

func (*IDEntitySourceTypeQuery) Descriptor deprecated 

func (*IDEntitySourceTypeQuery) Descriptor() ([]byte, []int)

Deprecated: Use IDEntitySourceTypeQuery.ProtoReflect.Descriptor instead.

func (*IDEntitySourceTypeQuery) GetEntitySourceType 

func (x *IDEntitySourceTypeQuery) GetEntitySourceType() string

func (*IDEntitySourceTypeQuery) GetId 

func (x *IDEntitySourceTypeQuery) GetId() string

func (*IDEntitySourceTypeQuery) ProtoMessage 

func (*IDEntitySourceTypeQuery) ProtoMessage()

func (*IDEntitySourceTypeQuery) ProtoReflect 

func (x *IDEntitySourceTypeQuery) ProtoReflect() protoreflect.Message

func (*IDEntitySourceTypeQuery) Reset 

func (x *IDEntitySourceTypeQuery) Reset()

func (*IDEntitySourceTypeQuery) String 

func (x *IDEntitySourceTypeQuery) String() string

type IDQuery 

type IDQuery struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

通用请求

func (*IDQuery) Descriptor deprecated 

func (*IDQuery) Descriptor() ([]byte, []int)

Deprecated: Use IDQuery.ProtoReflect.Descriptor instead.

func (*IDQuery) GetId 

func (x *IDQuery) GetId() string

func (*IDQuery) ProtoMessage 

func (*IDQuery) ProtoMessage()

func (*IDQuery) ProtoReflect 

func (x *IDQuery) ProtoReflect() protoreflect.Message

func (*IDQuery) Reset 

func (x *IDQuery) Reset()

func (*IDQuery) String 

func (x *IDQuery) String() string

type IDResponse 

type IDResponse struct {
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

通用响应

func (*IDResponse) Descriptor deprecated 

func (*IDResponse) Descriptor() ([]byte, []int)

Deprecated: Use IDResponse.ProtoReflect.Descriptor instead.

func (*IDResponse) GetID 

func (x *IDResponse) GetID() string

func (*IDResponse) ProtoMessage 

func (*IDResponse) ProtoMessage()

func (*IDResponse) ProtoReflect 

func (x *IDResponse) ProtoReflect() protoreflect.Message

func (*IDResponse) Reset 

func (x *IDResponse) Reset()

func (*IDResponse) String 

func (x *IDResponse) String() string

type ITEMFILTERRPCClient 

type ITEMFILTERRPCClient interface {
	//meta
	//GetMeta 获取服务的配置信息
	GetMeta(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MetaResponse, error)
	//blacklist
	// GetBlacklistList 获取黑名单列表
	GetBlacklistList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListResponse, error)
	//NewBlacklist 创建一个新的blacklist
	NewBlacklist(ctx context.Context, in *NewFilterQuery, opts ...grpc.CallOption) (*IDResponse, error)
	//GetBlacklistInfo 获取黑名单信息
	GetBlacklistInfo(ctx context.Context, in *IDQuery, opts ...grpc.CallOption) (*BlacklistInfoResponse, error)
	//DeleteBlacklist 删除blackList
	DeleteBlacklist(ctx context.Context, in *IDQuery, opts ...grpc.CallOption) (*IDResponse, error)
	//UpdateBlacklistSource 更新BlackList内不可用资源范围
	UpdateBlacklistSource(ctx context.Context, in *UpdateBlacklistSourceQuery, opts ...grpc.CallOption) (*IDResponse, error)
	//CheckSourceInBlacklist 检查物品在不在黑名单中
	CheckSourceInBlacklist(ctx context.Context, in *CheckSourceQuery, opts ...grpc.CallOption) (*CandidateStatusResponse, error)
	//FilterSourceInBlacklist 过滤掉在黑名单中的物品,保留不在的部分
	FilterSourceInBlacklist(ctx context.Context, in *FilterSourceQuery, opts ...grpc.CallOption) (*SurvivorResponse, error)
	//range
	//GetRangeList 获取范围列表
	GetRangeList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListResponse, error)
	//NewRange 创建一个新的range,注意创建并不会向其中添加元素,添加元素请调用AddRangeSource接口
	NewRange(ctx context.Context, in *NewFilterQuery, opts ...grpc.CallOption) (*IDResponse, error)
	//GetRangeInfo 获取范围信息
	GetRangeInfo(ctx context.Context, in *IDQuery, opts ...grpc.CallOption) (*RangeInfoResponse, error)
	//DeleteRange 删除范围
	DeleteRange(ctx context.Context, in *IDQuery, opts ...grpc.CallOption) (*IDResponse, error)
	// AddRangeSource 添加范围内元素
	AddRangeSource(ctx context.Context, in *AddRangeSourceQuery, opts ...grpc.CallOption) (*IDResponse, error)
	// BatchAddRangeSource 添加范围内元素
	BatchAddRangeSource(ctx context.Context, opts ...grpc.CallOption) (ITEMFILTERRPC_BatchAddRangeSourceClient, error)
	//CheckSourceInRange 检查物品在不在range中
	CheckSourceInRange(ctx context.Context, in *CheckSourceQuery, opts ...grpc.CallOption) (*CandidateStatusResponse, error)
	//FilterSourceNotInRange 过滤掉不在范围内的物品,保留在的部分
	FilterSourceNotInRange(ctx context.Context, in *FilterSourceQuery, opts ...grpc.CallOption) (*SurvivorResponse, error)
	//Context
	//GetContextStatus  获取上下文过滤器状态信息
	GetContextStatus(ctx context.Context, in *IDEntitySourceTypeQuery, opts ...grpc.CallOption) (*GetContextStatusResponse, error)
	//NewContexts 批量创建场景
	NewContexts(ctx context.Context, in *NewFilterQuery, opts ...grpc.CallOption) (*IDResponse, error)
	//Picker
	//GetPickerStatus  获取上下文过滤器状态信息
	GetPickerStatus(ctx context.Context, in *IDEntitySourceTypeQuery, opts ...grpc.CallOption) (*GetPickerStatusResponse, error)
	//NewPickers 批量创建Picker
	NewPickers(ctx context.Context, in *NewPickerFilterQuery, opts ...grpc.CallOption) (*IDResponse, error)
	//操作
	//SetEntitySourceUsed  设置资源在指定条件中已被使用
	SetEntitySourceUsed(ctx context.Context, in *SetSourceUsedQuery, opts ...grpc.CallOption) (*emptypb.Empty, error)
	//BatchSetEntitySourceUsed  设置资源在指定条件中已被使用
	BatchSetEntitySourceUsed(ctx context.Context, opts ...grpc.CallOption) (ITEMFILTERRPC_BatchSetEntitySourceUsedClient, error)
	//CheckEntitySource 检查实体资源是否可用
	CheckEntitySource(ctx context.Context, in *CheckQuery, opts ...grpc.CallOption) (*CandidateStatusResponse, error)
	//FilterEntitySource 过滤掉不符合的,保留可用的
	FilterEntitySource(ctx context.Context, in *FilterQuery, opts ...grpc.CallOption) (*SurvivorResponse, error)
	//PickerCounter
	// GetPickerCounterNumber 获取指定条件下PickerCounter的计数值
	// 需要启动相关功能
	GetPickerCounterNumber(ctx context.Context, in *GetPickerCounterNumberQuery, opts ...grpc.CallOption) (*GetPickerCounterNumberResponse, error)
}

ITEMFILTERRPCClient is the client API for ITEMFILTERRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewITEMFILTERRPCClient 

func NewITEMFILTERRPCClient(cc grpc.ClientConnInterface) ITEMFILTERRPCClient

type ITEMFILTERRPCServer 

type ITEMFILTERRPCServer interface {
	//meta
	//GetMeta 获取服务的配置信息
	GetMeta(context.Context, *emptypb.Empty) (*MetaResponse, error)
	//blacklist
	// GetBlacklistList 获取黑名单列表
	GetBlacklistList(context.Context, *emptypb.Empty) (*ListResponse, error)
	//NewBlacklist 创建一个新的blacklist
	NewBlacklist(context.Context, *NewFilterQuery) (*IDResponse, error)
	//GetBlacklistInfo 获取黑名单信息
	GetBlacklistInfo(context.Context, *IDQuery) (*BlacklistInfoResponse, error)
	//DeleteBlacklist 删除blackList
	DeleteBlacklist(context.Context, *IDQuery) (*IDResponse, error)
	//UpdateBlacklistSource 更新BlackList内不可用资源范围
	UpdateBlacklistSource(context.Context, *UpdateBlacklistSourceQuery) (*IDResponse, error)
	//CheckSourceInBlacklist 检查物品在不在黑名单中
	CheckSourceInBlacklist(context.Context, *CheckSourceQuery) (*CandidateStatusResponse, error)
	//FilterSourceInBlacklist 过滤掉在黑名单中的物品,保留不在的部分
	FilterSourceInBlacklist(context.Context, *FilterSourceQuery) (*SurvivorResponse, error)
	//range
	//GetRangeList 获取范围列表
	GetRangeList(context.Context, *emptypb.Empty) (*ListResponse, error)
	//NewRange 创建一个新的range,注意创建并不会向其中添加元素,添加元素请调用AddRangeSource接口
	NewRange(context.Context, *NewFilterQuery) (*IDResponse, error)
	//GetRangeInfo 获取范围信息
	GetRangeInfo(context.Context, *IDQuery) (*RangeInfoResponse, error)
	//DeleteRange 删除范围
	DeleteRange(context.Context, *IDQuery) (*IDResponse, error)
	// AddRangeSource 添加范围内元素
	AddRangeSource(context.Context, *AddRangeSourceQuery) (*IDResponse, error)
	// BatchAddRangeSource 添加范围内元素
	BatchAddRangeSource(ITEMFILTERRPC_BatchAddRangeSourceServer) error
	//CheckSourceInRange 检查物品在不在range中
	CheckSourceInRange(context.Context, *CheckSourceQuery) (*CandidateStatusResponse, error)
	//FilterSourceNotInRange 过滤掉不在范围内的物品,保留在的部分
	FilterSourceNotInRange(context.Context, *FilterSourceQuery) (*SurvivorResponse, error)
	//Context
	//GetContextStatus  获取上下文过滤器状态信息
	GetContextStatus(context.Context, *IDEntitySourceTypeQuery) (*GetContextStatusResponse, error)
	//NewContexts 批量创建场景
	NewContexts(context.Context, *NewFilterQuery) (*IDResponse, error)
	//Picker
	//GetPickerStatus  获取上下文过滤器状态信息
	GetPickerStatus(context.Context, *IDEntitySourceTypeQuery) (*GetPickerStatusResponse, error)
	//NewPickers 批量创建Picker
	NewPickers(context.Context, *NewPickerFilterQuery) (*IDResponse, error)
	//操作
	//SetEntitySourceUsed  设置资源在指定条件中已被使用
	SetEntitySourceUsed(context.Context, *SetSourceUsedQuery) (*emptypb.Empty, error)
	//BatchSetEntitySourceUsed  设置资源在指定条件中已被使用
	BatchSetEntitySourceUsed(ITEMFILTERRPC_BatchSetEntitySourceUsedServer) error
	//CheckEntitySource 检查实体资源是否可用
	CheckEntitySource(context.Context, *CheckQuery) (*CandidateStatusResponse, error)
	//FilterEntitySource 过滤掉不符合的,保留可用的
	FilterEntitySource(context.Context, *FilterQuery) (*SurvivorResponse, error)
	//PickerCounter
	// GetPickerCounterNumber 获取指定条件下PickerCounter的计数值
	// 需要启动相关功能
	GetPickerCounterNumber(context.Context, *GetPickerCounterNumberQuery) (*GetPickerCounterNumberResponse, error)
	// contains filtered or unexported methods
}

ITEMFILTERRPCServer is the server API for ITEMFILTERRPC service. All implementations must embed UnimplementedITEMFILTERRPCServer for forward compatibility

type ITEMFILTERRPC_BatchAddRangeSourceClient 

type ITEMFILTERRPC_BatchAddRangeSourceClient interface {
	Send(*AddRangeSourceQuery) error
	CloseAndRecv() (*ListResponse, error)
	grpc.ClientStream
}

type ITEMFILTERRPC_BatchAddRangeSourceServer 

type ITEMFILTERRPC_BatchAddRangeSourceServer interface {
	SendAndClose(*ListResponse) error
	Recv() (*AddRangeSourceQuery, error)
	grpc.ServerStream
}

type ITEMFILTERRPC_BatchSetEntitySourceUsedClient 

type ITEMFILTERRPC_BatchSetEntitySourceUsedClient interface {
	Send(*SetSourceUsedQuery) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type ITEMFILTERRPC_BatchSetEntitySourceUsedServer 

type ITEMFILTERRPC_BatchSetEntitySourceUsedServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*SetSourceUsedQuery, error)
	grpc.ServerStream
}

type ListResponse 

type ListResponse struct {
	Content []string `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

func (*ListResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetContent 

func (x *ListResponse) GetContent() []string

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type MetaBlacklistConfig 

type MetaBlacklistConfig struct {
	RangeInfoKey       string `protobuf:"bytes,1,opt,name=RangeInfoKey,proto3" json:"RangeInfoKey,omitempty"`
	InfoKeyNamespace   string `protobuf:"bytes,2,opt,name=InfoKeyNamespace,proto3" json:"InfoKeyNamespace,omitempty"`
	InfoDefaultTTLDays int32  `protobuf:"varint,3,opt,name=InfoDefaultTTLDays,proto3" json:"InfoDefaultTTLDays,omitempty"`
	IDGener            string `protobuf:"bytes,4,opt,name=IDGener,proto3" json:"IDGener,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaBlacklistConfig) Descriptor deprecated 

func (*MetaBlacklistConfig) Descriptor() ([]byte, []int)

Deprecated: Use MetaBlacklistConfig.ProtoReflect.Descriptor instead.

func (*MetaBlacklistConfig) GetIDGener 

func (x *MetaBlacklistConfig) GetIDGener() string

func (*MetaBlacklistConfig) GetInfoDefaultTTLDays 

func (x *MetaBlacklistConfig) GetInfoDefaultTTLDays() int32

func (*MetaBlacklistConfig) GetInfoKeyNamespace 

func (x *MetaBlacklistConfig) GetInfoKeyNamespace() string

func (*MetaBlacklistConfig) GetRangeInfoKey 

func (x *MetaBlacklistConfig) GetRangeInfoKey() string

func (*MetaBlacklistConfig) ProtoMessage 

func (*MetaBlacklistConfig) ProtoMessage()

func (*MetaBlacklistConfig) ProtoReflect 

func (x *MetaBlacklistConfig) ProtoReflect() protoreflect.Message

func (*MetaBlacklistConfig) Reset 

func (x *MetaBlacklistConfig) Reset()

func (*MetaBlacklistConfig) String 

func (x *MetaBlacklistConfig) String() string

type MetaContextConfig 

type MetaContextConfig struct {
	KeyTemplate    string              `protobuf:"bytes,1,opt,name=KeyTemplate,proto3" json:"KeyTemplate,omitempty"`
	DefaultSetting *RedisFilterSetting `protobuf:"bytes,2,opt,name=DefaultSetting,proto3" json:"DefaultSetting,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaContextConfig) Descriptor deprecated 

func (*MetaContextConfig) Descriptor() ([]byte, []int)

Deprecated: Use MetaContextConfig.ProtoReflect.Descriptor instead.

func (*MetaContextConfig) GetDefaultSetting 

func (x *MetaContextConfig) GetDefaultSetting() *RedisFilterSetting

func (*MetaContextConfig) GetKeyTemplate 

func (x *MetaContextConfig) GetKeyTemplate() string

func (*MetaContextConfig) ProtoMessage 

func (*MetaContextConfig) ProtoMessage()

func (*MetaContextConfig) ProtoReflect 

func (x *MetaContextConfig) ProtoReflect() protoreflect.Message

func (*MetaContextConfig) Reset 

func (x *MetaContextConfig) Reset()

func (*MetaContextConfig) String 

func (x *MetaContextConfig) String() string

type MetaDataStoreType 

type MetaDataStoreType int32

Meta 

const (
	MetaDataStoreType_SELF  MetaDataStoreType = 0
	MetaDataStoreType_REDIS MetaDataStoreType = 1
	MetaDataStoreType_ETCD  MetaDataStoreType = 2
)

func (MetaDataStoreType) Descriptor 

func (MetaDataStoreType) Descriptor() protoreflect.EnumDescriptor

func (MetaDataStoreType) Enum 

func (x MetaDataStoreType) Enum() *MetaDataStoreType

func (MetaDataStoreType) EnumDescriptor deprecated 

func (MetaDataStoreType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetaDataStoreType.Descriptor instead.

func (MetaDataStoreType) Number 

func (x MetaDataStoreType) Number() protoreflect.EnumNumber

func (MetaDataStoreType) String 

func (x MetaDataStoreType) String() string

func (MetaDataStoreType) Type 

func (MetaDataStoreType) Type() protoreflect.EnumType

type MetaInfo 

type MetaInfo struct {
	RedisURL            string                   `protobuf:"bytes,1,opt,name=RedisURL,proto3" json:"RedisURL,omitempty"`
	MetaDataStoreConfig *MetaMetaDataStoreConfig `protobuf:"bytes,2,opt,name=MetaDataStoreConfig,proto3" json:"MetaDataStoreConfig,omitempty"`
	BlacklistConfig     *MetaBlacklistConfig     `protobuf:"bytes,3,opt,name=BlacklistConfig,proto3" json:"BlacklistConfig,omitempty"`
	RangeConfig         *MetaRangeConfig         `protobuf:"bytes,4,opt,name=RangeConfig,proto3" json:"RangeConfig,omitempty"`
	ContextConfig       *MetaContextConfig       `protobuf:"bytes,5,opt,name=ContextConfig,proto3" json:"ContextConfig,omitempty"`
	PickerConfig        *MetaPickerConfig        `protobuf:"bytes,6,opt,name=PickerConfig,proto3" json:"PickerConfig,omitempty"`
	PickerCounterOn     bool                     `protobuf:"varint,7,opt,name=PickerCounterOn,proto3" json:"PickerCounterOn,omitempty"`
	PickerCounterConfig *MetaPickerCounterConfig `protobuf:"bytes,8,opt,name=PickerCounterConfig,proto3" json:"PickerCounterConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaInfo) Descriptor deprecated 

func (*MetaInfo) Descriptor() ([]byte, []int)

Deprecated: Use MetaInfo.ProtoReflect.Descriptor instead.

func (*MetaInfo) GetBlacklistConfig 

func (x *MetaInfo) GetBlacklistConfig() *MetaBlacklistConfig

func (*MetaInfo) GetContextConfig 

func (x *MetaInfo) GetContextConfig() *MetaContextConfig

func (*MetaInfo) GetMetaDataStoreConfig 

func (x *MetaInfo) GetMetaDataStoreConfig() *MetaMetaDataStoreConfig

func (*MetaInfo) GetPickerConfig 

func (x *MetaInfo) GetPickerConfig() *MetaPickerConfig

func (*MetaInfo) GetPickerCounterConfig 

func (x *MetaInfo) GetPickerCounterConfig() *MetaPickerCounterConfig

func (*MetaInfo) GetPickerCounterOn 

func (x *MetaInfo) GetPickerCounterOn() bool

func (*MetaInfo) GetRangeConfig 

func (x *MetaInfo) GetRangeConfig() *MetaRangeConfig

func (*MetaInfo) GetRedisURL 

func (x *MetaInfo) GetRedisURL() string

func (*MetaInfo) ProtoMessage 

func (*MetaInfo) ProtoMessage()

func (*MetaInfo) ProtoReflect 

func (x *MetaInfo) ProtoReflect() protoreflect.Message

func (*MetaInfo) Reset 

func (x *MetaInfo) Reset()

func (*MetaInfo) String 

func (x *MetaInfo) String() string

type MetaMetaDataStoreConfig 

type MetaMetaDataStoreConfig struct {
	StoreType MetaDataStoreType `protobuf:"varint,1,opt,name=StoreType,proto3,enum=itemfilterRPC.MetaDataStoreType" json:"StoreType,omitempty"`
	StoreURL  string            `protobuf:"bytes,2,opt,name=StoreURL,proto3" json:"StoreURL,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaMetaDataStoreConfig) Descriptor deprecated 

func (*MetaMetaDataStoreConfig) Descriptor() ([]byte, []int)

Deprecated: Use MetaMetaDataStoreConfig.ProtoReflect.Descriptor instead.

func (*MetaMetaDataStoreConfig) GetStoreType 

func (x *MetaMetaDataStoreConfig) GetStoreType() MetaDataStoreType

func (*MetaMetaDataStoreConfig) GetStoreURL 

func (x *MetaMetaDataStoreConfig) GetStoreURL() string

func (*MetaMetaDataStoreConfig) ProtoMessage 

func (*MetaMetaDataStoreConfig) ProtoMessage()

func (*MetaMetaDataStoreConfig) ProtoReflect 

func (x *MetaMetaDataStoreConfig) ProtoReflect() protoreflect.Message

func (*MetaMetaDataStoreConfig) Reset 

func (x *MetaMetaDataStoreConfig) Reset()

func (*MetaMetaDataStoreConfig) String 

func (x *MetaMetaDataStoreConfig) String() string

type MetaPickerConfig 

type MetaPickerConfig struct {
	KeyTemplate string                         `protobuf:"bytes,2,opt,name=KeyTemplate,proto3" json:"KeyTemplate,omitempty"`
	FilterInfos map[string]*RedisFilterSetting `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetaPickerConfig) Descriptor deprecated 

func (*MetaPickerConfig) Descriptor() ([]byte, []int)

Deprecated: Use MetaPickerConfig.ProtoReflect.Descriptor instead.

func (*MetaPickerConfig) GetFilterInfos 

func (x *MetaPickerConfig) GetFilterInfos() map[string]*RedisFilterSetting

func (*MetaPickerConfig) GetKeyTemplate 

func (x *MetaPickerConfig) GetKeyTemplate() string

func (*MetaPickerConfig) ProtoMessage 

func (*MetaPickerConfig) ProtoMessage()

func (*MetaPickerConfig) ProtoReflect 

func (x *MetaPickerConfig) ProtoReflect() protoreflect.Message

func (*MetaPickerConfig) Reset 

func (x *MetaPickerConfig) Reset()

func (*MetaPickerConfig) String 

func (x *MetaPickerConfig) String() string

type MetaPickerCounterConfig 

type MetaPickerCounterConfig struct {
	TTLDays                       int32  `protobuf:"varint,1,opt,name=TTLDays,proto3" json:"TTLDays,omitempty"`
	PickerCounterKeyTemplate      string `protobuf:"bytes,2,opt,name=PickerCounterKeyTemplate,proto3" json:"PickerCounterKeyTemplate,omitempty"`
	RangeCounterOn                bool   `protobuf:"varint,3,opt,name=RangeCounterOn,proto3" json:"RangeCounterOn,omitempty"`
	RangeTTLDays                  int32  `protobuf:"varint,4,opt,name=RangeTTLDays,proto3" json:"RangeTTLDays,omitempty"`
	RangePickerCounterKeyTemplate string `protobuf:"bytes,5,opt,name=RangePickerCounterKeyTemplate,proto3" json:"RangePickerCounterKeyTemplate,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaPickerCounterConfig) Descriptor deprecated 

func (*MetaPickerCounterConfig) Descriptor() ([]byte, []int)

Deprecated: Use MetaPickerCounterConfig.ProtoReflect.Descriptor instead.

func (*MetaPickerCounterConfig) GetPickerCounterKeyTemplate 

func (x *MetaPickerCounterConfig) GetPickerCounterKeyTemplate() string

func (*MetaPickerCounterConfig) GetRangeCounterOn 

func (x *MetaPickerCounterConfig) GetRangeCounterOn() bool

func (*MetaPickerCounterConfig) GetRangePickerCounterKeyTemplate 

func (x *MetaPickerCounterConfig) GetRangePickerCounterKeyTemplate() string

func (*MetaPickerCounterConfig) GetRangeTTLDays 

func (x *MetaPickerCounterConfig) GetRangeTTLDays() int32

func (*MetaPickerCounterConfig) GetTTLDays 

func (x *MetaPickerCounterConfig) GetTTLDays() int32

func (*MetaPickerCounterConfig) ProtoMessage 

func (*MetaPickerCounterConfig) ProtoMessage()

func (*MetaPickerCounterConfig) ProtoReflect 

func (x *MetaPickerCounterConfig) ProtoReflect() protoreflect.Message

func (*MetaPickerCounterConfig) Reset 

func (x *MetaPickerCounterConfig) Reset()

func (*MetaPickerCounterConfig) String 

func (x *MetaPickerCounterConfig) String() string

type MetaRangeConfig 

type MetaRangeConfig struct {
	RangeInfoKey       string `protobuf:"bytes,1,opt,name=RangeInfoKey,proto3" json:"RangeInfoKey,omitempty"`
	InfoKeyNamespace   string `protobuf:"bytes,2,opt,name=InfoKeyNamespace,proto3" json:"InfoKeyNamespace,omitempty"`
	InfoDefaultTTLDays int32  `protobuf:"varint,3,opt,name=InfoDefaultTTLDays,proto3" json:"InfoDefaultTTLDays,omitempty"`
	IDGener            string `protobuf:"bytes,4,opt,name=IDGener,proto3" json:"IDGener,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaRangeConfig) Descriptor deprecated 

func (*MetaRangeConfig) Descriptor() ([]byte, []int)

Deprecated: Use MetaRangeConfig.ProtoReflect.Descriptor instead.

func (*MetaRangeConfig) GetIDGener 

func (x *MetaRangeConfig) GetIDGener() string

func (*MetaRangeConfig) GetInfoDefaultTTLDays 

func (x *MetaRangeConfig) GetInfoDefaultTTLDays() int32

func (*MetaRangeConfig) GetInfoKeyNamespace 

func (x *MetaRangeConfig) GetInfoKeyNamespace() string

func (*MetaRangeConfig) GetRangeInfoKey 

func (x *MetaRangeConfig) GetRangeInfoKey() string

func (*MetaRangeConfig) ProtoMessage 

func (*MetaRangeConfig) ProtoMessage()

func (*MetaRangeConfig) ProtoReflect 

func (x *MetaRangeConfig) ProtoReflect() protoreflect.Message

func (*MetaRangeConfig) Reset 

func (x *MetaRangeConfig) Reset()

func (*MetaRangeConfig) String 

func (x *MetaRangeConfig) String() string

type MetaResponse 

type MetaResponse struct {
	Content *MetaInfo `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

meta

func (*MetaResponse) Descriptor deprecated 

func (*MetaResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetaResponse.ProtoReflect.Descriptor instead.

func (*MetaResponse) GetContent 

func (x *MetaResponse) GetContent() *MetaInfo

func (*MetaResponse) ProtoMessage 

func (*MetaResponse) ProtoMessage()

func (*MetaResponse) ProtoReflect 

func (x *MetaResponse) ProtoReflect() protoreflect.Message

func (*MetaResponse) Reset 

func (x *MetaResponse) Reset()

func (*MetaResponse) String 

func (x *MetaResponse) String() string

type NewFilterQuery 

type NewFilterQuery struct {
	Meta          *RedisFilterMeta    `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Setting       *RedisFilterSetting `protobuf:"bytes,2,opt,name=setting,proto3" json:"setting,omitempty"`
	EntitySources []string            `protobuf:"bytes,3,rep,name=entity_sources,json=entitySources,proto3" json:"entity_sources,omitempty"`
	// contains filtered or unexported fields
}

func (*NewFilterQuery) Descriptor deprecated 

func (*NewFilterQuery) Descriptor() ([]byte, []int)

Deprecated: Use NewFilterQuery.ProtoReflect.Descriptor instead.

func (*NewFilterQuery) GetEntitySources 

func (x *NewFilterQuery) GetEntitySources() []string

func (*NewFilterQuery) GetMeta 

func (x *NewFilterQuery) GetMeta() *RedisFilterMeta

func (*NewFilterQuery) GetSetting 

func (x *NewFilterQuery) GetSetting() *RedisFilterSetting

func (*NewFilterQuery) ProtoMessage 

func (*NewFilterQuery) ProtoMessage()

func (*NewFilterQuery) ProtoReflect 

func (x *NewFilterQuery) ProtoReflect() protoreflect.Message

func (*NewFilterQuery) Reset 

func (x *NewFilterQuery) Reset()

func (*NewFilterQuery) String 

func (x *NewFilterQuery) String() string

type NewPickerFilterQuery 

type NewPickerFilterQuery struct {
	Meta          *RedisFilterMeta               `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Settings      map[string]*RedisFilterSetting `` /* 157-byte string literal not displayed */
	EntitySources []string                       `protobuf:"bytes,3,rep,name=entity_sources,json=entitySources,proto3" json:"entity_sources,omitempty"`
	// contains filtered or unexported fields
}

Picker

func (*NewPickerFilterQuery) Descriptor deprecated 

func (*NewPickerFilterQuery) Descriptor() ([]byte, []int)

Deprecated: Use NewPickerFilterQuery.ProtoReflect.Descriptor instead.

func (*NewPickerFilterQuery) GetEntitySources 

func (x *NewPickerFilterQuery) GetEntitySources() []string

func (*NewPickerFilterQuery) GetMeta 

func (x *NewPickerFilterQuery) GetMeta() *RedisFilterMeta

func (*NewPickerFilterQuery) GetSettings 

func (x *NewPickerFilterQuery) GetSettings() map[string]*RedisFilterSetting

func (*NewPickerFilterQuery) ProtoMessage 

func (*NewPickerFilterQuery) ProtoMessage()

func (*NewPickerFilterQuery) ProtoReflect 

func (x *NewPickerFilterQuery) ProtoReflect() protoreflect.Message

func (*NewPickerFilterQuery) Reset 

func (x *NewPickerFilterQuery) Reset()

func (*NewPickerFilterQuery) String 

func (x *NewPickerFilterQuery) String() string

type RangeInfo 

type RangeInfo struct {
	Meta       *RedisFilterMeta    `protobuf:"bytes,1,opt,name=Meta,proto3" json:"Meta,omitempty"`
	FilterType RedisFilterType     `protobuf:"varint,2,opt,name=FilterType,proto3,enum=itemfilterRPC.RedisFilterType" json:"FilterType,omitempty"`
	Status     *RedisFilterStatus  `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	Setting    *RedisFilterSetting `protobuf:"bytes,4,opt,name=Setting,proto3" json:"Setting,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeInfo) Descriptor deprecated 

func (*RangeInfo) Descriptor() ([]byte, []int)

Deprecated: Use RangeInfo.ProtoReflect.Descriptor instead.

func (*RangeInfo) GetFilterType 

func (x *RangeInfo) GetFilterType() RedisFilterType

func (*RangeInfo) GetMeta 

func (x *RangeInfo) GetMeta() *RedisFilterMeta

func (*RangeInfo) GetSetting 

func (x *RangeInfo) GetSetting() *RedisFilterSetting

func (*RangeInfo) GetStatus 

func (x *RangeInfo) GetStatus() *RedisFilterStatus

func (*RangeInfo) ProtoMessage 

func (*RangeInfo) ProtoMessage()

func (*RangeInfo) ProtoReflect 

func (x *RangeInfo) ProtoReflect() protoreflect.Message

func (*RangeInfo) Reset 

func (x *RangeInfo) Reset()

func (*RangeInfo) String 

func (x *RangeInfo) String() string

type RangeInfoResponse 

type RangeInfoResponse struct {
	Info *RangeInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

range

func (*RangeInfoResponse) Descriptor deprecated 

func (*RangeInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use RangeInfoResponse.ProtoReflect.Descriptor instead.

func (*RangeInfoResponse) GetInfo 

func (x *RangeInfoResponse) GetInfo() *RangeInfo

func (*RangeInfoResponse) ProtoMessage 

func (*RangeInfoResponse) ProtoMessage()

func (*RangeInfoResponse) ProtoReflect 

func (x *RangeInfoResponse) ProtoReflect() protoreflect.Message

func (*RangeInfoResponse) Reset 

func (x *RangeInfoResponse) Reset()

func (*RangeInfoResponse) String 

func (x *RangeInfoResponse) String() string

type RedisFilterMeta 

type RedisFilterMeta struct {
	ID               string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	EntitySourceType string `protobuf:"bytes,2,opt,name=EntitySourceType,proto3" json:"EntitySourceType,omitempty"`
	Name             string `protobuf:"bytes,3,opt,name=Name,proto3" json:"Name,omitempty"`
	Desc             string `protobuf:"bytes,4,opt,name=Desc,proto3" json:"Desc,omitempty"`
	Key              string `protobuf:"bytes,5,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisFilterMeta) Descriptor deprecated 

func (*RedisFilterMeta) Descriptor() ([]byte, []int)

Deprecated: Use RedisFilterMeta.ProtoReflect.Descriptor instead.

func (*RedisFilterMeta) GetDesc 

func (x *RedisFilterMeta) GetDesc() string

func (*RedisFilterMeta) GetEntitySourceType 

func (x *RedisFilterMeta) GetEntitySourceType() string

func (*RedisFilterMeta) GetID 

func (x *RedisFilterMeta) GetID() string

func (*RedisFilterMeta) GetKey 

func (x *RedisFilterMeta) GetKey() string

func (*RedisFilterMeta) GetName 

func (x *RedisFilterMeta) GetName() string

func (*RedisFilterMeta) ProtoMessage 

func (*RedisFilterMeta) ProtoMessage()

func (*RedisFilterMeta) ProtoReflect 

func (x *RedisFilterMeta) ProtoReflect() protoreflect.Message

func (*RedisFilterMeta) Reset 

func (x *RedisFilterMeta) Reset()

func (*RedisFilterMeta) String 

func (x *RedisFilterMeta) String() string

type RedisFilterSetting 

type RedisFilterSetting struct {

	// Types that are assignable to Setting:
	//	*RedisFilterSetting_SetfilterSetting
	//	*RedisFilterSetting_BloomfilterSetting
	//	*RedisFilterSetting_CuckoofilterSetting
	Setting isRedisFilterSetting_Setting `protobuf_oneof:"setting"`
	// contains filtered or unexported fields
}

func (*RedisFilterSetting) Descriptor deprecated 

func (*RedisFilterSetting) Descriptor() ([]byte, []int)

Deprecated: Use RedisFilterSetting.ProtoReflect.Descriptor instead.

func (*RedisFilterSetting) GetBloomfilterSetting 

func (x *RedisFilterSetting) GetBloomfilterSetting() *BloomFilterSetting

func (*RedisFilterSetting) GetCuckoofilterSetting 

func (x *RedisFilterSetting) GetCuckoofilterSetting() *CuckooFilterSetting

func (*RedisFilterSetting) GetSetfilterSetting 

func (x *RedisFilterSetting) GetSetfilterSetting() *SetFilterSetting

func (*RedisFilterSetting) GetSetting 

func (m *RedisFilterSetting) GetSetting() isRedisFilterSetting_Setting

func (*RedisFilterSetting) ProtoMessage 

func (*RedisFilterSetting) ProtoMessage()

func (*RedisFilterSetting) ProtoReflect 

func (x *RedisFilterSetting) ProtoReflect() protoreflect.Message

func (*RedisFilterSetting) Reset 

func (x *RedisFilterSetting) Reset()

func (*RedisFilterSetting) String 

func (x *RedisFilterSetting) String() string

type RedisFilterSetting_BloomfilterSetting 

type RedisFilterSetting_BloomfilterSetting struct {
	BloomfilterSetting *BloomFilterSetting `protobuf:"bytes,2,opt,name=BloomfilterSetting,proto3,oneof"`
}

type RedisFilterSetting_CuckoofilterSetting 

type RedisFilterSetting_CuckoofilterSetting struct {
	CuckoofilterSetting *CuckooFilterSetting `protobuf:"bytes,3,opt,name=CuckoofilterSetting,proto3,oneof"`
}

type RedisFilterSetting_SetfilterSetting 

type RedisFilterSetting_SetfilterSetting struct {
	SetfilterSetting *SetFilterSetting `protobuf:"bytes,1,opt,name=setfilter_setting,json=setfilterSetting,proto3,oneof"`
}

type RedisFilterStatus 

type RedisFilterStatus struct {
	Exists     bool  `protobuf:"varint,1,opt,name=Exists,proto3" json:"Exists,omitempty"`
	Size       int64 `protobuf:"varint,2,opt,name=Size,proto3" json:"Size,omitempty"`
	TTLSeconds int64 `protobuf:"varint,3,opt,name=TTLSeconds,proto3" json:"TTLSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisFilterStatus) Descriptor deprecated 

func (*RedisFilterStatus) Descriptor() ([]byte, []int)

Deprecated: Use RedisFilterStatus.ProtoReflect.Descriptor instead.

func (*RedisFilterStatus) GetExists 

func (x *RedisFilterStatus) GetExists() bool

func (*RedisFilterStatus) GetSize 

func (x *RedisFilterStatus) GetSize() int64

func (*RedisFilterStatus) GetTTLSeconds 

func (x *RedisFilterStatus) GetTTLSeconds() int64

func (*RedisFilterStatus) ProtoMessage 

func (*RedisFilterStatus) ProtoMessage()

func (*RedisFilterStatus) ProtoReflect 

func (x *RedisFilterStatus) ProtoReflect() protoreflect.Message

func (*RedisFilterStatus) Reset 

func (x *RedisFilterStatus) Reset()

func (*RedisFilterStatus) String 

func (x *RedisFilterStatus) String() string

type RedisFilterType 

type RedisFilterType int32
const (
	RedisFilterType_SET    RedisFilterType = 0
	RedisFilterType_BLOOM  RedisFilterType = 1
	RedisFilterType_CUCKOO RedisFilterType = 2
)

func (RedisFilterType) Descriptor 

func (RedisFilterType) Descriptor() protoreflect.EnumDescriptor

func (RedisFilterType) Enum 

func (x RedisFilterType) Enum() *RedisFilterType

func (RedisFilterType) EnumDescriptor deprecated 

func (RedisFilterType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RedisFilterType.Descriptor instead.

func (RedisFilterType) Number 

func (x RedisFilterType) Number() protoreflect.EnumNumber

func (RedisFilterType) String 

func (x RedisFilterType) String() string

func (RedisFilterType) Type 

func (RedisFilterType) Type() protoreflect.EnumType

type SetFilterSetting 

type SetFilterSetting struct {
	MaxTTLSeconds int64 `protobuf:"varint,1,opt,name=MaxTTLSeconds,proto3" json:"MaxTTLSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*SetFilterSetting) Descriptor deprecated 

func (*SetFilterSetting) Descriptor() ([]byte, []int)

Deprecated: Use SetFilterSetting.ProtoReflect.Descriptor instead.

func (*SetFilterSetting) GetMaxTTLSeconds 

func (x *SetFilterSetting) GetMaxTTLSeconds() int64

func (*SetFilterSetting) ProtoMessage 

func (*SetFilterSetting) ProtoMessage()

func (*SetFilterSetting) ProtoReflect 

func (x *SetFilterSetting) ProtoReflect() protoreflect.Message

func (*SetFilterSetting) Reset 

func (x *SetFilterSetting) Reset()

func (*SetFilterSetting) String 

func (x *SetFilterSetting) String() string

type SetSourceUsedQuery 

type SetSourceUsedQuery struct {
	EnvInfo       *SetUsedEnvInfo `protobuf:"bytes,1,opt,name=env_info,json=envInfo,proto3" json:"env_info,omitempty"`
	EntitySources []string        `protobuf:"bytes,2,rep,name=entity_sources,json=entitySources,proto3" json:"entity_sources,omitempty"`
	// contains filtered or unexported fields
}

func (*SetSourceUsedQuery) Descriptor deprecated 

func (*SetSourceUsedQuery) Descriptor() ([]byte, []int)

Deprecated: Use SetSourceUsedQuery.ProtoReflect.Descriptor instead.

func (*SetSourceUsedQuery) GetEntitySources 

func (x *SetSourceUsedQuery) GetEntitySources() []string

func (*SetSourceUsedQuery) GetEnvInfo 

func (x *SetSourceUsedQuery) GetEnvInfo() *SetUsedEnvInfo

func (*SetSourceUsedQuery) ProtoMessage 

func (*SetSourceUsedQuery) ProtoMessage()

func (*SetSourceUsedQuery) ProtoReflect 

func (x *SetSourceUsedQuery) ProtoReflect() protoreflect.Message

func (*SetSourceUsedQuery) Reset 

func (x *SetSourceUsedQuery) Reset()

func (*SetSourceUsedQuery) String 

func (x *SetSourceUsedQuery) String() string

type SetUsedEnvInfo 

type SetUsedEnvInfo struct {
	EntitySourceType string           `protobuf:"bytes,1,opt,name=entity_source_type,json=entitySourceType,proto3" json:"entity_source_type,omitempty"`
	PickerId         string           `protobuf:"bytes,2,opt,name=picker_id,json=pickerId,proto3" json:"picker_id,omitempty"`
	ContextIds       map[string]int64 `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetUsedEnvInfo) Descriptor deprecated 

func (*SetUsedEnvInfo) Descriptor() ([]byte, []int)

Deprecated: Use SetUsedEnvInfo.ProtoReflect.Descriptor instead.

func (*SetUsedEnvInfo) GetContextIds 

func (x *SetUsedEnvInfo) GetContextIds() map[string]int64

func (*SetUsedEnvInfo) GetEntitySourceType 

func (x *SetUsedEnvInfo) GetEntitySourceType() string

func (*SetUsedEnvInfo) GetPickerId 

func (x *SetUsedEnvInfo) GetPickerId() string

func (*SetUsedEnvInfo) ProtoMessage 

func (*SetUsedEnvInfo) ProtoMessage()

func (*SetUsedEnvInfo) ProtoReflect 

func (x *SetUsedEnvInfo) ProtoReflect() protoreflect.Message

func (*SetUsedEnvInfo) Reset 

func (x *SetUsedEnvInfo) Reset()

func (*SetUsedEnvInfo) String 

func (x *SetUsedEnvInfo) String() string

type SurvivorResponse 

type SurvivorResponse struct {
	EntitySourceType string   `protobuf:"bytes,1,opt,name=entity_source_type,json=entitySourceType,proto3" json:"entity_source_type,omitempty"`
	Survivor         []string `protobuf:"bytes,2,rep,name=survivor,proto3" json:"survivor,omitempty"`
	// contains filtered or unexported fields
}

func (*SurvivorResponse) Descriptor deprecated 

func (*SurvivorResponse) Descriptor() ([]byte, []int)

Deprecated: Use SurvivorResponse.ProtoReflect.Descriptor instead.

func (*SurvivorResponse) GetEntitySourceType 

func (x *SurvivorResponse) GetEntitySourceType() string

func (*SurvivorResponse) GetSurvivor 

func (x *SurvivorResponse) GetSurvivor() []string

func (*SurvivorResponse) ProtoMessage 

func (*SurvivorResponse) ProtoMessage()

func (*SurvivorResponse) ProtoReflect 

func (x *SurvivorResponse) ProtoReflect() protoreflect.Message

func (*SurvivorResponse) Reset 

func (x *SurvivorResponse) Reset()

func (*SurvivorResponse) String 

func (x *SurvivorResponse) String() string

type UnimplementedITEMFILTERRPCServer 

type UnimplementedITEMFILTERRPCServer struct {
}

UnimplementedITEMFILTERRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedITEMFILTERRPCServer) AddRangeSource 

func (UnimplementedITEMFILTERRPCServer) AddRangeSource(context.Context, *AddRangeSourceQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) BatchAddRangeSource 

func (UnimplementedITEMFILTERRPCServer) BatchAddRangeSource(ITEMFILTERRPC_BatchAddRangeSourceServer) error

func (UnimplementedITEMFILTERRPCServer) BatchSetEntitySourceUsed 

func (UnimplementedITEMFILTERRPCServer) BatchSetEntitySourceUsed(ITEMFILTERRPC_BatchSetEntitySourceUsedServer) error

func (UnimplementedITEMFILTERRPCServer) CheckEntitySource 

func (UnimplementedITEMFILTERRPCServer) CheckEntitySource(context.Context, *CheckQuery) (*CandidateStatusResponse, error)

func (UnimplementedITEMFILTERRPCServer) CheckSourceInBlacklist 

func (UnimplementedITEMFILTERRPCServer) CheckSourceInBlacklist(context.Context, *CheckSourceQuery) (*CandidateStatusResponse, error)

func (UnimplementedITEMFILTERRPCServer) CheckSourceInRange 

func (UnimplementedITEMFILTERRPCServer) CheckSourceInRange(context.Context, *CheckSourceQuery) (*CandidateStatusResponse, error)

func (UnimplementedITEMFILTERRPCServer) DeleteBlacklist 

func (UnimplementedITEMFILTERRPCServer) DeleteBlacklist(context.Context, *IDQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) DeleteRange 

func (UnimplementedITEMFILTERRPCServer) DeleteRange(context.Context, *IDQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) FilterEntitySource 

func (UnimplementedITEMFILTERRPCServer) FilterEntitySource(context.Context, *FilterQuery) (*SurvivorResponse, error)

func (UnimplementedITEMFILTERRPCServer) FilterSourceInBlacklist 

func (UnimplementedITEMFILTERRPCServer) FilterSourceInBlacklist(context.Context, *FilterSourceQuery) (*SurvivorResponse, error)

func (UnimplementedITEMFILTERRPCServer) FilterSourceNotInRange 

func (UnimplementedITEMFILTERRPCServer) FilterSourceNotInRange(context.Context, *FilterSourceQuery) (*SurvivorResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetBlacklistInfo 

func (UnimplementedITEMFILTERRPCServer) GetBlacklistInfo(context.Context, *IDQuery) (*BlacklistInfoResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetBlacklistList 

func (UnimplementedITEMFILTERRPCServer) GetBlacklistList(context.Context, *emptypb.Empty) (*ListResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetContextStatus 

func (UnimplementedITEMFILTERRPCServer) GetContextStatus(context.Context, *IDEntitySourceTypeQuery) (*GetContextStatusResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetMeta 

func (UnimplementedITEMFILTERRPCServer) GetMeta(context.Context, *emptypb.Empty) (*MetaResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetPickerCounterNumber 

func (UnimplementedITEMFILTERRPCServer) GetPickerCounterNumber(context.Context, *GetPickerCounterNumberQuery) (*GetPickerCounterNumberResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetPickerStatus 

func (UnimplementedITEMFILTERRPCServer) GetPickerStatus(context.Context, *IDEntitySourceTypeQuery) (*GetPickerStatusResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetRangeInfo 

func (UnimplementedITEMFILTERRPCServer) GetRangeInfo(context.Context, *IDQuery) (*RangeInfoResponse, error)

func (UnimplementedITEMFILTERRPCServer) GetRangeList 

func (UnimplementedITEMFILTERRPCServer) GetRangeList(context.Context, *emptypb.Empty) (*ListResponse, error)

func (UnimplementedITEMFILTERRPCServer) NewBlacklist 

func (UnimplementedITEMFILTERRPCServer) NewBlacklist(context.Context, *NewFilterQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) NewContexts 

func (UnimplementedITEMFILTERRPCServer) NewContexts(context.Context, *NewFilterQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) NewPickers 

func (UnimplementedITEMFILTERRPCServer) NewPickers(context.Context, *NewPickerFilterQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) NewRange 

func (UnimplementedITEMFILTERRPCServer) NewRange(context.Context, *NewFilterQuery) (*IDResponse, error)

func (UnimplementedITEMFILTERRPCServer) SetEntitySourceUsed 

func (UnimplementedITEMFILTERRPCServer) SetEntitySourceUsed(context.Context, *SetSourceUsedQuery) (*emptypb.Empty, error)

func (UnimplementedITEMFILTERRPCServer) UpdateBlacklistSource 

func (UnimplementedITEMFILTERRPCServer) UpdateBlacklistSource(context.Context, *UpdateBlacklistSourceQuery) (*IDResponse, error)

type UnionMod 

type UnionMod int32
const (
	UnionMod_UnionByDayAndRange UnionMod = 0 //计算指定范围和时间内的聚合总体结果,结果的key为union,如果没有指定ranges则结果key为global
	UnionMod_UnionByRange       UnionMod = 1 //计算ranges中指定range们的并集,结果的key为每天日期,
	UnionMod_UnionByDay         UnionMod = 2 //计算每天各个range的并集,结果的key为rangeid,如果没有指定ranges则结果key为global
)

func (UnionMod) Descriptor 

func (UnionMod) Descriptor() protoreflect.EnumDescriptor

func (UnionMod) Enum 

func (x UnionMod) Enum() *UnionMod

func (UnionMod) EnumDescriptor deprecated 

func (UnionMod) EnumDescriptor() ([]byte, []int)

Deprecated: Use UnionMod.Descriptor instead.

func (UnionMod) Number 

func (x UnionMod) Number() protoreflect.EnumNumber

func (UnionMod) String 

func (x UnionMod) String() string

func (UnionMod) Type 

func (UnionMod) Type() protoreflect.EnumType

type UnsafeITEMFILTERRPCServer 

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

UnsafeITEMFILTERRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ITEMFILTERRPCServer will result in compilation errors.

type UpdateBlacklistSourceQuery 

type UpdateBlacklistSourceQuery struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Content []string `protobuf:"bytes,2,rep,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBlacklistSourceQuery) Descriptor deprecated 

func (*UpdateBlacklistSourceQuery) Descriptor() ([]byte, []int)

Deprecated: Use UpdateBlacklistSourceQuery.ProtoReflect.Descriptor instead.

func (*UpdateBlacklistSourceQuery) GetContent 

func (x *UpdateBlacklistSourceQuery) GetContent() []string

func (*UpdateBlacklistSourceQuery) GetId 

func (x *UpdateBlacklistSourceQuery) GetId() string

func (*UpdateBlacklistSourceQuery) ProtoMessage 

func (*UpdateBlacklistSourceQuery) ProtoMessage()

func (*UpdateBlacklistSourceQuery) ProtoReflect 

func (x *UpdateBlacklistSourceQuery) ProtoReflect() protoreflect.Message

func (*UpdateBlacklistSourceQuery) Reset 

func (x *UpdateBlacklistSourceQuery) Reset()

func (*UpdateBlacklistSourceQuery) String 

func (x *UpdateBlacklistSourceQuery) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.