redis

Aug 27, 2023

Changes in this version

+ func ServerMaker() (*server.Server, jrpctest.ClientMaker, func())

+ type Broker struct

+ func CreateBroker(ctx context.Context, domain string, opts *redis.UniversalOptions) *Broker

+ func (s *Broker) ReadRequest(ctx context.Context) (json.RawMessage, func(json.RawMessage) error, error)

+ func (s *Broker) Subscribe(ctx context.Context, clientId string) (broker.Subscription, error)

+ func (s *Broker) WriteRequest(ctx context.Context, clientId string, msg json.RawMessage) error

+ type RedisRequest struct

+ Message json.RawMessage

+ ReplyChannel string