Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2016 Changes in this version + const PackageName + var ConnectionConnectTimeoutFlag = config.DeclareDuration(PackageName, "connectionConnectTimeout", 20 * time.Second) + var ConnectionExpiryFlag = config.DeclareDuration(PackageName, "connectionExpiry", 5 * time.Minute) + var DisableProxyExtFlag = config.DeclareBool(PackageName, "disableProxyExt") + var DisableProxyInOutFlag = config.DeclareBool(PackageName, "disableProxyInOut") + var EnvExtListenPortFlag = config.DeclareString(PackageName, "envExtListenPort", "3502") + var EnvInListenPortFlag = config.DeclareString(PackageName, "envInListenPort", "3500") + var EnvOutListenPortFlag = config.DeclareString(PackageName, "envOutListenPort", "3838") + var InstanceConstructTimeoutFlag = config.DeclareDuration(PackageName, "instanceConstructTimeout", 15 * time.Second) + var ResourceConstructTimeoutFlag = config.DeclareDuration(PackageName, "resourceConstructTimeout", 20 * time.Second) + func GetHostAddrOnNode(node string) (string, error) + func RegisterThisHost(hostAddr string) (serviceSka *scale.SelfKeepAlive, sessionSka *scale.SelfKeepAlive, err error) + type Finder struct + func NewFinder(docker *dockerapi.Client, as *aerospike.Client) *Finder + func (finder *Finder) GetHost(env, service, resource string, fromExt bool) (hostInfo *LeverHostInfo, err error) + type LevInstTarget struct + ContainerID string + HostAddr string + InstanceID string + type LevResTarget struct + ContainerID string + HostAddr string + InstanceID string + LevInstSessionID string + type LeverHostInfo struct + CodeVersion int64 + ContainerID string + HostAddr string + InstanceID string + IsNewInstance bool + LevInstResourceID string + LevInstSessionID string + LevResResourceID string + LevResSessionID string + ServingID string + type LeverProxy struct + func NewLeverProxy(manager *hostman.Manager, finder *Finder, ownIPv4 string, ...) (*LeverProxy, error)