store

README

ipfs-mpi-store

Info

The store handles mpi program storing. It automatically delete unused file after a given delay.

WARNING : Development in progress, might contain bug

License

MIT

Documentation

Index

• func StringsToAddrs(addrStrings []string) (maddrs []maddr.Multiaddr, err error)
• type AddrList
  • func (al *AddrList) Set(value string) error
  • func (al *AddrList) String() string
• type Config
• type Store
  • func NewStore(ctx context.Context, host host.Host, config Config) (*Store, error)
  • func (s *Store) Add(f file.File, ctx context.Context) error
  • func (s *Store) Del(f file.File) error
  • func (s *Store) Get(ctx context.Context) error
  • func (s *Store) Init(ctx context.Context) error

Functions

func StringsToAddrs

func StringsToAddrs(addrStrings []string) (maddrs []maddr.Multiaddr, err error)

Types

type AddrList

type AddrList []maddr.Multiaddr

func (*AddrList) Set

func (al *AddrList) Set(value string) error

func (*AddrList) String

func (al *AddrList) String() string

type Config

type Config struct {
	Url             string
	Path            string
	Ipfs_store      string
	BootstrapPeers  AddrList
	ListenAddresses AddrList
	ProtocolID      string
	Maxsize         uint64
	Api_port        int
}

type Store

type Store struct {
	Ipfs_store string
	// contains filtered or unexported fields
}

func NewStore

func NewStore(ctx context.Context, host host.Host, config Config) (*Store, error)

func (*Store) Add

func (s *Store) Add(f file.File, ctx context.Context) error

func (*Store) Del

func (s *Store) Del(f file.File) error

func (*Store) Get

func (s *Store) Get(ctx context.Context) error

func (*Store) Init

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