publisher

package

v0.0.0-...-787377c Latest Latest Go to latest Published: Apr 5, 2024 License: GPL-3.0 Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/comrade-coop/apocryph

Documentation ¶

Index ¶

Variables
func FundPaymentChannel(ethClient *ethclient.Client, publisherAuth *bind.TransactOpts, ...) error
func GenerateDeploymentFilename(podFile string, deploymentFormat string) (deploymentFile string, relPodFile string, err error)
func GetPricingTableSubscribers(ethClient *ethclient.Client, registryContract common.Address, tableId *big.Int) ([]common.Address, error)
func GetProviderHostInfo(ipfs iface.CoreAPI, ethClient *ethclient.Client, ...) (*pb.HostInfo, error)
func LinkUploadsFromDeployment(pod *pb.Pod, deployment *pb.Deployment) *pb.Pod
func ReadPodAndDeployment(args []string, manifestFormat string, deploymentFormat string) (podFile string, deploymentFile string, pod *pb.Pod, deployment *pb.Deployment, ...)
func SaveDeployment(deploymentFile string, deploymentFormat string, deployment *pb.Deployment) error
func SendToProvider(ctx context.Context, ipfsP2p *ipfs.P2pApi, pod *pb.Pod, ...) error
func UploadImages(ctx context.Context, client *containerd.Client, IPFSAddress string, ...) error
func UploadSecrets(ctx context.Context, ipfs iface.CoreAPI, basepath string, pod *pb.Pod, ...) error
type P2pProvisionPodServiceClient
- func ConnectToProvider(ipfsP2p *ipfs.P2pApi, deployment *pb.Deployment, ...) (*P2pProvisionPodServiceClient, error)
- func SetFirstConnectingProvider(ipfsp2p *tpipfs.P2pApi, availableProviders ProviderHostInfoList, ...) (*P2pProvisionPodServiceClient, error)
type PricingTableList
- func FilterPricingTables(tables PricingTableList, filter *abi.RegistryNewPricingTable) PricingTableList
- func GetPricingTables(ethClient *ethclient.Client, registryContract common.Address, ...) (PricingTableList, error)
type ProviderHostInfoList
- func FilterProviderHostInfos(region string, peerId string, providers ProviderHostInfoList) (ProviderHostInfoList, error)
- func GetProviderHostInfos(ipfs iface.CoreAPI, ethClient *ethclient.Client, ...) (ProviderHostInfoList, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var DefaultDeploymentPath = "~/.apocryph/deployment"

View Source

var DefaultPodFile = "manifest.yaml"

Functions ¶

func FundPaymentChannel ¶

func FundPaymentChannel(ethClient *ethclient.Client, publisherAuth *bind.TransactOpts, deployment *pb.Deployment, funds *big.Int, unlockTimeInt *big.Int, mintFunds bool) error

func GenerateDeploymentFilename ¶

func GenerateDeploymentFilename(podFile string, deploymentFormat string) (deploymentFile string, relPodFile string, err error)

func GetPricingTableSubscribers ¶

func GetPricingTableSubscribers(ethClient *ethclient.Client, registryContract common.Address, tableId *big.Int) ([]common.Address, error)

func GetProviderHostInfo ¶

func GetProviderHostInfo(ipfs iface.CoreAPI, ethClient *ethclient.Client, registryContract common.Address, providerId common.Address) (*pb.HostInfo, error)

func LinkUploadsFromDeployment ¶

func LinkUploadsFromDeployment(pod *pb.Pod, deployment *pb.Deployment) *pb.Pod

func ReadPodAndDeployment ¶

func ReadPodAndDeployment(args []string, manifestFormat string, deploymentFormat string) (podFile string, deploymentFile string, pod *pb.Pod, deployment *pb.Deployment, err error)

func SaveDeployment ¶

func SaveDeployment(deploymentFile string, deploymentFormat string, deployment *pb.Deployment) error

func SendToProvider ¶

func SendToProvider(ctx context.Context, ipfsP2p *ipfs.P2pApi, pod *pb.Pod, deployment *pb.Deployment, client *P2pProvisionPodServiceClient) error

func UploadImages ¶

func UploadImages(ctx context.Context, client *containerd.Client, IPFSAddress string, pod *pb.Pod, deployment *pb.Deployment) error

func UploadSecrets ¶

func UploadSecrets(ctx context.Context, ipfs iface.CoreAPI, basepath string, pod *pb.Pod, deployment *pb.Deployment) error

Types ¶

type P2pProvisionPodServiceClient ¶

type P2pProvisionPodServiceClient struct {
	*tpipfs.IpfsAddr
	pbcon.ProvisionPodServiceClient
}

func ConnectToProvider ¶

func ConnectToProvider(ipfsP2p *ipfs.P2pApi, deployment *pb.Deployment, interceptor *pbcon.AuthInterceptorClient) (*P2pProvisionPodServiceClient, error)

func SetFirstConnectingProvider ¶

func SetFirstConnectingProvider(ipfsp2p *tpipfs.P2pApi, availableProviders ProviderHostInfoList, deployment *pb.Deployment, interceptor *protoconnect.AuthInterceptorClient) (*P2pProvisionPodServiceClient, error)

type PricingTableList ¶

type PricingTableList []*abi.RegistryNewPricingTable

func FilterPricingTables ¶

func FilterPricingTables(tables PricingTableList, filter *abi.RegistryNewPricingTable) PricingTableList

func GetPricingTables ¶

func GetPricingTables(ethClient *ethclient.Client, registryContract common.Address, tokenAddress common.Address) (PricingTableList, error)

type ProviderHostInfoList ¶

type ProviderHostInfoList map[common.Address]*pb.HostInfo

func FilterProviderHostInfos ¶

func FilterProviderHostInfos(region string, peerId string, providers ProviderHostInfoList) (ProviderHostInfoList, error)

func GetProviderHostInfos ¶

func GetProviderHostInfos(ipfs iface.CoreAPI, ethClient *ethclient.Client, registryContract common.Address, tables PricingTableList) (ProviderHostInfoList, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL