redismsq

package

v0.0.6 Latest Latest Go to latest Published: Sep 29, 2025 License: MIT Imports: 6 Imported by: 0

Details

Message queue on redis stream

Depends on redis(>=5.0.3), you can install it on Debian by

apt-get install redis

Server implement by

https://github.com/gwaysys/log-server

This section is empty.

This section is empty.

func New(rs *redis.RediStore, streamName string) proto.Adapter

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

func (a *Adapter) Close()

func (a *Adapter) Put(p *proto.Proto)

put a log protocol to log queue