service

Documentation

Index

• type StreamService
  • 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)

Types

type StreamService

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

StreamService offers three endpoints: one to create a new topic in Kafka, a second to expose the topic over a websocket and a third to host a web page that provides a demo.

func NewStreamService

func NewStreamService(port int, cfg *kafka.Config) *StreamService

NewStreamService will return a new stream service instance. If the given config is empty, it will default to localhost.

func (*StreamService) CreateStream

func (s *StreamService) CreateStream(r *http.Request) (int, interface{}, error)

CreateStream is a JSON endpoint for creating a new topic in Kafka.

func (*StreamService) Demo

func (s *StreamService) Demo(w http.ResponseWriter, r *http.Request)

Demo will serve an HTML page that demonstrates how to use the 'stream' endpoint.

func (*StreamService) Endpoints

func (s *StreamService) Endpoints() map[string]map[string]http.HandlerFunc

Endpoints returns the two endpoints for our stream service.

func (*StreamService) Middleware

func (s *StreamService) Middleware(h http.Handler) http.Handler

Middleware in this service will do nothing.

func (*StreamService) Prefix

func (s *StreamService) Prefix() string

Prefix is the string prefixed to all endpoint routes.

func (*StreamService) Stream

func (s *StreamService) Stream(w http.ResponseWriter, r *http.Request)

Stream will init a new pubsub.Publisher and pubsub.Subscriber then upgrade the current request to a websocket connection. Any messages consumed from Kafka will be published to the web socket and vice versa.