broker

Documentation

Overview

gen for home toolset

Index

• func GetAllProvider() []interface{}
• type Config
• type RedisBroker
  • func NewRedisBroker() *RedisBroker
  • func (r *RedisBroker) Consumer(job constraint.Job)
  • func (r *RedisBroker) Init()
  • func (r *RedisBroker) Loop()
  • func (r *RedisBroker) Push(event interface{}, names ...string)
  • func (r *RedisBroker) SetConfig(client constraint.RedisClient, config ...Config)
  • func (r *RedisBroker) SetWorker(worker constraint.Worker)

Functions

func GetAllProvider

func GetAllProvider() []interface{}

Types

type Config

type Config struct {
	Stream     string
	NoMkStream bool
	MaxLen     int64 // MAXLEN N
	// Approx causes MaxLen and MinID to use "~" matcher (instead of "=").
	Approx bool
	Limit  int64
}

type RedisBroker

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

@Bean

func NewRedisBroker

func NewRedisBroker() *RedisBroker

func (*RedisBroker) Consumer

func (r *RedisBroker) Consumer(job constraint.Job)

func (*RedisBroker) Init

func (r *RedisBroker) Init()

func (*RedisBroker) Loop

func (r *RedisBroker) Loop()

Loop 开启消费已经设置的stream

func (*RedisBroker) Push

func (r *RedisBroker) Push(event interface{}, names ...string)

func (*RedisBroker) SetConfig

func (r *RedisBroker) SetConfig(client constraint.RedisClient, config ...Config)

func (*RedisBroker) SetWorker

func (r *RedisBroker) SetWorker(worker constraint.Worker)