redis

Documentation

Index

• func NewRedisConn(conf config.Redis) (*redis.Client, error)
• type MessageConsumer
  • func (c *MessageConsumer) BeginConsume(ctx context.Context) (<-chan entity.Message, <-chan error)
  • func (c *MessageConsumer) Close() error
  • func (c *MessageConsumer) Subscribe(ctx context.Context, chatIDs ...entity.ChatID) error
  • func (c *MessageConsumer) Unsubscribe(ctx context.Context, chatIDs ...entity.ChatID) error
• type MessagePublishSubscriber
  • func NewMessagePublishSubscriber(cli *redis.Client) *MessagePublishSubscriber
  • func (ps *MessagePublishSubscriber) Publish(ctx context.Context, message entity.Message) error
  • func (ps *MessagePublishSubscriber) Subscribe(ctx context.Context, chatIDs ...entity.ChatID) service.MessageConsumer
• type ParticipantEventProduceConsumer
  • func NewParticipantEventProduceConsumer(cli *redis.Client) *ParticipantEventProduceConsumer
  • func (ps *ParticipantEventProduceConsumer) BeginConsume(ctx context.Context, userID int) (<-chan entity.ParticipantEvent, <-chan error)
  • func (ps *ParticipantEventProduceConsumer) Produce(ctx context.Context, event entity.ParticipantEvent) error

Functions

func NewRedisConn

func NewRedisConn(conf config.Redis) (*redis.Client, error)

Types

type MessageConsumer

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

func (*MessageConsumer) BeginConsume

func (c *MessageConsumer) BeginConsume(ctx context.Context) (<-chan entity.Message, <-chan error)

func (*MessageConsumer) Close

func (c *MessageConsumer) Close() error

func (*MessageConsumer) Subscribe

func (c *MessageConsumer) Subscribe(ctx context.Context, chatIDs ...entity.ChatID) error

func (*MessageConsumer) Unsubscribe

func (c *MessageConsumer) Unsubscribe(ctx context.Context, chatIDs ...entity.ChatID) error

type MessagePublishSubscriber

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

func NewMessagePublishSubscriber

func NewMessagePublishSubscriber(cli *redis.Client) *MessagePublishSubscriber

func (*MessagePublishSubscriber) Publish

func (ps *MessagePublishSubscriber) Publish(ctx context.Context, message entity.Message) error

func (*MessagePublishSubscriber) Subscribe

func (ps *MessagePublishSubscriber) Subscribe(ctx context.Context, chatIDs ...entity.ChatID) service.MessageConsumer

type ParticipantEventProduceConsumer

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

func NewParticipantEventProduceConsumer

func NewParticipantEventProduceConsumer(cli *redis.Client) *ParticipantEventProduceConsumer

func (*ParticipantEventProduceConsumer) BeginConsume

func (ps *ParticipantEventProduceConsumer) BeginConsume(ctx context.Context, userID int) (<-chan entity.ParticipantEvent, <-chan error)

func (*ParticipantEventProduceConsumer) Produce

func (ps *ParticipantEventProduceConsumer) Produce(ctx context.Context, event entity.ParticipantEvent) error