config

Documentation

Index

• Variables
• type Config
  • func GetAndValidateConfig(cfg *common.Config) (*Config, error)

Variables

var DefaultConfig = Config{}

Types

type Config

type Config struct {
	Project         string `config:"project_id" validate:"required"`
	Topic           string `config:"topic" validate:"required"`
	CredentialsFile string `config:"credentials_file"`
	Subscription    struct {
		Name                string        `config:"name" validate:"required"`
		RetainAckedMessages bool          `config:"retain_acked_messages"`
		RetentionDuration   time.Duration `config:"retention_duration"`
	}
	Json struct {
		Enabled     bool `config:"enabled"`
		AddErrorKey bool `config:"add_error_key"`
	}
}

func GetAndValidateConfig

func GetAndValidateConfig(cfg *common.Config) (*Config, error)