container

Documentation

Index

• type BFContainer
• type MemoryContainer
  • func NewMemoryContainer() *MemoryContainer
  • func (c *MemoryContainer) Export() (map[int32]map[int64]bool, error)
  • func (c *MemoryContainer) GetBit(containerId int32, val int64) (bool, error)
  • func (c *MemoryContainer) GetMaxBitSize() int64
  • func (c *MemoryContainer) GetSize() int64
  • func (c *MemoryContainer) Import(data map[int32]map[int64]bool) error
  • func (c *MemoryContainer) IncreaseSize()
  • func (c *MemoryContainer) Reset() bool
  • func (c *MemoryContainer) SetBit(containerId int32, val int64) SetStatus
  • func (c *MemoryContainer) SetSize(size int64)
• type RedisContainer
  • func NewRedisClusterContainer(opt *redis.ClusterOptions, keyPrefix string, maxKeyNum int32) *RedisContainer
  • func NewRedisContainer(opt *redis.Options, keyPrefix string, maxKeyNum int32) *RedisContainer
  • func (c *RedisContainer) Export() (map[int32]map[int64]bool, error)
  • func (c *RedisContainer) GetBit(containerId int32, val int64) (bool, error)
  • func (c *RedisContainer) GetMaxBitSize() int64
  • func (c *RedisContainer) GetSize() int64
  • func (c *RedisContainer) Import(data map[int32]map[int64]bool) error
  • func (c *RedisContainer) IncreaseSize()
  • func (c *RedisContainer) Reset() bool
  • func (c *RedisContainer) SetBit(containerId int32, val int64) SetStatus
  • func (c *RedisContainer) SetSize(size int64)
• type SetStatus

Types

type BFContainer

type BFContainer interface {
	Export() (map[int32]map[int64]bool, error)
	Import(map[int32]map[int64]bool) error
	GetBit(conainterId int32, index int64) (bool, error)
	SetBit(conainterId int32, index int64) SetStatus

	GetSize() int64
	SetSize(int64)
	IncreaseSize()

	Reset() bool
	GetMaxBitSize() int64
}

type MemoryContainer

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

func NewMemoryContainer

func NewMemoryContainer() *MemoryContainer

func (*MemoryContainer) Export

func (c *MemoryContainer) Export() (map[int32]map[int64]bool, error)

func (*MemoryContainer) GetBit

func (c *MemoryContainer) GetBit(containerId int32, val int64) (bool, error)

func (*MemoryContainer) GetMaxBitSize

func (c *MemoryContainer) GetMaxBitSize() int64

func (*MemoryContainer) GetSize

func (c *MemoryContainer) GetSize() int64

func (*MemoryContainer) Import

func (c *MemoryContainer) Import(data map[int32]map[int64]bool) error

func (*MemoryContainer) IncreaseSize

func (c *MemoryContainer) IncreaseSize()

func (*MemoryContainer) Reset

func (c *MemoryContainer) Reset() bool

func (*MemoryContainer) SetBit

func (c *MemoryContainer) SetBit(containerId int32, val int64) SetStatus

func (*MemoryContainer) SetSize

func (c *MemoryContainer) SetSize(size int64)

type RedisContainer

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

func NewRedisClusterContainer

func NewRedisClusterContainer(opt *redis.ClusterOptions, keyPrefix string, maxKeyNum int32) *RedisContainer

func NewRedisContainer

func NewRedisContainer(opt *redis.Options, keyPrefix string, maxKeyNum int32) *RedisContainer

func (*RedisContainer) Export

func (c *RedisContainer) Export() (map[int32]map[int64]bool, error)

func (*RedisContainer) GetBit

func (c *RedisContainer) GetBit(containerId int32, val int64) (bool, error)

func (*RedisContainer) GetMaxBitSize

func (c *RedisContainer) GetMaxBitSize() int64

func (*RedisContainer) GetSize

func (c *RedisContainer) GetSize() int64

func (*RedisContainer) Import

func (c *RedisContainer) Import(data map[int32]map[int64]bool) error

func (*RedisContainer) IncreaseSize

func (c *RedisContainer) IncreaseSize()

func (*RedisContainer) Reset

func (c *RedisContainer) Reset() bool

func (*RedisContainer) SetBit

func (c *RedisContainer) SetBit(containerId int32, val int64) SetStatus

func (*RedisContainer) SetSize

func (c *RedisContainer) SetSize(size int64)

type SetStatus

type SetStatus int32

const (
	SetBitFailed SetStatus = 0
	SetBitOK     SetStatus = 1
	SetBitExists SetStatus = 2
)