transporter

Documentation

Index

• type HttpToRedisChannelTransporter
  • func NewHttpToRedisChannelTransporter(logger *zap.Logger, redisClient *redis.Client, ...) *HttpToRedisChannelTransporter
  • func (t *HttpToRedisChannelTransporter) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type RedisChannelToWebsocketTransporter
  • func NewRedisChannelToWebsocketTransporter(logger *zap.Logger, redisClient *redis.Client, ...) *RedisChannelToWebsocketTransporter
  • func (t *RedisChannelToWebsocketTransporter) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type HttpToRedisChannelTransporter

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

func NewHttpToRedisChannelTransporter

func NewHttpToRedisChannelTransporter(logger *zap.Logger, redisClient *redis.Client, processor topic_message_processor.TopicMessageProcessor) *HttpToRedisChannelTransporter

func (*HttpToRedisChannelTransporter) ServeHTTP

func (t *HttpToRedisChannelTransporter) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RedisChannelToWebsocketTransporter

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

func NewRedisChannelToWebsocketTransporter

func NewRedisChannelToWebsocketTransporter(logger *zap.Logger, redisClient *redis.Client, processor topic_message_processor.TopicMessageProcessor, channel string) *RedisChannelToWebsocketTransporter

func (*RedisChannelToWebsocketTransporter) ServeHTTP

func (t *RedisChannelToWebsocketTransporter) ServeHTTP(w http.ResponseWriter, r *http.Request)