redis

package

v0.0.0-...-fe78ce7 Latest Latest Go to latest Published: Jan 17, 2022 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/13k/night-stalker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func LiveMatchesToZValues(liveMatches nscol.LiveMatches) []*redis.Z
func LiveMatchesToZValuesByTime(liveMatches nscol.LiveMatches) []*redis.Z
type ErrCommandFailure
type ErrPubsubFailure
type PubSub
- func NewPubSub(pubsub *redis.PubSub) *PubSub
- func (ps *PubSub) Watch(ctx context.Context, handler func(*redis.Message))
type Redis
- func NewRedis(c *redis.Client) *Redis

Constants ¶

View Source

const (
	KeyLiveMatches       = "live_matches"
	KeyLiveMatchesByTime = "live_matches_by_time"
)

View Source

const (
	TopicLiveMatchesReplace       = "live_matches.replace"
	TopicLiveMatchesAdd           = "live_matches.add"
	TopicLiveMatchesUpdate        = "live_matches.update"
	TopicLiveMatchesRemove        = "live_matches.remove"
	TopicPatternLiveMatchesAll    = "live_matches.*"
	TopicLiveMatchStatsAdd        = "live_match_stats.add"
	TopicPatternLiveMatchStatsAll = "live_match_stats.*"
)

Variables ¶

This section is empty.

Functions ¶

func LiveMatchesToZValues ¶

func LiveMatchesToZValues(liveMatches nscol.LiveMatches) []*redis.Z

func LiveMatchesToZValuesByTime ¶

func LiveMatchesToZValuesByTime(liveMatches nscol.LiveMatches) []*redis.Z

Types ¶

type ErrCommandFailure ¶

type ErrCommandFailure struct {
	*nserr.Err

	Cmd redis.Cmder
	Key string
}

type ErrPubsubFailure ¶

type ErrPubsubFailure struct {
	*nserr.Err

	Cmd   redis.Cmder
	Topic string
}

type PubSub ¶

type PubSub struct {
	*redis.PubSub
}

func NewPubSub ¶

func NewPubSub(pubsub *redis.PubSub) *PubSub

func (*PubSub) Watch ¶

func (ps *PubSub) Watch(ctx context.Context, handler func(*redis.Message))

type Redis ¶

type Redis struct {
	*redis.Client
}

func NewRedis ¶

func NewRedis(c *redis.Client) *Redis

func (*Redis) AddLiveMatches ¶

func (r *Redis) AddLiveMatches(liveMatches nscol.LiveMatches) error

func (*Redis) LiveMatchIDs ¶

func (r *Redis) LiveMatchIDs() (nscol.MatchIDs, error)

func (*Redis) PSubscribe ¶

func (r *Redis) PSubscribe(pattern string) (*PubSub, error)

func (*Redis) PubLiveMatchStatsAdd ¶

func (r *Redis) PubLiveMatchStatsAdd(stats nscol.LiveMatchStats) error

func (*Redis) PubLiveMatchesAdd ¶

func (r *Redis) PubLiveMatchesAdd(liveMatches nscol.LiveMatches) error

func (*Redis) PubLiveMatchesRemove ¶

func (r *Redis) PubLiveMatchesRemove(matchIDs nscol.MatchIDs) error

func (*Redis) RemoveLiveMatches ¶

func (r *Redis) RemoveLiveMatches(matchIDs nscol.MatchIDs) error

Source Files ¶

View all Source files

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