tracing

Documentation

Index

• type NodeStore
  • func NewNodeStore(delegate routing.NodeInfoStore) *NodeStore
  • func (r *NodeStore) Add(ctx context.Context, nodeInfo models.NodeInfo) error
  • func (r *NodeStore) Delete(ctx context.Context, nodeID string) error
  • func (r *NodeStore) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)
  • func (r *NodeStore) Get(ctx context.Context, nodeID string) (models.NodeInfo, error)
  • func (r *NodeStore) GetByPrefix(ctx context.Context, prefix string) (models.NodeInfo, error)
  • func (r *NodeStore) List(ctx context.Context, filters ...routing.NodeInfoFilter) ([]models.NodeInfo, error)

Types

type NodeStore

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

func NewNodeStore

func NewNodeStore(delegate routing.NodeInfoStore) *NodeStore

func (*NodeStore) Add

func (r *NodeStore) Add(ctx context.Context, nodeInfo models.NodeInfo) error

func (*NodeStore) Delete

func (r *NodeStore) Delete(ctx context.Context, nodeID string) error

func (*NodeStore) FindPeer

func (r *NodeStore) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)

func (*NodeStore) Get

func (r *NodeStore) Get(ctx context.Context, nodeID string) (models.NodeInfo, error)

func (*NodeStore) GetByPrefix

func (r *NodeStore) GetByPrefix(ctx context.Context, prefix string) (models.NodeInfo, error)

func (*NodeStore) List

func (r *NodeStore) List(ctx context.Context, filters ...routing.NodeInfoFilter) ([]models.NodeInfo, error)