config

package

Go to main page

Versions in this module

v1

v1.8.0

Jan 15, 2026

v1.7.1

Jan 22, 2026

v1.7.0

Dec 18, 2025

v1.6.0

Dec 10, 2025

v1.5.0

Nov 10, 2025

v1.4.0

Nov 7, 2025

Changes in this version

type DB

+ LogLevel int

v1.3.0

Oct 30, 2025

Changes in this version

type Config

+ Validations []validation.ConfigField

v1.2.0

Oct 9, 2025

v1.1.0

Sep 29, 2025

Changes in this version

+ var ErrConfirmJobAfterMustBeEqualGreaterThanZero = errors.New("confirm job delay must be equal or greater than zero")

type Orbital

+ ConfirmJobAfter time.Duration

v1.0.1

Aug 28, 2025

Changes in this version

type GRPCServer

+ Client commoncfg.GRPCClient

v1.0.0

Aug 21, 2025

Changes in this version

+ const WorkerNameConfirmJob

+ const WorkerNameCreateTask

+ const WorkerNameNotifyEvent

+ const WorkerNameReconcile

+ var ErrAMQPConfigMissing = errors.New("AMQP configuration is missing")

+ var ErrBackoffBaseIntervalMustBeGreaterThanZero = errors.New("backoff base interval must be greater than zero")

+ var ErrBackoffMaxIntervalMustBeGreaterThanZero = errors.New("backoff max interval must be greater than zero")

+ var ErrConfirmJobDelayMustBeEqualGreaterThanZero = errors.New("confirm job delay must be equal or greater than zero")

+ var ErrEmptyCAFile = errors.New("CA file must not be empty")

+ var ErrEmptyCertFile = errors.New("certificate file must not be empty")

+ var ErrEmptyKeyFile = errors.New("key file must not be empty")

+ var ErrEmptyRegion = errors.New("region must not be empty")

+ var ErrEmptySource = errors.New("source must not be empty")

+ var ErrEmptyTarget = errors.New("target must not be empty")

+ var ErrEmptyURL = errors.New("URL must not be empty")

+ var ErrEmptyWorkerName = errors.New("worker name must not be empty")

+ var ErrExecIntervalMustBeGreaterThanZero = errors.New("worker exec interval must be greater than zero")

+ var ErrMaxReconcileCountMustBeGreaterThanZero = errors.New("max reconcile count must be greater than zero")

+ var ErrNilAuth = errors.New("authentication configuration is missing")

+ var ErrNilConnection = errors.New("connection configuration is missing")

+ var ErrNumberOfWorkersMustBeGreaterThanZero = errors.New("number of workers must be greater than zero")

+ var ErrTaskLimitNumMustBeGreaterThanZero = errors.New("task limit number must be greater than zero")

+ var ErrTimeoutMustBeGreaterThanZero = errors.New("timeout must be greater than zero")

+ var ErrUnsupportedAuthType = errors.New("authentication type is not supported")

+ var ErrUnsupportedConnectionType = errors.New("connection type is not supported")

+ var ErrUnsupportedWorkerName = errors.New(...)

+ type AMQP struct

+ Source string

+ Target string

+ Url string

+ type Auth struct

+ MTLS *MTLS

+ Type AuthType

+ type AuthType string

+ const AuthTypeMTLS

+ const AuthTypeNone

+ type Config struct

+ Database DB

+ DebugMode bool

+ GRPCServer GRPCServer

+ Orbital Orbital

+ func (c *Config) Validate() error

+ type Connection struct

+ AMQP *AMQP

+ Auth Auth

+ Type ConnectionType

+ type ConnectionType string

+ const ConnectionTypeAMQP

+ type DB struct

+ Host string

+ Name string

+ Password commoncfg.SourceRef

+ Port string

+ User commoncfg.SourceRef

+ type GRPCServer struct

+ ClientAttributes commoncfg.GRPCClientAttributes

+ type MTLS struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ type Orbital struct

+ BackoffBaseIntervalSec int64

+ BackoffMaxIntervalSec int64

+ ConfirmJobDelay time.Duration

+ MaxReconcileCount int64

+ Targets []Target

+ TaskLimitNum int

+ Workers []Worker

+ func (o *Orbital) GetWorker(workerName string) *Worker

+ func (o *Orbital) Validate() error

+ type Server struct

+ Port string

+ type Target struct

+ Connection *Connection

+ Region string

+ type Worker struct

+ ExecInterval time.Duration

+ Name string

+ NoOfWorkers int

+ Timeout time.Duration

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