env

Documentation

Index

• type AmqpConfig
• type CassandraConfig
• type EnvConfig
  • func ReadEnvConfigFile(envConfigFile string) (*EnvConfig, error)
  • func (ec *EnvConfig) Deserialize(jsonBytes []byte) error
• type SslOptions
• type WebapiConfig

Types

type AmqpConfig

type AmqpConfig struct {
	URL           string `json:"url"`
	Exchange      string `json:"exchange"`
	PrefetchCount int    `json:"prefetch_count"`
	PrefetchSize  int    `json:"prefetch_size"`
}

type CassandraConfig

type CassandraConfig struct {
	Hosts                     []string    `json:"hosts"`
	Port                      int         `json:"port"`
	Username                  string      `json:"username"`
	Password                  string      `json:"password"`
	WriterWorkers             int         `json:"writer_workers"`              // 20 is conservative, 80 is aggressive
	NumConns                  int         `json:"num_conns"`                   // gocql default is 2, don't make it too high
	Timeout                   int         `json:"timeout"`                     // in ms, set it to 5s, gocql default 600ms is way too aggressive for heavy writes by multiple workers
	ConnectTimeout            int         `json:"connect_timeout"`             // in ms, set it to 1s, gocql default 600ms may be ok, but let's stay on the safe side
	KeyspaceReplicationConfig string      `json:"keyspace_replication_config"` // { 'class' : 'NetworkTopologyStrategy', 'datacenter1' : 1 }
	SslOpts                   *SslOptions `json:"ssl_opts"`
}

type EnvConfig

type EnvConfig struct {
	HandlerExecutableType             string                     `json:"handler_executable_type"`
	Cassandra                         CassandraConfig            `json:"cassandra"`
	Amqp                              AmqpConfig                 `json:"amqp"`
	ZapConfig                         zap.Config                 `json:"zap_config"`
	ThreadPoolSize                    int                        `json:"thread_pool_size"`
	DeadLetterTtl                     int                        `json:"dead_letter_ttl"`
	CaPath                            string                     `json:"ca_path"`
	Webapi                            WebapiConfig               `json:"webapi,omitempty"`
	CustomProcessorsSettings          map[string]json.RawMessage `json:"custom_processors"`
	CustomProcessorDefFactoryInstance sc.CustomProcessorDefFactory
}

func ReadEnvConfigFile

func ReadEnvConfigFile(envConfigFile string) (*EnvConfig, error)

func (*EnvConfig) Deserialize

func (ec *EnvConfig) Deserialize(jsonBytes []byte) error

type SslOptions

type SslOptions struct {
	CertPath               string `json:"cert_path"`
	KeyPath                string `json:"key_path"`
	CaPath                 string `json:"ca_path"`
	EnableHostVerification bool   `json:"enable_host_verification"`
}

This was not tested outside of the EnableHostVerification=false scenario

type WebapiConfig

type WebapiConfig struct {
	Port                     int    `json:"webapi_port"`
	AccessControlAllowOrigin string `json:"access_control_allow_origin"`
}