proxy

Documentation

Index

• func TestApi(r *gin.RouterGroup, ns *Server) error
• type Person
• type Server
  • func (s *Server) Connect() error
  • func (s *Server) Receive(topic string) error
  • func (s *Server) Send(topic string, payload interface{}) error

Functions

func TestApi

func TestApi(r *gin.RouterGroup, ns *Server) error

Types

type Person

type Person struct {
	Name string `json:"name"`
}

type Server

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

func (*Server) Connect

func (s *Server) Connect() error

func (*Server) Receive

func (s *Server) Receive(topic string) error

TODO need to close subscription

func (*Server) Send

func (s *Server) Send(topic string, payload interface{}) error