subscriber

Documentation

Index

• type Core
  • func NewCore(q *redis.Redis, topicCore *topic.Core) *Core
  • func (c *Core) CreateSubscriber(req Subscriber)
• type Server
  • func NewServer(topicCore *topic.Core, subscriberCore *Core) *Server
  • func (s *Server) CreateSubscriber(w http.ResponseWriter, r *http.Request)
• type Subscriber

Types

type Core

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

func NewCore

func NewCore(q *redis.Redis, topicCore *topic.Core) *Core

func (*Core) CreateSubscriber

func (c *Core) CreateSubscriber(req Subscriber)

type Server

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

func NewServer

func NewServer(topicCore *topic.Core, subscriberCore *Core) *Server

func (*Server) CreateSubscriber

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

type Subscriber

type Subscriber struct {
	Url         string `json:"url"`
	TimeoutInMs int    `json:"timeout_in_ms"`
	// contains filtered or unexported fields
}