Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Development = types.BacalhauConfig{ Metrics: types.MetricsConfig{ Libp2pTracerPath: os.DevNull, EventTracerPath: os.DevNull, }, Update: types.UpdateConfig{ SkipChecks: true, }, Auth: types.AuthConfig{ Methods: map[string]types.AuthenticatorConfig{ "ClientKey": { Type: authn.MethodTypeChallenge, }, }, }, Node: types.NodeConfig{ NameProvider: "puuid", ClientAPI: types.APIConfig{ Host: "bootstrap.development.bacalhau.org", Port: 1234, }, ServerAPI: types.APIConfig{ Host: "0.0.0.0", Port: 1234, TLS: types.TLSConfiguration{}, }, Network: types.NetworkConfig{ Type: models.NetworkTypeLibp2p, Port: 4222, Cluster: types.NetworkClusterConfig{ Name: "global", Port: 6222, }, }, BootstrapAddresses: []string{ "/ip4/34.86.177.175/tcp/1235/p2p/QmfYBQ3HouX9zKcANNXbgJnpyLpTYS9nKBANw6RUQKZffu", "/ip4/35.245.221.171/tcp/1235/p2p/QmNjEQByyK8GiMTvnZqGyURuwXDCtzp9X6gJRKkpWfai7S", }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * time.Minute), NodeInfoStoreTTL: types.Duration(10 * time.Minute), DownloadURLRequestRetries: 3, LoggingMode: logger.LogModeDefault, Type: []string{"requester"}, AllowListedLocalPaths: []string{}, Labels: map[string]string{}, DisabledFeatures: types.FeatureConfig{ Engines: []string{}, Publishers: []string{}, Storages: []string{}, }, Libp2p: types.Libp2pConfig{ SwarmPort: 1235, PeerConnect: "none", }, IPFS: types.IpfsConfig{ Connect: "", PrivateInternal: true, SwarmAddresses: []string{ "/ip4/34.86.177.175/tcp/4001/p2p/12D3KooWMSdbPzUf8WWkEcjxpCzkUfToasP9wRjFHy2iCZ6iiZdV", "/ip4/34.86.177.175/udp/4001/quic/p2p/12D3KooWMSdbPzUf8WWkEcjxpCzkUfToasP9wRjFHy2iCZ6iiZdV", "/ip4/35.245.221.171/tcp/4001/p2p/12D3KooWRBYMhTF6MNh6eN84xcZtg6EX2wJguqEtRTNq4C7aytbu", "/ip4/35.245.221.171/udp/4001/quic/p2p/12D3KooWRBYMhTF6MNh6eN84xcZtg6EX2wJguqEtRTNq4C7aytbu", }, Profile: "flatfs", SwarmListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, GatewayListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, APIListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, }, Compute: DevelopmentComputeConfig, Requester: DevelopmentRequesterConfig, WebUI: types.WebUIConfig{ Enabled: false, Port: 8483, }, StrictVersionMatch: false, }, }
View Source
var DevelopmentComputeConfig = types.ComputeConfig{ Capacity: types.CapacityConfig{ IgnorePhysicalResourceLimits: false, TotalResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, JobResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, DefaultJobResourceLimits: models.ResourcesConfig{ CPU: "500m", Memory: "1Gb", Disk: "", GPU: "", }, QueueResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, }, ExecutionStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, JobTimeouts: types.JobTimeoutConfig{ JobExecutionTimeoutClientIDBypassList: []string{}, JobNegotiationTimeout: types.Duration(3 * time.Minute), MinJobExecutionTimeout: types.Duration(500 * time.Millisecond), MaxJobExecutionTimeout: types.Duration(model.NoJobTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, Queue: types.QueueConfig{}, Logging: types.LoggingConfig{ LogRunningExecutionsInterval: types.Duration(10 * time.Second), }, ManifestCache: types.DockerCacheConfig{ Size: 1000, Duration: types.Duration(1 * time.Hour), Frequency: types.Duration(1 * time.Hour), }, LogStreamConfig: types.LogStreamConfig{ ChannelBufferSize: 10, }, LocalPublisher: types.LocalPublisherConfig{ Address: "127.0.0.1", Port: 6001, }, }
View Source
var DevelopmentRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, JobStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, HousekeepingBackgroundTaskInterval: types.Duration(30 * time.Second), NodeRankRandomnessRange: 5, OverAskForBidsFactor: 3, FailureInjectionConfig: model.FailureInjectionRequesterConfig{ IsBadActor: false, }, EvaluationBroker: types.EvaluationBrokerConfig{ EvalBrokerVisibilityTimeout: types.Duration(60 * time.Second), EvalBrokerInitialRetryDelay: types.Duration(1 * time.Second), EvalBrokerSubsequentRetryDelay: types.Duration(30 * time.Second), EvalBrokerMaxRetryCount: 10, }, Worker: types.WorkerConfig{ WorkerCount: runtime.NumCPU(), WorkerEvalDequeueTimeout: types.Duration(5 * time.Second), WorkerEvalDequeueBaseBackoff: types.Duration(1 * time.Second), WorkerEvalDequeueMaxBackoff: types.Duration(30 * time.Second), }, JobDefaults: types.JobDefaults{ ExecutionTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, }
View Source
var Local = types.BacalhauConfig{ Metrics: types.MetricsConfig{ Libp2pTracerPath: os.DevNull, EventTracerPath: os.DevNull, }, Update: types.UpdateConfig{ SkipChecks: true, }, Auth: types.AuthConfig{ Methods: map[string]types.AuthenticatorConfig{ "ClientKey": { Type: authn.MethodTypeChallenge, }, }, }, Node: types.NodeConfig{ NameProvider: "puuid", ClientAPI: types.APIConfig{ Host: "0.0.0.0", Port: 1234, }, ServerAPI: types.APIConfig{ Host: "0.0.0.0", Port: 1234, TLS: types.TLSConfiguration{}, }, Network: types.NetworkConfig{ Type: models.NetworkTypeLibp2p, Port: 4222, Cluster: types.NetworkClusterConfig{ Name: "global", Port: 6222, }, }, BootstrapAddresses: []string{}, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * time.Minute), NodeInfoStoreTTL: types.Duration(10 * time.Minute), DownloadURLRequestRetries: 3, LoggingMode: logger.LogModeDefault, Type: []string{"requester"}, AllowListedLocalPaths: []string{}, Labels: map[string]string{}, DisabledFeatures: types.FeatureConfig{ Engines: []string{}, Publishers: []string{}, Storages: []string{}, }, Libp2p: types.Libp2pConfig{ SwarmPort: 1235, PeerConnect: "none", }, IPFS: types.IpfsConfig{ Connect: "", PrivateInternal: true, SwarmAddresses: []string{}, Profile: "flatfs", SwarmListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, GatewayListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, APIListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, }, Compute: LocalComputeConfig, Requester: LocalRequesterConfig, WebUI: types.WebUIConfig{ Enabled: false, Port: 8483, }, StrictVersionMatch: false, }, }
View Source
var LocalComputeConfig = types.ComputeConfig{ Capacity: types.CapacityConfig{ IgnorePhysicalResourceLimits: false, TotalResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, JobResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, DefaultJobResourceLimits: models.ResourcesConfig{ CPU: "500m", Memory: "1Gb", Disk: "", GPU: "", }, QueueResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, }, ExecutionStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, JobTimeouts: types.JobTimeoutConfig{ JobExecutionTimeoutClientIDBypassList: []string{}, JobNegotiationTimeout: types.Duration(3 * time.Minute), MinJobExecutionTimeout: types.Duration(500 * time.Millisecond), MaxJobExecutionTimeout: types.Duration(model.NoJobTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, Queue: types.QueueConfig{}, Logging: types.LoggingConfig{ LogRunningExecutionsInterval: types.Duration(10 * time.Second), }, ManifestCache: types.DockerCacheConfig{ Size: 1000, Duration: types.Duration(1 * time.Hour), Frequency: types.Duration(1 * time.Hour), }, LogStreamConfig: types.LogStreamConfig{ ChannelBufferSize: 10, }, LocalPublisher: types.LocalPublisherConfig{ Address: "127.0.0.1", Port: 6001, }, }
View Source
var LocalRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, JobStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, HousekeepingBackgroundTaskInterval: types.Duration(30 * time.Second), NodeRankRandomnessRange: 5, OverAskForBidsFactor: 3, FailureInjectionConfig: model.FailureInjectionRequesterConfig{ IsBadActor: false, }, EvaluationBroker: types.EvaluationBrokerConfig{ EvalBrokerVisibilityTimeout: types.Duration(60 * time.Second), EvalBrokerInitialRetryDelay: types.Duration(1 * time.Second), EvalBrokerSubsequentRetryDelay: types.Duration(30 * time.Second), EvalBrokerMaxRetryCount: 10, }, Worker: types.WorkerConfig{ WorkerCount: runtime.NumCPU(), WorkerEvalDequeueTimeout: types.Duration(5 * time.Second), WorkerEvalDequeueBaseBackoff: types.Duration(1 * time.Second), WorkerEvalDequeueMaxBackoff: types.Duration(30 * time.Second), }, JobDefaults: types.JobDefaults{ ExecutionTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, }
View Source
var Production = types.BacalhauConfig{ Metrics: types.MetricsConfig{ Libp2pTracerPath: os.DevNull, EventTracerPath: os.DevNull, }, Update: types.UpdateConfig{ SkipChecks: false, CheckFrequency: types.Duration(24 * time.Hour), }, Auth: types.AuthConfig{ Methods: map[string]types.AuthenticatorConfig{ "ClientKey": { Type: authn.MethodTypeChallenge, }, }, }, Node: types.NodeConfig{ NameProvider: "puuid", ClientAPI: types.APIConfig{ Host: "bootstrap.production.bacalhau.org", Port: 1234, }, ServerAPI: types.APIConfig{ Host: "0.0.0.0", Port: 1234, TLS: types.TLSConfiguration{}, }, Network: types.NetworkConfig{ Type: models.NetworkTypeLibp2p, Port: 4222, Cluster: types.NetworkClusterConfig{ Name: "global", Port: 6222, }, }, BootstrapAddresses: []string{ "/ip4/35.245.161.250/tcp/1235/p2p/QmbxGSsM6saCTyKkiWSxhJCt6Fgj7M9cns1vzYtfDbB5Ws", "/ip4/34.86.254.26/tcp/1235/p2p/QmeXjeQDinxm7zRiEo8ekrJdbs7585BM6j7ZeLVFrA7GPe", "/ip4/35.245.215.155/tcp/1235/p2p/QmPLPUUjaVE3wQNSSkxmYoaBPHVAWdjBjDYmMkWvtMZxAf", }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * time.Minute), NodeInfoStoreTTL: types.Duration(10 * time.Minute), DownloadURLRequestRetries: 3, LoggingMode: logger.LogModeDefault, Type: []string{"requester"}, AllowListedLocalPaths: []string{}, Labels: map[string]string{}, DisabledFeatures: types.FeatureConfig{ Engines: []string{}, Publishers: []string{}, Storages: []string{}, }, Libp2p: types.Libp2pConfig{ SwarmPort: 1235, PeerConnect: "none", }, IPFS: types.IpfsConfig{ Connect: "", PrivateInternal: true, SwarmAddresses: []string{ "/ip4/35.245.161.250/tcp/4001/p2p/12D3KooWAQpZzf3qiNxpwizXeArGjft98ZBoMNgVNNpoWtKAvtYH", "/ip4/35.245.161.250/udp/4001/quic/p2p/12D3KooWAQpZzf3qiNxpwizXeArGjft98ZBoMNgVNNpoWtKAvtYH", "/ip4/34.86.254.26/tcp/4001/p2p/12D3KooWLfFBjDo8dFe1Q4kSm8inKjPeHzmLBkQ1QAjTHocAUazK", "/ip4/34.86.254.26/udp/4001/quic/p2p/12D3KooWLfFBjDo8dFe1Q4kSm8inKjPeHzmLBkQ1QAjTHocAUazK", "/ip4/35.245.215.155/tcp/4001/p2p/12D3KooWH3rxmhLUrpzg81KAwUuXXuqeGt4qyWRniunb5ipjemFF", "/ip4/35.245.215.155/udp/4001/quic/p2p/12D3KooWH3rxmhLUrpzg81KAwUuXXuqeGt4qyWRniunb5ipjemFF", "/ip4/34.145.201.224/tcp/4001/p2p/12D3KooWBCBZnXnNbjxqqxu2oygPdLGseEbfMbFhrkDTRjUNnZYf", "/ip4/34.145.201.224/udp/4001/quic/p2p/12D3KooWBCBZnXnNbjxqqxu2oygPdLGseEbfMbFhrkDTRjUNnZYf", "/ip4/35.245.41.51/tcp/4001/p2p/12D3KooWJM8j97yoDTb7B9xV1WpBXakT4Zof3aMgFuSQQH56rCXa", "/ip4/35.245.41.51/udp/4001/quic/p2p/12D3KooWJM8j97yoDTb7B9xV1WpBXakT4Zof3aMgFuSQQH56rCXa", }, Profile: "flatfs", SwarmListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, GatewayListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, APIListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, }, Compute: ProductionComputeConfig, Requester: ProductionRequesterConfig, WebUI: types.WebUIConfig{ Enabled: false, Port: 8483, }, StrictVersionMatch: false, }, }
View Source
var ProductionComputeConfig = types.ComputeConfig{ Capacity: types.CapacityConfig{ IgnorePhysicalResourceLimits: false, TotalResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, JobResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, DefaultJobResourceLimits: models.ResourcesConfig{ CPU: "500m", Memory: "1Gb", Disk: "", GPU: "", }, QueueResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, }, ExecutionStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, JobTimeouts: types.JobTimeoutConfig{ JobExecutionTimeoutClientIDBypassList: []string{}, JobNegotiationTimeout: types.Duration(3 * time.Minute), MinJobExecutionTimeout: types.Duration(500 * time.Millisecond), MaxJobExecutionTimeout: types.Duration(model.NoJobTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, Queue: types.QueueConfig{}, Logging: types.LoggingConfig{ LogRunningExecutionsInterval: types.Duration(10 * time.Second), }, ManifestCache: types.DockerCacheConfig{ Size: 1000, Duration: types.Duration(1 * time.Hour), Frequency: types.Duration(1 * time.Hour), }, LogStreamConfig: types.LogStreamConfig{ ChannelBufferSize: 10, }, LocalPublisher: types.LocalPublisherConfig{ Address: "public", Port: 6001, }, }
View Source
var ProductionRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, JobStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, HousekeepingBackgroundTaskInterval: types.Duration(30 * time.Second), NodeRankRandomnessRange: 5, OverAskForBidsFactor: 3, FailureInjectionConfig: model.FailureInjectionRequesterConfig{ IsBadActor: false, }, EvaluationBroker: types.EvaluationBrokerConfig{ EvalBrokerVisibilityTimeout: types.Duration(60 * time.Second), EvalBrokerInitialRetryDelay: types.Duration(1 * time.Second), EvalBrokerSubsequentRetryDelay: types.Duration(30 * time.Second), EvalBrokerMaxRetryCount: 10, }, Worker: types.WorkerConfig{ WorkerCount: runtime.NumCPU(), WorkerEvalDequeueTimeout: types.Duration(5 * time.Second), WorkerEvalDequeueBaseBackoff: types.Duration(1 * time.Second), WorkerEvalDequeueMaxBackoff: types.Duration(30 * time.Second), }, JobDefaults: types.JobDefaults{ ExecutionTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, }
View Source
var Staging = types.BacalhauConfig{ Metrics: types.MetricsConfig{ Libp2pTracerPath: os.DevNull, EventTracerPath: os.DevNull, }, Update: types.UpdateConfig{ SkipChecks: false, CheckFrequency: types.Duration(24 * time.Hour), }, Auth: types.AuthConfig{ Methods: map[string]types.AuthenticatorConfig{ "ClientKey": { Type: authn.MethodTypeChallenge, }, }, }, Node: types.NodeConfig{ NameProvider: "puuid", ClientAPI: types.APIConfig{ Host: "bootstrap.staging.bacalhau.org", Port: 1234, }, ServerAPI: types.APIConfig{ Host: "0.0.0.0", Port: 1234, TLS: types.TLSConfiguration{}, }, Network: types.NetworkConfig{ Type: models.NetworkTypeLibp2p, Port: 4222, Cluster: types.NetworkClusterConfig{ Name: "global", Port: 6222, }, }, BootstrapAddresses: []string{ "/ip4/34.85.228.65/tcp/1235/p2p/QmafZ9oCXCJZX9Wt1nhrGS9FVVq41qhcBRSNWCkVhz3Nvv", "/ip4/34.86.73.105/tcp/1235/p2p/QmVHCeiLzhFJPCyCj5S1RTAk1vBEvxd8r5A6E4HyJGQtbJ", "/ip4/34.150.138.100/tcp/1235/p2p/QmRr9qPTe4mU7aS9faKnWgvn1NtXt36FT8YUULRPCn2f3K", }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * time.Minute), NodeInfoStoreTTL: types.Duration(10 * time.Minute), DownloadURLRequestRetries: 3, LoggingMode: logger.LogModeDefault, Type: []string{"requester"}, AllowListedLocalPaths: []string{}, Labels: map[string]string{}, DisabledFeatures: types.FeatureConfig{ Engines: []string{}, Publishers: []string{}, Storages: []string{}, }, Libp2p: types.Libp2pConfig{ SwarmPort: 1235, PeerConnect: "none", }, IPFS: types.IpfsConfig{ Connect: "", PrivateInternal: true, SwarmAddresses: []string{ "/ip4/34.85.228.65/tcp/4001/p2p/12D3KooWCWSTjjWh7SVoVv24W47z3T1Ly1tgnwZ56CCqCku5e4dS", "/ip4/34.85.228.65/udp/4001/quic/p2p/12D3KooWCWSTjjWh7SVoVv24W47z3T1Ly1tgnwZ56CCqCku5e4dS", "/ip4/34.86.73.105/tcp/4001/p2p/12D3KooWQuhW3LSpvhea25Zed47Z7fD5Cq2nw1xmapQ2tAUJ3q4F", "/ip4/34.86.73.105/udp/4001/quic/p2p/12D3KooWQuhW3LSpvhea25Zed47Z7fD5Cq2nw1xmapQ2tAUJ3q4F", "/ip4/34.150.138.100/tcp/4001/p2p/12D3KooWQm1T8EN8fMBz7rLviHxTGdRnohZ9nDPGbW4bfi78ckVT", "/ip4/34.150.138.100/udp/4001/quic/p2p/12D3KooWQm1T8EN8fMBz7rLviHxTGdRnohZ9nDPGbW4bfi78ckVT", "/ip4/35.245.247.85/tcp/4001/p2p/12D3KooWEztGEJtqtzy7th2d7cTw2iR4CQCPHFUYvj66rhh9Cf7h", "/ip4/35.245.247.85/udp/4001/quic/p2p/12D3KooWEztGEJtqtzy7th2d7cTw2iR4CQCPHFUYvj66rhh9Cf7h", }, Profile: "flatfs", SwarmListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, GatewayListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, APIListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, }, Compute: StagingComputeConfig, Requester: StagingRequesterConfig, WebUI: types.WebUIConfig{ Enabled: false, Port: 8483, }, StrictVersionMatch: false, }, }
View Source
var StagingComputeConfig = types.ComputeConfig{ Capacity: types.CapacityConfig{ IgnorePhysicalResourceLimits: false, TotalResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, JobResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, DefaultJobResourceLimits: models.ResourcesConfig{ CPU: "500m", Memory: "1Gb", Disk: "", GPU: "", }, QueueResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, }, ExecutionStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, JobTimeouts: types.JobTimeoutConfig{ JobExecutionTimeoutClientIDBypassList: []string{}, JobNegotiationTimeout: types.Duration(3 * time.Minute), MinJobExecutionTimeout: types.Duration(500 * time.Millisecond), MaxJobExecutionTimeout: types.Duration(model.NoJobTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, Queue: types.QueueConfig{}, Logging: types.LoggingConfig{ LogRunningExecutionsInterval: types.Duration(10 * time.Second), }, ManifestCache: types.DockerCacheConfig{ Size: 1000, Duration: types.Duration(1 * time.Hour), Frequency: types.Duration(1 * time.Hour), }, LogStreamConfig: types.LogStreamConfig{ ChannelBufferSize: 10, }, LocalPublisher: types.LocalPublisherConfig{ Address: "public", Port: 6001, }, }
View Source
var StagingRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, JobStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, HousekeepingBackgroundTaskInterval: types.Duration(30 * time.Second), NodeRankRandomnessRange: 5, OverAskForBidsFactor: 3, FailureInjectionConfig: model.FailureInjectionRequesterConfig{ IsBadActor: false, }, EvaluationBroker: types.EvaluationBrokerConfig{ EvalBrokerVisibilityTimeout: types.Duration(60 * time.Second), EvalBrokerInitialRetryDelay: types.Duration(1 * time.Second), EvalBrokerSubsequentRetryDelay: types.Duration(30 * time.Second), EvalBrokerMaxRetryCount: 10, }, Worker: types.WorkerConfig{ WorkerCount: runtime.NumCPU(), WorkerEvalDequeueTimeout: types.Duration(5 * time.Second), WorkerEvalDequeueBaseBackoff: types.Duration(1 * time.Second), WorkerEvalDequeueMaxBackoff: types.Duration(30 * time.Second), }, JobDefaults: types.JobDefaults{ ExecutionTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, }
View Source
var Testing = types.BacalhauConfig{ Metrics: types.MetricsConfig{ Libp2pTracerPath: os.DevNull, EventTracerPath: os.DevNull, }, Update: types.UpdateConfig{ SkipChecks: true, }, Auth: types.AuthConfig{ Methods: map[string]types.AuthenticatorConfig{ "ClientKey": { Type: authn.MethodTypeChallenge, }, }, }, Node: types.NodeConfig{ NameProvider: "puuid", ClientAPI: types.APIConfig{ Host: "test", Port: 9999, }, ServerAPI: types.APIConfig{ Host: "test", Port: 9999, TLS: types.TLSConfiguration{}, }, Network: types.NetworkConfig{ Type: models.NetworkTypeLibp2p, Port: 4222, Cluster: types.NetworkClusterConfig{ Name: "global", Port: 6222, }, }, BootstrapAddresses: []string{ "/ip4/0.0.0.0/tcp/1235/p2p/QmcWJnVXJ82DKJq8ED79LADR4ZBTnwgTK7yn6JQbNVMbbC", }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * time.Minute), NodeInfoStoreTTL: types.Duration(10 * time.Minute), DownloadURLRequestRetries: 3, LoggingMode: logger.LogModeDefault, Type: []string{"requester"}, AllowListedLocalPaths: []string{}, Labels: map[string]string{}, DisabledFeatures: types.FeatureConfig{ Engines: []string{}, Publishers: []string{}, Storages: []string{}, }, Libp2p: types.Libp2pConfig{ SwarmPort: 1235, PeerConnect: "none", }, IPFS: types.IpfsConfig{ Connect: "", PrivateInternal: true, SwarmAddresses: []string{ "/ip4/0.0.0.0/tcp/1235/p2p/QmcWJnVXJ82DKJq8ED79LADR4ZBTnwgTK7yn6JQbNVMbbC", }, Profile: "flatfs", SwarmListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, GatewayListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, APIListenAddresses: []string{"/ip4/0.0.0.0/tcp/0", "/ip6/::1/tcp/0"}, }, Compute: TestingComputeConfig, Requester: TestingRequesterConfig, WebUI: types.WebUIConfig{ Enabled: false, Port: 8483, }, StrictVersionMatch: false, }, }
View Source
var TestingComputeConfig = types.ComputeConfig{ Capacity: types.CapacityConfig{ IgnorePhysicalResourceLimits: false, TotalResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, JobResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, DefaultJobResourceLimits: models.ResourcesConfig{ CPU: "100m", Memory: "100Mi", Disk: "", GPU: "", }, QueueResourceLimits: models.ResourcesConfig{ CPU: "", Memory: "", Disk: "", GPU: "", }, }, ExecutionStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, JobTimeouts: types.JobTimeoutConfig{ JobExecutionTimeoutClientIDBypassList: []string{}, JobNegotiationTimeout: types.Duration(3 * time.Minute), MinJobExecutionTimeout: types.Duration(500 * time.Millisecond), MaxJobExecutionTimeout: types.Duration(model.NoJobTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, Queue: types.QueueConfig{}, Logging: types.LoggingConfig{ LogRunningExecutionsInterval: types.Duration(10 * time.Second), }, ManifestCache: types.DockerCacheConfig{ Size: 1000, Duration: types.Duration(1 * time.Hour), Frequency: types.Duration(1 * time.Hour), }, LogStreamConfig: types.LogStreamConfig{ ChannelBufferSize: 10, }, LocalPublisher: types.LocalPublisherConfig{ Address: "private", Port: 6001, }, }
View Source
var TestingRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: model.JobSelectionPolicy{ Locality: model.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, JobStore: types.JobStoreConfig{ Type: types.BoltDB, Path: "", }, HousekeepingBackgroundTaskInterval: types.Duration(30 * time.Second), NodeRankRandomnessRange: 5, OverAskForBidsFactor: 3, FailureInjectionConfig: model.FailureInjectionRequesterConfig{ IsBadActor: false, }, EvaluationBroker: types.EvaluationBrokerConfig{ EvalBrokerVisibilityTimeout: types.Duration(60 * time.Second), EvalBrokerInitialRetryDelay: types.Duration(1 * time.Second), EvalBrokerSubsequentRetryDelay: types.Duration(30 * time.Second), EvalBrokerMaxRetryCount: 10, }, Worker: types.WorkerConfig{ WorkerCount: runtime.NumCPU(), WorkerEvalDequeueTimeout: types.Duration(5 * time.Second), WorkerEvalDequeueBaseBackoff: types.Duration(1 * time.Second), WorkerEvalDequeueMaxBackoff: types.Duration(30 * time.Second), }, JobDefaults: types.JobDefaults{ ExecutionTimeout: types.Duration(30 * time.Second), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, }
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.