config

package
v0.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 23, 2026 License: MIT Imports: 20 Imported by: 29

Documentation

Overview

Package config contains Funnel configuration structures and defaults.

Index

Constants

This section is empty.

Variables

View Source 
var File_config_config_proto protoreflect.FileDescriptor

Functions

func ApplyDefaultResources added in v0.11.8 

func ApplyDefaultResources(res *tes.Resources, k8s *KubernetesResources) *tes.Resources

func Examples 

func Examples() map[string]string

Examples returns a set of example configurations strings.

func GetResourceLimits added in v0.11.8 

func GetResourceLimits(k8s *KubernetesResources) *tes.Resources

func K8sConfigToTesResources added in v0.11.8 

func K8sConfigToTesResources(cpu, ram, disk string) *tes.Resources

func Parse 

func Parse(raw []byte, conf *Config) error

Parse parses a YAML doc into the given Config instance.

func ParseCpus added in v0.11.8 

func ParseCpus(s string) (float64, error)

ParseCPU parses Kubernetes-style CPU values (e.g., "100m", "0.5", "2") ParseCpus handles both CPU (m) and RAM/Disk (Mi, Gi)

func ParseFile 

func ParseFile(relpath string, conf *Config) error

ParseFile parses a Funnel config file, which is formatted in YAML, and returns a Config struct.

func ParseMemory added in v0.11.8 

func ParseMemory(s string) (float64, error)

ParseMemory parses Kubernetes-style memory values (e.g., "512Mi", "1Gi", "1000") and returns the value in Gigabytes (float64).

func ToYaml 

func ToYaml(c *Config) ([]byte, error)

ToYaml formats the configuration into YAML and returns the bytes.

func ToYamlFile 

func ToYamlFile(c *Config, path string) error

ToYamlFile writes the configuration to a YAML file.

Types

type AWSBatch 

type AWSBatch struct {
	JobDefinition     string               `protobuf:"bytes,1,opt,name=JobDefinition,proto3" json:"JobDefinition,omitempty"`
	JobQueue          string               `protobuf:"bytes,2,opt,name=JobQueue,proto3" json:"JobQueue,omitempty"`
	DisableReconciler bool                 `protobuf:"varint,3,opt,name=DisableReconciler,proto3" json:"DisableReconciler,omitempty"`
	ReconcileRate     *durationpb.Duration `protobuf:"bytes,4,opt,name=ReconcileRate,proto3" json:"ReconcileRate,omitempty"`
	AWSConfig         *AWSConfig           `protobuf:"bytes,5,opt,name=AWSConfig,proto3" json:"AWSConfig,omitempty"`
	// contains filtered or unexported fields
}

AWSBatch describes the configuration for the AWS Batch compute backend.

func (*AWSBatch) Descriptor deprecated added in v0.11.4 

func (*AWSBatch) Descriptor() ([]byte, []int)

Deprecated: Use AWSBatch.ProtoReflect.Descriptor instead.

func (*AWSBatch) GetAWSConfig added in v0.11.4 

func (x *AWSBatch) GetAWSConfig() *AWSConfig

func (*AWSBatch) GetDisableReconciler added in v0.11.4 

func (x *AWSBatch) GetDisableReconciler() bool

func (*AWSBatch) GetJobDefinition added in v0.11.4 

func (x *AWSBatch) GetJobDefinition() string

func (*AWSBatch) GetJobQueue added in v0.11.4 

func (x *AWSBatch) GetJobQueue() string

func (*AWSBatch) GetReconcileRate added in v0.11.4 

func (x *AWSBatch) GetReconcileRate() *durationpb.Duration

func (*AWSBatch) ProtoMessage added in v0.11.4 

func (*AWSBatch) ProtoMessage()

func (*AWSBatch) ProtoReflect added in v0.11.4 

func (x *AWSBatch) ProtoReflect() protoreflect.Message

func (*AWSBatch) Reset added in v0.11.4 

func (x *AWSBatch) Reset()

func (*AWSBatch) String added in v0.11.4 

func (x *AWSBatch) String() string

type AWSConfig 

type AWSConfig struct {
	Endpoint                  string `protobuf:"bytes,1,opt,name=Endpoint,proto3" json:"Endpoint,omitempty"`
	Region                    string `protobuf:"bytes,2,opt,name=Region,proto3" json:"Region,omitempty"`
	MaxRetries                int32  `protobuf:"varint,3,opt,name=MaxRetries,proto3" json:"MaxRetries,omitempty"`
	Key                       string `protobuf:"bytes,4,opt,name=Key,proto3" json:"Key,omitempty"`
	Secret                    string `protobuf:"bytes,5,opt,name=Secret,proto3" json:"Secret,omitempty"`
	DisableAutoCredentialLoad bool   `protobuf:"varint,6,opt,name=DisableAutoCredentialLoad,proto3" json:"DisableAutoCredentialLoad,omitempty"`
	// contains filtered or unexported fields
}

AWSConfig describes the configuration for creating AWS Session instances.

func (*AWSConfig) Descriptor deprecated added in v0.11.4 

func (*AWSConfig) Descriptor() ([]byte, []int)

Deprecated: Use AWSConfig.ProtoReflect.Descriptor instead.

func (*AWSConfig) GetDisableAutoCredentialLoad added in v0.11.4 

func (x *AWSConfig) GetDisableAutoCredentialLoad() bool

func (*AWSConfig) GetEndpoint added in v0.11.4 

func (x *AWSConfig) GetEndpoint() string

func (*AWSConfig) GetKey added in v0.11.4 

func (x *AWSConfig) GetKey() string

func (*AWSConfig) GetMaxRetries added in v0.11.4 

func (x *AWSConfig) GetMaxRetries() int32

func (*AWSConfig) GetRegion added in v0.11.4 

func (x *AWSConfig) GetRegion() string

func (*AWSConfig) GetSecret added in v0.11.4 

func (x *AWSConfig) GetSecret() string

func (*AWSConfig) ProtoMessage added in v0.11.4 

func (*AWSConfig) ProtoMessage()

func (*AWSConfig) ProtoReflect added in v0.11.4 

func (x *AWSConfig) ProtoReflect() protoreflect.Message

func (*AWSConfig) Reset added in v0.11.4 

func (x *AWSConfig) Reset()

func (*AWSConfig) String added in v0.11.4 

func (x *AWSConfig) String() string

type AmazonS3Storage 

type AmazonS3Storage struct {
	Disabled  bool       `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	SSE       *SSE       `protobuf:"bytes,2,opt,name=SSE,proto3" json:"SSE,omitempty"`
	AWSConfig *AWSConfig `protobuf:"bytes,3,opt,name=AWSConfig,proto3" json:"AWSConfig,omitempty"`
	// contains filtered or unexported fields
}

AmazonS3Storage describes the configuration for the Amazon S3 storage backend.

func (*AmazonS3Storage) Descriptor deprecated added in v0.11.4 

func (*AmazonS3Storage) Descriptor() ([]byte, []int)

Deprecated: Use AmazonS3Storage.ProtoReflect.Descriptor instead.

func (*AmazonS3Storage) GetAWSConfig added in v0.11.4 

func (x *AmazonS3Storage) GetAWSConfig() *AWSConfig

func (*AmazonS3Storage) GetDisabled added in v0.11.4 

func (x *AmazonS3Storage) GetDisabled() bool

func (*AmazonS3Storage) GetSSE added in v0.11.4 

func (x *AmazonS3Storage) GetSSE() *SSE

func (*AmazonS3Storage) ProtoMessage added in v0.11.4 

func (*AmazonS3Storage) ProtoMessage()

func (*AmazonS3Storage) ProtoReflect added in v0.11.4 

func (x *AmazonS3Storage) ProtoReflect() protoreflect.Message

func (*AmazonS3Storage) Reset added in v0.11.4 

func (x *AmazonS3Storage) Reset()

func (*AmazonS3Storage) String added in v0.11.4 

func (x *AmazonS3Storage) String() string

func (*AmazonS3Storage) Valid 

func (s *AmazonS3Storage) Valid() bool

Valid validates the AmazonS3Storage configuration

type Badger 

type Badger struct {
	Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	// contains filtered or unexported fields
}

Badger describes configuration for the Badger embedded database.

func (*Badger) Descriptor deprecated added in v0.11.4 

func (*Badger) Descriptor() ([]byte, []int)

Deprecated: Use Badger.ProtoReflect.Descriptor instead.

func (*Badger) GetPath added in v0.11.4 

func (x *Badger) GetPath() string

func (*Badger) ProtoMessage added in v0.11.4 

func (*Badger) ProtoMessage()

func (*Badger) ProtoReflect added in v0.11.4 

func (x *Badger) ProtoReflect() protoreflect.Message

func (*Badger) Reset added in v0.11.4 

func (x *Badger) Reset()

func (*Badger) String added in v0.11.4 

func (x *Badger) String() string

type BasicCredential 

type BasicCredential struct {
	User     string `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"`
	Admin    bool   `protobuf:"varint,3,opt,name=Admin,proto3" json:"Admin,omitempty"`
	// contains filtered or unexported fields
}

BasicCredential describes a username and password for use with Funnel's basic auth.

func (*BasicCredential) Descriptor deprecated added in v0.11.4 

func (*BasicCredential) Descriptor() ([]byte, []int)

Deprecated: Use BasicCredential.ProtoReflect.Descriptor instead.

func (*BasicCredential) GetAdmin added in v0.11.4 

func (x *BasicCredential) GetAdmin() bool

func (*BasicCredential) GetPassword added in v0.11.4 

func (x *BasicCredential) GetPassword() string

func (*BasicCredential) GetUser added in v0.11.4 

func (x *BasicCredential) GetUser() string

func (*BasicCredential) ProtoMessage added in v0.11.4 

func (*BasicCredential) ProtoMessage()

func (*BasicCredential) ProtoReflect added in v0.11.4 

func (x *BasicCredential) ProtoReflect() protoreflect.Message

func (*BasicCredential) Reset added in v0.11.4 

func (x *BasicCredential) Reset()

func (*BasicCredential) String added in v0.11.4 

func (x *BasicCredential) String() string

type BoltDB 

type BoltDB struct {
	Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	// contains filtered or unexported fields
}

BoltDB describes the configuration for the BoltDB embedded database.

func (*BoltDB) Descriptor deprecated added in v0.11.4 

func (*BoltDB) Descriptor() ([]byte, []int)

Deprecated: Use BoltDB.ProtoReflect.Descriptor instead.

func (*BoltDB) GetPath added in v0.11.4 

func (x *BoltDB) GetPath() string

func (*BoltDB) ProtoMessage added in v0.11.4 

func (*BoltDB) ProtoMessage()

func (*BoltDB) ProtoReflect added in v0.11.4 

func (x *BoltDB) ProtoReflect() protoreflect.Message

func (*BoltDB) Reset added in v0.11.4 

func (x *BoltDB) Reset()

func (*BoltDB) String added in v0.11.4 

func (x *BoltDB) String() string

type Config 

type Config struct {

	// Component selectors
	EventWriters []string `protobuf:"bytes,1,rep,name=EventWriters,proto3" json:"EventWriters,omitempty"`
	Database     string   `protobuf:"bytes,2,opt,name=Database,proto3" json:"Database,omitempty"`
	Compute      string   `protobuf:"bytes,3,opt,name=Compute,proto3" json:"Compute,omitempty"`
	// Funnel components
	Server    *Server              `protobuf:"bytes,4,opt,name=Server,proto3" json:"Server,omitempty"`
	RPCClient *RPCClient           `protobuf:"bytes,5,opt,name=RPCClient,proto3" json:"RPCClient,omitempty"`
	Scheduler *Scheduler           `protobuf:"bytes,6,opt,name=Scheduler,proto3" json:"Scheduler,omitempty"`
	Node      *Node                `protobuf:"bytes,7,opt,name=Node,proto3" json:"Node,omitempty"`
	Worker    *Worker              `protobuf:"bytes,8,opt,name=Worker,proto3" json:"Worker,omitempty"`
	Logger    *logger.LoggerConfig `protobuf:"bytes,9,opt,name=Logger,proto3" json:"Logger,omitempty"` // Placeholder for logger.Config
	// Databases / event handlers
	BoltDB    *BoltDB    `protobuf:"bytes,10,opt,name=BoltDB,proto3" json:"BoltDB,omitempty"`
	Badger    *Badger    `protobuf:"bytes,11,opt,name=Badger,proto3" json:"Badger,omitempty"`
	DynamoDB  *DynamoDB  `protobuf:"bytes,12,opt,name=DynamoDB,proto3" json:"DynamoDB,omitempty"`
	Elastic   *Elastic   `protobuf:"bytes,13,opt,name=Elastic,proto3" json:"Elastic,omitempty"`
	MongoDB   *MongoDB   `protobuf:"bytes,14,opt,name=MongoDB,proto3" json:"MongoDB,omitempty"`
	Kafka     *Kafka     `protobuf:"bytes,15,opt,name=Kafka,proto3" json:"Kafka,omitempty"`
	PubSub    *PubSub    `protobuf:"bytes,16,opt,name=PubSub,proto3" json:"PubSub,omitempty"`
	Datastore *Datastore `protobuf:"bytes,17,opt,name=Datastore,proto3" json:"Datastore,omitempty"`
	Postgres  *Postgres  `protobuf:"bytes,33,opt,name=Postgres,proto3" json:"Postgres,omitempty"`
	// Compute
	HTCondor   *HPCBackend `protobuf:"bytes,18,opt,name=HTCondor,proto3" json:"HTCondor,omitempty"`
	Slurm      *HPCBackend `protobuf:"bytes,19,opt,name=Slurm,proto3" json:"Slurm,omitempty"`
	PBS        *HPCBackend `protobuf:"bytes,20,opt,name=PBS,proto3" json:"PBS,omitempty"`
	GridEngine *GridEngine `protobuf:"bytes,21,opt,name=GridEngine,proto3" json:"GridEngine,omitempty"`
	AWSBatch   *AWSBatch   `protobuf:"bytes,22,opt,name=AWSBatch,proto3" json:"AWSBatch,omitempty"`
	Kubernetes *Kubernetes `protobuf:"bytes,23,opt,name=Kubernetes,proto3" json:"Kubernetes,omitempty"`
	GCPBatch   *GCPBatch   `protobuf:"bytes,24,opt,name=GCPBatch,proto3" json:"GCPBatch,omitempty"`
	// Storage
	LocalStorage  *LocalStorage       `protobuf:"bytes,25,opt,name=LocalStorage,proto3" json:"LocalStorage,omitempty"`
	AmazonS3      *AmazonS3Storage    `protobuf:"bytes,26,opt,name=AmazonS3,proto3" json:"AmazonS3,omitempty"`
	GenericS3     []*GenericS3Storage `protobuf:"bytes,27,rep,name=GenericS3,proto3" json:"GenericS3,omitempty"`
	GoogleStorage *GoogleCloudStorage `protobuf:"bytes,28,opt,name=GoogleStorage,proto3" json:"GoogleStorage,omitempty"`
	Swift         *SwiftStorage       `protobuf:"bytes,29,opt,name=Swift,proto3" json:"Swift,omitempty"`
	HTTPStorage   *HTTPStorage        `protobuf:"bytes,30,opt,name=HTTPStorage,proto3" json:"HTTPStorage,omitempty"`
	FTPStorage    *FTPStorage         `protobuf:"bytes,31,opt,name=FTPStorage,proto3" json:"FTPStorage,omitempty"`
	// Plugins
	Plugins *Plugins `protobuf:"bytes,32,opt,name=Plugins,proto3" json:"Plugins,omitempty"`
	// contains filtered or unexported fields
}

Config describes configuration for Funnel.

func DefaultConfig 

func DefaultConfig() *Config

DefaultConfig returns configuration with simple defaults.

func EmptyConfig added in v0.11.4 

func EmptyConfig() *Config

func (*Config) Descriptor deprecated added in v0.11.4 

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetAWSBatch added in v0.11.4 

func (x *Config) GetAWSBatch() *AWSBatch

func (*Config) GetAmazonS3 added in v0.11.4 

func (x *Config) GetAmazonS3() *AmazonS3Storage

func (*Config) GetBadger added in v0.11.4 

func (x *Config) GetBadger() *Badger

func (*Config) GetBoltDB added in v0.11.4 

func (x *Config) GetBoltDB() *BoltDB

func (*Config) GetCompute added in v0.11.4 

func (x *Config) GetCompute() string

func (*Config) GetDatabase added in v0.11.4 

func (x *Config) GetDatabase() string

func (*Config) GetDatastore added in v0.11.4 

func (x *Config) GetDatastore() *Datastore

func (*Config) GetDynamoDB added in v0.11.4 

func (x *Config) GetDynamoDB() *DynamoDB

func (*Config) GetElastic added in v0.11.4 

func (x *Config) GetElastic() *Elastic

func (*Config) GetEventWriters added in v0.11.4 

func (x *Config) GetEventWriters() []string

func (*Config) GetFTPStorage added in v0.11.4 

func (x *Config) GetFTPStorage() *FTPStorage

func (*Config) GetGCPBatch added in v0.11.8 

func (x *Config) GetGCPBatch() *GCPBatch

func (*Config) GetGenericS3 added in v0.11.4 

func (x *Config) GetGenericS3() []*GenericS3Storage

func (*Config) GetGoogleStorage added in v0.11.4 

func (x *Config) GetGoogleStorage() *GoogleCloudStorage

func (*Config) GetGridEngine added in v0.11.4 

func (x *Config) GetGridEngine() *GridEngine

func (*Config) GetHTCondor added in v0.11.4 

func (x *Config) GetHTCondor() *HPCBackend

func (*Config) GetHTTPStorage added in v0.11.4 

func (x *Config) GetHTTPStorage() *HTTPStorage

func (*Config) GetKafka added in v0.11.4 

func (x *Config) GetKafka() *Kafka

func (*Config) GetKubernetes added in v0.11.4 

func (x *Config) GetKubernetes() *Kubernetes

func (*Config) GetLocalStorage added in v0.11.4 

func (x *Config) GetLocalStorage() *LocalStorage

func (*Config) GetLogger added in v0.11.4 

func (x *Config) GetLogger() *logger.LoggerConfig

func (*Config) GetMongoDB added in v0.11.4 

func (x *Config) GetMongoDB() *MongoDB

func (*Config) GetNode added in v0.11.4 

func (x *Config) GetNode() *Node

func (*Config) GetPBS added in v0.11.4 

func (x *Config) GetPBS() *HPCBackend

func (*Config) GetPlugins added in v0.11.4 

func (x *Config) GetPlugins() *Plugins

func (*Config) GetPostgres added in v0.11.8 

func (x *Config) GetPostgres() *Postgres

func (*Config) GetPubSub added in v0.11.4 

func (x *Config) GetPubSub() *PubSub

func (*Config) GetRPCClient added in v0.11.4 

func (x *Config) GetRPCClient() *RPCClient

func (*Config) GetScheduler added in v0.11.4 

func (x *Config) GetScheduler() *Scheduler

func (*Config) GetServer added in v0.11.4 

func (x *Config) GetServer() *Server

func (*Config) GetSlurm added in v0.11.4 

func (x *Config) GetSlurm() *HPCBackend

func (*Config) GetSwift added in v0.11.4 

func (x *Config) GetSwift() *SwiftStorage

func (*Config) GetWorker added in v0.11.4 

func (x *Config) GetWorker() *Worker

func (*Config) ProtoMessage added in v0.11.4 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect added in v0.11.4 

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset added in v0.11.4 

func (x *Config) Reset()

func (*Config) String added in v0.11.4 

func (x *Config) String() string

type ContainerConfig 

type ContainerConfig struct {
	Id              string            `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Image           string            `protobuf:"bytes,2,opt,name=Image,proto3" json:"Image,omitempty"`
	Name            string            `protobuf:"bytes,3,opt,name=Name,proto3" json:"Name,omitempty"`
	Command         []string          `protobuf:"bytes,4,rep,name=Command,proto3" json:"Command,omitempty"`
	Workdir         string            `protobuf:"bytes,5,opt,name=Workdir,proto3" json:"Workdir,omitempty"`
	RemoveContainer bool              `protobuf:"varint,6,opt,name=RemoveContainer,proto3" json:"RemoveContainer,omitempty"`
	Env             map[string]string `` /* 133-byte string literal not displayed */
	DriverCommand   string            `protobuf:"bytes,8,opt,name=DriverCommand,proto3" json:"DriverCommand,omitempty"`
	RunCommand      string            `protobuf:"bytes,9,opt,name=RunCommand,proto3" json:"RunCommand,omitempty"`
	PullCommand     string            `protobuf:"bytes,10,opt,name=PullCommand,proto3" json:"PullCommand,omitempty"`
	StopCommand     string            `protobuf:"bytes,11,opt,name=StopCommand,proto3" json:"StopCommand,omitempty"`
	EnableTags      bool              `protobuf:"varint,12,opt,name=EnableTags,proto3" json:"EnableTags,omitempty"`
	Tags            map[string]string `` // Note: io.Reader and io.Writer (Stdin, Stdout, Stderr) are omitted as they are not serializable in Protobuf
	/* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

ContainerConfig describes container configuration.

func (*ContainerConfig) Descriptor deprecated added in v0.11.4 

func (*ContainerConfig) Descriptor() ([]byte, []int)

Deprecated: Use ContainerConfig.ProtoReflect.Descriptor instead.

func (*ContainerConfig) GetCommand added in v0.11.4 

func (x *ContainerConfig) GetCommand() []string

func (*ContainerConfig) GetDriverCommand added in v0.11.4 

func (x *ContainerConfig) GetDriverCommand() string

func (*ContainerConfig) GetEnableTags added in v0.11.4 

func (x *ContainerConfig) GetEnableTags() bool

func (*ContainerConfig) GetEnv added in v0.11.4 

func (x *ContainerConfig) GetEnv() map[string]string

func (*ContainerConfig) GetId added in v0.11.4 

func (x *ContainerConfig) GetId() string

func (*ContainerConfig) GetImage added in v0.11.4 

func (x *ContainerConfig) GetImage() string

func (*ContainerConfig) GetName added in v0.11.4 

func (x *ContainerConfig) GetName() string

func (*ContainerConfig) GetPullCommand added in v0.11.4 

func (x *ContainerConfig) GetPullCommand() string

func (*ContainerConfig) GetRemoveContainer added in v0.11.4 

func (x *ContainerConfig) GetRemoveContainer() bool

func (*ContainerConfig) GetRunCommand added in v0.11.4 

func (x *ContainerConfig) GetRunCommand() string

func (*ContainerConfig) GetStopCommand added in v0.11.4 

func (x *ContainerConfig) GetStopCommand() string

func (*ContainerConfig) GetTags added in v0.11.4 

func (x *ContainerConfig) GetTags() map[string]string

func (*ContainerConfig) GetWorkdir added in v0.11.4 

func (x *ContainerConfig) GetWorkdir() string

func (*ContainerConfig) ProtoMessage added in v0.11.4 

func (*ContainerConfig) ProtoMessage()

func (*ContainerConfig) ProtoReflect added in v0.11.4 

func (x *ContainerConfig) ProtoReflect() protoreflect.Message

func (*ContainerConfig) Reset added in v0.11.4 

func (x *ContainerConfig) Reset()

func (*ContainerConfig) String added in v0.11.4 

func (x *ContainerConfig) String() string

type Datastore 

type Datastore struct {
	Project         string `protobuf:"bytes,1,opt,name=Project,proto3" json:"Project,omitempty"`
	CredentialsFile string `protobuf:"bytes,2,opt,name=CredentialsFile,proto3" json:"CredentialsFile,omitempty"`
	// contains filtered or unexported fields
}

Datastore configures access to a Google Cloud Datastore database backend.

func (*Datastore) Descriptor deprecated added in v0.11.4 

func (*Datastore) Descriptor() ([]byte, []int)

Deprecated: Use Datastore.ProtoReflect.Descriptor instead.

func (*Datastore) GetCredentialsFile added in v0.11.4 

func (x *Datastore) GetCredentialsFile() string

func (*Datastore) GetProject added in v0.11.4 

func (x *Datastore) GetProject() string

func (*Datastore) ProtoMessage added in v0.11.4 

func (*Datastore) ProtoMessage()

func (*Datastore) ProtoReflect added in v0.11.4 

func (x *Datastore) ProtoReflect() protoreflect.Message

func (*Datastore) Reset added in v0.11.4 

func (x *Datastore) Reset()

func (*Datastore) String added in v0.11.4 

func (x *Datastore) String() string

type Duration 

type Duration durationpb.Duration

Duration is a wrapper type around durationpb.Duration to provide compatibility with pflag and text (un)marshaling.

func (*Duration) AsProto added in v0.11.4 

func (d *Duration) AsProto() *durationpb.Duration

AsProto returns the underlying *durationpb.Duration for use in Protobuf messages.

func (*Duration) MarshalText 

func (d *Duration) MarshalText() ([]byte, error)

MarshalText converts a duration to text.

func (*Duration) Set 

func (d *Duration) Set(raw string) error

Set sets the duration from the given string. Implements the pflag.Value interface.

func (*Duration) String 

func (d *Duration) String() string

String returns the string representation of the duration.

func (*Duration) Type 

func (d *Duration) Type() string

Type returns the name of this type. Implements the pflag.Value interface.

func (*Duration) UnmarshalText 

func (d *Duration) UnmarshalText(text []byte) error

UnmarshalText parses text into a duration value.

type DynamoDB 

type DynamoDB struct {
	TableBasename string     `protobuf:"bytes,1,opt,name=TableBasename,proto3" json:"TableBasename,omitempty"`
	AWSConfig     *AWSConfig `protobuf:"bytes,2,opt,name=AWSConfig,proto3" json:"AWSConfig,omitempty"`
	// contains filtered or unexported fields
}

DynamoDB describes the configuration for Amazon DynamoDB.

func (*DynamoDB) Descriptor deprecated added in v0.11.4 

func (*DynamoDB) Descriptor() ([]byte, []int)

Deprecated: Use DynamoDB.ProtoReflect.Descriptor instead.

func (*DynamoDB) GetAWSConfig added in v0.11.4 

func (x *DynamoDB) GetAWSConfig() *AWSConfig

func (*DynamoDB) GetTableBasename added in v0.11.4 

func (x *DynamoDB) GetTableBasename() string

func (*DynamoDB) ProtoMessage added in v0.11.4 

func (*DynamoDB) ProtoMessage()

func (*DynamoDB) ProtoReflect added in v0.11.4 

func (x *DynamoDB) ProtoReflect() protoreflect.Message

func (*DynamoDB) Reset added in v0.11.4 

func (x *DynamoDB) Reset()

func (*DynamoDB) String added in v0.11.4 

func (x *DynamoDB) String() string

type Elastic 

type Elastic struct {
	IndexPrefix  string `protobuf:"bytes,1,opt,name=IndexPrefix,proto3" json:"IndexPrefix,omitempty"`
	URL          string `protobuf:"bytes,2,opt,name=URL,proto3" json:"URL,omitempty"`
	Username     string `protobuf:"bytes,3,opt,name=Username,proto3" json:"Username,omitempty"`
	Password     string `protobuf:"bytes,4,opt,name=Password,proto3" json:"Password,omitempty"`
	CloudID      string `protobuf:"bytes,5,opt,name=CloudID,proto3" json:"CloudID,omitempty"`
	APIKey       string `protobuf:"bytes,6,opt,name=APIKey,proto3" json:"APIKey,omitempty"`
	ServiceToken string `protobuf:"bytes,7,opt,name=ServiceToken,proto3" json:"ServiceToken,omitempty"`
	// contains filtered or unexported fields
}

Elastic configures access to an Elasticsearch database.

func (*Elastic) Descriptor deprecated added in v0.11.4 

func (*Elastic) Descriptor() ([]byte, []int)

Deprecated: Use Elastic.ProtoReflect.Descriptor instead.

func (*Elastic) GetAPIKey added in v0.11.4 

func (x *Elastic) GetAPIKey() string

func (*Elastic) GetCloudID added in v0.11.4 

func (x *Elastic) GetCloudID() string

func (*Elastic) GetIndexPrefix added in v0.11.4 

func (x *Elastic) GetIndexPrefix() string

func (*Elastic) GetPassword added in v0.11.4 

func (x *Elastic) GetPassword() string

func (*Elastic) GetServiceToken added in v0.11.4 

func (x *Elastic) GetServiceToken() string

func (*Elastic) GetURL added in v0.11.4 

func (x *Elastic) GetURL() string

func (*Elastic) GetUsername added in v0.11.4 

func (x *Elastic) GetUsername() string

func (*Elastic) ProtoMessage added in v0.11.4 

func (*Elastic) ProtoMessage()

func (*Elastic) ProtoReflect added in v0.11.4 

func (x *Elastic) ProtoReflect() protoreflect.Message

func (*Elastic) Reset added in v0.11.4 

func (x *Elastic) Reset()

func (*Elastic) String added in v0.11.4 

func (x *Elastic) String() string

type FTPStorage 

type FTPStorage struct {
	Disabled bool           `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	Timeout  *TimeoutConfig `protobuf:"bytes,2,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	User     string         `protobuf:"bytes,3,opt,name=User,proto3" json:"User,omitempty"`
	Password string         `protobuf:"bytes,4,opt,name=Password,proto3" json:"Password,omitempty"`
	// contains filtered or unexported fields
}

FTPStorage configures the FTP storage backend.

func (*FTPStorage) Descriptor deprecated added in v0.11.4 

func (*FTPStorage) Descriptor() ([]byte, []int)

Deprecated: Use FTPStorage.ProtoReflect.Descriptor instead.

func (*FTPStorage) GetDisabled added in v0.11.4 

func (x *FTPStorage) GetDisabled() bool

func (*FTPStorage) GetPassword added in v0.11.4 

func (x *FTPStorage) GetPassword() string

func (*FTPStorage) GetTimeout added in v0.11.4 

func (x *FTPStorage) GetTimeout() *TimeoutConfig

func (*FTPStorage) GetUser added in v0.11.4 

func (x *FTPStorage) GetUser() string

func (*FTPStorage) ProtoMessage added in v0.11.4 

func (*FTPStorage) ProtoMessage()

func (*FTPStorage) ProtoReflect added in v0.11.4 

func (x *FTPStorage) ProtoReflect() protoreflect.Message

func (*FTPStorage) Reset added in v0.11.4 

func (x *FTPStorage) Reset()

func (*FTPStorage) String added in v0.11.4 

func (x *FTPStorage) String() string

func (*FTPStorage) Valid 

func (h *FTPStorage) Valid() bool

Valid validates the FTPStorage configuration.

type GCPBatch added in v0.11.7 

type GCPBatch struct {
	Location          string               `protobuf:"bytes,1,opt,name=Location,proto3" json:"Location,omitempty"`
	GoogleStorage     string               `protobuf:"bytes,2,opt,name=GoogleStorage,proto3" json:"GoogleStorage,omitempty"`
	Project           string               `protobuf:"bytes,3,opt,name=Project,proto3" json:"Project,omitempty"`
	DisableReconciler bool                 `protobuf:"varint,4,opt,name=DisableReconciler,proto3" json:"DisableReconciler,omitempty"`
	ReconcileRate     *durationpb.Duration `protobuf:"bytes,5,opt,name=ReconcileRate,proto3" json:"ReconcileRate,omitempty"`
	GCPBatch          *GCPBatch            `protobuf:"bytes,6,opt,name=GCPBatch,proto3" json:"GCPBatch,omitempty"`
	// contains filtered or unexported fields
}

GCPBatch describes the configuration for the GCP Batch compute backend.

func (*GCPBatch) Descriptor deprecated added in v0.11.8 

func (*GCPBatch) Descriptor() ([]byte, []int)

Deprecated: Use GCPBatch.ProtoReflect.Descriptor instead.

func (*GCPBatch) GetDisableReconciler added in v0.11.8 

func (x *GCPBatch) GetDisableReconciler() bool

func (*GCPBatch) GetGCPBatch added in v0.11.8 

func (x *GCPBatch) GetGCPBatch() *GCPBatch

func (*GCPBatch) GetGoogleStorage added in v0.11.8 

func (x *GCPBatch) GetGoogleStorage() string

func (*GCPBatch) GetLocation added in v0.11.8 

func (x *GCPBatch) GetLocation() string

func (*GCPBatch) GetProject added in v0.11.8 

func (x *GCPBatch) GetProject() string

func (*GCPBatch) GetReconcileRate added in v0.11.8 

func (x *GCPBatch) GetReconcileRate() *durationpb.Duration

func (*GCPBatch) ProtoMessage added in v0.11.8 

func (*GCPBatch) ProtoMessage()

func (*GCPBatch) ProtoReflect added in v0.11.8 

func (x *GCPBatch) ProtoReflect() protoreflect.Message

func (*GCPBatch) Reset added in v0.11.8 

func (x *GCPBatch) Reset()

func (*GCPBatch) String added in v0.11.8 

func (x *GCPBatch) String() string

type GenericS3Storage 

type GenericS3Storage struct {
	Disabled bool   `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	Endpoint string `protobuf:"bytes,2,opt,name=Endpoint,proto3" json:"Endpoint,omitempty"`
	Key      string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
	Secret   string `protobuf:"bytes,4,opt,name=Secret,proto3" json:"Secret,omitempty"`
	Region   string `protobuf:"bytes,5,opt,name=Region,proto3" json:"Region,omitempty"`
	Bucket   string `protobuf:"bytes,6,opt,name=Bucket,proto3" json:"Bucket,omitempty"`
	KmsKeyID string `protobuf:"bytes,7,opt,name=KmsKeyID,proto3" json:"KmsKeyID,omitempty"`
	// AWS Account ID, needed for S3 CSI Driver
	// https://github.com/awslabs/mountpoint-s3/blob/v1.20.0/doc/CONFIGURATION.md#data-encryption
	AccountID string `protobuf:"bytes,8,opt,name=AccountID,proto3" json:"AccountID,omitempty"`
	// contains filtered or unexported fields
}

GenericS3Storage describes the configuration for the Generic S3 storage backend.

func (*GenericS3Storage) Descriptor deprecated added in v0.11.4 

func (*GenericS3Storage) Descriptor() ([]byte, []int)

Deprecated: Use GenericS3Storage.ProtoReflect.Descriptor instead.

func (*GenericS3Storage) GetAccountID added in v0.11.4 

func (x *GenericS3Storage) GetAccountID() string

func (*GenericS3Storage) GetBucket added in v0.11.4 

func (x *GenericS3Storage) GetBucket() string

func (*GenericS3Storage) GetDisabled added in v0.11.4 

func (x *GenericS3Storage) GetDisabled() bool

func (*GenericS3Storage) GetEndpoint added in v0.11.4 

func (x *GenericS3Storage) GetEndpoint() string

func (*GenericS3Storage) GetKey added in v0.11.4 

func (x *GenericS3Storage) GetKey() string

func (*GenericS3Storage) GetKmsKeyID added in v0.11.4 

func (x *GenericS3Storage) GetKmsKeyID() string

func (*GenericS3Storage) GetRegion added in v0.11.4 

func (x *GenericS3Storage) GetRegion() string

func (*GenericS3Storage) GetSecret added in v0.11.4 

func (x *GenericS3Storage) GetSecret() string

func (*GenericS3Storage) ProtoMessage added in v0.11.4 

func (*GenericS3Storage) ProtoMessage()

func (*GenericS3Storage) ProtoReflect added in v0.11.4 

func (x *GenericS3Storage) ProtoReflect() protoreflect.Message

func (*GenericS3Storage) Reset added in v0.11.4 

func (x *GenericS3Storage) Reset()

func (*GenericS3Storage) String added in v0.11.4 

func (x *GenericS3Storage) String() string

func (*GenericS3Storage) Valid 

func (s *GenericS3Storage) Valid() bool

Valid validates the S3Storage configuration

type GoogleCloudStorage 

type GoogleCloudStorage struct {
	Disabled        bool   `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	CredentialsFile string `protobuf:"bytes,2,opt,name=CredentialsFile,proto3" json:"CredentialsFile,omitempty"`
	// contains filtered or unexported fields
}

GoogleCloudStorage describes configuration for the Google Cloud storage backend.

func (*GoogleCloudStorage) Descriptor deprecated added in v0.11.4 

func (*GoogleCloudStorage) Descriptor() ([]byte, []int)

Deprecated: Use GoogleCloudStorage.ProtoReflect.Descriptor instead.

func (*GoogleCloudStorage) GetCredentialsFile added in v0.11.4 

func (x *GoogleCloudStorage) GetCredentialsFile() string

func (*GoogleCloudStorage) GetDisabled added in v0.11.4 

func (x *GoogleCloudStorage) GetDisabled() bool

func (*GoogleCloudStorage) ProtoMessage added in v0.11.4 

func (*GoogleCloudStorage) ProtoMessage()

func (*GoogleCloudStorage) ProtoReflect added in v0.11.4 

func (x *GoogleCloudStorage) ProtoReflect() protoreflect.Message

func (*GoogleCloudStorage) Reset added in v0.11.4 

func (x *GoogleCloudStorage) Reset()

func (*GoogleCloudStorage) String added in v0.11.4 

func (x *GoogleCloudStorage) String() string

func (*GoogleCloudStorage) Valid 

func (g *GoogleCloudStorage) Valid() bool

Valid validates the Storage configuration.

type GridEngine added in v0.11.4 

type GridEngine struct {
	Template     string `protobuf:"bytes,1,opt,name=Template,proto3" json:"Template,omitempty"`
	TemplateFile string `protobuf:"bytes,2,opt,name=TemplateFile,proto3" json:"TemplateFile,omitempty"`
	// contains filtered or unexported fields
}

func (*GridEngine) Descriptor deprecated added in v0.11.4 

func (*GridEngine) Descriptor() ([]byte, []int)

Deprecated: Use GridEngine.ProtoReflect.Descriptor instead.

func (*GridEngine) GetTemplate added in v0.11.4 

func (x *GridEngine) GetTemplate() string

func (*GridEngine) GetTemplateFile added in v0.11.4 

func (x *GridEngine) GetTemplateFile() string

func (*GridEngine) ProtoMessage added in v0.11.4 

func (*GridEngine) ProtoMessage()

func (*GridEngine) ProtoReflect added in v0.11.4 

func (x *GridEngine) ProtoReflect() protoreflect.Message

func (*GridEngine) Reset added in v0.11.4 

func (x *GridEngine) Reset()

func (*GridEngine) String added in v0.11.4 

func (x *GridEngine) String() string

type HPCBackend 

type HPCBackend struct {
	DisableReconciler bool                 `protobuf:"varint,1,opt,name=DisableReconciler,proto3" json:"DisableReconciler,omitempty"`
	ReconcileRate     *durationpb.Duration `protobuf:"bytes,2,opt,name=ReconcileRate,proto3" json:"ReconcileRate,omitempty"`
	Template          string               `protobuf:"bytes,3,opt,name=Template,proto3" json:"Template,omitempty"`
	TemplateFile      string               `protobuf:"bytes,4,opt,name=TemplateFile,proto3" json:"TemplateFile,omitempty"`
	// contains filtered or unexported fields
}

HPCBackend describes the configuration for an HPC scheduler backend.

func (*HPCBackend) Descriptor deprecated added in v0.11.4 

func (*HPCBackend) Descriptor() ([]byte, []int)

Deprecated: Use HPCBackend.ProtoReflect.Descriptor instead.

func (*HPCBackend) GetDisableReconciler added in v0.11.4 

func (x *HPCBackend) GetDisableReconciler() bool

func (*HPCBackend) GetReconcileRate added in v0.11.4 

func (x *HPCBackend) GetReconcileRate() *durationpb.Duration

func (*HPCBackend) GetTemplate added in v0.11.4 

func (x *HPCBackend) GetTemplate() string

func (*HPCBackend) GetTemplateFile added in v0.11.4 

func (x *HPCBackend) GetTemplateFile() string

func (*HPCBackend) ProtoMessage added in v0.11.4 

func (*HPCBackend) ProtoMessage()

func (*HPCBackend) ProtoReflect added in v0.11.4 

func (x *HPCBackend) ProtoReflect() protoreflect.Message

func (*HPCBackend) Reset added in v0.11.4 

func (x *HPCBackend) Reset()

func (*HPCBackend) String added in v0.11.4 

func (x *HPCBackend) String() string

type HTTPStorage 

type HTTPStorage struct {
	Disabled bool           `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	Timeout  *TimeoutConfig `protobuf:"bytes,2,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// contains filtered or unexported fields
}

HTTPStorage configures the HTTP storage backend.

func (*HTTPStorage) Descriptor deprecated added in v0.11.4 

func (*HTTPStorage) Descriptor() ([]byte, []int)

Deprecated: Use HTTPStorage.ProtoReflect.Descriptor instead.

func (*HTTPStorage) GetDisabled added in v0.11.4 

func (x *HTTPStorage) GetDisabled() bool

func (*HTTPStorage) GetTimeout added in v0.11.4 

func (x *HTTPStorage) GetTimeout() *TimeoutConfig

func (*HTTPStorage) ProtoMessage added in v0.11.4 

func (*HTTPStorage) ProtoMessage()

func (*HTTPStorage) ProtoReflect added in v0.11.4 

func (x *HTTPStorage) ProtoReflect() protoreflect.Message

func (*HTTPStorage) Reset added in v0.11.4 

func (x *HTTPStorage) Reset()

func (*HTTPStorage) String added in v0.11.4 

func (x *HTTPStorage) String() string

func (*HTTPStorage) Valid 

func (h *HTTPStorage) Valid() bool

Valid validates the HTTPStorage configuration.

type Kafka 

type Kafka struct {
	Servers []string `protobuf:"bytes,1,rep,name=Servers,proto3" json:"Servers,omitempty"`
	Topic   string   `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	// contains filtered or unexported fields
}

Kafka configures access to a Kafka topic for task event reading/writing.

func (*Kafka) Descriptor deprecated added in v0.11.4 

func (*Kafka) Descriptor() ([]byte, []int)

Deprecated: Use Kafka.ProtoReflect.Descriptor instead.

func (*Kafka) GetServers added in v0.11.4 

func (x *Kafka) GetServers() []string

func (*Kafka) GetTopic added in v0.11.4 

func (x *Kafka) GetTopic() string

func (*Kafka) ProtoMessage added in v0.11.4 

func (*Kafka) ProtoMessage()

func (*Kafka) ProtoReflect added in v0.11.4 

func (x *Kafka) ProtoReflect() protoreflect.Message

func (*Kafka) Reset added in v0.11.4 

func (x *Kafka) Reset()

func (*Kafka) String added in v0.11.4 

func (x *Kafka) String() string

type Kubernetes 

type Kubernetes struct {
	Executor               string               `protobuf:"bytes,1,opt,name=Executor,proto3" json:"Executor,omitempty"`
	WorkerTemplate         string               `protobuf:"bytes,2,opt,name=WorkerTemplate,proto3" json:"WorkerTemplate,omitempty"`
	ExecutorTemplate       string               `protobuf:"bytes,3,opt,name=ExecutorTemplate,proto3" json:"ExecutorTemplate,omitempty"`
	PVTemplate             string               `protobuf:"bytes,4,opt,name=PVTemplate,proto3" json:"PVTemplate,omitempty"`
	PVCTemplate            string               `protobuf:"bytes,5,opt,name=PVCTemplate,proto3" json:"PVCTemplate,omitempty"`
	ConfigMapTemplate      string               `protobuf:"bytes,6,opt,name=ConfigMapTemplate,proto3" json:"ConfigMapTemplate,omitempty"`
	Namespace              string               `protobuf:"bytes,7,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	JobsNamespace          string               `protobuf:"bytes,8,opt,name=JobsNamespace,proto3" json:"JobsNamespace,omitempty"`
	ServiceAccount         string               `protobuf:"bytes,9,opt,name=ServiceAccount,proto3" json:"ServiceAccount,omitempty"`
	ServiceAccountTemplate string               `protobuf:"bytes,10,opt,name=ServiceAccountTemplate,proto3" json:"ServiceAccountTemplate,omitempty"`
	RoleTemplate           string               `protobuf:"bytes,11,opt,name=RoleTemplate,proto3" json:"RoleTemplate,omitempty"`
	RoleBindingTemplate    string               `protobuf:"bytes,12,opt,name=RoleBindingTemplate,proto3" json:"RoleBindingTemplate,omitempty"`
	DisableReconciler      bool                 `protobuf:"varint,13,opt,name=DisableReconciler,proto3" json:"DisableReconciler,omitempty"`
	ReconcileRate          *durationpb.Duration `protobuf:"bytes,14,opt,name=ReconcileRate,proto3" json:"ReconcileRate,omitempty"`
	DisableJobCleanup      bool                 `protobuf:"varint,15,opt,name=DisableJobCleanup,proto3" json:"DisableJobCleanup,omitempty"`
	// NodeSelector + Tolerations for scheduling jobs onto specific nodes
	// https://kubernetes.io/docs/tasks/configure-pod-container/assign-pods-nodes/#create-a-pod-that-gets-scheduled-to-your-chosen-node
	NodeSelector map[string]string `` /* 152-byte string literal not displayed */
	Tolerations  []*Toleration     `protobuf:"bytes,17,rep,name=Tolerations,proto3" json:"Tolerations,omitempty"`
	// Optional Kubernetes resource defaults and limits for tasks running on the Kubernetes backend.
	Resources *KubernetesResources `protobuf:"bytes,18,opt,name=Resources,proto3" json:"Resources,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes describes the configuration for the Kubernetes compute backend.

func (*Kubernetes) Descriptor deprecated added in v0.11.4 

func (*Kubernetes) Descriptor() ([]byte, []int)

Deprecated: Use Kubernetes.ProtoReflect.Descriptor instead.

func (*Kubernetes) GetConfigMapTemplate added in v0.11.4 

func (x *Kubernetes) GetConfigMapTemplate() string

func (*Kubernetes) GetDisableJobCleanup added in v0.11.4 

func (x *Kubernetes) GetDisableJobCleanup() bool

func (*Kubernetes) GetDisableReconciler added in v0.11.4 

func (x *Kubernetes) GetDisableReconciler() bool

func (*Kubernetes) GetExecutor added in v0.11.4 

func (x *Kubernetes) GetExecutor() string

func (*Kubernetes) GetExecutorTemplate added in v0.11.4 

func (x *Kubernetes) GetExecutorTemplate() string

func (*Kubernetes) GetJobsNamespace added in v0.11.4 

func (x *Kubernetes) GetJobsNamespace() string

func (*Kubernetes) GetNamespace added in v0.11.4 

func (x *Kubernetes) GetNamespace() string

func (*Kubernetes) GetNodeSelector added in v0.11.4 

func (x *Kubernetes) GetNodeSelector() map[string]string

func (*Kubernetes) GetPVCTemplate added in v0.11.4 

func (x *Kubernetes) GetPVCTemplate() string

func (*Kubernetes) GetPVTemplate added in v0.11.4 

func (x *Kubernetes) GetPVTemplate() string

func (*Kubernetes) GetReconcileRate added in v0.11.4 

func (x *Kubernetes) GetReconcileRate() *durationpb.Duration

func (*Kubernetes) GetResources added in v0.11.8 

func (x *Kubernetes) GetResources() *KubernetesResources

func (*Kubernetes) GetRoleBindingTemplate added in v0.11.8 

func (x *Kubernetes) GetRoleBindingTemplate() string

func (*Kubernetes) GetRoleTemplate added in v0.11.8 

func (x *Kubernetes) GetRoleTemplate() string

func (*Kubernetes) GetServiceAccount added in v0.11.4 

func (x *Kubernetes) GetServiceAccount() string

func (*Kubernetes) GetServiceAccountTemplate added in v0.11.8 

func (x *Kubernetes) GetServiceAccountTemplate() string

func (*Kubernetes) GetTolerations added in v0.11.4 

func (x *Kubernetes) GetTolerations() []*Toleration

func (*Kubernetes) GetWorkerTemplate added in v0.11.4 

func (x *Kubernetes) GetWorkerTemplate() string

func (*Kubernetes) ProtoMessage added in v0.11.4 

func (*Kubernetes) ProtoMessage()

func (*Kubernetes) ProtoReflect added in v0.11.4 

func (x *Kubernetes) ProtoReflect() protoreflect.Message

func (*Kubernetes) Reset added in v0.11.4 

func (x *Kubernetes) Reset()

func (*Kubernetes) String added in v0.11.4 

func (x *Kubernetes) String() string

type KubernetesResources added in v0.11.8 

type KubernetesResources struct {
	Defaults *ResourceDefaults `protobuf:"bytes,1,opt,name=Defaults,proto3" json:"Defaults,omitempty"`
	Limits   *ResourceLimits   `protobuf:"bytes,2,opt,name=Limits,proto3" json:"Limits,omitempty"`
	// contains filtered or unexported fields
}

KubernetesResources describes default and maximum resource limits for Kubernetes tasks.

func (*KubernetesResources) Descriptor deprecated added in v0.11.8 

func (*KubernetesResources) Descriptor() ([]byte, []int)

Deprecated: Use KubernetesResources.ProtoReflect.Descriptor instead.

func (*KubernetesResources) GetDefaults added in v0.11.8 

func (x *KubernetesResources) GetDefaults() *ResourceDefaults

func (*KubernetesResources) GetLimits added in v0.11.8 

func (x *KubernetesResources) GetLimits() *ResourceLimits

func (*KubernetesResources) ProtoMessage added in v0.11.8 

func (*KubernetesResources) ProtoMessage()

func (*KubernetesResources) ProtoReflect added in v0.11.8 

func (x *KubernetesResources) ProtoReflect() protoreflect.Message

func (*KubernetesResources) Reset added in v0.11.8 

func (x *KubernetesResources) Reset()

func (*KubernetesResources) String added in v0.11.8 

func (x *KubernetesResources) String() string

type LocalStorage 

type LocalStorage struct {
	Disabled    bool     `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	AllowedDirs []string `protobuf:"bytes,2,rep,name=AllowedDirs,proto3" json:"AllowedDirs,omitempty"`
	// contains filtered or unexported fields
}

LocalStorage describes the directories Funnel can read from and write to.

func (*LocalStorage) Descriptor deprecated added in v0.11.4 

func (*LocalStorage) Descriptor() ([]byte, []int)

Deprecated: Use LocalStorage.ProtoReflect.Descriptor instead.

func (*LocalStorage) GetAllowedDirs added in v0.11.4 

func (x *LocalStorage) GetAllowedDirs() []string

func (*LocalStorage) GetDisabled added in v0.11.4 

func (x *LocalStorage) GetDisabled() bool

func (*LocalStorage) ProtoMessage added in v0.11.4 

func (*LocalStorage) ProtoMessage()

func (*LocalStorage) ProtoReflect added in v0.11.4 

func (x *LocalStorage) ProtoReflect() protoreflect.Message

func (*LocalStorage) Reset added in v0.11.4 

func (x *LocalStorage) Reset()

func (*LocalStorage) String added in v0.11.4 

func (x *LocalStorage) String() string

func (*LocalStorage) Valid 

func (l *LocalStorage) Valid() bool

Valid validates the LocalStorage configuration

type MongoDB 

type MongoDB struct {
	Addrs    []string       `protobuf:"bytes,1,rep,name=Addrs,proto3" json:"Addrs,omitempty"`
	Database string         `protobuf:"bytes,2,opt,name=Database,proto3" json:"Database,omitempty"`
	Timeout  *TimeoutConfig `protobuf:"bytes,3,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	Username string         `protobuf:"bytes,4,opt,name=Username,proto3" json:"Username,omitempty"`
	Password string         `protobuf:"bytes,5,opt,name=Password,proto3" json:"Password,omitempty"`
	// contains filtered or unexported fields
}

MongoDB configures access to a MongoDB database.

func (*MongoDB) Descriptor deprecated added in v0.11.4 

func (*MongoDB) Descriptor() ([]byte, []int)

Deprecated: Use MongoDB.ProtoReflect.Descriptor instead.

func (*MongoDB) GetAddrs added in v0.11.4 

func (x *MongoDB) GetAddrs() []string

func (*MongoDB) GetDatabase added in v0.11.4 

func (x *MongoDB) GetDatabase() string

func (*MongoDB) GetPassword added in v0.11.4 

func (x *MongoDB) GetPassword() string

func (*MongoDB) GetTimeout added in v0.11.4 

func (x *MongoDB) GetTimeout() *TimeoutConfig

func (*MongoDB) GetUsername added in v0.11.4 

func (x *MongoDB) GetUsername() string

func (*MongoDB) ProtoMessage added in v0.11.4 

func (*MongoDB) ProtoMessage()

func (*MongoDB) ProtoReflect added in v0.11.4 

func (x *MongoDB) ProtoReflect() protoreflect.Message

func (*MongoDB) Reset added in v0.11.4 

func (x *MongoDB) Reset()

func (*MongoDB) String added in v0.11.4 

func (x *MongoDB) String() string

type Node 

type Node struct {
	ID         string               `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Resources  *Resources           `protobuf:"bytes,2,opt,name=Resources,proto3" json:"Resources,omitempty"`
	Timeout    *TimeoutConfig       `protobuf:"bytes,3,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	UpdateRate *durationpb.Duration `protobuf:"bytes,4,opt,name=UpdateRate,proto3" json:"UpdateRate,omitempty"`
	Metadata   map[string]string    `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

Node contains the configuration for a node.

func (*Node) Descriptor deprecated added in v0.11.4 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetID added in v0.11.4 

func (x *Node) GetID() string

func (*Node) GetMetadata added in v0.11.4 

func (x *Node) GetMetadata() map[string]string

func (*Node) GetResources added in v0.11.4 

func (x *Node) GetResources() *Resources

func (*Node) GetTimeout added in v0.11.4 

func (x *Node) GetTimeout() *TimeoutConfig

func (*Node) GetUpdateRate added in v0.11.4 

func (x *Node) GetUpdateRate() *durationpb.Duration

func (*Node) ProtoMessage added in v0.11.4 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect added in v0.11.4 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset added in v0.11.4 

func (x *Node) Reset()

func (*Node) String added in v0.11.4 

func (x *Node) String() string

type OidcAuth 

type OidcAuth struct {
	ServiceConfigURL string   `protobuf:"bytes,1,opt,name=ServiceConfigURL,proto3" json:"ServiceConfigURL,omitempty"`
	ClientId         string   `protobuf:"bytes,2,opt,name=ClientId,proto3" json:"ClientId,omitempty"`
	ClientSecret     string   `protobuf:"bytes,3,opt,name=ClientSecret,proto3" json:"ClientSecret,omitempty"`
	RedirectURL      string   `protobuf:"bytes,4,opt,name=RedirectURL,proto3" json:"RedirectURL,omitempty"`
	RequireScope     string   `protobuf:"bytes,5,opt,name=RequireScope,proto3" json:"RequireScope,omitempty"`
	RequireAudience  string   `protobuf:"bytes,6,opt,name=RequireAudience,proto3" json:"RequireAudience,omitempty"`
	Admins           []string `protobuf:"bytes,7,rep,name=Admins,proto3" json:"Admins,omitempty"`
	// contains filtered or unexported fields
}

OidcAuth describes OpenID Connect authentication configuration.

func (*OidcAuth) Descriptor deprecated added in v0.11.4 

func (*OidcAuth) Descriptor() ([]byte, []int)

Deprecated: Use OidcAuth.ProtoReflect.Descriptor instead.

func (*OidcAuth) GetAdmins added in v0.11.4 

func (x *OidcAuth) GetAdmins() []string

func (*OidcAuth) GetClientId added in v0.11.4 

func (x *OidcAuth) GetClientId() string

func (*OidcAuth) GetClientSecret added in v0.11.4 

func (x *OidcAuth) GetClientSecret() string

func (*OidcAuth) GetRedirectURL added in v0.11.4 

func (x *OidcAuth) GetRedirectURL() string

func (*OidcAuth) GetRequireAudience added in v0.11.4 

func (x *OidcAuth) GetRequireAudience() string

func (*OidcAuth) GetRequireScope added in v0.11.4 

func (x *OidcAuth) GetRequireScope() string

func (*OidcAuth) GetServiceConfigURL added in v0.11.4 

func (x *OidcAuth) GetServiceConfigURL() string

func (*OidcAuth) ProtoMessage added in v0.11.4 

func (*OidcAuth) ProtoMessage()

func (*OidcAuth) ProtoReflect added in v0.11.4 

func (x *OidcAuth) ProtoReflect() protoreflect.Message

func (*OidcAuth) Reset added in v0.11.4 

func (x *OidcAuth) Reset()

func (*OidcAuth) String added in v0.11.4 

func (x *OidcAuth) String() string

type Plugins added in v0.11.4 

type Plugins struct {
	Path   string            `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Params map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

This config matches the funnel plugins repo protobuf

func (*Plugins) Descriptor deprecated added in v0.11.4 

func (*Plugins) Descriptor() ([]byte, []int)

Deprecated: Use Plugins.ProtoReflect.Descriptor instead.

func (*Plugins) GetParams added in v0.11.4 

func (x *Plugins) GetParams() map[string]string

func (*Plugins) GetPath added in v0.11.4 

func (x *Plugins) GetPath() string

func (*Plugins) ProtoMessage added in v0.11.4 

func (*Plugins) ProtoMessage()

func (*Plugins) ProtoReflect added in v0.11.4 

func (x *Plugins) ProtoReflect() protoreflect.Message

func (*Plugins) Reset added in v0.11.4 

func (x *Plugins) Reset()

func (*Plugins) String added in v0.11.4 

func (x *Plugins) String() string

type Postgres added in v0.11.8 

type Postgres struct {
	Host          string         `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Database      string         `protobuf:"bytes,2,opt,name=Database,proto3" json:"Database,omitempty"`
	User          string         `protobuf:"bytes,3,opt,name=User,proto3" json:"User,omitempty"`
	Password      string         `protobuf:"bytes,4,opt,name=Password,proto3" json:"Password,omitempty"`
	AdminUser     string         `protobuf:"bytes,5,opt,name=AdminUser,proto3" json:"AdminUser,omitempty"`
	AdminPassword string         `protobuf:"bytes,6,opt,name=AdminPassword,proto3" json:"AdminPassword,omitempty"`
	Timeout       *TimeoutConfig `protobuf:"bytes,7,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// contains filtered or unexported fields
}

Postgres configures access to a PostgreSQL database.

func (*Postgres) Descriptor deprecated added in v0.11.8 

func (*Postgres) Descriptor() ([]byte, []int)

Deprecated: Use Postgres.ProtoReflect.Descriptor instead.

func (*Postgres) GetAdminPassword added in v0.11.8 

func (x *Postgres) GetAdminPassword() string

func (*Postgres) GetAdminUser added in v0.11.8 

func (x *Postgres) GetAdminUser() string

func (*Postgres) GetDatabase added in v0.11.8 

func (x *Postgres) GetDatabase() string

func (*Postgres) GetHost added in v0.11.8 

func (x *Postgres) GetHost() string

func (*Postgres) GetPassword added in v0.11.8 

func (x *Postgres) GetPassword() string

func (*Postgres) GetTimeout added in v0.11.8 

func (x *Postgres) GetTimeout() *TimeoutConfig

func (*Postgres) GetUser added in v0.11.8 

func (x *Postgres) GetUser() string

func (*Postgres) ProtoMessage added in v0.11.8 

func (*Postgres) ProtoMessage()

func (*Postgres) ProtoReflect added in v0.11.8 

func (x *Postgres) ProtoReflect() protoreflect.Message

func (*Postgres) Reset added in v0.11.8 

func (x *Postgres) Reset()

func (*Postgres) String added in v0.11.8 

func (x *Postgres) String() string

type PubSub 

type PubSub struct {
	Topic           string `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Project         string `protobuf:"bytes,2,opt,name=Project,proto3" json:"Project,omitempty"`
	CredentialsFile string `protobuf:"bytes,3,opt,name=CredentialsFile,proto3" json:"CredentialsFile,omitempty"`
	// contains filtered or unexported fields
}

PubSub configures access to Google Cloud Pub/Sub.

func (*PubSub) Descriptor deprecated added in v0.11.4 

func (*PubSub) Descriptor() ([]byte, []int)

Deprecated: Use PubSub.ProtoReflect.Descriptor instead.

func (*PubSub) GetCredentialsFile added in v0.11.4 

func (x *PubSub) GetCredentialsFile() string

func (*PubSub) GetProject added in v0.11.4 

func (x *PubSub) GetProject() string

func (*PubSub) GetTopic added in v0.11.4 

func (x *PubSub) GetTopic() string

func (*PubSub) ProtoMessage added in v0.11.4 

func (*PubSub) ProtoMessage()

func (*PubSub) ProtoReflect added in v0.11.4 

func (x *PubSub) ProtoReflect() protoreflect.Message

func (*PubSub) Reset added in v0.11.4 

func (x *PubSub) Reset()

func (*PubSub) String added in v0.11.4 

func (x *PubSub) String() string

type RPCClient 

type RPCClient struct {
	Credential    *BasicCredential `protobuf:"bytes,1,opt,name=Credential,proto3" json:"Credential,omitempty"`
	ServerAddress string           `protobuf:"bytes,2,opt,name=ServerAddress,proto3" json:"ServerAddress,omitempty"`
	Timeout       *TimeoutConfig   `protobuf:"bytes,3,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	MaxRetries    uint32           `protobuf:"varint,4,opt,name=MaxRetries,proto3" json:"MaxRetries,omitempty"`
	// contains filtered or unexported fields
}

RPCClient describes configuration for gRPC clients.

func (*RPCClient) Descriptor deprecated added in v0.11.4 

func (*RPCClient) Descriptor() ([]byte, []int)

Deprecated: Use RPCClient.ProtoReflect.Descriptor instead.

func (*RPCClient) GetCredential added in v0.11.4 

func (x *RPCClient) GetCredential() *BasicCredential

func (*RPCClient) GetMaxRetries added in v0.11.4 

func (x *RPCClient) GetMaxRetries() uint32

func (*RPCClient) GetServerAddress added in v0.11.4 

func (x *RPCClient) GetServerAddress() string

func (*RPCClient) GetTimeout added in v0.11.4 

func (x *RPCClient) GetTimeout() *TimeoutConfig

func (*RPCClient) ProtoMessage added in v0.11.4 

func (*RPCClient) ProtoMessage()

func (*RPCClient) ProtoReflect added in v0.11.4 

func (x *RPCClient) ProtoReflect() protoreflect.Message

func (*RPCClient) Reset added in v0.11.4 

func (x *RPCClient) Reset()

func (*RPCClient) String added in v0.11.4 

func (x *RPCClient) String() string

type ResourceDefaults added in v0.11.8 

type ResourceDefaults struct {
	Cpus   string `protobuf:"bytes,1,opt,name=Cpus,proto3" json:"Cpus,omitempty"`
	RamGb  string `protobuf:"bytes,2,opt,name=RamGb,proto3" json:"RamGb,omitempty"`
	DiskGb string `protobuf:"bytes,3,opt,name=DiskGb,proto3" json:"DiskGb,omitempty"`
	// contains filtered or unexported fields
}

ResourceDefaults describes default and maximum resource limits for tasks.

func (*ResourceDefaults) Descriptor deprecated added in v0.11.8 

func (*ResourceDefaults) Descriptor() ([]byte, []int)

Deprecated: Use ResourceDefaults.ProtoReflect.Descriptor instead.

func (*ResourceDefaults) GetCpus added in v0.11.8 

func (x *ResourceDefaults) GetCpus() string

func (*ResourceDefaults) GetDiskGb added in v0.11.8 

func (x *ResourceDefaults) GetDiskGb() string

func (*ResourceDefaults) GetRamGb added in v0.11.8 

func (x *ResourceDefaults) GetRamGb() string

func (*ResourceDefaults) ProtoMessage added in v0.11.8 

func (*ResourceDefaults) ProtoMessage()

func (*ResourceDefaults) ProtoReflect added in v0.11.8 

func (x *ResourceDefaults) ProtoReflect() protoreflect.Message

func (*ResourceDefaults) Reset added in v0.11.8 

func (x *ResourceDefaults) Reset()

func (*ResourceDefaults) String added in v0.11.8 

func (x *ResourceDefaults) String() string

type ResourceLimits added in v0.11.8 

type ResourceLimits struct {
	Cpus   string `protobuf:"bytes,1,opt,name=Cpus,proto3" json:"Cpus,omitempty"`
	RamGb  string `protobuf:"bytes,2,opt,name=RamGb,proto3" json:"RamGb,omitempty"`
	DiskGb string `protobuf:"bytes,3,opt,name=DiskGb,proto3" json:"DiskGb,omitempty"`
	// contains filtered or unexported fields
}

ResourceLimits describes maximum resource limits for tasks.

func (*ResourceLimits) Descriptor deprecated added in v0.11.8 

func (*ResourceLimits) Descriptor() ([]byte, []int)

Deprecated: Use ResourceLimits.ProtoReflect.Descriptor instead.

func (*ResourceLimits) GetCpus added in v0.11.8 

func (x *ResourceLimits) GetCpus() string

func (*ResourceLimits) GetDiskGb added in v0.11.8 

func (x *ResourceLimits) GetDiskGb() string

func (*ResourceLimits) GetRamGb added in v0.11.8 

func (x *ResourceLimits) GetRamGb() string

func (*ResourceLimits) ProtoMessage added in v0.11.8 

func (*ResourceLimits) ProtoMessage()

func (*ResourceLimits) ProtoReflect added in v0.11.8 

func (x *ResourceLimits) ProtoReflect() protoreflect.Message

func (*ResourceLimits) Reset added in v0.11.8 

func (x *ResourceLimits) Reset()

func (*ResourceLimits) String added in v0.11.8 

func (x *ResourceLimits) String() string

type Resources added in v0.1.2 

type Resources struct {
	Cpus   float64 `protobuf:"fixed64,1,opt,name=Cpus,proto3" json:"Cpus,omitempty"`
	RamGb  float64 `protobuf:"fixed64,2,opt,name=RamGb,proto3" json:"RamGb,omitempty"`
	DiskGb float64 `protobuf:"fixed64,3,opt,name=DiskGb,proto3" json:"DiskGb,omitempty"`
	// contains filtered or unexported fields
}

Resources describes the CPU, RAM, and disk resources required by a task.

func (*Resources) Descriptor deprecated added in v0.11.4 

func (*Resources) Descriptor() ([]byte, []int)

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpus added in v0.11.4 

func (x *Resources) GetCpus() float64

func (*Resources) GetDiskGb added in v0.11.4 

func (x *Resources) GetDiskGb() float64

func (*Resources) GetRamGb added in v0.11.4 

func (x *Resources) GetRamGb() float64

func (*Resources) ProtoMessage added in v0.11.4 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect added in v0.11.4 

func (x *Resources) ProtoReflect() protoreflect.Message

func (*Resources) Reset added in v0.11.4 

func (x *Resources) Reset()

func (*Resources) String added in v0.11.4 

func (x *Resources) String() string

type SSE added in v0.11.4 

type SSE struct {
	CustomerKeyFile string `protobuf:"bytes,1,opt,name=CustomerKeyFile,proto3" json:"CustomerKeyFile,omitempty"`
	KMSKey          string `protobuf:"bytes,2,opt,name=KMSKey,proto3" json:"KMSKey,omitempty"`
	// contains filtered or unexported fields
}

func (*SSE) Descriptor deprecated added in v0.11.4 

func (*SSE) Descriptor() ([]byte, []int)

Deprecated: Use SSE.ProtoReflect.Descriptor instead.

func (*SSE) GetCustomerKeyFile added in v0.11.4 

func (x *SSE) GetCustomerKeyFile() string

func (*SSE) GetKMSKey added in v0.11.4 

func (x *SSE) GetKMSKey() string

func (*SSE) ProtoMessage added in v0.11.4 

func (*SSE) ProtoMessage()

func (*SSE) ProtoReflect added in v0.11.4 

func (x *SSE) ProtoReflect() protoreflect.Message

func (*SSE) Reset added in v0.11.4 

func (x *SSE) Reset()

func (*SSE) String added in v0.11.4 

func (x *SSE) String() string

type Scheduler 

type Scheduler struct {
	ScheduleRate    *durationpb.Duration `protobuf:"bytes,1,opt,name=ScheduleRate,proto3" json:"ScheduleRate,omitempty"`
	ScheduleChunk   int32                `protobuf:"varint,2,opt,name=ScheduleChunk,proto3" json:"ScheduleChunk,omitempty"`
	NodePingTimeout *TimeoutConfig       `protobuf:"bytes,3,opt,name=NodePingTimeout,proto3" json:"NodePingTimeout,omitempty"`
	NodeInitTimeout *TimeoutConfig       `protobuf:"bytes,4,opt,name=NodeInitTimeout,proto3" json:"NodeInitTimeout,omitempty"`
	NodeDeadTimeout *TimeoutConfig       `protobuf:"bytes,5,opt,name=NodeDeadTimeout,proto3" json:"NodeDeadTimeout,omitempty"`
	// contains filtered or unexported fields
}

Scheduler contains Funnel's basic scheduler configuration.

func (*Scheduler) Descriptor deprecated added in v0.11.4 

func (*Scheduler) Descriptor() ([]byte, []int)

Deprecated: Use Scheduler.ProtoReflect.Descriptor instead.

func (*Scheduler) GetNodeDeadTimeout added in v0.11.4 

func (x *Scheduler) GetNodeDeadTimeout() *TimeoutConfig

func (*Scheduler) GetNodeInitTimeout added in v0.11.4 

func (x *Scheduler) GetNodeInitTimeout() *TimeoutConfig

func (*Scheduler) GetNodePingTimeout added in v0.11.4 

func (x *Scheduler) GetNodePingTimeout() *TimeoutConfig

func (*Scheduler) GetScheduleChunk added in v0.11.4 

func (x *Scheduler) GetScheduleChunk() int32

func (*Scheduler) GetScheduleRate added in v0.11.4 

func (x *Scheduler) GetScheduleRate() *durationpb.Duration

func (*Scheduler) ProtoMessage added in v0.11.4 

func (*Scheduler) ProtoMessage()

func (*Scheduler) ProtoReflect added in v0.11.4 

func (x *Scheduler) ProtoReflect() protoreflect.Message

func (*Scheduler) Reset added in v0.11.4 

func (x *Scheduler) Reset()

func (*Scheduler) String added in v0.11.4 

func (x *Scheduler) String() string

type Server 

type Server struct {
	ServiceName      string             `protobuf:"bytes,1,opt,name=ServiceName,proto3" json:"ServiceName,omitempty"`
	HostName         string             `protobuf:"bytes,2,opt,name=HostName,proto3" json:"HostName,omitempty"`
	HTTPPort         string             `protobuf:"bytes,3,opt,name=HTTPPort,proto3" json:"HTTPPort,omitempty"`
	RPCPort          string             `protobuf:"bytes,4,opt,name=RPCPort,proto3" json:"RPCPort,omitempty"`
	BasicAuth        []*BasicCredential `protobuf:"bytes,5,rep,name=BasicAuth,proto3" json:"BasicAuth,omitempty"`
	OidcAuth         *OidcAuth          `protobuf:"bytes,6,opt,name=OidcAuth,proto3" json:"OidcAuth,omitempty"`
	DisableHTTPCache bool               `protobuf:"varint,7,opt,name=DisableHTTPCache,proto3" json:"DisableHTTPCache,omitempty"`
	TaskAccess       string             `protobuf:"bytes,8,opt,name=TaskAccess,proto3" json:"TaskAccess,omitempty"`
	// contains filtered or unexported fields
}

Server describes configuration for the server.

func (*Server) Descriptor deprecated added in v0.11.4 

func (*Server) Descriptor() ([]byte, []int)

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetBasicAuth added in v0.11.4 

func (x *Server) GetBasicAuth() []*BasicCredential

func (*Server) GetDisableHTTPCache added in v0.11.4 

func (x *Server) GetDisableHTTPCache() bool

func (*Server) GetHTTPPort added in v0.11.4 

func (x *Server) GetHTTPPort() string

func (*Server) GetHostName added in v0.11.4 

func (x *Server) GetHostName() string

func (*Server) GetOidcAuth added in v0.11.4 

func (x *Server) GetOidcAuth() *OidcAuth

func (*Server) GetRPCPort added in v0.11.4 

func (x *Server) GetRPCPort() string

func (*Server) GetServiceName added in v0.11.4 

func (x *Server) GetServiceName() string

func (*Server) GetTaskAccess added in v0.11.4 

func (x *Server) GetTaskAccess() string

func (*Server) HTTPAddress 

func (c *Server) HTTPAddress() string

HTTPAddress returns the HTTP address based on HostName and HTTPPort

func (*Server) ProtoMessage added in v0.11.4 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect added in v0.11.4 

func (x *Server) ProtoReflect() protoreflect.Message

func (*Server) RPCAddress 

func (c *Server) RPCAddress() string

RPCAddress returns the RPC address based on HostName and RPCPort

func (*Server) Reset added in v0.11.4 

func (x *Server) Reset()

func (*Server) String added in v0.11.4 

func (x *Server) String() string

type SwiftStorage 

type SwiftStorage struct {
	Disabled       bool   `protobuf:"varint,1,opt,name=Disabled,proto3" json:"Disabled,omitempty"`
	UserName       string `protobuf:"bytes,2,opt,name=UserName,proto3" json:"UserName,omitempty"`
	Password       string `protobuf:"bytes,3,opt,name=Password,proto3" json:"Password,omitempty"`
	AuthURL        string `protobuf:"bytes,4,opt,name=AuthURL,proto3" json:"AuthURL,omitempty"`
	TenantName     string `protobuf:"bytes,5,opt,name=TenantName,proto3" json:"TenantName,omitempty"`
	TenantID       string `protobuf:"bytes,6,opt,name=TenantID,proto3" json:"TenantID,omitempty"`
	RegionName     string `protobuf:"bytes,7,opt,name=RegionName,proto3" json:"RegionName,omitempty"`
	ChunkSizeBytes int64  `protobuf:"varint,8,opt,name=ChunkSizeBytes,proto3" json:"ChunkSizeBytes,omitempty"`
	MaxRetries     int32  `protobuf:"varint,9,opt,name=MaxRetries,proto3" json:"MaxRetries,omitempty"`
	// contains filtered or unexported fields
}

SwiftStorage configures the OpenStack Swift object storage backend.

func (*SwiftStorage) Descriptor deprecated added in v0.11.4 

func (*SwiftStorage) Descriptor() ([]byte, []int)

Deprecated: Use SwiftStorage.ProtoReflect.Descriptor instead.

func (*SwiftStorage) GetAuthURL added in v0.11.4 

func (x *SwiftStorage) GetAuthURL() string

func (*SwiftStorage) GetChunkSizeBytes added in v0.11.4 

func (x *SwiftStorage) GetChunkSizeBytes() int64

func (*SwiftStorage) GetDisabled added in v0.11.4 

func (x *SwiftStorage) GetDisabled() bool

func (*SwiftStorage) GetMaxRetries added in v0.11.4 

func (x *SwiftStorage) GetMaxRetries() int32

func (*SwiftStorage) GetPassword added in v0.11.4 

func (x *SwiftStorage) GetPassword() string

func (*SwiftStorage) GetRegionName added in v0.11.4 

func (x *SwiftStorage) GetRegionName() string

func (*SwiftStorage) GetTenantID added in v0.11.4 

func (x *SwiftStorage) GetTenantID() string

func (*SwiftStorage) GetTenantName added in v0.11.4 

func (x *SwiftStorage) GetTenantName() string

func (*SwiftStorage) GetUserName added in v0.11.4 

func (x *SwiftStorage) GetUserName() string

func (*SwiftStorage) ProtoMessage added in v0.11.4 

func (*SwiftStorage) ProtoMessage()

func (*SwiftStorage) ProtoReflect added in v0.11.4 

func (x *SwiftStorage) ProtoReflect() protoreflect.Message

func (*SwiftStorage) Reset added in v0.11.4 

func (x *SwiftStorage) Reset()

func (*SwiftStorage) String added in v0.11.4 

func (x *SwiftStorage) String() string

func (*SwiftStorage) Valid 

func (s *SwiftStorage) Valid() bool

Valid validates the SwiftStorage configuration.

type TimeoutConfig added in v0.11.4 

type TimeoutConfig struct {

	// Types that are valid to be assigned to TimeoutOption:
	//
	//	*TimeoutConfig_Duration
	//	*TimeoutConfig_Disabled
	TimeoutOption isTimeoutConfig_TimeoutOption `protobuf_oneof:"timeout_option"`
	// contains filtered or unexported fields
}

func (*TimeoutConfig) Descriptor deprecated added in v0.11.4 

func (*TimeoutConfig) Descriptor() ([]byte, []int)

Deprecated: Use TimeoutConfig.ProtoReflect.Descriptor instead.

func (*TimeoutConfig) GetDisabled added in v0.11.4 

func (x *TimeoutConfig) GetDisabled() bool

func (*TimeoutConfig) GetDuration added in v0.11.4 

func (x *TimeoutConfig) GetDuration() *durationpb.Duration

func (*TimeoutConfig) GetTimeoutOption added in v0.11.4 

func (x *TimeoutConfig) GetTimeoutOption() isTimeoutConfig_TimeoutOption

func (*TimeoutConfig) ProtoMessage added in v0.11.4 

func (*TimeoutConfig) ProtoMessage()

func (*TimeoutConfig) ProtoReflect added in v0.11.4 

func (x *TimeoutConfig) ProtoReflect() protoreflect.Message

func (*TimeoutConfig) Reset added in v0.11.4 

func (x *TimeoutConfig) Reset()

func (*TimeoutConfig) String added in v0.11.4 

func (x *TimeoutConfig) String() string

type TimeoutConfig_Disabled added in v0.11.4 

type TimeoutConfig_Disabled struct {
	Disabled bool `protobuf:"varint,2,opt,name=disabled,proto3,oneof"` // Represents an infinite or disabled timeout
}

type TimeoutConfig_Duration added in v0.11.4 

type TimeoutConfig_Duration struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3,oneof"`
}

type Toleration added in v0.11.4 

type Toleration struct {
	Key               string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Operator          string `protobuf:"bytes,2,opt,name=Operator,proto3" json:"Operator,omitempty"`                          // "Equal" or "Exists"
	Value             string `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"`                                // Required when operator is "Equal"
	Effect            string `protobuf:"bytes,4,opt,name=Effect,proto3" json:"Effect,omitempty"`                              // "NoSchedule", "PreferNoSchedule", or "NoExecute"
	TolerationSeconds *int64 `protobuf:"varint,5,opt,name=TolerationSeconds,proto3,oneof" json:"TolerationSeconds,omitempty"` // Only used with "NoExecute" effect
	// contains filtered or unexported fields
}

Kubernetes toleration https://kubernetes.io/docs/concepts/scheduling-eviction/taint-and-toleration/

func (*Toleration) Descriptor deprecated added in v0.11.4 

func (*Toleration) Descriptor() ([]byte, []int)

Deprecated: Use Toleration.ProtoReflect.Descriptor instead.

func (*Toleration) GetEffect added in v0.11.4 

func (x *Toleration) GetEffect() string

func (*Toleration) GetKey added in v0.11.4 

func (x *Toleration) GetKey() string

func (*Toleration) GetOperator added in v0.11.4 

func (x *Toleration) GetOperator() string

func (*Toleration) GetTolerationSeconds added in v0.11.4 

func (x *Toleration) GetTolerationSeconds() int64

func (*Toleration) GetValue added in v0.11.4 

func (x *Toleration) GetValue() string

func (*Toleration) ProtoMessage added in v0.11.4 

func (*Toleration) ProtoMessage()

func (*Toleration) ProtoReflect added in v0.11.4 

func (x *Toleration) ProtoReflect() protoreflect.Message

func (*Toleration) Reset added in v0.11.4 

func (x *Toleration) Reset()

func (*Toleration) String added in v0.11.4 

func (x *Toleration) String() string

type Worker 

type Worker struct {
	WorkDir              string               `protobuf:"bytes,1,opt,name=WorkDir,proto3" json:"WorkDir,omitempty"`
	ScratchPath          string               `protobuf:"bytes,2,opt,name=ScratchPath,proto3" json:"ScratchPath,omitempty"`
	PollingRate          *durationpb.Duration `protobuf:"bytes,3,opt,name=PollingRate,proto3" json:"PollingRate,omitempty"`
	LogUpdateRate        *durationpb.Duration `protobuf:"bytes,4,opt,name=LogUpdateRate,proto3" json:"LogUpdateRate,omitempty"`
	LogTailSize          int64                `protobuf:"varint,5,opt,name=LogTailSize,proto3" json:"LogTailSize,omitempty"`
	LeaveWorkDir         bool                 `protobuf:"varint,6,opt,name=LeaveWorkDir,proto3" json:"LeaveWorkDir,omitempty"`
	MaxParallelTransfers int32                `protobuf:"varint,7,opt,name=MaxParallelTransfers,proto3" json:"MaxParallelTransfers,omitempty"`
	Container            *ContainerConfig     `protobuf:"bytes,8,opt,name=Container,proto3" json:"Container,omitempty"`
	DriverCommand        string               `protobuf:"bytes,9,opt,name=DriverCommand,proto3" json:"DriverCommand,omitempty"`
	// contains filtered or unexported fields
}

Worker contains worker configuration.

func (*Worker) Descriptor deprecated added in v0.11.4 

func (*Worker) Descriptor() ([]byte, []int)

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetContainer added in v0.11.4 

func (x *Worker) GetContainer() *ContainerConfig

func (*Worker) GetDriverCommand added in v0.11.4 

func (x *Worker) GetDriverCommand() string

func (*Worker) GetLeaveWorkDir added in v0.11.4 

func (x *Worker) GetLeaveWorkDir() bool

func (*Worker) GetLogTailSize added in v0.11.4 

func (x *Worker) GetLogTailSize() int64

func (*Worker) GetLogUpdateRate added in v0.11.4 

func (x *Worker) GetLogUpdateRate() *durationpb.Duration

func (*Worker) GetMaxParallelTransfers added in v0.11.4 

func (x *Worker) GetMaxParallelTransfers() int32

func (*Worker) GetPollingRate added in v0.11.4 

func (x *Worker) GetPollingRate() *durationpb.Duration

func (*Worker) GetScratchPath added in v0.11.4 

func (x *Worker) GetScratchPath() string

func (*Worker) GetWorkDir added in v0.11.4 

func (x *Worker) GetWorkDir() string

func (*Worker) ProtoMessage added in v0.11.4 

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect added in v0.11.4 

func (x *Worker) ProtoReflect() protoreflect.Message

func (*Worker) Reset added in v0.11.4 

func (x *Worker) Reset()

func (*Worker) String added in v0.11.4 

func (x *Worker) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.