event

package

v0.8.2 Latest Latest Go to latest Published: Apr 25, 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.Event, error)

func (ec *DefaultEventCenter) Pub(e *types.Event) 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.Event, error)

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

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