websockets

Documentation

Index

• func Subscribe(consumer *kafka.Consumer) func(http.ResponseWriter, *http.Request)
• type Hub
• type Subscriber
• type Topics
  • func (t Topics) Slice() []string
  • func (t Topics) Validate() error

Functions

func Subscribe

func Subscribe(consumer *kafka.Consumer) func(http.ResponseWriter, *http.Request)

Types

type Hub

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

type Subscriber

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

type Topics

type Topics map[string]struct{}

func (Topics) Slice

func (t Topics) Slice() []string

func (Topics) Validate

func (t Topics) Validate() error