config

Apr 16, 2018

Changes in this version

type ClustersInfo

+ ClusterInitialFailoverVersions map[string]int64

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

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

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

Aug 7, 2017

Changes in this version

type Cassandra

+ Password string

+ Port int

+ User string

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)