plugin

Documentation

Index

• Constants
• Variables
• type DatastoreProcess
  • func OpenProcess(ctx context.Context, cfg storjds.Config) (*DatastoreProcess, error)
  • func (p *DatastoreProcess) Close() error
• type StorjConfig
  • func (storj *StorjConfig) Create(path string) (repo.Datastore, error)
  • func (storj *StorjConfig) DiskSpec() fsrepo.DiskSpec
  • func (storj *StorjConfig) RunDebug(ctx context.Context) (err error)
• type StorjPlugin
  • func (plugin *StorjPlugin) Close() error
  • func (plugin StorjPlugin) DatastoreConfigParser() fsrepo.ConfigFromMap
  • func (plugin StorjPlugin) DatastoreTypeName() string
  • func (plugin StorjPlugin) Init(env *plugin.Environment) error
  • func (plugin StorjPlugin) Name() string
  • func (plugin *StorjPlugin) Start(node *core.IpfsNode) error
  • func (plugin StorjPlugin) Version() string

Constants

const (
	DefaultNodeConnectionPoolCapacity       = 100
	DefaultNodeConnectionPoolKeyCapacity    = 5
	DefaultNodeConnectionPoolIdleExpiration = 2 * time.Minute

	DefaultSatelliteConnectionPoolCapacity       = 10
	DefaultSatelliteConnectionPoolKeyCapacity    = 0
	DefaultSatelliteConnectionPoolIdleExpiration = 2 * time.Minute
)

Variables

var Error = errs.Class("storjds")

Error is the error class for Storj datastore plugin.

var Plugins = []plugin.Plugin{
	&StorjPlugin{},
}

Types

type DatastoreProcess

type DatastoreProcess struct {
	*storjds.Datastore
	DB *db.DB
}

func OpenProcess

func OpenProcess(ctx context.Context, cfg storjds.Config) (*DatastoreProcess, error)

func (*DatastoreProcess) Close

func (p *DatastoreProcess) Close() error

type StorjConfig

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

func (*StorjConfig) Create

func (storj *StorjConfig) Create(path string) (repo.Datastore, error)

func (*StorjConfig) DiskSpec

func (storj *StorjConfig) DiskSpec() fsrepo.DiskSpec

func (*StorjConfig) RunDebug

func (storj *StorjConfig) RunDebug(ctx context.Context) (err error)

type StorjPlugin

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

func (*StorjPlugin) Close

func (plugin *StorjPlugin) Close() error

func (StorjPlugin) DatastoreConfigParser

func (plugin StorjPlugin) DatastoreConfigParser() fsrepo.ConfigFromMap

func (StorjPlugin) DatastoreTypeName

func (plugin StorjPlugin) DatastoreTypeName() string

func (StorjPlugin) Init

func (plugin StorjPlugin) Init(env *plugin.Environment) error

func (StorjPlugin) Name

func (plugin StorjPlugin) Name() string

func (*StorjPlugin) Start

func (plugin *StorjPlugin) Start(node *core.IpfsNode) error

func (StorjPlugin) Version

func (plugin StorjPlugin) Version() string