storage

Documentation

Index

• type ChunkNotifierStore
• type ExampleChunkMatcher
  • func (cn *ExampleChunkMatcher) Match(n listener.Notification, address string) bool
• type ExampleChunkNotifier
  • func NewExampleChunkNotifier(cstore ChunkNotifierStore) *ExampleChunkNotifier
  • func (cn *ExampleChunkNotifier) Notify(c *types.ChunkNotification) error
• type ExampleChunkWaiter
  • func NewExampleChunkWaiter(awb broadcaster.Broadcaster) *ExampleChunkWaiter
  • func (cw *ExampleChunkWaiter) WaitForChunk(c *types.ChunkNotification)

Types

type ChunkNotifierStore

type ChunkNotifierStore interface {
	Notify(channelName string, n interface{}) error
}

type ExampleChunkMatcher

type ExampleChunkMatcher struct{}

func (*ExampleChunkMatcher) Match

func (cn *ExampleChunkMatcher) Match(n listener.Notification, address string) bool

type ExampleChunkNotifier

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

func NewExampleChunkNotifier

func NewExampleChunkNotifier(cstore ChunkNotifierStore) *ExampleChunkNotifier

func (*ExampleChunkNotifier) Notify

func (cn *ExampleChunkNotifier) Notify(c *types.ChunkNotification) error

type ExampleChunkWaiter

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

func NewExampleChunkWaiter

func NewExampleChunkWaiter(awb broadcaster.Broadcaster) *ExampleChunkWaiter

func (*ExampleChunkWaiter) WaitForChunk

func (cw *ExampleChunkWaiter) WaitForChunk(c *types.ChunkNotification)