handler

Documentation

Index

• type Handler
  • func NewHandler(b broker.Broker) *Handler
  • func (h *Handler) Name() string
  • func (h *Handler) Publish(stream pb.Broker_PublishServer) error
  • func (h *Handler) Subscribe(stream pb.Broker_SubscribeServer) error

Types

type Handler

type Handler struct {
	pb.UnimplementedBrokerServer
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(b broker.Broker) *Handler

func (*Handler) Name

func (h *Handler) Name() string

func (*Handler) Publish

func (h *Handler) Publish(stream pb.Broker_PublishServer) error

Publish receives events from remote client and forwards them to the internal broker.

func (*Handler) Subscribe

func (h *Handler) Subscribe(stream pb.Broker_SubscribeServer) error

Subscribe forwards subscriptions from remote clients