model

package

Go to main page

Versions in this module

v1

v1.4.0

Jun 24, 2024

v1.4.0-rc10

Jun 24, 2024

v1.3.2

Jun 4, 2024

v1.3.2-rc3

Jun 4, 2024

v1.3.2-rc2

May 30, 2024

v1.3.2-rc1

May 30, 2024

v1.3.1

May 23, 2024

v1.3.1-rc2

May 23, 2024

v1.3.1-rc1

May 22, 2024

v1.3.0

Mar 24, 2024

v1.3.0-rc3

Mar 21, 2024

v1.3.0-rc2

Mar 21, 2024

v1.3.0-rc1

Mar 21, 2024

v1.2.3

Mar 14, 2024

v1.2.3-rc2

Mar 14, 2024

v1.2.3-rc1

Mar 14, 2024

v1.2.2

Mar 4, 2024

Changes in this version

type LogsPayload

+ Tail bool

type Publisher

+ const PublisherLocal

v1.2.2-rc3

Mar 1, 2024

v1.2.2-rc2

Feb 29, 2024

v1.2.2-rc1

Feb 15, 2024

v1.2.1

Jan 30, 2024

v1.2.1-rc3

Jan 30, 2024

v1.2.1-rc2

Dec 21, 2023

v1.2.1-rc1

Dec 20, 2023

v1.2.0

Dec 11, 2023

v1.2.0-rc1

Dec 11, 2023

v1.1.7-rc1

Dec 7, 2023

v1.1.6

Nov 20, 2023

v1.1.6-rc1

Nov 20, 2023

v1.1.6-rc

Nov 20, 2023

v1.1.6-dev2

Nov 19, 2023

v1.1.6-dev

Nov 19, 2023

v1.1.5

Nov 16, 2023

v1.1.5-rc1

Nov 15, 2023

v1.1.4

Nov 9, 2023

v1.1.4-rc2

Nov 9, 2023

v1.1.4-rc1

Nov 8, 2023

v1.1.3

Nov 2, 2023

v1.1.3-rc1

Nov 2, 2023

v1.1.2

Oct 20, 2023

v1.1.2-rc2

Oct 24, 2023

v1.1.2-rc1

Oct 20, 2023

v1.1.1

Oct 9, 2023

v1.1.0

Sep 25, 2023

v1.1.0-rc2

Sep 20, 2023

v1.0.4

Sep 12, 2023

Changes in this version

+ const DefaultDownloadTimeout

+ const DefaultJobTimeout

+ const DefaultNamespace

+ const EngineKeyEntryModuleWasm

+ const EngineKeyEntrypointDocker

+ const EngineKeyEntrypointWasm

+ const EngineKeyEnvironmentVariablesDocker

+ const EngineKeyEnvironmentVariablesWasm

+ const EngineKeyImageDocker

+ const EngineKeyImportModulesWasm

+ const EngineKeyParametersDocker

+ const EngineKeyParametersWasm

+ const EngineKeyWorkingDirectoryDocker

+ const JobTypeBatch

+ const JobTypeOps

+ const JobTypeService

+ const JobTypeSystem

+ const Unknown

+ var NoJobTimeout time.Duration = time.Duration(math.MaxInt64).Truncate(time.Second)

+ func ConvertBytesString(val string) uint64

+ func ConvertCPUString(val string) float64

+ func ConvertGPUString(val string) uint64

+ func DecodeEngineSpec(spec EngineSpec) (*T, error)

type APIVersion

+ const V1beta2

type Deal

+ TargetingMode TargetingMode

+ func (d Deal) IsValid() error

+ type DockerEngineBuilder struct

+ func NewDockerEngineBuilder(image string) *DockerEngineBuilder

+ func (b *DockerEngineBuilder) Build() EngineSpec

+ func (b *DockerEngineBuilder) WithEntrypoint(e ...string) *DockerEngineBuilder

+ func (b *DockerEngineBuilder) WithEnvironmentVariables(e ...string) *DockerEngineBuilder

+ func (b *DockerEngineBuilder) WithParameters(e ...string) *DockerEngineBuilder

+ func (b *DockerEngineBuilder) WithWorkingDirectory(e string) *DockerEngineBuilder

+ type DockerEngineSpec struct

+ Entrypoint []string

+ EnvironmentVariables []string

+ Image string

+ Parameters []string

+ WorkingDirectory string

+ type EngineBuilder struct

+ func NewEngineBuilder() *EngineBuilder

+ func (b *EngineBuilder) Build() EngineSpec

+ func (b *EngineBuilder) WithParam(key string, value interface{}) *EngineBuilder

+ func (b *EngineBuilder) WithType(t string) *EngineBuilder

+ type EngineSpec struct

+ Params map[string]interface{}

+ Type string

+ func DeserializeEngineSpec(in []byte) (EngineSpec, error)

+ func (e EngineSpec) Engine() Engine

+ func (e EngineSpec) Format(f fmt.State, c rune)

+ func (e EngineSpec) Serialize() ([]byte, error)

+ func (e EngineSpec) String() string

+ type ExecutionDesiredState int

+ const ExecutionDesiredStatePending

+ const ExecutionDesiredStateRunning

+ const ExecutionDesiredStateStopped

type ExecutionState

+ DesiredState ExecutionDesiredState

type ExecutionStateType

+ const ExecutionStateCancelled

+ const ExecutionStateUndefined

+ func (s ExecutionStateType) IsPending() bool

+ func (s ExecutionStateType) IsUndefined() bool

+ type FailureInjectionComputeConfig struct

+ IsBadActor bool

+ type FailureInjectionConfig struct

+ Compute FailureInjectionComputeConfig

+ Requester FailureInjectionRequesterConfig

+ type FailureInjectionRequesterConfig struct

+ IsBadActor bool

type Job

+ func (j Job) Type() string

type JobEventType

+ const JobEventCompleted

+ func (je JobEventType) IsUndefined() bool

type JobSelectionDataLocality

+ func (i *JobSelectionDataLocality) UnmarshalText(text []byte) error

+ func (i *JobSelectionDataLocality) UnmarshalYAML(value *yaml.Node) error

+ func (i JobSelectionDataLocality) MarshalYAML() (interface{}, error)

type JobSpecDocker

+ Parameters []string

type JobState

+ func (s *JobState) ActiveCount() int

+ func (s *JobState) CompletedCount() int

+ func (s *JobState) NonDiscardedCount() int

+ func (s *JobState) NonTerminalExecutions() []*ExecutionState

type JobStateType

+ const JobStateUndefined

+ func (s JobStateType) IsUndefined() bool

type LabelSelectorRequirement

+ func (r LabelSelectorRequirement) String() string

type NodeType

+ const NodeTypeRequester

type PublicKey

+ func (pk PublicKey) String() string

type ResourceUsageData

+ func ParseResourceUsageConfig(usage ResourceUsageConfig) ResourceUsageData

type Spec

+ EngineSpec EngineSpec

+ type TargetingMode bool

+ const TargetAll

+ const TargetAny

+ func ParseTargetingMode(s string) (TargetingMode, error)

+ func (t TargetingMode) String() string

+ type WasmEngineBuilder struct

+ func NewWasmEngineBuilder(entryModule StorageSpec) *WasmEngineBuilder

+ func (b *WasmEngineBuilder) Build() EngineSpec

+ func (b *WasmEngineBuilder) WithEntrypoint(e string) *WasmEngineBuilder

+ func (b *WasmEngineBuilder) WithEnvironmentVariables(e map[string]string) *WasmEngineBuilder

+ func (b *WasmEngineBuilder) WithImportModules(e ...StorageSpec) *WasmEngineBuilder

+ func (b *WasmEngineBuilder) WithParameters(e ...string) *WasmEngineBuilder

+ type WasmEngineSpec struct

+ EntryModule StorageSpec

+ Entrypoint string

+ EnvironmentVariables map[string]string

+ ImportModules []StorageSpec

+ Parameters []string

v1.0.3

Jun 1, 2023

v1.0.2

May 31, 2023

v1.0.1

May 31, 2023

Changes in this version

type StorageSpec

+ ReadWrite bool

type Verifier

+ const VerifierExternal

v1.0.0

May 9, 2023

v0

v0.3.29

May 3, 2023

Changes in this version

+ func InstalledTypes(ctx context.Context, provider Provider[Key, Value], allKeys []Key) []Key

+ type ChainedProvider struct

+ Providers []Provider[Key, Value]

+ func (c *ChainedProvider[Key, Value]) Get(ctx context.Context, key Key) (v Value, err error)

+ func (c *ChainedProvider[Key, Value]) Has(ctx context.Context, key Key) bool

type ComputeNodeInfo

+ Publishers []Publisher

+ StorageSources []StorageSourceType

+ Verifiers []Verifier

+ type ConfiguredProvider struct

+ func (c *ConfiguredProvider[Key, Value]) Get(ctx context.Context, key Key) (v Value, err error)

+ func (c *ConfiguredProvider[Key, Value]) Has(ctx context.Context, key Key) bool

+ type DownloadItem struct

+ CID string

+ Name string

+ SourceType StorageSourceType

+ Target string

+ URL string

type DownloaderSettings

+ SingleFile string

type Provider

+ func NewConfiguredProvider(inner Provider[Key, Value], disabled []Key) Provider[Key, Value]

v0.3.28

Apr 14, 2023

v0.3.27

Apr 13, 2023

v0.3.26

Apr 13, 2023

Changes in this version

type ExecutionState

+ AcceptedAskForBid bool

type JobSelectionDataLocality

+ func ParseJobSelectionDataLocality(s string) (ret JobSelectionDataLocality, err error)

+ func (i JobSelectionDataLocality) String() string

type JobStateType

+ func JobStateTypes() []JobStateType

+ type LogsPayload struct

+ ClientID string

+ ExecutionID string

+ Follow bool

+ JobID string

+ WithHistory bool

+ func (j LogsPayload) GetClientID() string

type Publisher

+ const PublisherS3

+ type PublisherSpec struct

+ Params map[string]interface{}

+ Type Publisher

+ type S3StorageSpec struct

+ Bucket string

+ ChecksumSHA256 string

+ Endpoint string

+ Key string

+ Region string

+ VersionID string

type Spec

+ PublisherSpec PublisherSpec

type StorageSourceType

+ const StorageSourceRepoClone

+ const StorageSourceRepoCloneLFS

+ const StorageSourceS3

type StorageSpec

+ Repo string

+ S3 *S3StorageSpec

v0.3.25

Mar 21, 2023

Changes in this version

type Deal

+ func (d Deal) GetConcurrency() int

+ func (d Deal) GetConfidence() int

type DownloaderSettings

+ Raw bool

type JobState

+ func (s *JobState) GroupExecutionsByState() map[ExecutionStateType][]ExecutionState

type JobStateType

+ const JobStateCompletedPartially

v0.3.24

Mar 4, 2023

Changes in this version

+ func ShortID(id string) string

type DownloaderSettings

+ LocalIPFS bool

type Job

+ func (j Job) ID() string

+ func (j Job) String() string

type JobCancelPayload

+ func (j JobCancelPayload) GetClientID() string

type JobCreatePayload

+ func (j JobCreatePayload) GetClientID() string

type JobHistory

+ ExecutionState *StateChange[ExecutionStateType]

+ JobState *StateChange[JobStateType]

type JobState

+ Executions []ExecutionState

type JobStateType

+ const JobStateQueued

+ type StateChange struct

+ New StateType

+ Previous StateType

v0.3.24-build-testing-01

Mar 9, 2023

v0.3.23

Feb 28, 2023

Changes in this version

+ const DefaultIPFSTimeout

+ const DownloadCIDsFolderName

+ const DownloadFilePerm

+ const DownloadFilenameExitCode

+ const DownloadFilenameStderr

+ const DownloadFilenameStdout

+ const DownloadFolderPerm

+ const DownloadShardsFolderName

+ const DownloadVolumesFolderName

+ const MaxNumberOfObjectsToSerialize

+ const MaxSerializedStringInput

+ const ShortIDLength

+ const TracerAttributeNameJobID

+ const TracerAttributeNameNodeID

+ var ExcludeNone []ExcludedTag = []ExcludedTag

+ var IncludeAny []IncludedTag = []IncludedTag

+ func ConfirmMaxSliceSize(t T, maxSize int) error

+ func EngineNames() []string

+ func FromLabelSelectorRequirements(requirements ...LabelSelectorRequirement) ([]labels.Requirement, error)

+ func IsValidEngine(e Engine) bool

+ func IsValidPublisher(publisherType Publisher) bool

+ func IsValidStorageSourceType(sourceType StorageSourceType) bool

+ func IsValidVerifier(verifierType Verifier) bool

+ func JSONMarshalIndentWithMax(t T, indentSpaces int) ([]byte, error)

+ func JSONMarshalWithMax(t T) ([]byte, error)

+ func JSONUnmarshalWithMax(b []byte, t *T) error

+ func PublisherNames() []string

+ func Reinterpret(node datamodel.Node, schema *Schema) (*T, error)

+ func StorageSourceNames() []string

+ func UnmarshalIPLD(b []byte, decoder codec.Decoder, schema *Schema) (*T, error)

+ func VerifierNames() []string

+ func YAMLMarshalWithMax(t T) ([]byte, error)

+ func YAMLUnmarshalWithMax(b []byte, t *T) error

+ type APIVersion int

+ const V1alpha1

+ const V1beta1

+ func APIVersionLatest() APIVersion

+ func ParseAPIVersion(str string) (APIVersion, error)

+ func (i APIVersion) String() string

+ type BacalhauConfig struct

+ Annotations []string

+ Dnt bool

+ Publisher Publisher

+ Resources ResourceSpec

+ Timeout time.Duration

+ Verifier Verifier

+ type BuildVersionInfo struct

+ BuildDate time.Time

+ GOARCH string

+ GOOS string

+ GitCommit string

+ GitVersion string

+ Major string

+ Minor string

+ type ComputeNodeInfo struct

+ AvailableCapacity ResourceUsageData

+ EnqueuedExecutions int

+ ExecutionEngines []Engine

+ MaxCapacity ResourceUsageData

+ MaxJobRequirements ResourceUsageData

+ RunningExecutions int

+ type ComputeNodeInfoProvider interface

+ GetComputeInfo func(ctx context.Context) ComputeNodeInfo

+ type Deal struct

+ Concurrency int

+ Confidence int

+ MinBids int

+ type DebugInfo struct

+ Component string

+ Info interface{}

+ type DebugInfoProvider interface

+ GetDebugInfo func() (DebugInfo, error)

+ type DockerInputs struct

+ Entrypoint []string

+ Env IPLDMap[string, string]

+ Mounts IPLDMap[string, Resource]

+ Outputs IPLDMap[string, datamodel.Node]

+ Workdir string

+ func (docker DockerInputs) UnmarshalInto(with string, spec *Spec) error

+ type DownloaderSettings struct

+ IPFSSwarmAddrs string

+ OutputDir string

+ Timeout time.Duration

+ type Engine int

+ const EngineDocker

+ const EngineLanguage

+ const EngineNoop

+ const EnginePythonWasm

+ const EngineWasm

+ func EngineTypes() []Engine

+ func ParseEngine(str string) (Engine, error)

+ func (e *Engine) UnmarshalText(text []byte) (err error)

+ func (e Engine) MarshalText() ([]byte, error)

+ func (i Engine) String() string

+ type ExcludedTag string

+ type ExecutionID struct

+ ExecutionID string

+ JobID string

+ NodeID string

+ ShardIndex int

+ func (e ExecutionID) ShardID() ShardID

+ func (e ExecutionID) String() string

+ type ExecutionState struct

+ ComputeReference string

+ CreateTime time.Time

+ JobID string

+ NodeID string

+ PublishedResult StorageSpec

+ RunOutput *RunCommandResult

+ ShardIndex int

+ State ExecutionStateType

+ Status string

+ UpdateTime time.Time

+ VerificationProposal []byte

+ VerificationResult VerificationResult

+ Version int

+ func (e ExecutionState) HasAcceptedAskForBid() bool

+ func (e ExecutionState) ID() ExecutionID

+ func (e ExecutionState) ShardID() ShardID

+ func (e ExecutionState) String() string

+ type ExecutionStateType int

+ const ExecutionStateAskForBid

+ const ExecutionStateAskForBidAccepted

+ const ExecutionStateAskForBidRejected

+ const ExecutionStateBidAccepted

+ const ExecutionStateBidRejected

+ const ExecutionStateCanceled

+ const ExecutionStateCompleted

+ const ExecutionStateFailed

+ const ExecutionStateNew

+ const ExecutionStateResultAccepted

+ const ExecutionStateResultProposed

+ const ExecutionStateResultRejected

+ func ExecutionStateTypes() []ExecutionStateType

+ func (i ExecutionStateType) String() string

+ func (s *ExecutionStateType) UnmarshalText(text []byte) (err error)

+ func (s ExecutionStateType) IsActive() bool

+ func (s ExecutionStateType) IsDiscarded() bool

+ func (s ExecutionStateType) IsTerminal() bool

+ func (s ExecutionStateType) MarshalText() ([]byte, error)

+ type HTTPResource string

+ type IPFSResource string

+ type IPLDMap struct

+ Keys []K

+ Values map[K]V

+ type IncludedTag string

+ type Job struct

+ APIVersion string

+ Metadata Metadata

+ Spec Spec

+ func NewJob() *Job

+ func NewJobWithSaneProductionDefaults() (*Job, error)

+ type JobCancelPayload struct

+ ClientID string

+ JobID string

+ Reason string

+ type JobCreatePayload struct

+ APIVersion string

+ ClientID string

+ Spec *Spec

+ type JobEvent struct

+ APIVersion string

+ ClientID string

+ Deal Deal

+ EventName JobEventType

+ EventTime time.Time

+ ExecutionID string

+ JobExecutionPlan JobExecutionPlan

+ JobID string

+ PublishedResult StorageSpec

+ RunOutput *RunCommandResult

+ SenderPublicKey PublicKey

+ ShardIndex int

+ SourceNodeID string

+ Spec Spec

+ Status string

+ TargetNodeID string

+ VerificationProposal []byte

+ VerificationResult VerificationResult

+ type JobEventType int

+ const JobEventBid

+ const JobEventBidAccepted

+ const JobEventBidCancelled

+ const JobEventBidRejected

+ const JobEventCanceled

+ const JobEventComputeError

+ const JobEventCreated

+ const JobEventDealUpdated

+ const JobEventError

+ const JobEventInitialSubmission

+ const JobEventInvalidRequest

+ const JobEventResultsAccepted

+ const JobEventResultsProposed

+ const JobEventResultsPublished

+ const JobEventResultsRejected

+ const JobEventRunning

+ func JobEventTypes() []JobEventType

+ func ParseJobEventType(str string) (JobEventType, error)

+ func (i JobEventType) String() string

+ func (je *JobEventType) UnmarshalText(text []byte) (err error)

+ func (je JobEventType) IsIgnorable() bool

+ func (je JobEventType) IsTerminal() bool

+ func (je JobEventType) MarshalText() ([]byte, error)

+ type JobExecutionPlan struct

+ TotalShards int

+ type JobHistory struct

+ Comment string

+ ComputeReference string

+ JobID string

+ NewState string

+ NewStateType ExecutionStateType

+ NewVersion int

+ NodeID string

+ PreviousState string

+ ShardIndex int

+ Time time.Time

+ Type JobHistoryType

+ type JobHistoryType int

+ const JobHistoryTypeExecutionLevel

+ const JobHistoryTypeJobLevel

+ const JobHistoryTypeShardLevel

+ func (i JobHistoryType) String() string

+ func (s *JobHistoryType) UnmarshalText(text []byte) (err error)

+ func (s JobHistoryType) MarshalText() ([]byte, error)

+ type JobLocalEventType int

+ const JobLocalEventBid

+ const JobLocalEventBidAccepted

+ const JobLocalEventBidRejected

+ const JobLocalEventSelected

+ const JobLocalEventVerified

+ func JobLocalEventTypes() []JobLocalEventType

+ func ParseJobLocalEventType(str string) (JobLocalEventType, error)

+ func (i JobLocalEventType) String() string

+ func (jle *JobLocalEventType) UnmarshalText(text []byte) (err error)

+ func (jle JobLocalEventType) MarshalText() ([]byte, error)

+ type JobRequester struct

+ RequesterNodeID string

+ RequesterPublicKey PublicKey

+ type JobSelectionDataLocality int64

+ const Anywhere

+ const Local

+ type JobSelectionPolicy struct

+ AcceptNetworkedJobs bool

+ Locality JobSelectionDataLocality

+ ProbeExec string

+ ProbeHTTP string

+ RejectStatelessJobs bool

+ func NewDefaultJobSelectionPolicy() JobSelectionPolicy

+ type JobShard struct

+ Index int

+ Job *Job

+ func (shard JobShard) ID() string

+ func (shard JobShard) ShardID() ShardID

+ func (shard JobShard) String() string

+ type JobShardingConfig struct

+ BasePath string

+ BatchSize int

+ GlobPattern string

+ type JobSpecDocker struct

+ Entrypoint []string

+ EnvironmentVariables []string

+ Image string

+ WorkingDirectory string

+ type JobSpecLanguage struct

+ Command string

+ Context StorageSpec

+ Deterministic bool

+ Language string

+ LanguageVersion string

+ ProgramPath string

+ RequirementsPath string

+ type JobSpecWasm struct

+ EntryModule StorageSpec

+ EntryPoint string

+ EnvironmentVariables map[string]string

+ ImportModules []StorageSpec

+ Parameters []string

+ type JobState struct

+ CreateTime time.Time

+ JobID string

+ Shards map[int]ShardState

+ State JobStateType

+ TimeoutAt time.Time

+ UpdateTime time.Time

+ Version int

+ type JobStateType int

+ const JobStateCancelled

+ const JobStateCompleted

+ const JobStateError

+ const JobStateInProgress

+ const JobStateNew

+ const JobStatePartialError

+ func (i JobStateType) String() string

+ func (s *JobStateType) UnmarshalText(text []byte) (err error)

+ func (s JobStateType) IsTerminal() bool

+ func (s JobStateType) MarshalText() ([]byte, error)

+ type JobType interface

+ UnmarshalInto func(with string, spec *Spec) error

+ type JobWithInfo struct

+ History []JobHistory

+ Job Job

+ State JobState

+ type KeyInt int

+ type KeyString string

+ type LabelSelectorRequirement struct

+ Key string

+ Operator selection.Operator

+ Values []string

+ func ToLabelSelectorRequirements(requirements ...labels.Requirement) []LabelSelectorRequirement

+ type MappedProvider struct

+ func NewMappedProvider(providables map[Key]Value) *MappedProvider[Key, Value]

+ func (provider *MappedProvider[Key, Value]) Add(key Key, value Value)

+ func (provider *MappedProvider[Key, Value]) Get(ctx context.Context, key Key) (v Value, err error)

+ func (provider *MappedProvider[Key, Value]) Has(ctx context.Context, key Key) bool

+ type Metadata struct

+ ClientID string

+ CreatedAt time.Time

+ ID string

+ Requester JobRequester

+ type Millicores int

+ const Core

+ const Millicore

+ func (m Millicores) String() string

+ type Network int

+ const NetworkFull

+ const NetworkHTTP

+ const NetworkNone

+ func ParseNetwork(s string) (Network, error)

+ func (i Network) String() string

+ func (n *Network) UnmarshalText(text []byte) (err error)

+ func (n Network) MarshalText() ([]byte, error)

+ type NetworkConfig struct

+ Domains []string

+ Type Network

+ func (n NetworkConfig) Disabled() bool

+ func (n NetworkConfig) DomainSet() []string

+ func (n NetworkConfig) IsValid() (err error)

+ type NodeInfo struct

+ BacalhauVersion BuildVersionInfo

+ ComputeNodeInfo ComputeNodeInfo

+ Labels map[string]string

+ NodeType NodeType

+ PeerInfo peer.AddrInfo

+ func (n NodeInfo) IsComputeNode() bool

+ type NodeInfoProvider interface

+ GetNodeInfo func(ctx context.Context) NodeInfo

+ type NodeType int

+ const NodeTypeCompute

+ func (i NodeType) String() string

+ type NoopProvider struct

+ func (p *NoopProvider[Key, Value]) Get(context.Context, Key) (Value, error)

+ func (p *NoopProvider[Key, Value]) Has(context.Context, Key) bool

+ type NoopTask struct

+ func (n NoopTask) UnmarshalInto(with string, spec *Spec) error

+ type Providable interface

+ IsInstalled func(context.Context) (bool, error)

+ type Provider interface

+ Get func(context.Context, Key) (Value, error)

+ Has func(context.Context, Key) bool

+ func NewNoopProvider(noopProvidable Value) Provider[Key, Value]

+ type ProviderKey interface

+ type PublicKey []byte

+ func (pk *PublicKey) UnmarshalText(text []byte) error

+ func (pk PublicKey) MarshalText() ([]byte, error)

+ type PublishedResult struct

+ Data StorageSpec

+ NodeID string

+ ShardIndex int

+ type Publisher int

+ const PublisherEstuary

+ const PublisherFilecoin

+ const PublisherIpfs

+ const PublisherNoop

+ func ParsePublisher(str string) (Publisher, error)

+ func PublisherTypes() []Publisher

+ func (i Publisher) String() string

+ func (p *Publisher) UnmarshalText(text []byte) (err error)

+ func (p Publisher) MarshalText() ([]byte, error)

+ type Resource struct

+ HTTP *HTTPResource

+ IPFS *IPFSResource

+ type ResourceSpec struct

+ Cpu Millicores

+ Disk datasize.ByteSize

+ Gpu int

+ Memory datasize.ByteSize

+ type ResourceUsageConfig struct

+ CPU string

+ Disk string

+ GPU string

+ Memory string

+ type ResourceUsageData struct

+ CPU float64

+ Disk uint64

+ GPU uint64

+ Memory uint64

+ func (r ResourceUsageData) Add(other ResourceUsageData) ResourceUsageData

+ func (r ResourceUsageData) Intersect(other ResourceUsageData) ResourceUsageData

+ func (r ResourceUsageData) IsZero() bool

+ func (r ResourceUsageData) LessThan(other ResourceUsageData) bool

+ func (r ResourceUsageData) LessThanEq(other ResourceUsageData) bool

+ func (r ResourceUsageData) Max(other ResourceUsageData) ResourceUsageData

+ func (r ResourceUsageData) Multi(factor float64) ResourceUsageData

+ func (r ResourceUsageData) String() string

+ func (r ResourceUsageData) Sub(other ResourceUsageData) ResourceUsageData

+ type ResourceUsageProfile struct

+ Job ResourceUsageData

+ SystemTotal ResourceUsageData

+ SystemUsing ResourceUsageData

+ type RunCommandResult struct

+ ErrorMsg string

+ ExitCode int

+ STDERR string

+ STDOUT string

+ StderrTruncated bool

+ StdoutTruncated bool

+ func NewRunCommandResult() *RunCommandResult

+ type Schema schema.TypeSystem

+ var BacalhauTaskSchema *Schema = load(bacalhauTaskSchemaPath)

+ var UCANTaskSchema *Schema = load(ucanTaskSchemaPath)

+ func (s *Schema) GetSchemaType(obj interface{}) schema.Type

+ func (s *Schema) GetSchemaTypeName(obj interface{}) string

+ type ShardID struct

+ Index int

+ JobID string

+ func (shard ShardID) ID() string

+ func (shard ShardID) String() string

+ type ShardState struct

+ CreateTime time.Time

+ Executions []ExecutionState

+ JobID string

+ ShardIndex int

+ State ShardStateType

+ UpdateTime time.Time

+ Version int

+ func (s ShardState) ID() ShardID

+ type ShardStateType int

+ const ShardStateCancelled

+ const ShardStateCompleted

+ const ShardStateError

+ const ShardStateInProgress

+ const ShardStateNew

+ func (i ShardStateType) String() string

+ func (s *ShardStateType) UnmarshalText(text []byte) (err error)

+ func (s ShardStateType) IsTerminal() bool

+ func (s ShardStateType) MarshalText() ([]byte, error)

+ type SimulatorConfig struct

+ Compute SimulatorConfigCompute

+ Requester SimulatorConfigRequester

+ type SimulatorConfigCompute struct

+ IsBadActor bool

+ type SimulatorConfigRequester struct

+ IsBadActor bool

+ type Spec struct

+ Annotations []string

+ Contexts []StorageSpec

+ Deal Deal

+ DoNotTrack bool

+ Docker JobSpecDocker

+ Engine Engine

+ ExecutionPlan JobExecutionPlan

+ Inputs []StorageSpec

+ Language JobSpecLanguage

+ Network NetworkConfig

+ NodeSelectors []LabelSelectorRequirement

+ Outputs []StorageSpec

+ Publisher Publisher

+ Resources ResourceUsageConfig

+ Sharding JobShardingConfig

+ Timeout float64

+ Verifier Verifier

+ Wasm JobSpecWasm

+ func (s *Spec) AllStorageSpecs() []*StorageSpec

+ func (s *Spec) GetTimeout() time.Duration

+ type StorageSourceType int

+ const StorageSourceEstuary

+ const StorageSourceFilecoin

+ const StorageSourceFilecoinUnsealed

+ const StorageSourceIPFS

+ const StorageSourceInline

+ const StorageSourceLocalDirectory

+ const StorageSourceURLDownload

+ func ParseStorageSourceType(str string) (StorageSourceType, error)

+ func StorageSourceTypes() []StorageSourceType

+ func (i StorageSourceType) String() string

+ func (ss *StorageSourceType) UnmarshalText(text []byte) (err error)

+ func (ss StorageSourceType) MarshalText() ([]byte, error)

+ type StorageSpec struct

+ CID string

+ Metadata map[string]string

+ Name string

+ Path string

+ SourcePath string

+ StorageSource StorageSourceType

+ URL string

+ type Task struct

+ Do TaskType

+ Inputs datamodel.Node

+ Meta IPLDMap[string, datamodel.Node]

+ With string

+ func (task *Task) ToSpec() (*Spec, error)

+ type TaskType string

+ const TaskTypeDocker

+ const TaskTypeNoop

+ const TaskTypeWasm

+ type TestFatalErrorHandlerContents struct

+ Code int

+ Message string

+ type VerificationResult struct

+ Complete bool

+ Result bool

+ type Verifier int

+ const VerifierDeterministic

+ const VerifierNoop

+ func ParseVerifier(str string) (Verifier, error)

+ func VerifierTypes() []Verifier

+ func (i Verifier) String() string

+ func (v *Verifier) UnmarshalText(text []byte) (err error)

+ func (v Verifier) MarshalText() ([]byte, error)

+ type WasmInputs struct

+ Entrypoint string

+ Env IPLDMap[string, string]

+ Modules []Resource

+ Mounts IPLDMap[string, Resource]

+ Outputs IPLDMap[string, datamodel.Node]

+ Parameters []string

+ func (wasm *WasmInputs) UnmarshalInto(with string, spec *Spec) error

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