configuration

Documentation

Index

• type Config
  • func Load(location string) (config Config, err error)
• type Duration
  • func (this *Duration) GetDuration() time.Duration
  • func (this *Duration) SetDuration(dur time.Duration)
  • func (this *Duration) SetString(str string) error
  • func (this *Duration) UnmarshalJSON(bytes []byte) (err error)

Types

type Config

type Config struct {
	Port            string `json:"port"`
	Debug           bool   `json:"debug"`
	EnableSwaggerUi bool   `json:"enable_swagger_ui"`
	EditForward     string `json:"edit_forward"`
	DevNotifierUrl  string `json:"dev_notifier_url"`

	DisableCom bool `json:"disable_com"`

	KafkaUrl                  string `json:"kafka_url"`
	DefaultKafkaConsumerGroup string `json:"default_kafka_consumer_group"`
	DoneTopic                 string `json:"done_topic"`
	HandleDoneWait            bool   `json:"handle_done_wait"`
	KafkaDoneBatchSize        int    `json:"kafka_done_batch_size"`

	MongoUrl                   string `json:"mongo_url"`
	MongoDatabase              string `json:"mongo_database"`
	MongoPermissionsCollection string `json:"mongo_permissions_collection"`
	MongoTopicsCollection      string `json:"mongo_topics_collection"`

	DisabledTopicConsumers []string `json:"disabled_topic_consumers"` //may be needed to fix service with broken topic consumer

	CheckDbTopicChangesInterval Duration `json:"check_db_topic_changes_interval"`
}

func Load

func Load(location string) (config Config, err error)

loads config from json in location and used environment variables (e.g KafkaUrl --> KAFKA_URL)

type Duration

type Duration struct {
	// contains filtered or unexported fields
}

func (*Duration) GetDuration

func (this *Duration) GetDuration() time.Duration

func (*Duration) SetDuration

func (this *Duration) SetDuration(dur time.Duration)

func (*Duration) SetString

func (this *Duration) SetString(str string) error

func (*Duration) UnmarshalJSON

func (this *Duration) UnmarshalJSON(bytes []byte) (err error)