eventbus

Documentation

Index

• type RedisEventBus
  • func NewRedisEventBus(redisConn thirdparty.BaseRedisClient, maxLen int64, eventsTopic string) *RedisEventBus
  • func (ce *RedisEventBus) Push(ctx context.Context, event events.Event) error
• type RedisEventsReader
  • func NewRedisEventsReader(conn thirdparty.BaseRedisClient, stream string, readerName string, ...) *RedisEventsReader
  • func (re *RedisEventsReader) Commit(ctx context.Context, commitInfo interface{}) error
  • func (re *RedisEventsReader) Read(ctx context.Context, limit int32) ([]events.EventWrapper, error)

Types

type RedisEventBus

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

func NewRedisEventBus

func NewRedisEventBus(redisConn thirdparty.BaseRedisClient, maxLen int64, eventsTopic string) *RedisEventBus

func (*RedisEventBus) Push

func (ce *RedisEventBus) Push(ctx context.Context, event events.Event) error

type RedisEventsReader

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

func NewRedisEventsReader

func NewRedisEventsReader(conn thirdparty.BaseRedisClient, stream string, readerName string, autocommit bool) *RedisEventsReader

func (*RedisEventsReader) Commit

func (re *RedisEventsReader) Commit(ctx context.Context, commitInfo interface{}) error

func (*RedisEventsReader) Read

func (re *RedisEventsReader) Read(ctx context.Context, limit int32) ([]events.EventWrapper, error)