event

package

v1.0.0 Latest Latest Go to latest Published: Apr 27, 2021 License: MIT Imports: 8 Imported by: 0

Details

View Source

const (
	ProviderRedis = "redis"
)

This section is empty.

func NewEventCenter(log *zap.SugaredLogger, config Config) types.EventCenter

type Config struct {
	Provider string
	Redis    rdb.Config
}

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

func NewDefaultEventCenter(log *zap.SugaredLogger) *DefaultEventCenter

func (ec *DefaultEventCenter) Get() (*types.Message, error)

func (ec *DefaultEventCenter) Pub(e *types.Message) error

func (ec *DefaultEventCenter) StartWorker(context.Context, types.EventHandler)

default event center can not have worker

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

func NewRedisEventCenter(kv *redis.Client, key string, log *zap.SugaredLogger) *RedisEventCenter

func (ec *RedisEventCenter) Get() (*types.Message, error)

func (ec *RedisEventCenter) Pub(e *types.Message) error

func (ec *RedisEventCenter) StartWorker(ctx context.Context, handler types.EventHandler)