seeds

package
v0.0.0-...-5e0e610 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2018 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CentralSeed

type CentralSeed struct {
	Seed
	// contains filtered or unexported fields
}

type CentralSeedServer

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

func NewCentralSeedServer

func NewCentralSeedServer() *CentralSeedServer

func (*CentralSeedServer) New

func (server *CentralSeedServer) New(
	register SeedRegister, namespace string, seedId string, bits uint) *CentralSeed

func (*CentralSeedServer) Start

func (server *CentralSeedServer) Start(d time.Duration)

func (*CentralSeedServer) Stop

func (server *CentralSeedServer) Stop()

type GoRedisAdapter

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

func NewGoRedisAdapter

func NewGoRedisAdapter(addrs []string, pwd string) *GoRedisAdapter

func (*GoRedisAdapter) Close

func (m *GoRedisAdapter) Close()

func (*GoRedisAdapter) Del

func (m *GoRedisAdapter) Del(key string) bool

func (*GoRedisAdapter) Expire

func (m *GoRedisAdapter) Expire(key string, seconds uint) bool

func (*GoRedisAdapter) Get

func (m *GoRedisAdapter) Get(key string) string

func (*GoRedisAdapter) Set

func (m *GoRedisAdapter) Set(key string, value string, seconds uint) bool

type RedisAdapter

type RedisAdapter interface {
	Get(key string) string
	Set(key string, value string, expire uint) bool
	Expire(key string, seconds uint) bool
	Del(key string) bool
}

type RedisSeedRegister

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

func NewRedisSeedRegister

func NewRedisSeedRegister(adapter RedisAdapter, from uint, to uint) *RedisSeedRegister

func (*RedisSeedRegister) Refresh

func (r *RedisSeedRegister) Refresh(namespace string, seedId string, generatorId int) int

func (*RedisSeedRegister) Register

func (r *RedisSeedRegister) Register(namespace string, seedId string) int

func (*RedisSeedRegister) Unregister

func (r *RedisSeedRegister) Unregister(namespace string, seedId string, generatorId int)

type Seed

type Seed struct {
	GeneratorId   int
	GeneratorBits uint
}

func NewArgSeed

func NewArgSeed() *Seed

func NewIpAddressSeed

func NewIpAddressSeed(ip int, generatorBits uint) *Seed

func NewLocalIpAddressSeed

func NewLocalIpAddressSeed(generatorBits uint) *Seed

type SeedRegister

type SeedRegister interface {
	Register(namespace string, seedId string) int
	Refresh(namespace string, seedId string, generatorId int) int
	Unregister(namespace string, seedId string, generatorId int)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL