pubsub

Documentation

Index

• type BlobDownloadedPubSub
  • func NewBlobDownloadedPubSub() *BlobDownloadedPubSub
  • func (m *BlobDownloadedPubSub) Publish(blob refs.Blob, size blobs.Size)
  • func (m *BlobDownloadedPubSub) Subscribe(ctx context.Context) <-chan queries.BlobDownloaded
• type GoChannelPubSub
  • func NewGoChannelPubSub[T any]() *GoChannelPubSub[T]
  • func (g *GoChannelPubSub[T]) Publish(value T)
  • func (g *GoChannelPubSub[T]) Subscribe(ctx context.Context) <-chan T
• type MessagePubSub
  • func NewMessagePubSub() *MessagePubSub
  • func (m *MessagePubSub) PublishNewMessage(msg message.Message)
  • func (m *MessagePubSub) SubscribeToNewMessages(ctx context.Context) <-chan message.Message
• type NewPeer
• type NewPeerPubSub
  • func NewNewPeerPubSub() *NewPeerPubSub
  • func (m *NewPeerPubSub) HandleNewPeer(ctx context.Context, peer transport.Peer)
  • func (m *NewPeerPubSub) SubscribeToRequests(ctx context.Context) <-chan NewPeer
• type Request
• type RequestPubSub
  • func NewRequestPubSub() *RequestPubSub
  • func (m *RequestPubSub) HandleRequest(ctx context.Context, s rpc.Stream, req *rpc.Request)
  • func (m *RequestPubSub) SubscribeToRequests(ctx context.Context) <-chan Request
• type RoomAttendantEvent
• type RoomAttendantEventPubSub
  • func NewRoomAttendantEventPubSub() *RoomAttendantEventPubSub
  • func (p *RoomAttendantEventPubSub) PublishAttendantEvent(ctx context.Context, portal transport.Peer, event rooms.RoomAttendantsEvent) error
  • func (p *RoomAttendantEventPubSub) SubscribeToAttendantEvents(ctx context.Context) <-chan RoomAttendantEvent

Types

type BlobDownloadedPubSub

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

func NewBlobDownloadedPubSub

func NewBlobDownloadedPubSub() *BlobDownloadedPubSub

func (*BlobDownloadedPubSub) Publish

func (m *BlobDownloadedPubSub) Publish(blob refs.Blob, size blobs.Size)

func (*BlobDownloadedPubSub) Subscribe

func (m *BlobDownloadedPubSub) Subscribe(ctx context.Context) <-chan queries.BlobDownloaded

type GoChannelPubSub

type GoChannelPubSub[T any] struct {
	// contains filtered or unexported fields
}

func NewGoChannelPubSub

func NewGoChannelPubSub[T any]() *GoChannelPubSub[T]

func (*GoChannelPubSub[T]) Publish

func (g *GoChannelPubSub[T]) Publish(value T)

func (*GoChannelPubSub[T]) Subscribe

func (g *GoChannelPubSub[T]) Subscribe(ctx context.Context) <-chan T

type MessagePubSub

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

func NewMessagePubSub

func NewMessagePubSub() *MessagePubSub

func (*MessagePubSub) PublishNewMessage

func (m *MessagePubSub) PublishNewMessage(msg message.Message)

func (*MessagePubSub) SubscribeToNewMessages

func (m *MessagePubSub) SubscribeToNewMessages(ctx context.Context) <-chan message.Message

type NewPeer

type NewPeer struct {
	Ctx  context.Context
	Peer transport.Peer
}

type NewPeerPubSub

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

func NewNewPeerPubSub

func NewNewPeerPubSub() *NewPeerPubSub

func (*NewPeerPubSub) HandleNewPeer

func (m *NewPeerPubSub) HandleNewPeer(ctx context.Context, peer transport.Peer)

func (*NewPeerPubSub) SubscribeToRequests

func (m *NewPeerPubSub) SubscribeToRequests(ctx context.Context) <-chan NewPeer

type Request

type Request struct {
	Ctx    context.Context
	Stream rpc.Stream
	Req    *rpc.Request
}

type RequestPubSub

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

func NewRequestPubSub

func NewRequestPubSub() *RequestPubSub

func (*RequestPubSub) HandleRequest

func (m *RequestPubSub) HandleRequest(ctx context.Context, s rpc.Stream, req *rpc.Request)

func (*RequestPubSub) SubscribeToRequests

func (m *RequestPubSub) SubscribeToRequests(ctx context.Context) <-chan Request

type RoomAttendantEvent

type RoomAttendantEvent struct {
	Context context.Context
	Portal  transport.Peer
	Event   rooms.RoomAttendantsEvent
}

type RoomAttendantEventPubSub

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

func NewRoomAttendantEventPubSub

func NewRoomAttendantEventPubSub() *RoomAttendantEventPubSub

func (*RoomAttendantEventPubSub) PublishAttendantEvent

func (p *RoomAttendantEventPubSub) PublishAttendantEvent(ctx context.Context, portal transport.Peer, event rooms.RoomAttendantsEvent) error

func (*RoomAttendantEventPubSub) SubscribeToAttendantEvents

func (p *RoomAttendantEventPubSub) SubscribeToAttendantEvents(ctx context.Context) <-chan RoomAttendantEvent