stream

Documentation

Index

• type StreamServer
  • func NewStreamServer(cfg config.Config) *StreamServer
  • func (s *StreamServer) Start()
• type StreamServerConfig

Types

type StreamServer

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

func NewStreamServer

func NewStreamServer(cfg config.Config) *StreamServer

func (*StreamServer) Start

func (s *StreamServer) Start()

type StreamServerConfig

type StreamServerConfig struct {
	Port       string   `mapstructure:"port"`
	Domain     string   `mapstructure:"domain"`
	HubURLs    []string `mapstructure:"hub-urls"`
	LeafPort   int      `mapstructure:"leaf-port"`
	StreamPath string   `mapstructure:"stream-path"`
	KVPath     string   `mapstructure:"kv-path"`
	SinkPath   string   `mapstructure:"sink-path"`
}