broadcasts

Documentation

Index

• type BlobStoreBroadcast
  • func NewBlobStoreEmitter() (ssb.BlobStoreEmitter, *BlobStoreBroadcast)
  • func (bcst *BlobStoreBroadcast) Register(sink ssb.BlobStoreEmitter) ssb.CancelFunc
• type BlobStoreFuncEmitter
  • func (e BlobStoreFuncEmitter) Close() error
  • func (e BlobStoreFuncEmitter) EmitBlob(not ssb.BlobStoreNotification) error
• type BlobStoreSink
  • func (bcst *BlobStoreSink) Close() error
  • func (bcst *BlobStoreSink) EmitBlob(nf ssb.BlobStoreNotification) error
• type BlobWantsBroadcast
  • func NewBlobWantsEmitter() (ssb.BlobWantsEmitter, *BlobWantsBroadcast)
  • func (bcst *BlobWantsBroadcast) Register(sink ssb.BlobWantsEmitter) ssb.CancelFunc
• type BlobWantsSink
  • func (bcst *BlobWantsSink) Close() error
  • func (bcst *BlobWantsSink) EmitWant(w ssb.BlobWant) error

Types

type BlobStoreBroadcast

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

BlobStoreBroadcast is an interface for registering one or more Sinks to recieve updates.

func NewBlobStoreEmitter

func NewBlobStoreEmitter() (ssb.BlobStoreEmitter, *BlobStoreBroadcast)

NewBlobStoreEmitter returns the Sink, to write to the broadcaster, and the new broadcast instance.

func (*BlobStoreBroadcast) Register

func (bcst *BlobStoreBroadcast) Register(sink ssb.BlobStoreEmitter) ssb.CancelFunc

Register a Sink for updates to be sent. also returns

type BlobStoreFuncEmitter

type BlobStoreFuncEmitter func(not ssb.BlobStoreNotification) error

util

func (BlobStoreFuncEmitter) Close

func (e BlobStoreFuncEmitter) Close() error

func (BlobStoreFuncEmitter) EmitBlob

func (e BlobStoreFuncEmitter) EmitBlob(not ssb.BlobStoreNotification) error

type BlobStoreSink

type BlobStoreSink BlobStoreBroadcast

func (*BlobStoreSink) Close

func (bcst *BlobStoreSink) Close() error

Close implements the Sink interface.

func (*BlobStoreSink) EmitBlob

func (bcst *BlobStoreSink) EmitBlob(nf ssb.BlobStoreNotification) error

Pour implements the Sink interface.

type BlobWantsBroadcast

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

BlobWantsBroadcast is an interface for registering one or more Sinks to recieve updates.

func NewBlobWantsEmitter

func NewBlobWantsEmitter() (ssb.BlobWantsEmitter, *BlobWantsBroadcast)

NewBlobWantsEmitter returns the Sink, to write to the broadcaster, and the new broadcast instance.

func (*BlobWantsBroadcast) Register

func (bcst *BlobWantsBroadcast) Register(sink ssb.BlobWantsEmitter) ssb.CancelFunc

Register a Sink for updates to be sent. also returns

type BlobWantsSink

type BlobWantsSink BlobWantsBroadcast

func (*BlobWantsSink) Close

func (bcst *BlobWantsSink) Close() error

Close implements the Sink interface.

func (*BlobWantsSink) EmitWant

func (bcst *BlobWantsSink) EmitWant(w ssb.BlobWant) error

Pour implements the Sink interface.