processor

Documentation

Index

• type Processor
  • func NewProcessor(flags flags.Common, envVars *environment.Variables, startupTimer startup.Timer, ...) *Processor
  • func (cp *Processor) Process(serviceConfig config.Configuration) error
• type UpdatedStream

Types

type Processor

type Processor struct {
	Logger logger.LoggingClient
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor(
	flags flags.Common,
	envVars *environment.Variables,
	startupTimer startup.Timer,
	ctx context.Context,
	wg *sync.WaitGroup,
	configUpdated UpdatedStream,
	dic *di.Container,
) *Processor

NewProcessor creates a new configuration Processor

func (*Processor) Process

func (cp *Processor) Process(serviceConfig config.Configuration) error

type UpdatedStream

type UpdatedStream chan struct{}

UpdatedStream defines the stream type that is notified by ListenForChanges when a configuration update is received.