redis_stream

Documentation

Index

• type Subscription
  • func (s Subscription) Next(ctx context.Context) (transport.Message, error)
• type Topic
  • func (t *Topic) Publish(ctx context.Context, m transport.Message) error
  • func (t *Topic) String() string
  • func (t *Topic) Subscribe(ctx context.Context) transport.Subscription

Types

type Subscription

type Subscription struct {
	*redis.PubSub
	Logger    log.Logger
	LocalNode uuid.UUID
}

func (Subscription) Next

func (s Subscription) Next(ctx context.Context) (transport.Message, error)

type Topic

type Topic struct {
	Redis     *redis.Client
	Logger    log.Logger
	Name      string
	LocalNode uuid.UUID
}

func (*Topic) Publish

func (t *Topic) Publish(ctx context.Context, m transport.Message) error

func (*Topic) String

func (t *Topic) String() string

func (*Topic) Subscribe

func (t *Topic) Subscribe(ctx context.Context) transport.Subscription