daemon

Documentation

Index

• Constants
• func Fetch(envkey, clientNameArg, clientVersionArg string, rollingReload bool, ...) (string, error)
• func FetchMap(envkey, clientNameArg, clientVersionArg string, rollingReload bool, ...) (parser.EnvMap, parser.EnvMap, error)
• func InlineStart(shouldCacheArg bool, memCacheArg bool)
• func IsAlive() bool
• func LaunchDetachedIfNeeded(opts DaemonOptions) error
• func ListenChange(props ListenChangeProps)
• func ListenChangeWithEnv(envkey, clientName, clientVersion string, rollingReload bool, rollingPct uint8, ...)
• func RemoveListener(envkey string)
• func Stop()
• type DaemonOptions
• type DaemonResponse
• type EnvkeyMeta
• type ListenChangeProps
• type SocketAuth

Constants

const CHECK_SUSPENDED_INTERVAL = 1000 * 10 // 10 seconds

const JITTER = 500 //ms

const SUSPENSION_MIN_DELTA = 100 // 100 ms

const WS_PING_INTERVAL = time.Duration(10) * time.Second

Functions

func Fetch

func Fetch(envkey, clientNameArg, clientVersionArg string, rollingReload bool, rollingPct uint8, watchThrottle uint32) (string, error)

func FetchMap

func FetchMap(envkey, clientNameArg, clientVersionArg string, rollingReload bool, rollingPct uint8, watchThrottle uint32) (parser.EnvMap, parser.EnvMap, error)

func InlineStart

func InlineStart(shouldCacheArg bool, memCacheArg bool)

func IsAlive

func IsAlive() bool

func LaunchDetachedIfNeeded

func LaunchDetachedIfNeeded(opts DaemonOptions) error

func ListenChange

func ListenChange(props ListenChangeProps)

func ListenChangeWithEnv

func ListenChangeWithEnv(envkey, clientName, clientVersion string, rollingReload bool, rollingPct uint8, watchThrottle uint32, onChange func(parser.EnvMap, parser.EnvMap))

func RemoveListener

func RemoveListener(envkey string)

func Stop

func Stop()

Types

type DaemonOptions

type DaemonOptions struct {
	VerboseOutput bool
	ShouldCache   bool
	MemCache      bool
}

type DaemonResponse

type DaemonResponse struct {
	CurrentEnv  parser.EnvMap
	PreviousEnv parser.EnvMap
}

type EnvkeyMeta

type EnvkeyMeta struct {
	ClientName    string
	ClientVersion string
}

type ListenChangeProps

type ListenChangeProps struct {
	Envkey                 string
	WatchThrottle          uint32
	OnChange               func()
	OnStartRolling         func(batchNum, totalBatches uint16, watchThrottle uint32)
	OnRollingComplete      func()
	OnInvalid              func()
	OnThrottled            func()
	OnLostDaemonConnection func(error)
	OnDaemonConnectFailed  func(error)
	OnWillReconnect        func()
	OnReconnected          func()
	OnReconnectedNoChange  func()
	OnSuspended            func()
	OnSuspendedNoChange    func()
}

type SocketAuth

type SocketAuth struct {
	Type         string `json:"type"`
	EnvkeyIdPart string `json:"envkeyIdPart"`
	ConnectionId string `json:"connectionId"`
}