topic

Documentation

Index

• type Core
  • func NewCore(q *redis.Redis) *Core
  • func (c *Core) CreateSubscriber(topicName string, subsName string)
  • func (c *Core) Publish(topic string, body bytes.Buffer, header map[string][]string) error
  • func (c *Core) SubscriberExists(topic string, subs string) bool
  • func (c *Core) TopicExists(topic string) bool
• type Server
  • func NewServer(c *Core) *Server
  • func (s *Server) CreateTopic(w http.ResponseWriter, r *http.Request)
  • func (s *Server) GetTopic(w http.ResponseWriter, r *http.Request)
  • func (s *Server) Publish(w http.ResponseWriter, r *http.Request)
• type Topic

Types

type Core

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

func NewCore

func NewCore(q *redis.Redis) *Core

func (*Core) CreateSubscriber

func (c *Core) CreateSubscriber(topicName string, subsName string)

func (*Core) Publish

func (c *Core) Publish(topic string, body bytes.Buffer, header map[string][]string) error

func (*Core) SubscriberExists

func (c *Core) SubscriberExists(topic string, subs string) bool

func (*Core) TopicExists

func (c *Core) TopicExists(topic string) bool

type Server

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

func NewServer

func NewServer(c *Core) *Server

func (*Server) CreateTopic

func (s *Server) CreateTopic(w http.ResponseWriter, r *http.Request)

func (*Server) GetTopic

func (s *Server) GetTopic(w http.ResponseWriter, r *http.Request)

func (*Server) Publish

func (s *Server) Publish(w http.ResponseWriter, r *http.Request)

type Topic

type Topic struct {
	TimeoutInMs int  `json:"timeout_in_ms"`
	IsDurable   bool `json:"is_durable"`
	// contains filtered or unexported fields
}