Documentation
¶
Index ¶
- Variables
- func Init(containerized bool, dockerHubID string) error
- func Read(configSourceStr string, containerizedRun bool, configNotFoundErrMsg string, ...) error
- type AppConfig
- func (a *AppConfig) Close()
- func (a *AppConfig) CloseEventsConsumers()
- func (a *AppConfig) CloseLast()
- func (a *AppConfig) CloseWriteAheadLog()
- func (a *AppConfig) ScheduleClosing(c io.Closer)
- func (a *AppConfig) ScheduleEventsConsumerClosing(c io.Closer)
- func (a *AppConfig) ScheduleLastClosing(c io.Closer)
- func (a *AppConfig) ScheduleWriteAheadLogClosing(c io.Closer)
- type VersionReminder
Constants ¶
This section is empty.
Variables ¶
var ( Instance *AppConfig RawVersion string MajorVersion string BuiltAt string MinorVersion string Beta bool )
var VersionRegex = regexp.MustCompile(`v(\d\.\d\d?)[-|\.](beta)?(\d?\d?)`)
Functions ¶
func Read ¶
func Read(configSourceStr string, containerizedRun bool, configNotFoundErrMsg string, appName string) error
Read reads config from configSourceStr that might be (HTTP URL or path to YAML/JSON file or plain JSON string) replaces all ${env.VAR} placeholders with OS variables configSourceStr might be overridden by "config_location" ENV variable returns err if occurred
Types ¶
type AppConfig ¶
type AppConfig struct {
ServerName string
Authority string
ConfigPath string
ConfiguratorURL string
ConfiguratorToken string
DisableSkipEventsWarn bool
EmptyGIFPixelOnexOne []byte
UaResolver useragent.Resolver
AuthorizationService *authorization.Service
GlobalDDLLogsWriter io.Writer
GlobalQueryLogsWriter io.Writer
SingerLogsWriter io.Writer
AirbyteLogsWriter io.Writer
SourcesLogsWriter io.Writer
GlobalUniqueIDField *identifiers.UniqueID
EnrichWithHTTPContext bool
// contains filtered or unexported fields
}
AppConfig is a main Application Global Configuration
func (*AppConfig) CloseEventsConsumers ¶
func (a *AppConfig) CloseEventsConsumers()
CloseEventsConsumers closes events queues(streaming) and loggers(batch) in the last call for preventing losing events
func (*AppConfig) CloseLast ¶
func (a *AppConfig) CloseLast()
CloseLast closes meta.Storage, coordinationService closers in the last call
func (*AppConfig) CloseWriteAheadLog ¶
func (a *AppConfig) CloseWriteAheadLog()
CloseWriteAheadLog closes write-ahead-log service in the last call
func (*AppConfig) ScheduleClosing ¶
func (*AppConfig) ScheduleEventsConsumerClosing ¶
ScheduleEventsConsumerClosing adds events consumer closer into slice for closing
func (*AppConfig) ScheduleLastClosing ¶
ScheduleLastClosing adds meta.Storage, coordinationService closers
func (*AppConfig) ScheduleWriteAheadLogClosing ¶
ScheduleWriteAheadLogClosing adds wal.Service closer
type VersionReminder ¶
type VersionReminder struct {
// contains filtered or unexported fields
}
func NewVersionReminder ¶
func NewVersionReminder(ctx context.Context) *VersionReminder
func (*VersionReminder) Close ¶
func (vn *VersionReminder) Close() error
func (*VersionReminder) Start ¶
func (vn *VersionReminder) Start()
Source Files