objectmanager

type LookupOption func(*LookupOptions)

type LookupOptions struct {
	// Lookups are used to perform db queries for these filters
	// TODO find a better name for this
	Lookups struct {
		ObjectHashes []tilde.Digest
		StreamHashes []tilde.Digest
		ContentTypes []string
		Owners       []did.DID
	}
	// filters are the lookups equivalents for matching objects for pubsub
	Filters []ObjectFilter
}

type ObjectFilter func(*object.Object) bool

type ObjectManager interface {
	Put(
		ctx context.Context,
		o *object.Object,
	) error
	Append(
		ctx context.Context,
		o *object.Object,
	) (*object.Object, error)
	Request(
		ctx context.Context,
		hash tilde.Digest,
		peer *peer.ConnectionInfo,
	) (*object.Object, error)
	RequestStream(
		ctx context.Context,
		rootHash tilde.Digest,
		recipients ...*peer.ConnectionInfo,
	) (object.ReadCloser, error)
	AddStreamSubscription(
		ctx context.Context,
		rootHash tilde.Digest,
	) error
	Subscribe(
		lookupOptions ...LookupOption,
	) ObjectSubscription
}

type ObjectPubSub interface {
	Publish(*object.Object)
	Subscribe(...ObjectFilter) ObjectSubscription
}

type ObjectSubscription interface {
	object.ReadCloser
	Channel() <-chan *object.Object
}

type Option func(*manager)

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