stagingzone

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 15, 2023 License: Apache-2.0, MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrWaitForRemoteAggregate = fmt.Errorf("waiting for remote content aggregation")
View Source 
var ErrZoneCouldNotBeClaimed = fmt.Errorf("zone could not be claimed")

Functions

This section is empty.

Types

type IManager 

type IManager interface {
	CreateAggregate(ctx context.Context, conts []util.Content) (ipld.Node, error)
	AggregateStagingZone(ctx context.Context, zone *model.StagingZone, zoneCont *util.Content, loc string) error
	GetStagingZoneContents(ctx context.Context, user uint, zoneID uint, limit int, offset int) ([]util.Content, error)
	GetStagingZoneWithoutContents(ctx context.Context, userID uint, zoneID uint) (*model.StagingZone, error)
	GetStagingZonesForUser(ctx context.Context, userID uint, limit int, offset int) ([]*model.StagingZone, error)
}

func NewManager 

func NewManager(
	ctx context.Context,
	db *gorm.DB,
	tbs *util.TrackingBlockstore,
	nd *node.Node,
	cfg *config.Estuary,
	log *zap.SugaredLogger,
	shuttleMgr shuttle.IManager,
) IManager

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.