proxy

Documentation

Index

• type HTTPReader
  • func (h *HTTPReader) Close() error
  • func (h *HTTPReader) Read(bytes []byte) (int, error)
• type HTTPWriter
  • func (h *HTTPWriter) Close() error
  • func (h *HTTPWriter) Write(bytes []byte) (n int, err error)
• type Handler
  • func (s *Handler) Handle(key string, initialMessage string, incomingMessages <-chan string, ...)

Types

type HTTPReader

type HTTPReader struct {
	Buffered   []byte
	Chan       <-chan string
	EOF        bool
	MessageKey string
}

func (*HTTPReader) Close

func (h *HTTPReader) Close() error

func (*HTTPReader) Read

func (h *HTTPReader) Read(bytes []byte) (int, error)

type HTTPWriter

type HTTPWriter struct {
	Message    common.HTTPMessage
	MessageKey string
	Chan       chan<- common.Message
	// contains filtered or unexported fields
}

func (*HTTPWriter) Close

func (h *HTTPWriter) Close() error

func (*HTTPWriter) Write

func (h *HTTPWriter) Write(bytes []byte) (n int, err error)

type Handler

type Handler struct {
}

func (*Handler) Handle

func (s *Handler) Handle(key string, initialMessage string, incomingMessages <-chan string, response chan<- common.Message)