namesys

Nov 22, 2021

Changes in this version

type Option

+ func WithDatastore(datastore ds.Datastore) Option

Feb 6, 2020

Changes in this version

+ type Pubsub interface

+ Join func(topic string, opts ...pubsub.TopicOpt) (*pubsub.Topic, error)

+ RegisterTopicValidator func(topic string, val pubsub.Validator, opts ...pubsub.ValidatorOpt) error

Dec 9, 2019

Changes in this version

+ const FetchProtoID

+ type Option func(*PubsubValueStore) error

+ func WithRebroadcastInitialDelay(duration time.Duration) Option

+ func WithRebroadcastInterval(duration time.Duration) Option

Mar 2, 2019

Changes in this version

+ func KeyToTopic(key string) string

+ type PubsubValueStore struct

+ Validator record.Validator

+ func NewPubsubValueStore(ctx context.Context, host p2phost.Host, cr routing.ContentRouting, ...) *PubsubValueStore

+ func (p *PubsubValueStore) Cancel(name string) (bool, error)

+ func (p *PubsubValueStore) GetSubscriptions() []string

+ func (p *PubsubValueStore) GetValue(ctx context.Context, key string, opts ...ropts.Option) ([]byte, error)

+ func (p *PubsubValueStore) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) error

+ func (p *PubsubValueStore) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ func (p *PubsubValueStore) Subscribe(key string) error