filecoinlotus

Documentation

Index

• type Publisher
  • func NewPublisher(ctx context.Context, cm *system.CleanupManager, config PublisherConfig) (*Publisher, error)
  • func (l *Publisher) IsInstalled(ctx context.Context) (bool, error)
  • func (l *Publisher) PublishResult(ctx context.Context, executionID string, j model.Job, resultPath string) (model.StorageSpec, error)
  • func (l *Publisher) ValidateJob(ctx context.Context, j model.Job) error
• type PublisherConfig

Types

type Publisher

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

func NewPublisher

func NewPublisher(
	ctx context.Context,
	cm *system.CleanupManager,
	config PublisherConfig,
) (*Publisher, error)

func (*Publisher) IsInstalled

func (l *Publisher) IsInstalled(ctx context.Context) (bool, error)

func (*Publisher) PublishResult

func (l *Publisher) PublishResult(
	ctx context.Context,
	executionID string,
	j model.Job,
	resultPath string,
) (model.StorageSpec, error)

func (*Publisher) ValidateJob

func (l *Publisher) ValidateJob(ctx context.Context, j model.Job) error

type PublisherConfig

type PublisherConfig struct {
	// How long the deal for the data should be created for
	StorageDuration time.Duration
	// Location of the Lotus configuration directory - either $LOTUS_PATH or ~/.lotus
	PathDir string
	// Directory to use when uploading content to Lotus - optional
	UploadDir string
	// How close miner should be when selecting the cheapest
	MaximumPing time.Duration
}