proxy

Documentation

Index

• type Handler
  • func (s *Handler) Handle(key string, initialMessage string, incomingMessages <-chan string, ...)
• 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)

Types

type Handler

type Handler struct {
}

func (*Handler) Handle

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

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)