ipfs

Documentation

Index

• type IPFSPublisher
  • func NewIPFSPublisher(ctx context.Context, _ *system.CleanupManager, cl ipfs.Client) (*IPFSPublisher, error)
  • func (publisher *IPFSPublisher) IsInstalled(ctx context.Context) (bool, error)
  • func (publisher *IPFSPublisher) PublishResult(ctx context.Context, executionID string, j model.Job, resultPath string) (model.StorageSpec, error)
  • func (publisher *IPFSPublisher) ValidateJob(ctx context.Context, j model.Job) error

Types

type IPFSPublisher

type IPFSPublisher struct {
	IPFSClient ipfs.Client
}

func NewIPFSPublisher

func NewIPFSPublisher(
	ctx context.Context,
	_ *system.CleanupManager,
	cl ipfs.Client,
) (*IPFSPublisher, error)

func (*IPFSPublisher) IsInstalled

func (publisher *IPFSPublisher) IsInstalled(ctx context.Context) (bool, error)

func (*IPFSPublisher) PublishResult

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

func (*IPFSPublisher) ValidateJob

func (publisher *IPFSPublisher) ValidateJob(ctx context.Context, j model.Job) error