redis

Documentation

Overview

redis @author LanguageY++2013 2023/5/16 17:00 @company soulgame

redis @author LanguageY++2013 2023/5/12 09:27 @company soulgame

redis @author LanguageY++2013 2023/5/16 17:06 @company soulgame

Index

• type Option
  • func WithConsumer(consumer string) Option
  • func WithGoroutineNum(num int) Option
  • func WithReadTimeout(timeout time.Duration) Option
• type RedisStreamPublisher
  • func NewRedisStreamPublisher(conf redis_wrapper.Configure) *RedisStreamPublisher
  • func (p RedisStreamPublisher) Name() string
  • func (p RedisStreamPublisher) Send(topic string, ev *open.MatchEvent) error
• type RedisStreamSubscriber
  • func NewRedisStreamSubscriber(conf redis_wrapper.Configure, topic string, group string, opts ...Option) *RedisStreamSubscriber
  • func (s *RedisStreamSubscriber) Name() string
  • func (s *RedisStreamSubscriber) Start()
• type StreamEntry

Types

type Option

type Option func(s *RedisStreamSubscriber)

func WithConsumer

func WithConsumer(consumer string) Option

func WithGoroutineNum

func WithGoroutineNum(num int) Option

func WithReadTimeout

func WithReadTimeout(timeout time.Duration) Option

type RedisStreamPublisher

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

func NewRedisStreamPublisher

func NewRedisStreamPublisher(conf redis_wrapper.Configure) *RedisStreamPublisher

func (RedisStreamPublisher) Name

func (p RedisStreamPublisher) Name() string

func (RedisStreamPublisher) Send

func (p RedisStreamPublisher) Send(topic string, ev *open.MatchEvent) error

type RedisStreamSubscriber

type RedisStreamSubscriber struct {
	pubsub.EventHandlers
	// contains filtered or unexported fields
}

func NewRedisStreamSubscriber

func NewRedisStreamSubscriber(conf redis_wrapper.Configure, topic string, group string, opts ...Option) *RedisStreamSubscriber

func (*RedisStreamSubscriber) Name

func (s *RedisStreamSubscriber) Name() string

func (*RedisStreamSubscriber) Start

func (s *RedisStreamSubscriber) Start()

type StreamEntry

type StreamEntry struct {
	redis_wrapper.StreamBaseMsg
	open.MatchEvent
	MatchEventType int `redis:"MatchEventType"`
}