redispublisher

Documentation

Index

• Constants
• func New(clientOpt ClientOption, opts ...Option) (easypubsub.Publisher, error)
• type ChannelGenerator
• type ClientOption
  • func ClusterClient(opts *redis.ClusterOptions) ClientOption
  • func FailoverClient(opts *redis.FailoverOptions) ClientOption
  • func SampleClient(opts *redis.Options) ClientOption
• type MsgMarshaler
• type Option
  • func WithChannelGenerator(generateChannel ChannelGenerator) Option
  • func WithLogger(logger easypubsub.Logger) Option
  • func WithMsgMarshaler(marshalMsg MsgMarshaler) Option
• type Publisher
  • func (pub *Publisher) Close() error
  • func (pub *Publisher) Publish(topic string, msg *easypubsub.Message) (result *easypubsub.PublishResult)
  • func (pub *Publisher) String() string

Constants

const (
	NORMAL = 0
	CLOSED = 1
)

Functions

func New

func New(clientOpt ClientOption, opts ...Option) (easypubsub.Publisher, error)

Types

type ChannelGenerator

type ChannelGenerator func(topic string) (channel string)

type ClientOption

type ClientOption func(o *clientOptions)

func ClusterClient

func ClusterClient(opts *redis.ClusterOptions) ClientOption

func FailoverClient

func FailoverClient(opts *redis.FailoverOptions) ClientOption

func SampleClient

func SampleClient(opts *redis.Options) ClientOption

type MsgMarshaler

type MsgMarshaler func(topic string, msg *easypubsub.Message) ([]byte, error)

type Option

type Option func(o *options)

func WithChannelGenerator

func WithChannelGenerator(generateChannel ChannelGenerator) Option

func WithLogger

func WithLogger(logger easypubsub.Logger) Option

func WithMsgMarshaler

func WithMsgMarshaler(marshalMsg MsgMarshaler) Option

type Publisher

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

func (*Publisher) Close

func (pub *Publisher) Close() error

func (*Publisher) Publish

func (pub *Publisher) Publish(topic string, msg *easypubsub.Message) (result *easypubsub.PublishResult)

func (*Publisher) String

func (pub *Publisher) String() string