nats

Documentation

Index

• type Broker
  • 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

Types

type Broker

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

func CreateBroker

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

func (*Broker) ReadRequest

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

func (*Broker) Subscribe

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

func (*Broker) WriteRequest

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

type RedisRequest

type RedisRequest struct {
	ReplyChannel string          `json:"r"`
	Message      json.RawMessage `json:"msg"`
}