substrate

Documentation

Index

• type Option
  • func StorageMethod(method storageMethod) Option
• type Service
  • func New(srv nodeIface.Service, factory kvdb.Factory, options ...Option) (*Service, error)
  • func (s *Service) Add(content io.Reader) (cid.Cid, error)
  • func (s *Service) Cache() components.Cache
  • func (s *Service) CheckTns(components.MatchDefinition) ([]components.Serviceable, error)
  • func (s *Service) Close() error
  • func (s *Service) Get(context storageIface.Context) (storageIface.Storage, error)
  • func (s *Service) GetFile(ctx context.Context, cid cid.Cid) (peer.ReadSeekCloser, error)
  • func (s *Service) Storage(context storageIface.Context) (storageIface.Storage, error)
  • func (s *Service) Storages() map[string]storageIface.Storage

Types

type Option

type Option func(*Service) error

func StorageMethod

func StorageMethod(method storageMethod) Option

Note: smartops run inside the storage method, so a new method must implement it's own smartOps calls

type Service

type Service struct {
	nodeIface.Service
	// contains filtered or unexported fields
}

func New

func New(srv nodeIface.Service, factory kvdb.Factory, options ...Option) (*Service, error)

func (*Service) Add

func (s *Service) Add(content io.Reader) (cid.Cid, error)

func (*Service) Cache

func (s *Service) Cache() components.Cache

func (*Service) CheckTns

func (s *Service) CheckTns(components.MatchDefinition) ([]components.Serviceable, error)

func (*Service) Close

func (s *Service) Close() error

func (*Service) Get

func (s *Service) Get(context storageIface.Context) (storageIface.Storage, error)

func (*Service) GetFile

func (s *Service) GetFile(ctx context.Context, cid cid.Cid) (peer.ReadSeekCloser, error)

func (*Service) Storage

func (s *Service) Storage(context storageIface.Context) (storageIface.Storage, error)

Context Config will be generated by New()

func (*Service) Storages

func (s *Service) Storages() map[string]storageIface.Storage