Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Development = types.BacalhauConfig{ Metrics: types.MetricsConfig{ 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{ Port: 4222, }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * 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{}, }, IPFS: types.IpfsConfig{ Connect: "", }, 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: "", }, }, 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(models.NoTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: models.JobSelectionPolicy{ Locality: models.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, 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, }, ControlPlaneSettings: types.ComputeControlPlaneConfig{ InfoUpdateFrequency: types.Duration(60 * time.Second), ResourceUpdateFrequency: types.Duration(30 * time.Second), HeartbeatFrequency: types.Duration(15 * time.Second), HeartbeatTopic: "heartbeat", }, }
View Source
var DevelopmentRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: models.JobSelectionPolicy{ Locality: models.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: models.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), }, Scheduler: types.SchedulerConfig{ QueueBackoff: types.Duration(30 * time.Second), NodeOverSubscriptionFactor: 1.5, }, JobDefaults: types.JobDefaults{ TotalTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, ControlPlaneSettings: types.RequesterControlPlaneConfig{ HeartbeatCheckFrequency: types.Duration(30 * time.Second), HeartbeatTopic: "heartbeat", NodeDisconnectedAfter: types.Duration(30 * time.Second), }, NodeInfoStoreTTL: types.Duration(10 * time.Minute), }
View Source
var Local = types.BacalhauConfig{ Metrics: types.MetricsConfig{ 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{ Port: 4222, }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * 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{}, }, IPFS: types.IpfsConfig{ Connect: "", }, 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: "", }, }, 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(models.NoTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: models.JobSelectionPolicy{ Locality: models.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, 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, }, ControlPlaneSettings: types.ComputeControlPlaneConfig{ InfoUpdateFrequency: types.Duration(60 * time.Second), ResourceUpdateFrequency: types.Duration(30 * time.Second), HeartbeatFrequency: types.Duration(15 * time.Second), HeartbeatTopic: "heartbeat", }, }
View Source
var LocalRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: models.JobSelectionPolicy{ Locality: models.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: models.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), }, Scheduler: types.SchedulerConfig{ QueueBackoff: types.Duration(30 * time.Second), NodeOverSubscriptionFactor: 1.5, }, JobDefaults: types.JobDefaults{ TotalTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, ControlPlaneSettings: types.RequesterControlPlaneConfig{ HeartbeatCheckFrequency: types.Duration(30 * time.Second), HeartbeatTopic: "heartbeat", NodeDisconnectedAfter: types.Duration(30 * time.Second), }, NodeInfoStoreTTL: types.Duration(10 * time.Minute), }
View Source
var Production = types.BacalhauConfig{ Metrics: types.MetricsConfig{ 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{ Port: 4222, }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * 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{}, }, IPFS: types.IpfsConfig{ Connect: "", }, 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: "", }, }, 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(models.NoTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: models.JobSelectionPolicy{ Locality: models.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, 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, }, ControlPlaneSettings: types.ComputeControlPlaneConfig{ InfoUpdateFrequency: types.Duration(60 * time.Second), ResourceUpdateFrequency: types.Duration(30 * time.Second), HeartbeatFrequency: types.Duration(15 * time.Second), HeartbeatTopic: "heartbeat", }, }
View Source
var ProductionRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: models.JobSelectionPolicy{ Locality: models.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: models.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), }, Scheduler: types.SchedulerConfig{ QueueBackoff: types.Duration(1 * time.Minute), NodeOverSubscriptionFactor: 1.5, }, JobDefaults: types.JobDefaults{ TotalTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, ControlPlaneSettings: types.RequesterControlPlaneConfig{ HeartbeatCheckFrequency: types.Duration(30 * time.Second), HeartbeatTopic: "heartbeat", NodeDisconnectedAfter: types.Duration(30 * time.Second), }, NodeInfoStoreTTL: types.Duration(10 * time.Minute), }
View Source
var Staging = types.BacalhauConfig{ Metrics: types.MetricsConfig{ 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{ Port: 4222, }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * 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{}, }, IPFS: types.IpfsConfig{ Connect: "", }, 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: "", }, }, 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(models.NoTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: models.JobSelectionPolicy{ Locality: models.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, 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, }, ControlPlaneSettings: types.ComputeControlPlaneConfig{ InfoUpdateFrequency: types.Duration(60 * time.Second), ResourceUpdateFrequency: types.Duration(30 * time.Second), HeartbeatFrequency: types.Duration(15 * time.Second), HeartbeatTopic: "heartbeat", }, }
View Source
var StagingRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: models.JobSelectionPolicy{ Locality: models.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: models.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), }, Scheduler: types.SchedulerConfig{ QueueBackoff: types.Duration(1 * time.Minute), NodeOverSubscriptionFactor: 1.5, }, JobDefaults: types.JobDefaults{ TotalTimeout: types.Duration(30 * time.Minute), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, ControlPlaneSettings: types.RequesterControlPlaneConfig{ HeartbeatCheckFrequency: types.Duration(30 * time.Second), HeartbeatTopic: "heartbeat", NodeDisconnectedAfter: types.Duration(30 * time.Second), }, NodeInfoStoreTTL: types.Duration(10 * time.Minute), }
View Source
var Testing = types.BacalhauConfig{ Metrics: types.MetricsConfig{ 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{ Port: 4222, }, DownloadURLRequestTimeout: types.Duration(300 * time.Second), VolumeSizeRequestTimeout: types.Duration(2 * 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{}, }, IPFS: types.IpfsConfig{ Connect: "", }, 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: "", }, }, 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(models.NoTimeout), DefaultJobExecutionTimeout: types.Duration(10 * time.Minute), }, JobSelection: models.JobSelectionPolicy{ Locality: models.Anywhere, RejectStatelessJobs: false, AcceptNetworkedJobs: false, ProbeHTTP: "", ProbeExec: "", }, 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, }, ControlPlaneSettings: types.ComputeControlPlaneConfig{ InfoUpdateFrequency: types.Duration(60 * time.Second), ResourceUpdateFrequency: types.Duration(30 * time.Second), HeartbeatFrequency: types.Duration(15 * time.Second), HeartbeatTopic: "heartbeat", }, }
View Source
var TestingRequesterConfig = types.RequesterConfig{ ExternalVerifierHook: "", JobSelectionPolicy: models.JobSelectionPolicy{ Locality: models.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: models.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), }, Scheduler: types.SchedulerConfig{ QueueBackoff: types.Duration(5 * time.Second), NodeOverSubscriptionFactor: 1.5, }, JobDefaults: types.JobDefaults{ TotalTimeout: types.Duration(30 * time.Second), }, StorageProvider: types.StorageProviderConfig{ S3: types.S3StorageProviderConfig{ PreSignedURLExpiration: types.Duration(30 * time.Minute), }, }, ControlPlaneSettings: types.RequesterControlPlaneConfig{ HeartbeatCheckFrequency: types.Duration(30 * time.Second), HeartbeatTopic: "heartbeat", NodeDisconnectedAfter: types.Duration(30 * time.Second), }, NodeInfoStoreTTL: types.Duration(10 * time.Minute), }
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.