internal

package
v0.33.17-new-ingestion... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2024 License: AGPL-3.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Nonce

func Nonce() ([]byte, error)

Nonce returns random string that is used to store unique items in herocache.

Types

type MockUpdatableTopicProvider added in v0.33.1

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

MockUpdatableTopicProvider is a mock implementation of the TopicProvider interface. TODO: this should be moved to a common package (e.g. network/p2p/test). Currently, it is not possible to do so because of a circular dependency.

func NewMockUpdatableTopicProvider added in v0.33.1

func NewMockUpdatableTopicProvider() *MockUpdatableTopicProvider

func (*MockUpdatableTopicProvider) GetTopics added in v0.33.1

func (m *MockUpdatableTopicProvider) GetTopics() []string

func (*MockUpdatableTopicProvider) ListPeers added in v0.33.1

func (m *MockUpdatableTopicProvider) ListPeers(topic string) []peer.ID

func (*MockUpdatableTopicProvider) UpdateSubscriptions added in v0.33.1

func (m *MockUpdatableTopicProvider) UpdateSubscriptions(topic string, peers []peer.ID)

func (*MockUpdatableTopicProvider) UpdateTopics added in v0.33.1

func (m *MockUpdatableTopicProvider) UpdateTopics(topics []string)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL