broker

Documentation

Index

• type Broker
  • func (h *Broker) Publish(ctx context.Context, stream pb.Broker_PublishStream) error
  • func (h *Broker) Subscribe(ctx context.Context, req *pb.SubscribeRequest, ...) error

Types

type Broker

type Broker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Broker) Publish

func (h *Broker) Publish(ctx context.Context, stream pb.Broker_PublishStream) error

func (*Broker) Subscribe

func (h *Broker) Subscribe(ctx context.Context, req *pb.SubscribeRequest, stream pb.Broker_SubscribeStream) error