pubsubredis

Documentation

Index

• Constants
• func BuildWithOption(info meta.ServiceInfo, log *blog.Logger, cli *redis.Client, opts ...Option) module.IPubsub
• type ChannelOption
  • func WithReadMode(mode string) ChannelOption
• type ChannelParm
• type Option
• type Parm

Constants

const (
	ReadModeBeginning = "0-0"
	ReadModeLatest    = "$"
)

const (
	BraidPubsubTopic = "braid.pubsub.streams"
)

Functions

func BuildWithOption

func BuildWithOption(info meta.ServiceInfo, log *blog.Logger, cli *redis.Client, opts ...Option) module.IPubsub

Types

type ChannelOption

type ChannelOption func(*ChannelParm)

func WithReadMode

func WithReadMode(mode string) ChannelOption

type ChannelParm

type ChannelParm struct {
	ReadMode string
}

type Option

type Option func(*Parm)

Option config wraps

type Parm

type Parm struct {
}