Versions in this module Expand all Collapse all v1 v1.7.1 Jan 29, 2021 v1.7.0 Dec 8, 2020 Changes in this version + const FetchProtoID + func KeyToTopic(key string) string + type Option func(*PubsubValueStore) error + func WithRebroadcastInitialDelay(duration time.Duration) Option + func WithRebroadcastInterval(duration time.Duration) Option + type Pubsub interface + Join func(topic string, opts ...pubsub.TopicOpt) (*pubsub.Topic, error) + RegisterTopicValidator func(topic string, validator interface{}, opts ...pubsub.ValidatorOpt) error + type PubsubValueStore struct + Validator record.Validator + func NewPubsubValueStore(ctx context.Context, host host.Host, ps Pubsub, validator record.Validator, ...) (*PubsubValueStore, error) + func (p *PubsubValueStore) Cancel(name string) (bool, error) + func (p *PubsubValueStore) GetSubscriptions() []string + func (p *PubsubValueStore) GetValue(ctx context.Context, key string, opts ...routing.Option) ([]byte, error) + func (p *PubsubValueStore) PutValue(ctx context.Context, key string, value []byte, opts ...routing.Option) error + func (p *PubsubValueStore) SearchValue(ctx context.Context, key string, opts ...routing.Option) (<-chan []byte, error) + func (p *PubsubValueStore) Subscribe(key string) error