shuttle

Dec 12, 2022

Changes in this version

+ var ErrNilParams = fmt.Errorf("shuttle message had nil params")

+ var ErrNoShuttleConnection = fmt.Errorf("no connection to requested shuttle")

+ type IManager interface

+ AddrInfo func(handle string) *peer.AddrInfo

+ AggregateContent func(ctx context.Context, loc string, zone util.Content, ...) error

+ CanAddContent func(handle string) bool

+ CleanupPreparedRequest func(ctx context.Context, loc string, dbid uint, authToken string) error

+ CommPContent func(ctx context.Context, loc string, data cid.Cid) error

+ Connect func(ws *websocket.Conn, handle string, done chan struct{}) (func() error, func(), error)

+ ConsolidateContent func(ctx context.Context, loc string, contents []util.Content) error

+ GetByAuth func(auth string) (*model.Shuttle, error)

+ GetLocationForRetrieval func(ctx context.Context, cont util.Content) (string, error)

+ GetLocationForStorage func(ctx context.Context, obj cid.Cid, uid uint) (string, error)

+ GetPreferredUploadEndpoints func(u *util.User) ([]string, error)

+ GetShuttlesConfig func(u *util.User) (interface{}, error)

+ GetTransferStatus func(ctx context.Context, contLoc string, d *model.ContentDeal) (*filclient.ChannelState, error)

+ HostName func(handle string) string

+ IsOnline func(handle string) bool

+ PinContent func(ctx context.Context, loc string, cont util.Content, origins []*peer.AddrInfo) error

+ PrepareForDataRequest func(ctx context.Context, loc string, dbid uint, authToken string, propCid cid.Cid, ...) error

+ RestartTransfer func(ctx context.Context, loc string, chanid datatransfer.ChannelID, ...) error

+ SplitContent func(ctx context.Context, loc string, cont uint, size int64) error

+ StartTransfer func(ctx context.Context, loc string, cd *model.ContentDeal, datacid cid.Cid) error

+ StorageStats func(handle string) *util.ShuttleStorageStats

+ UnpinContent func(ctx context.Context, loc string, conts []uint) error

+ func NewManager(ctx context.Context, db *gorm.DB, cfg *config.Estuary, log *zap.SugaredLogger, ...) (IManager, error)