websocket

Documentation

Index

• Constants
• type Config
• type Consumer
  • func ConsumerFromConfig(c Config, l loggers.Logger) (*Consumer, error)
  • func ConsumerFromConfigWithDialer(d *websocket.Dialer, c Config, l loggers.Logger) (*Consumer, error)
  • func (c *Consumer) Close() error
• type Producer
  • func ProducerFromConfig(c Config, l loggers.Logger) (*Producer, error)
  • func ProducerFromConfigWithDialer(d *websocket.Dialer, c Config, l loggers.Logger) (*Producer, error)
  • func (p *Producer) Close() error
• type Websocket
  • func FromConfig(c Config, l loggers.Logger) *Websocket
  • func (q *Websocket) Close() error
  • func (q *Websocket) Consumer() (consumer.Consumer, error)
  • func (q *Websocket) Producer() (producer.Producer, error)

Constants

const (
	Name = "websocket"
)

Types

type Config

type Config struct {
	Addr               string
	ConsumerBufferSize uint
}

type Consumer

type Consumer struct {
	*readwriter.Consumer
	// contains filtered or unexported fields
}

func ConsumerFromConfig

func ConsumerFromConfig(c Config, l loggers.Logger) (*Consumer, error)

func ConsumerFromConfigWithDialer

func ConsumerFromConfigWithDialer(d *websocket.Dialer, c Config, l loggers.Logger) (*Consumer, error)

func (*Consumer) Close

func (c *Consumer) Close() error

type Producer

type Producer struct {
	*readwriter.Producer
	// contains filtered or unexported fields
}

func ProducerFromConfig

func ProducerFromConfig(c Config, l loggers.Logger) (*Producer, error)

func ProducerFromConfigWithDialer

func ProducerFromConfigWithDialer(d *websocket.Dialer, c Config, l loggers.Logger) (*Producer, error)

func (*Producer) Close

func (p *Producer) Close() error

type Websocket

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

func FromConfig

func FromConfig(c Config, l loggers.Logger) *Websocket

func (*Websocket) Close

func (q *Websocket) Close() error

func (*Websocket) Consumer

func (q *Websocket) Consumer() (consumer.Consumer, error)

func (*Websocket) Producer

func (q *Websocket) Producer() (producer.Producer, error)