Documentation ¶
Index ¶
- Constants
- Variables
- func IPKaxap(k net.IP) string
- func KaxapMSISDN(v string) string
- func Msisdn(m *Mirror, input interface{}) (string, error)
- func Uint32Kaxap(k uint32) string
- type ChanScanner
- type Mirror
- type MirrorConfig
- type Redis
- func (r *Redis) ConsumeKeyChan(ctx context.Context, ch <-chan interface{}, fn TupleOp) error
- func (r *Redis) ConsumeScanner(ctx context.Context, s common.Scanner, fn TupleOp) error
- func (r *Redis) Get(key string) (string, error)
- func (r *Redis) NewKeyEventSource() common.ScanCloser
- func (r *Redis) NewScanner(window int) common.Scanner
- type RedisConfig
- type TupleOp
Constants ¶
View Source
const ( EventExpire = iota EventExpired EventDel )
event types
Variables ¶
View Source
var (
ErrNotFound = errors.New("Key not found")
)
Functions ¶
func KaxapMSISDN ¶ added in v1.0.2
func Uint32Kaxap ¶ added in v1.0.2
Types ¶
type ChanScanner ¶ added in v1.0.2
type ChanScanner struct {
// contains filtered or unexported fields
}
func NewChanScanner ¶ added in v1.0.2
func NewChanScanner() *ChanScanner
func (*ChanScanner) Close ¶ added in v1.0.2
func (cs *ChanScanner) Close()
func (*ChanScanner) Err ¶ added in v1.0.2
func (cs *ChanScanner) Err() error
func (*ChanScanner) HasNext ¶ added in v1.0.2
func (cs *ChanScanner) HasNext() bool
func (*ChanScanner) Next ¶ added in v1.0.2
func (cs *ChanScanner) Next() string
func (*ChanScanner) Put ¶ added in v1.0.2
func (cs *ChanScanner) Put(k string)
type Mirror ¶
type Mirror struct {
// contains filtered or unexported fields
}
func NewMirror ¶
func NewMirror(c MirrorConfig) (*Mirror, error)
type MirrorConfig ¶
type Redis ¶ added in v1.0.2
type Redis struct {
// contains filtered or unexported fields
}
func NewRedis ¶ added in v1.0.2
func NewRedis(c RedisConfig) (*Redis, error)
func (*Redis) ConsumeKeyChan ¶ added in v1.1.0
func (*Redis) ConsumeScanner ¶ added in v1.1.0
get keys from Scanner, GET them from redis, then process them via TupleOp if TupleOp returns false: stop and return latest error value if error is encountered, finish and return it.
func (*Redis) NewKeyEventSource ¶ added in v1.0.2
func (r *Redis) NewKeyEventSource() common.ScanCloser
type RedisConfig ¶ added in v1.0.2
Click to show internal directories.
Click to hide internal directories.