_default

package
v0.0.0-...-9cc7e76 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2024 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnsupportedMetaFormat = errors.New("unsupported metadata format")
)

Functions

This section is empty.

Types

type HTTPServiceDefault 

type HTTPServiceDefault struct {
	service.ServiceBase
}

func NewHTTP 

func NewHTTP(params service.ServiceParams) *HTTPServiceDefault

func (*HTTPServiceDefault) GetHttpRouter 

func (h *HTTPServiceDefault) GetHttpRouter() map[string]http.HandlerFunc

func (*HTTPServiceDefault) Init 

func (h *HTTPServiceDefault) Init(ctx context.Context) error

func (*HTTPServiceDefault) Start 

func (h *HTTPServiceDefault) Start(ctx context.Context) error

func (*HTTPServiceDefault) Stop 

func (h *HTTPServiceDefault) Stop(ctx context.Context) error

type MediatorDefault 

type MediatorDefault struct {
	service.ServiceBase
}

func NewMediator 

func NewMediator(params service.ServiceParams) *MediatorDefault

func (MediatorDefault) AddPeer 

func (m MediatorDefault) AddPeer(peer net.Peer) error

func (MediatorDefault) AddStorageLocation 

func (m MediatorDefault) AddStorageLocation(hash *encoding.Multihash, nodeId *encoding.NodeId, location storage.StorageLocation, message []byte) error

func (MediatorDefault) ConnectToNode 

func (m MediatorDefault) ConnectToNode(connectionUris []*url.URL, retried bool, fromPeer net.Peer) error

func (MediatorDefault) GetCachedStorageLocations 

func (m MediatorDefault) GetCachedStorageLocations(hash *encoding.Multihash, kinds []types.StorageLocationType) (map[string]storage.StorageLocation, error)

func (MediatorDefault) HashQueryRoutingTable 

func (m MediatorDefault) HashQueryRoutingTable() structs.Map

func (MediatorDefault) NetworkId 

func (m MediatorDefault) NetworkId() string

func (MediatorDefault) NodeId 

func (m MediatorDefault) NodeId() *encoding.NodeId

func (MediatorDefault) Peers 

func (m MediatorDefault) Peers() structs.Map

func (MediatorDefault) ProviderStore 

func (m MediatorDefault) ProviderStore() storage.ProviderStore

func (MediatorDefault) RegistryGet 

func (m MediatorDefault) RegistryGet(pk []byte) (protocol.SignedRegistryEntry, error)

func (MediatorDefault) RegistrySet 

func (m MediatorDefault) RegistrySet(sre protocol.SignedRegistryEntry, trusted bool, receivedFrom net.Peer) error

func (MediatorDefault) SelfConnectionUris 

func (m MediatorDefault) SelfConnectionUris() []*url.URL

func (MediatorDefault) SendPublicPeersToPeer 

func (m MediatorDefault) SendPublicPeersToPeer(peer net.Peer, peersToSend []net.Peer) error

func (MediatorDefault) ServicesStarted 

func (m MediatorDefault) ServicesStarted() bool

func (MediatorDefault) SignMessageSimple 

func (m MediatorDefault) SignMessageSimple(message []byte) ([]byte, error)

func (MediatorDefault) SortNodesByScore 

func (m MediatorDefault) SortNodesByScore(nodes []*encoding.NodeId) ([]*encoding.NodeId, error)

type P2PNodeResponse 

type P2PNodeResponse struct {
	Id   string   `json:"id"`
	Uris []string `json:"uris"`
}

type P2PNodesResponse 

type P2PNodesResponse struct {
	Nodes []P2PNodeResponse `json:"nodes"`
}

type P2PServiceDefault 

type P2PServiceDefault struct {
	service.ServiceBase
	// contains filtered or unexported fields
}

func NewP2P 

func NewP2P(params service.ServiceParams) *P2PServiceDefault

func (*P2PServiceDefault) AddPeer 

func (p *P2PServiceDefault) AddPeer(peer net.Peer) error

func (*P2PServiceDefault) ConnectToNode 

func (p *P2PServiceDefault) ConnectToNode(connectionUris []*url.URL, retry uint, fromPeer net.Peer) error

func (*P2PServiceDefault) ConnectionTracker 

func (p *P2PServiceDefault) ConnectionTracker() *sync.WaitGroup

func (*P2PServiceDefault) DownVote 

func (p *P2PServiceDefault) DownVote(nodeId *encoding.NodeId) error

func (*P2PServiceDefault) GetNodeScore 

func (p *P2PServiceDefault) GetNodeScore(nodeId *encoding.NodeId) (float64, error)

func (*P2PServiceDefault) HashQueryRoutingTable 

func (n *P2PServiceDefault) HashQueryRoutingTable() structs.Map

func (*P2PServiceDefault) Init 

func (p *P2PServiceDefault) Init(ctx context.Context) error

func (*P2PServiceDefault) NetworkId 

func (p *P2PServiceDefault) NetworkId() string

func (*P2PServiceDefault) NodeId 

func (p *P2PServiceDefault) NodeId() *encoding.NodeId

func (*P2PServiceDefault) OnNewPeer 

func (p *P2PServiceDefault) OnNewPeer(peer net.Peer, verifyId bool) error

func (*P2PServiceDefault) OnNewPeerListen 

func (p *P2PServiceDefault) OnNewPeerListen(peer net.Peer, verifyId bool)

func (*P2PServiceDefault) Peers 

func (p *P2PServiceDefault) Peers() structs.Map

func (*P2PServiceDefault) SelfConnectionUris 

func (p *P2PServiceDefault) SelfConnectionUris() []*url.URL

func (*P2PServiceDefault) SendHashRequest 

func (p *P2PServiceDefault) SendHashRequest(hash *encoding.Multihash, kinds []types.StorageLocationType) error

func (*P2PServiceDefault) SendPublicPeersToPeer 

func (p *P2PServiceDefault) SendPublicPeersToPeer(peer net.Peer, peersToSend []net.Peer) error

func (*P2PServiceDefault) SignMessageSimple 

func (p *P2PServiceDefault) SignMessageSimple(message []byte) ([]byte, error)

func (*P2PServiceDefault) SortNodesByScore 

func (p *P2PServiceDefault) SortNodesByScore(nodes []*encoding.NodeId) ([]*encoding.NodeId, error)

func (*P2PServiceDefault) Start 

func (p *P2PServiceDefault) Start(ctx context.Context) error

func (*P2PServiceDefault) Stop 

func (p *P2PServiceDefault) Stop(ctx context.Context) error

func (*P2PServiceDefault) UpVote 

func (p *P2PServiceDefault) UpVote(nodeId *encoding.NodeId) error

func (*P2PServiceDefault) WaitOnConnectedPeers 

func (p *P2PServiceDefault) WaitOnConnectedPeers()

type RegistryServiceDefault 

type RegistryServiceDefault struct {
	service.ServiceBase
	// contains filtered or unexported fields
}

func NewRegistry 

func NewRegistry(params service.ServiceParams) *RegistryServiceDefault

func (*RegistryServiceDefault) BroadcastEntry 

func (r *RegistryServiceDefault) BroadcastEntry(sre protocol.SignedRegistryEntry, receivedFrom net.Peer) error

func (*RegistryServiceDefault) Get 

func (r *RegistryServiceDefault) Get(pk []byte) (protocol.SignedRegistryEntry, error)

func (*RegistryServiceDefault) Init 

func (r *RegistryServiceDefault) Init(ctx context.Context) error

func (*RegistryServiceDefault) Listen 

func (r *RegistryServiceDefault) Listen(pk []byte, cb func(sre protocol.SignedRegistryEntry)) (func(), error)

func (*RegistryServiceDefault) SendRegistryRequest 

func (r *RegistryServiceDefault) SendRegistryRequest(pk []byte) error

func (*RegistryServiceDefault) Set 

func (r *RegistryServiceDefault) Set(sre protocol.SignedRegistryEntry, trusted bool, receivedFrom net.Peer) error

func (*RegistryServiceDefault) Start 

func (r *RegistryServiceDefault) Start(ctx context.Context) error

func (*RegistryServiceDefault) Stop 

func (r *RegistryServiceDefault) Stop(ctx context.Context) error

type StorageService 

type StorageService struct {
	service.ServiceBase
	// contains filtered or unexported fields
}

func NewStorage 

func NewStorage(params service.ServiceParams) *StorageService

func (*StorageService) AddStorageLocation 

func (s *StorageService) AddStorageLocation(hash *encoding.Multihash, nodeId *encoding.NodeId, location storage.StorageLocation, message []byte) error

func (*StorageService) DownloadBytesByCID 

func (s *StorageService) DownloadBytesByCID(cid *encoding.CID) (bytes []byte, err error)

func (*StorageService) DownloadBytesByHash 

func (s *StorageService) DownloadBytesByHash(hash *encoding.Multihash) ([]byte, error)

func (*StorageService) GetCachedStorageLocations 

func (s *StorageService) GetCachedStorageLocations(hash *encoding.Multihash, kinds []types.StorageLocationType, local bool) (map[string]storage.StorageLocation, error)

func (*StorageService) GetMetadataByCID 

func (s *StorageService) GetMetadataByCID(cid *encoding.CID) (md metadata.Metadata, err error)

func (*StorageService) Init 

func (s *StorageService) Init(ctx context.Context) error

func (*StorageService) ParseMetadata 

func (s *StorageService) ParseMetadata(bytes []byte, cid *encoding.CID) (metadata.Metadata, error)

func (*StorageService) ProviderStore 

func (n *StorageService) ProviderStore() storage.ProviderStore

func (*StorageService) SetProviderStore 

func (n *StorageService) SetProviderStore(store storage.ProviderStore)

func (*StorageService) Start 

func (s *StorageService) Start(ctx context.Context) error

func (*StorageService) Stop 

func (s *StorageService) Stop(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.