swim

type Arg struct{}

type BootstrapOptions struct {
	// Slice of hosts to bootstrap with, prioritized over provided file
	Hosts []string

	// File containing a JSON array of hosts to bootstrap with
	File string

	// Whether or not gossip should start
	Stopped bool

	// Amount of time before join requests time out
	JoinTimeout time.Duration

	// Minimum number of nodes to join
	JoinSize int

	// Maximum time to attempt joins before joining cluster times out
	MaxJoinDuration time.Duration

	// number of nodes to attempt to join
	ParallelismFactor int
}

type Change struct {
	Source            string `json:"source"`
	SourceIncarnation int64  `json:"sourceIncarnationNumber"`
	Address           string `json:"address"`
	Incarnation       int64  `json:"incarnationNumber"`
	Status            string `json:"status"`
	// Use util.Timestamp for bi-direction binding to time encoded as
	// integer Unix timestamp in JSON
	Timestamp util.Timestamp `json:"timestamp"`
}

type ChangeFilteredEvent struct {
	Change Change
}

type ChangesCalculatedEvent struct {
	Changes []Change
}

type ChecksumComputeEvent struct {
	Duration time.Duration `json:"duration"`
	Checksum uint32        `json:"checksum"`
}

type Endpoint string

type EventListener interface {
	HandleEvent(events.Event)
}

type FullSyncEvent struct {
	Remote         string `json:"remote"`
	RemoteChecksum uint32 `json:"remoteChecksum"`
}

type JoinCompleteEvent struct {
	Duration  time.Duration `json:"duration"`
	NumJoined int           `json:"numJoined"`
	Joined    []string      `json:"joined"`
}

type JoinFailedEvent struct {
	Reason JoinFailedReason
	Error  error
}

type JoinFailedReason string

type JoinReceiveEvent struct {
	Local  string `json:"local"`
	Source string `json:"source"`
}

type JoinTriesUpdateEvent struct {
	Retries int
}

type MakeNodeStatusEvent struct {
	Status string
}

type MaxPAdjustedEvent struct {
	OldPCount int `json:"oldPCount"`
	NewPCount int `json:"newPCount"`
}

type Member struct {
	sync.RWMutex
	Address     string `json:"address"`
	Status      string `json:"status"`
	Incarnation int64  `json:"incarnationNumber"`
}

type MemberStats struct {
	Checksum uint32   `json:"checksum"`
	Members  []Member `json:"members"`
}

type MemberlistChangesAppliedEvent struct {
	Changes     []Change `json:"changes"`
	OldChecksum uint32   `json:"oldChecksum"`
	NewChecksum uint32   `json:"newChecksum"`
	NumMembers  int      `json:"numMembers"`
}

type MemberlistChangesReceivedEvent struct {
	Changes []Change `json:"changes"`
}

type Node struct {
	// contains filtered or unexported fields
}

type NodeInterface interface {
	Bootstrap(opts *BootstrapOptions) ([]string, error)
	CountReachableMembers() int
	Destroy()
	GetReachableMembers() []string
	MemberStats() MemberStats
	ProtocolStats() ProtocolStats
	Ready() bool
	RegisterListener(l EventListener)
}

type Options struct {
	SuspicionTimeout  time.Duration
	MinProtocolPeriod time.Duration

	JoinTimeout, PingTimeout, PingRequestTimeout time.Duration

	PingRequestSize int

	RollupFlushInterval time.Duration
	RollupMaxUpdates    int

	BootstrapFile  string
	BootstrapHosts []string

	Logger log.Logger
}

type PingReceiveEvent struct {
	Local   string   `json:"local"`
	Source  string   `json:"source"`
	Changes []Change `json:"changes"`
}

type PingRequestPingEvent struct {
	Local    string        `json:"local"`
	Source   string        `json:"source"`
	Target   string        `json:"target"`
	Duration time.Duration `json:"duration"`
}

type PingRequestReceiveEvent struct {
	Local   string   `json:"local"`
	Source  string   `json:"source"`
	Target  string   `json:"target"`
	Changes []Change `json:"changes"`
}

type PingRequestsSendCompleteEvent struct {
	Local    string        `json:"local"`
	Target   string        `json:"target"`
	Peers    []string      `json:"peers"`
	Duration time.Duration `json:"duration"`
}

type PingRequestsSendEvent struct {
	Local  string   `json:"local"`
	Target string   `json:"target"`
	Peers  []string `json:"peers"`
}

type PingSendCompleteEvent struct {
	Local    string        `json:"local"`
	Remote   string        `json:"remote"`
	Changes  []Change      `json:"changes"`
	Duration time.Duration `json:"duration"`
}

type PingSendEvent struct {
	Local   string   `json:"local"`
	Remote  string   `json:"remote"`
	Changes []Change `json:"changes"`
}

type ProtocolDelayComputeEvent struct {
	Duration time.Duration `json:"duration"`
}

type ProtocolFrequencyEvent struct {
	Duration time.Duration `json:"duration"`
}

type ProtocolStats struct {
	Timing     Timing        `json:"timing"`
	Rate       time.Duration `json:"protocolRate"`
	ClientRate float64       `json:"clientRate"`
	ServerRate float64       `json:"serverRate"`
	TotalRate  float64       `json:"totalRate"`
}

type RefuteUpdateEvent struct{}

type RequestBeforeReadyEvent struct {
	Endpoint Endpoint
}

type Status struct {
	Status string `json:"status"`
}

type Timing struct {
	Type     string  `json:"type"`
	Min      int64   `json:"min"`
	Max      int64   `json:"max"`
	Sum      int64   `json:"sum"`
	Variance float64 `json:"variance"`
	Mean     float64 `json:"mean"`
	StdDev   float64 `json:"std_dev"`
	Count    int64   `json:"count"`
	Median   float64 `json:"median"`
	P75      float64 `json:"p75"`
	P95      float64 `json:"p95"`
	P99      float64 `json:"p99"`
	P999     float64 `json:"p999"`
}