signaling

Documentation

Index

• type SignalingController
  • func NewSignalingController(addr string, logger *zap.Logger, opts ...grpc.ServerOption) *SignalingController
  • func (sc *SignalingController) Publish(ctx context.Context, req *signaling.PublishRequest) (*signaling.PublishResponse, error)
  • func (sc *SignalingController) Start(ctx context.Context) error
  • func (sc *SignalingController) Subscribe(req *signaling.SubscribeRequest, stream signaling.Signaling_SubscribeServer) error
  • func (sc *SignalingController) Unsubscribe(ctx context.Context, request *api.UnsubscribeRequest) (*api.UnsubscribeResponse, error)

Types

type SignalingController

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

func NewSignalingController

func NewSignalingController(addr string, logger *zap.Logger, opts ...grpc.ServerOption) *SignalingController

func (*SignalingController) Publish

func (sc *SignalingController) Publish(ctx context.Context, req *signaling.PublishRequest) (*signaling.PublishResponse, error)

func (*SignalingController) Start

func (sc *SignalingController) Start(ctx context.Context) error

func (*SignalingController) Subscribe

func (sc *SignalingController) Subscribe(req *signaling.SubscribeRequest, stream signaling.Signaling_SubscribeServer) error

func (*SignalingController) Unsubscribe

func (sc *SignalingController) Unsubscribe(ctx context.Context, request *api.UnsubscribeRequest) (*api.UnsubscribeResponse, error)