share

Documentation

Index

• Variables
• func CacheAvailability[A share.Availability](lc fx.Lifecycle, ds datastore.Batching, avail A) share.Availability
• func ConstructModule(tp node.Type, cfg *Config, options ...fx.Option) fx.Option
• func Discovery(cfg Config) func(routing.ContentRouting, host.Host) *discovery.Discovery
• type Config
  • func DefaultConfig() Config
  • func (cfg *Config) Validate() error
• type Module
  • func NewModule(lc fx.Lifecycle, bServ blockservice.BlockService, avail share.Availability) Module

Variables

var (
	ErrNegativeInterval = errors.New("interval must be positive")
)

Functions

func CacheAvailability

func CacheAvailability[A share.Availability](lc fx.Lifecycle, ds datastore.Batching, avail A) share.Availability

CacheAvailability wraps either Full or Light availability with a cache for result sampling.

func ConstructModule

func ConstructModule(tp node.Type, cfg *Config, options ...fx.Option) fx.Option

func Discovery

func Discovery(cfg Config) func(routing.ContentRouting, host.Host) *discovery.Discovery

Types

type Config

type Config struct {
	// PeersLimit defines how many peers will be added during discovery.
	PeersLimit uint
	// DiscoveryInterval is an interval between discovery sessions.
	DiscoveryInterval time.Duration
	// AdvertiseInterval is a interval between advertising sessions.
	// NOTE: only full and bridge can advertise themselves.
	AdvertiseInterval time.Duration
}

func DefaultConfig

func DefaultConfig() Config

func (*Config) Validate

func (cfg *Config) Validate() error

Validate performs basic validation of the config.

type Module

type Module interface {
	share.Availability
	GetShare(ctx context.Context, dah *share.Root, row, col int) (share.Share, error)
	GetShares(ctx context.Context, root *share.Root) ([][]share.Share, error)
	GetSharesByNamespace(ctx context.Context, root *share.Root, namespace namespace.ID) ([]share.Share, error)
}

Module provides access to any data square or block share on the network.

All Get methods provided on Module follow the following flow:

1. Check local storage for the requested Share.
2. If exists * Load from disk * Return
3. If not * Find provider on the network * Fetch the Share from the provider * Store the Share * Return

func NewModule

func NewModule(lc fx.Lifecycle, bServ blockservice.BlockService, avail share.Availability) Module