server

type Command struct {
	Type CommandType `json:"type"`
	Body string      `json:"body"`
}

type CommandHandler func(command Command) error

type CommandType string

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

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

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

type InternalReader interface {
	SetKeepAlive(keepalive bool) error
	Close() error
	Reader() io.Reader
}

type InternalTcpListener interface {
	Close() error
	Accept(deadline time.Time) (InternalReader, *TcpAcceptError)
}

type JsonResponse struct {
	Error   bool        `json:"error"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type MockHttpServer struct {
	Actions map[string]int
	// contains filtered or unexported fields
}

type MockReader struct {
	Actions map[string]int
	// contains filtered or unexported fields
}

type MockTcpListener struct {
	Actions map[string]int
	// contains filtered or unexported fields
}

type PublishPayload struct {
	Type string `json:"type"`
	Data string `json:"data"`
}

type Server interface {
	Start()
	Cancel()
	CommandHandlers() map[CommandType]CommandHandler
}

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

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