Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

logic

package

Go to main page

Versions in this module

v1

v1.4.219

Jul 10, 2015

v1.4.204

Jul 8, 2015

Changes in this version

type TopologyRecovery

+ Id int64

+ func ReadRecentFailureDetections(page int) ([]TopologyRecovery, error)

v1.4.196

Jul 6, 2015

Changes in this version

+ func AttemptFailureDetectionRegistration(analysisEntry *inst.ReplicationAnalysis) (bool, error)

+ func ClearActiveFailureDetections() error

v1.4.191

Jul 3, 2015

Changes in this version

+ var ThisHostname string

+ func AccountedDiscoverInstance(instanceKey inst.InstanceKey, pendingTokens chan bool, ...)

+ func AttemptElection() (bool, error)

+ func AttemptRecoveryRegistration(analysisEntry *inst.ReplicationAnalysis) (bool, error)

+ func CheckAndRecover(specificInstance *inst.InstanceKey, candidateInstanceKey *inst.InstanceKey, ...) (actionTaken bool, instance *inst.Instance, err error)

+ func ClearActiveRecoveries() error

+ func ContinuousAgentsPoll()

+ func ContinuousDiscovery()

+ func CreateElectionAnchor(force bool) error

+ func DiscoverInstance(instanceKey inst.InstanceKey)

+ func ElectedNode() (string, string, bool, error)

+ func GetCandidateSiblingOfIntermediateMaster(intermediateMasterKey *inst.InstanceKey) (*inst.Instance, error)

+ func GetHash(input []byte) string

+ func GetRandomData() []byte

+ func GrabElection() (bool, error)

+ func IsElected() (bool, error)

+ func RecoverDeadIntermediateMaster(analysisEntry inst.ReplicationAnalysis) (actionTaken bool, successorInstance *inst.Instance, err error)

+ func RecoverDeadMaster(analysisEntry inst.ReplicationAnalysis) (bool, *inst.Instance, error)

+ func Reelect() error

+ func ResolveRecovery(failedKey *inst.InstanceKey, successorKey *inst.InstanceKey) error

+ func StartDiscovery(instanceKey inst.InstanceKey)

+ type HealthStatus struct

+ ActiveNode string

+ AvailableNodes []string

+ Error error

+ Healthy bool

+ Hostname string

+ IsActiveNode bool

+ Token string

+ func HealthTest() (*HealthStatus, error)

+ type InstancesByCountSlaves [](*inst.Instance)

+ func (this InstancesByCountSlaves) Len() int

+ func (this InstancesByCountSlaves) Less(i, j int) bool

+ func (this InstancesByCountSlaves) Swap(i, j int)

+ type Token struct

+ Hash string

+ var ProcessToken *Token = NewToken()

+ func NewToken() *Token

+ type TopologyRecovery struct

+ AnalysisEntry inst.ReplicationAnalysis

+ IsActive bool

+ ProcessingNodeHostname string

+ ProcessingNodeToken string

+ RecoveryEndTimestamp string

+ RecoveryStartTimestamp string

+ SuccessorKey inst.InstanceKey

+ TopologyRecoveryId int64

+ func ReadActiveClusterRecovery(clusterName string) ([]TopologyRecovery, error)

+ func ReadActiveRecoveries() ([]TopologyRecovery, error)

+ func ReadCompletedRecoveries(page int) ([]TopologyRecovery, error)

+ func ReadRecentRecoveries(page int) ([]TopologyRecovery, error)

+ func ReadRecentlyActiveClusterRecovery(clusterName string) ([]TopologyRecovery, error)

+ func ReadRecentlyActiveInstanceRecovery(instanceKey *inst.InstanceKey) ([]TopologyRecovery, error)