app

Documentation

Index

• type ClientMessageType
• type HttpServer
  • func NewHttpServer(b *broker.Broker, logger *zap.Logger) *HttpServer
  • func (h *HttpServer) StartHttpServer(port string)
• type TCPMessage
• type TCPServer
  • func NewTCPServer(listenAddress string, logger *zap.Logger) *TCPServer
  • func (s *TCPServer) Start() error

Types

type ClientMessageType

type ClientMessageType string

const (
	RESPONSE  ClientMessageType = "Response"
	SUBSCRIBE ClientMessageType = "Subscribe"
	PRODUCE   ClientMessageType = "Produce"
)

type HttpServer

type HttpServer struct {
	Broker *broker.Broker
	Router *mux.Router
	Logger *zap.Logger
}

func NewHttpServer

func NewHttpServer(b *broker.Broker, logger *zap.Logger) *HttpServer

func (*HttpServer) StartHttpServer

func (h *HttpServer) StartHttpServer(port string)

type TCPMessage

type TCPMessage struct {
	Type       ClientMessageType `json:"type"`
	Payload    json.RawMessage   `json:"payload"`
	Queue      string            `json:"queue"`
	Enviorment string            `json:"enviorment"`
	Sender     string            `json:"sender"`
	Connection *net.Conn
}

type TCPServer

type TCPServer struct {
	Logger *zap.Logger

	MsgChannel chan TCPMessage
	// contains filtered or unexported fields
}

func NewTCPServer

func NewTCPServer(listenAddress string, logger *zap.Logger) *TCPServer

func (*TCPServer) Start

func (s *TCPServer) Start() error