X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/3a81f54c8c0da6babdfb9014a64079b6b41f73c7..8b873a9b3b8865a4d451263e48b49122b9c32759:/sdk/go/arvados/config.go diff --git a/sdk/go/arvados/config.go b/sdk/go/arvados/config.go index aa0e83c66a..db4e6dcd89 100644 --- a/sdk/go/arvados/config.go +++ b/sdk/go/arvados/config.go @@ -57,6 +57,14 @@ func (sc *Config) GetCluster(clusterID string) (*Cluster, error) { } } +type WebDAVCacheConfig struct { + TTL Duration + UUIDTTL Duration + MaxCollectionEntries int + MaxCollectionBytes int64 + MaxPermissionEntries int + MaxUUIDEntries int +} type Cluster struct { ClusterID string `json:"-"` ManagementToken string @@ -69,30 +77,39 @@ type Cluster struct { API struct { AsyncPermissionsUpdateInterval Duration - DisabledAPIs []string + DisabledAPIs StringSet MaxIndexDatabaseRead int MaxItemsPerResponse int MaxRequestAmplification int MaxRequestSize int RailsSessionSecretToken string RequestTimeout Duration + SendTimeout Duration + WebsocketClientEventQueue int + WebsocketServerEventQueue int } AuditLogs struct { MaxAge Duration MaxDeleteBatch int - UnloggedAttributes []string + UnloggedAttributes StringSet } Collections struct { - BlobSigning bool - BlobSigningKey string - BlobSigningTTL Duration - CollectionVersioning bool - DefaultTrashLifetime Duration - DefaultReplication int - ManagedProperties map[string]interface{} + BlobSigning bool + BlobSigningKey string + BlobSigningTTL Duration + CollectionVersioning bool + DefaultTrashLifetime Duration + DefaultReplication int + ManagedProperties map[string]struct { + Value interface{} + Function string + Protected bool + } PreserveVersionIfIdle Duration TrashSweepInterval Duration TrustAllContent bool + + WebDAVCache WebDAVCacheConfig } Git struct { Repositories string @@ -128,10 +145,10 @@ type Cluster struct { AutoSetupNewUsers bool AutoSetupNewUsersWithRepository bool AutoSetupNewUsersWithVmUUID string - AutoSetupUsernameBlacklist []string + AutoSetupUsernameBlacklist StringSet EmailSubjectPrefix string - NewInactiveUserNotificationRecipients []string - NewUserNotificationRecipients []string + NewInactiveUserNotificationRecipients StringSet + NewUserNotificationRecipients StringSet NewUsersAreActive bool UserNotifierEmailFrom string UserProfileNotificationAddress string @@ -141,7 +158,7 @@ type Cluster struct { APIClientConnectTimeout Duration APIClientReceiveTimeout Duration APIResponseCompression bool - ApplicationMimetypesWithViewIcon map[string]struct{} + ApplicationMimetypesWithViewIcon StringSet ArvadosDocsite string ArvadosPublicDataDocURL string DefaultOpenIdPrefix string @@ -249,24 +266,23 @@ type InstanceType struct { type ContainersConfig struct { CloudVMs CloudVMsConfig + CrunchRunCommand string + CrunchRunArgumentsList []string DefaultKeepCacheRAM ByteSize DispatchPrivateKey string LogReuseDecisions bool MaxComputeVMs int MaxDispatchAttempts int MaxRetryAttempts int + MinRetryPeriod Duration + ReserveExtraRAM ByteSize StaleLockTimeout Duration - SupportedDockerImageFormats []string + SupportedDockerImageFormats StringSet UsePreemptibleInstances bool JobsAPI struct { - Enable string - GitInternalDir string - DefaultDockerImage string - CrunchJobWrapper string - CrunchJobUser string - CrunchRefreshTrigger string - ReuseJobIfOutputsDiffer bool + Enable string + GitInternalDir string } Logging struct { MaxAge Duration @@ -281,13 +297,16 @@ type ContainersConfig struct { LogUpdateSize ByteSize } SLURM struct { - Managed struct { + PrioritySpread int64 + SbatchArgumentsList []string + SbatchEnvironmentVariables map[string]string + Managed struct { DNSServerConfDir string DNSServerConfTemplate string DNSServerReloadCommand string DNSServerUpdateCommand string ComputeNodeDomain string - ComputeNodeNameservers []string + ComputeNodeNameservers StringSet AssignNodeHostname string } } @@ -375,6 +394,40 @@ func (it *InstanceTypeMap) UnmarshalJSON(data []byte) error { return nil } +type StringSet map[string]struct{} + +// UnmarshalJSON handles old config files that provide an array of +// instance types instead of a hash. +func (ss *StringSet) UnmarshalJSON(data []byte) error { + if len(data) > 0 && data[0] == '[' { + var arr []string + err := json.Unmarshal(data, &arr) + if err != nil { + return err + } + if len(arr) == 0 { + *ss = nil + return nil + } + *ss = make(map[string]struct{}, len(arr)) + for _, t := range arr { + (*ss)[t] = struct{}{} + } + return nil + } + var hash map[string]struct{} + err := json.Unmarshal(data, &hash) + if err != nil { + return err + } + *ss = make(map[string]struct{}, len(hash)) + for t, _ := range hash { + (*ss)[t] = struct{}{} + } + + return nil +} + type ServiceName string const (