ingress

Documentation

Index

• type PubSubReader
  • func (rdr *PubSubReader) Read(p []byte) (int, error)
• type PubSubWriter
  • func (wrt *PubSubWriter) Write(p []byte) (int, error)
• type WsCollector
  • func (wsc *WsCollector) Collect(c *websocket.Conn)

Types

type PubSubReader

type PubSubReader struct {
	Channel <-chan *redis.Message
	Ctx     context.Context
	// contains filtered or unexported fields
}

PubSubReader is an io.Reader that reads from a redis PubSub channel

func (*PubSubReader) Read

func (rdr *PubSubReader) Read(p []byte) (int, error)

type PubSubWriter

type PubSubWriter struct {
	Redis   *redis.Client
	Channel string
}

PubSubWriter is an io.Writer that publishes to a redis PubSub channel

func (*PubSubWriter) Write

func (wrt *PubSubWriter) Write(p []byte) (int, error)

type WsCollector

type WsCollector struct {
	Redis            *redis.Client
	Addr             string
	DefaultNamespace string
}

WsCollector is a Websocket ProIO data collector

func (*WsCollector) Collect

func (wsc *WsCollector) Collect(c *websocket.Conn)