metadatastore

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: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultOpts = Options{
	ConnTimeout:                         50,
	NamespaceBase:                       "itemfilter",
	BlacklistConfig_RangeInfoKey:        "blacklists",
	BlacklistConfig_InfoKeySubnamespace: "infoblacklist",
	RangeConfig_RangeInfoKey:            "range",
	RangeConfig_InfoKeySubnamespace:     "inforange",
	RangeConfig_FilterType:              "set",
}
View Source 
var ErrNotFound = errors.New("NotFound")
View Source 
var ErrNotImplemented = errors.New("NotImplemented")

Functions

func WithOptions 

func WithOptions(opts *Options) optparams.Option[Options]

WithOptions 使用特定单机redis连接设置

Types

type EtcdMetadataStore 

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

func NewEtcdMetadataStore 

func NewEtcdMetadataStore() *EtcdMetadataStore

func (*EtcdMetadataStore) BlacklistInfoKey 

func (s *EtcdMetadataStore) BlacklistInfoKey(blacklistid string) string

func (*EtcdMetadataStore) BlacklistInfoNamespace 

func (s *EtcdMetadataStore) BlacklistInfoNamespace() string

func (*EtcdMetadataStore) BlacklistRangeKey 

func (s *EtcdMetadataStore) BlacklistRangeKey() string

黑名单

func (*EtcdMetadataStore) DeleteBlacklist 

func (s *EtcdMetadataStore) DeleteBlacklist(id string) error

func (*EtcdMetadataStore) DeleteRange 

func (s *EtcdMetadataStore) DeleteRange(id string) error

func (*EtcdMetadataStore) GetBlacklistInfo 

func (s *EtcdMetadataStore) GetBlacklistInfo(id string) (*itemfilterRPC_pb.BlacklistInfo, error)

func (*EtcdMetadataStore) GetBlacklistList 

func (s *EtcdMetadataStore) GetBlacklistList() ([]string, error)

func (*EtcdMetadataStore) GetRangeInfo 

func (s *EtcdMetadataStore) GetRangeInfo(id string) (*itemfilterRPC_pb.RangeInfo, error)

func (*EtcdMetadataStore) GetRangeList 

func (s *EtcdMetadataStore) GetRangeList() ([]string, error)

func (*EtcdMetadataStore) Init 

func (s *EtcdMetadataStore) Init(opts ...optparams.Option[Options]) error

func (*EtcdMetadataStore) NewBlacklist 

func (s *EtcdMetadataStore) NewBlacklist(info *itemfilterRPC_pb.NewFilterQuery) error

func (*EtcdMetadataStore) NewRange 

func (s *EtcdMetadataStore) NewRange(info *itemfilterRPC_pb.NewFilterQuery) error

func (*EtcdMetadataStore) RangeInfoKey 

func (s *EtcdMetadataStore) RangeInfoKey(rangeid string) string

func (*EtcdMetadataStore) RangeInfoNamespace 

func (s *EtcdMetadataStore) RangeInfoNamespace() string

func (*EtcdMetadataStore) RangeRangeKey 

func (s *EtcdMetadataStore) RangeRangeKey() string

range

type MetadataStore 

type MetadataStore interface {
	Init(opts ...optparams.Option[Options]) error
	// 黑名单
	BlacklistRangeKey() string
	BlacklistInfoNamespace() string
	BlacklistInfoKey(blacklistid string) string

	GetBlacklistList() ([]string, error)
	NewBlacklist(*itemfilterRPC_pb.NewFilterQuery) error
	GetBlacklistInfo(id string) (*itemfilterRPC_pb.BlacklistInfo, error)
	DeleteBlacklist(id string) error

	// range
	RangeRangeKey() string
	RangeInfoNamespace() string
	RangeInfoKey(rangeid string) string

	GetRangeList() ([]string, error)
	NewRange(*itemfilterRPC_pb.NewFilterQuery) error
	GetRangeInfo(id string) (*itemfilterRPC_pb.RangeInfo, error)
	DeleteRange(id string) error
}

type Options 

type Options struct {
	URL                                 string
	RedisRouteMod                       string
	ConnTimeout                         int
	NamespaceBase                       string
	BlacklistConfig_RangeInfoKey        string
	BlacklistConfig_InfoKeySubnamespace string
	RangeConfig_RangeInfoKey            string
	RangeConfig_InfoKeySubnamespace     string
	RangeConfig_FilterType              string
	BlacklistConfig_DefaultTTLDays      int
	RangeConfig_DefaultTTLDays          int
}

Option 设置key行为的选项

type RedisMetadataStore 

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

func NewRedisMetadataStore 

func NewRedisMetadataStore() *RedisMetadataStore

func (*RedisMetadataStore) BlacklistInfoKey 

func (s *RedisMetadataStore) BlacklistInfoKey(blacklistid string) string

func (*RedisMetadataStore) BlacklistInfoNamespace 

func (s *RedisMetadataStore) BlacklistInfoNamespace() string

func (*RedisMetadataStore) BlacklistRangeKey 

func (s *RedisMetadataStore) BlacklistRangeKey() string

黑名单

func (*RedisMetadataStore) DeleteBlacklist 

func (s *RedisMetadataStore) DeleteBlacklist(id string) error

func (*RedisMetadataStore) DeleteRange 

func (s *RedisMetadataStore) DeleteRange(id string) error

func (*RedisMetadataStore) GetBlacklistInfo 

func (s *RedisMetadataStore) GetBlacklistInfo(id string) (*itemfilterRPC_pb.BlacklistInfo, error)

func (*RedisMetadataStore) GetBlacklistList 

func (s *RedisMetadataStore) GetBlacklistList() ([]string, error)

func (*RedisMetadataStore) GetRangeInfo 

func (s *RedisMetadataStore) GetRangeInfo(id string) (*itemfilterRPC_pb.RangeInfo, error)

func (*RedisMetadataStore) GetRangeList 

func (s *RedisMetadataStore) GetRangeList() ([]string, error)

func (*RedisMetadataStore) Init 

func (s *RedisMetadataStore) Init(opts ...optparams.Option[Options]) error

func (*RedisMetadataStore) NewBlacklist 

func (s *RedisMetadataStore) NewBlacklist(info *itemfilterRPC_pb.NewFilterQuery) error

func (*RedisMetadataStore) NewRange 

func (s *RedisMetadataStore) NewRange(info *itemfilterRPC_pb.NewFilterQuery) error

func (*RedisMetadataStore) RangeInfoKey 

func (s *RedisMetadataStore) RangeInfoKey(rangeid string) string

func (*RedisMetadataStore) RangeInfoNamespace 

func (s *RedisMetadataStore) RangeInfoNamespace() string

func (*RedisMetadataStore) RangeRangeKey 

func (s *RedisMetadataStore) RangeRangeKey() string

range

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.