config

package

Go to main page

Versions in this module

v0

v0.20.0

Apr 16, 2021

v0.19.2

Apr 16, 2021

v0.19.1

Mar 30, 2021

v0.19.0

Feb 8, 2021

Changes in this version

+ func CheckAWSSigningConfig(config AWSSigning) error

+ type AWSEnvironmentCredential struct

+ Region string

+ type AWSSigning struct

+ Enable bool

+ EnvironmentCredential *AWSEnvironmentCredential

+ StaticCredential *AWSStaticCredential

+ type AWSStaticCredential struct

+ AccessKey string

+ Region string

+ SecretKey string

+ SessionToken string

type ElasticSearchConfig

+ AWSSigning AWSSigning

v0.18.2

Mar 17, 2021

v0.18.1

Mar 1, 2021

v0.18.0

Jan 22, 2021

Changes in this version

type Cassandra

+ CQLClient gocql.Client

+ type ClusterConfig struct

+ Brokers []string

type Config

+ func (c *Config) ValidateAndFillDefaults() error

type ElasticSearchConfig

+ DisableHealthCheck bool

+ type KafkaConfig struct

+ Applications map[string]TopicList

+ Clusters map[string]ClusterConfig

+ SASL auth.SASL

+ TLS auth.TLS

+ Topics map[string]TopicConfig

+ func (k *KafkaConfig) GetBrokersForKafkaCluster(kafkaCluster string) []string

+ func (k *KafkaConfig) GetKafkaClusterForTopic(topic string) string

+ func (k *KafkaConfig) GetTopicsForApplication(app string) TopicList

+ func (k *KafkaConfig) Validate(checkApp bool)

+ type TopicConfig struct

+ Cluster string

+ type TopicList struct

+ DLQTopic string

+ Topic string

v0.17.0

Jan 13, 2021

Changes in this version

+ type ElasticSearchConfig struct

+ DisableSniff bool

+ Indices map[string]string

+ Password string

+ URL url.URL

+ Username string

+ Version string

+ func (cfg *ElasticSearchConfig) GetVisibilityIndex() string

+ func (cfg *ElasticSearchConfig) SetUsernamePassword()

type Persistence

+ ErrorInjectionRate dynamicconfig.FloatPropertyFn

v0.16.1

Jan 21, 2021

v0.16.0

Dec 4, 2020

Changes in this version

type SQL

+ DecodingTypes []string

+ EncodingType string

v0.15.1

Oct 22, 2020

v0.15.0

Oct 8, 2020

v0.14.2

Oct 8, 2020

v0.14.1

Sep 22, 2020

v0.14.0

Sep 14, 2020

Changes in this version

type Cassandra

+ Region string

v0.13.0

Jul 7, 2020

Changes in this version

+ type Blobstore struct

+ Filestore *FileBlobstore

type Config

+ Blobstore Blobstore

+ type FileBlobstore struct

+ OutputDirectory string

v0.12.0

May 26, 2020

Changes in this version

+ type CustomDatastoreConfig struct

+ Name string

+ Options map[string]string

type DataStore

+ CustomDataStoreConfig *CustomDatastoreConfig

+ type GstorageArchiver struct

+ CredentialsPath string

type HistoryArchiverProvider

+ Gstorage *GstorageArchiver

+ S3store *S3Archiver

type Metrics

+ Prefix string

+ type S3Archiver struct

+ Endpoint *string

+ Region string

+ S3ForcePathStyle bool

type SQL

+ TLS *auth.TLS

type VisibilityArchiverProvider

+ Gstorage *GstorageArchiver

+ S3store *S3Archiver

v0.12.0-reset-patch

Nov 19, 2022

v0.11.0

Feb 15, 2020

Changes in this version

type Cassandra

+ TLS *auth.TLS

type RPCFactory

+ func (d *RPCFactory) GetDispatcher() *yarpc.Dispatcher

type RingpopFactory

+ func (factory *RingpopFactory) GetMembershipMonitor() (membership.Monitor, error)

type SQL

+ PluginName string

v0.10.3

Dec 3, 2019

v0.10.2

Nov 27, 2019

v0.10.1

Nov 21, 2019

v0.10.0

Oct 18, 2019

v0.9.8

Nov 14, 2019

v0.9.7

Oct 28, 2019

v0.9.5

Oct 18, 2019

v0.9.4

Oct 14, 2019

v0.9.3

Oct 7, 2019

v0.9.0

Sep 17, 2019

Changes in this version

+ const ReplicationConsumerTypeKafka

+ const ReplicationConsumerTypeRPC

type ClusterMetadata

+ ReplicationConsumer *ReplicationConsumerConfig

type DataStore

+ ElasticSearch *elasticsearch.Config

+ type FetcherConfig struct

+ AggregationIntervalSecs int

+ ErrorRetryWaitSecs int

+ RPCParallelism int

+ TimerJitterCoefficient float64

+ type FilestoreArchiver struct

+ DirMode string

+ FileMode string

type Persistence

+ AdvancedVisibilityStore string

+ func (c *Persistence) IsAdvancedVisibilityConfigExist() bool

+ type ReplicationConsumerConfig struct

+ FetcherConfig *FetcherConfig

+ ProcessorConfig *ReplicationTaskProcessorConfig

+ Type string

+ type ReplicationTaskProcessorConfig struct

+ NoTaskInitialWaitIntervalSecs int

+ NoTaskMaxWaitIntervalSecs int

+ NoTaskWaitBackoffCoefficient float64

v0.8.6

Aug 27, 2019

v0.8.5

Aug 27, 2019

v0.8.4

Aug 26, 2019

v0.8.3

Aug 14, 2019

Changes in this version

type Archival

+ func (a *Archival) Validate(domainDefaults *ArchivalDomainDefaults) error

v0.8.2

Aug 13, 2019

v0.8.1

Aug 12, 2019

v0.8.0

Aug 12, 2019

v0.7.3

Aug 8, 2019

v0.7.2

Aug 8, 2019

v0.7.1

Aug 6, 2019

v0.7.0

Jul 30, 2019

Changes in this version

type Archival

+ History HistoryArchival

+ Visibility VisibilityArchival

+ type ArchivalDomainDefaults struct

+ History HistoryArchivalDomainDefaults

+ Visibility VisibilityArchivalDomainDefaults

type Config

+ DomainDefaults DomainDefaults

+ type DomainDefaults struct

+ Archival ArchivalDomainDefaults

+ type FilestoreHistoryArchiver struct

+ DirMode string

+ FileMode string

+ type FilestoreVisibilityArchiver struct

+ type HistoryArchival struct

+ EnableRead bool

+ Provider *HistoryArchiverProvider

+ Status string

+ type HistoryArchivalDomainDefaults struct

+ Status string

+ URI string

+ type HistoryArchiverProvider struct

+ Filestore *FilestoreHistoryArchiver

+ type VisibilityArchival struct

+ EnableRead bool

+ Provider *VisibilityArchiverProvider

+ Status string

+ type VisibilityArchivalDomainDefaults struct

+ Status string

+ URI string

+ type VisibilityArchiverProvider struct

+ Filestore *FilestoreVisibilityArchiver

v0.6.1

Jul 26, 2019

v0.6.0

Jul 24, 2019

Changes in this version

type PublicClient

+ RefreshInterval time.Duration

v0.5.9

Jun 17, 2019

Changes in this version

type Archival

+ S3store *s3store.Config

type BootstrapMode

+ const BootstrapModeDNS

type Persistence

+ TransactionSizeLimit dynamicconfig.IntPropertyFn

type VisibilityConfig

+ ValidSearchAttributes dynamicconfig.MapPropertyFn

v0.5.8

May 14, 2019

Changes in this version

+ type ClusterInformation struct

+ Enabled bool

+ InitialFailoverVersion int64

+ RPCAddress string

+ RPCName string

+ type ClusterMetadata struct

+ ClusterInformation map[string]ClusterInformation

+ CurrentClusterName string

+ EnableGlobalDomain bool

+ FailoverVersionIncrement int64

+ MasterClusterName string

type ClustersInfo

+ func (c ClustersInfo) ToClusterMetadata() ClusterMetadata

type Config

+ ClusterMetadata ClusterMetadata

+ DynamicConfigClient dynamicconfig.FileBasedClientConfig

v0.5.7

May 8, 2019

Changes in this version

+ const StoreTypeCassandra

+ const StoreTypeSQL

+ var CadenceServices = []string

+ func NewPrometheusReporter(config *prometheus.Configuration, configOpts prometheus.ConfigurationOptions) (prometheus.Reporter, error)

type Archival

+ DefaultBucket string

+ EnableReadFromArchival bool

type Config

+ PublicClient PublicClient

type Logger

+ func (cfg *Logger) NewZapLogger() *zap.Logger

type Metrics

+ Prometheus *prometheus.Configuration

type Persistence

+ func (c *Persistence) DefaultStoreType() string

+ type PublicClient struct

+ HostPort string

type RingpopFactory

+ func (factory *RingpopFactory) Create(dispatcher *yarpc.Dispatcher) (membership.Monitor, error)

type SQL

+ ConnectAttributes map[string]string

+ MaxConnLifetime time.Duration

+ MaxIdleConns int

type VisibilityConfig

+ ESIndexMaxResultWindow dynamicconfig.IntPropertyFn

+ MaxQPS dynamicconfig.IntPropertyFn

v0.5.5

Mar 12, 2019

v0.5.4

Mar 8, 2019

Changes in this version

type Archival

+ Status string

type SQL

+ NumShards int

v0.5.3

Feb 19, 2019

Changes in this version

type Persistence

+ VisibilityConfig *VisibilityConfig

type RPC

+ BindOnIP string

+ type VisibilityConfig struct

+ EnableReadFromClosedExecutionV2 dynamicconfig.BoolPropertyFn

+ EnableSampling dynamicconfig.BoolPropertyFn

+ VisibilityClosedMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityListMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityOpenMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

v0.5.2

Feb 12, 2019

Changes in this version

type Config

+ DCRedirectionPolicy DCRedirectionPolicy

+ ElasticSearch elasticsearch.Config

+ type DCRedirectionPolicy struct

+ Policy string

+ ToDC string

v0.5.1

Jan 18, 2019

v0.5.0

Jan 7, 2019

Changes in this version

+ type Address struct

+ RPCAddress string

+ RPCName string

+ type Archival struct

+ Enabled bool

+ Filestore filestore.Config

type ClustersInfo

+ ClusterAddress map[string]Address

type Config

+ Archival Archival

type Persistence

+ SamplingConfig SamplingConfig

+ type SamplingConfig struct

+ VisibilityClosedMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityListMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

+ VisibilityOpenMaxQPS dynamicconfig.IntPropertyFnWithDomainFilter

v0.4.0

Oct 19, 2018

Changes in this version

type Cassandra

+ MaxConns int

+ MaxQPS int

type Config

+ Persistence Persistence

+ func (c *Config) Validate() error

+ type DataStore struct

+ Cassandra *Cassandra

+ SQL *SQL

+ type Persistence struct

+ DataStores map[string]DataStore

+ DefaultStore string

+ HistoryMaxConns int

+ NumHistoryShards int

+ VisibilityStore string

+ func (c *Persistence) SetMaxQPS(key string, qps int)

+ func (c *Persistence) Validate() error

+ type SQL struct

+ ConnectAddr string

+ ConnectProtocol string

+ DatabaseName string

+ DriverName string

+ MaxConns int

+ MaxQPS int

+ Password string

+ User string

v0.3.15

Jul 26, 2018

v0.3.14

Jul 24, 2018

v0.3.13

Jun 9, 2018

v0.3.12

May 26, 2018

v0.3.11

Apr 16, 2018

Changes in this version

type ClustersInfo

+ ClusterInitialFailoverVersions map[string]int64

v0.3.10

Apr 10, 2018

v0.3.9

Mar 14, 2018

v0.3.8

Mar 13, 2018

v0.3.7

Mar 12, 2018

Changes in this version

+ type ClustersInfo struct

+ ClusterNames []string

+ CurrentClusterName string

+ EnableGlobalDomain bool

+ FailoverVersionIncrement int64

+ InitialFailoverVersion int64

+ MasterClusterName string

type Config

+ ClustersInfo ClustersInfo

+ Kafka messaging.KafkaConfig

+ type Replicator struct

v0.3.6

Jan 30, 2018

v0.3.5

Jan 12, 2018

Changes in this version

+ type PProf struct

+ Port int

+ func (cfg *PProf) NewInitializer(logger bark.Logger) *PProfInitializerImpl

+ type PProfInitializerImpl struct

+ Logger bark.Logger

+ PProf *PProf

+ func (initializer *PProfInitializerImpl) Start() error

type Service

+ PProf PProf

v0.3.4

Dec 12, 2017

v0.3.3

Dec 5, 2017

v0.3.2

Sep 29, 2017

Changes in this version

+ func ListenIP() (net.IP, error)

+ type RPC struct

+ BindOnLocalHost bool

+ DisableLogging bool

+ LogLevel string

+ Port int

+ func (cfg *RPC) NewFactory(sName string, logger bark.Logger) *RPCFactory

+ type RPCFactory struct

+ func (d *RPCFactory) CreateDispatcher() *yarpc.Dispatcher

+ func (d *RPCFactory) CreateDispatcherForOutbound(callerName, serviceName, hostName string) *yarpc.Dispatcher

type Service

+ RPC RPC

v0.3.1

Aug 15, 2017

v0.3.0

Aug 7, 2017

Changes in this version

type Cassandra

+ Password string

+ Port int

+ User string

v0.2.0

Jun 30, 2017

Changes in this version

+ const EnvKeyAvailabilityZone

+ const EnvKeyConfigDir

+ const EnvKeyEnvironment

+ const EnvKeyRoot

+ func Load(env string, configDir string, zone string, config interface{}) error

+ type BootstrapMode int

+ const BootstrapModeCustom

+ const BootstrapModeFile

+ const BootstrapModeHosts

+ const BootstrapModeNone

+ func (m *BootstrapMode) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type Cassandra struct

+ Consistency string

+ Datacenter string

+ Hosts string

+ Keyspace string

+ NumHistoryShards int

+ VisibilityKeyspace string

+ type Config struct

+ Cassandra Cassandra

+ Log Logger

+ Ringpop Ringpop

+ Services map[string]Service

+ func (c *Config) String() string

+ type Logger struct

+ Level string

+ OutputFile string

+ Stdout bool

+ func (cfg *Logger) NewBarkLogger() bark.Logger

+ type Metrics struct

+ M3 *m3.Configuration

+ Statsd *Statsd

+ Tags map[string]string

+ func (c *Metrics) NewScope() tally.Scope

+ type Ringpop struct

+ BootstrapFile string

+ BootstrapHosts []string

+ BootstrapMode BootstrapMode

+ DiscoveryProvider discovery.DiscoverProvider

+ MaxJoinDuration time.Duration

+ Name string

+ func (rpConfig *Ringpop) NewFactory() (*RingpopFactory, error)

+ type RingpopFactory struct

+ func (factory *RingpopFactory) CreateRingpop(ch *tchannel.Channel) (*ringpop.Ringpop, error)

+ type Service struct

+ Metrics Metrics

+ TChannel TChannel

+ type Statsd struct

+ FlushBytes int

+ FlushInterval time.Duration

+ HostPort string

+ Prefix string

+ type TChannel struct

+ BindOnLocalHost bool

+ DisableLogging bool

+ LogLevel string

+ Port int

+ func (cfg *TChannel) NewFactory() *TChannelFactory

+ type TChannelFactory struct

+ func (factory *TChannelFactory) CreateChannel(sName string, thriftServices []thrift.TChanServer) (*tchannel.Channel, *thrift.Server)

v0.1.1-beta

Jun 7, 2017

v0.1.0-beta

Jun 6, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL