numbers

Documentation

Index

• Constants
• func Init(logger *zap.Logger) base.IConnector
• type Commit
• type CommitCustom
• type CommitCustomLicense
• type Connector
  • func (c *Connector) CreateExecution(defUID uuid.UUID, task string, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)
  • func (con *Connector) Test(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (connectorPB.ConnectorResource_State, error)
• type Execution
  • func (e *Execution) Execute(inputs []*structpb.Struct) ([]*structpb.Struct, error)
• type Input
• type Output

Constants

const ApiUrlCommit = "https://eo883tj75azolos.m.pipedream.net"

const ApiUrlMe = "https://api.numbersprotocol.io/api/v3/auth/users/me"

const ApiUrlPin = "https://eoqctv92ahgrcif.m.pipedream.net"

Functions

func Init

func Init(logger *zap.Logger) base.IConnector

Types

type Commit

type Commit struct {
	AssetCid              string        `json:"assetCid"`
	AssetSha256           string        `json:"assetSha256"`
	EncodingFormat        string        `json:"encodingFormat"`
	AssetTimestampCreated int64         `json:"assetTimestampCreated"`
	AssetCreator          *string       `json:"assetCreator,omitempty"`
	Abstract              *string       `json:"abstract,omitempty"`
	Custom                *CommitCustom `json:"custom,omitempty"`
	Testnet               bool          `json:"testnet"`
}

type CommitCustom

type CommitCustom struct {
	DigitalSourceType *string              `json:"digitalSourceType,omitempty"`
	MiningPreference  *string              `json:"miningPreference,omitempty"`
	GeneratedThrough  string               `json:"generatedThrough"`
	GeneratedBy       *string              `json:"generatedBy,omitempty"`
	CreatorWallet     *string              `json:"creatorWallet,omitempty"`
	License           *CommitCustomLicense `json:"license,omitempty"`
	Metadata          *struct {
		Pipeline *struct {
			Uid    *string     `json:"uid,omitempty"`
			Recipe interface{} `json:"recipe,omitempty"`
		} `json:"pipeline,omitempty"`
		Owner *struct {
			Uid *string `json:"uid,omitempty"`
		} `json:"owner,omitempty"`
	} `json:"instillMetadata,omitempty"`
}

type CommitCustomLicense

type CommitCustomLicense struct {
	Name     *string `json:"name,omitempty"`
	Document *string `json:"document,omitempty"`
}

type Connector

type Connector struct {
	base.Connector
}

func (*Connector) CreateExecution

func (c *Connector) CreateExecution(defUID uuid.UUID, task string, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)

func (*Connector) Test

func (con *Connector) Test(defUid uuid.UUID, config *structpb.Struct, logger *zap.Logger) (connectorPB.ConnectorResource_State, error)

type Execution

type Execution struct {
	base.Execution
}

func (*Execution) Execute

func (e *Execution) Execute(inputs []*structpb.Struct) ([]*structpb.Struct, error)

type Input

type Input struct {
	Images       []string `json:"images"`
	AssetCreator *string  `json:"asset_creator,omitempty"`
	Abstract     *string  `json:"abstract,omitempty"`
	Custom       *struct {
		DigitalSourceType *string `json:"digital_source_type,omitempty"`
		MiningPreference  *string `json:"mining_preference,omitempty"`
		GeneratedThrough  *string `json:"generated_through,omitempty"`
		GeneratedBy       *string `json:"generated_by,omitempty"`
		CreatorWallet     *string `json:"creator_wallet,omitempty"`
		License           *struct {
			Name     *string `json:"name,omitempty"`
			Document *string `json:"document,omitempty"`
		} `json:"license,omitempty"`
		Metadata *struct {
			Pipeline *struct {
				Uid    *string     `json:"uid,omitempty"`
				Recipe interface{} `json:"recipe,omitempty"`
			} `json:"pipeline,omitempty"`
			Owner *struct {
				Uid *string `json:"uid,omitempty"`
			} `json:"owner,omitempty"`
		} `json:"metadata,omitempty"`
	} `json:"custom,omitempty"`
}

type Output

type Output struct {
	AssetUrls []string `json:"asset_urls"`
}