redisbus

Documentation

Index

• func CreateBus(config RedisConfig) (core.EventBus, error)
• type EventBus
  • func (bus EventBus) Publish(message interface{}) error
  • func (bus EventBus) Subscribe(event reflect.Type, eventHandler core.EventHandler, ...) error
• type RedisConfig

Functions

func CreateBus

func CreateBus(config RedisConfig) (core.EventBus, error)

Types

type EventBus

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

func (EventBus) Publish

func (bus EventBus) Publish(message interface{}) error

func (EventBus) Subscribe

func (bus EventBus) Subscribe(event reflect.Type, eventHandler core.EventHandler, resilienceOptions *core.RetryOptions) error

type RedisConfig

type RedisConfig struct {
	Uri      string
	Password string
}