Versions in this module Expand all Collapse all v2 v2.0.0 Feb 8, 2019 Changes in this version + type StreamService struct + func NewStreamService(port int, cfg *kafka.Config) *StreamService + func (s *StreamService) CreateStream(r *http.Request) (int, interface{}, error) + func (s *StreamService) Demo(w http.ResponseWriter, r *http.Request) + func (s *StreamService) Endpoints() map[string]map[string]http.HandlerFunc + func (s *StreamService) Middleware(h http.Handler) http.Handler + func (s *StreamService) Prefix() string + func (s *StreamService) Stream(w http.ResponseWriter, r *http.Request) Other modules containing this package github.com/CASE-fold/gizmo