pushsync

type DB interface {
	// subscribe to chunk to be push synced - iterates from earliest to newest
	SubscribePush(context.Context) (<-chan storage.Chunk, func())
	// called to set a chunk as synced - and allow it to be garbage collected
	// TODO this should take ... last argument to delete many in one batch
	Set(context.Context, chunk.ModeSet, ...storage.Address) error
}

type PubSub interface {
	Register(topic string, prox bool, handler func(msg []byte, p *p2p.Peer) error) func()
	Send(to []byte, topic string, msg []byte) error
	BaseAddr() []byte
	IsClosestTo([]byte) bool
}

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

type Store interface {
	Put(context.Context, chunk.ModePut, ...chunk.Chunk) ([]bool, error)
}

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