220 lines
5.2 KiB
Go
220 lines
5.2 KiB
Go
package server
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
// ----------------
|
|
// Discovery struct
|
|
// ----------------
|
|
|
|
const TimeToLife = 60 // when server won't occur in the discovery channel longer than this, it should be considered as not-alive
|
|
|
|
// Discovery contains information about a single server and is used for server discovery
|
|
type Discovery struct {
|
|
Hostname string `json:"hostname"`
|
|
Labels Labels `json:"labels"`
|
|
|
|
// For internal use to check if the server is still alive.
|
|
// Contains timestamp of the last check.
|
|
LastCheck int64 `json:"last_check"`
|
|
|
|
TTL uint `json:"-"` // after how many second consider the server to be off, if 0 then 60 secs is used
|
|
}
|
|
|
|
// Validate checks all values in the struct if the content is valid
|
|
func (d *Discovery) Validate() error {
|
|
// TODO: implement
|
|
return nil
|
|
}
|
|
|
|
// IsAlive return true if the server should be considered as alive
|
|
func (d *Discovery) IsAlive() bool {
|
|
if d.TTL == 0 {
|
|
d.TTL = TimeToLife
|
|
}
|
|
return time.Now().Unix()-d.LastCheck < int64(d.TTL)
|
|
}
|
|
|
|
func (d *Discovery) Bytes() ([]byte, error) {
|
|
data, err := json.Marshal(d)
|
|
return data, err
|
|
}
|
|
|
|
// FindLabels returns list of labels with given prefix. For example "service:ns" has prefix "service" or "service:".
|
|
// It doesn't have to be prefix, but for example "service:test" will match "service:test" and also "service:test2".
|
|
func (d *Discovery) FindLabels(prefix string) Labels {
|
|
labels := Labels{}
|
|
for _, label := range d.Labels {
|
|
if strings.HasPrefix(label.String(), prefix) {
|
|
labels = append(labels, label)
|
|
}
|
|
}
|
|
return labels
|
|
}
|
|
|
|
// -----------------
|
|
// Discovery storage
|
|
// -----------------
|
|
|
|
// Discoveries helps to store instances of Discovery struct and access them in thread safe mode
|
|
type Discoveries struct {
|
|
activeServers []Discovery
|
|
LogChannel chan string
|
|
TTL uint
|
|
}
|
|
|
|
func (d *Discoveries) hostnameIndex(hostname string) int {
|
|
for idx, discovery := range d.activeServers {
|
|
if discovery.Hostname == hostname {
|
|
return idx
|
|
}
|
|
}
|
|
return -1
|
|
}
|
|
|
|
// Add appends a new discovery/server to the storage
|
|
func (d *Discoveries) Add(discovery Discovery) {
|
|
if d.Exist(discovery.Hostname) {
|
|
d.Refresh(discovery.Hostname)
|
|
|
|
idx := d.hostnameIndex(discovery.Hostname)
|
|
if idx >= 0 {
|
|
d.activeServers[idx].Labels = discovery.Labels
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
discovery.LastCheck = time.Now().Unix()
|
|
d.activeServers = append(d.activeServers, discovery)
|
|
if d.LogChannel != nil {
|
|
d.LogChannel <- fmt.Sprintf("%s registered", discovery.Hostname)
|
|
}
|
|
}
|
|
|
|
// Refresh updates
|
|
func (d *Discoveries) Refresh(hostname string) {
|
|
idx := d.hostnameIndex(hostname)
|
|
if idx >= 0 {
|
|
d.activeServers[idx].LastCheck = time.Now().Unix()
|
|
}
|
|
}
|
|
|
|
// Delete removes server identified by hostname from the storage
|
|
func (d *Discoveries) Delete(hostname string) {
|
|
if !d.Exist(hostname) {
|
|
return
|
|
}
|
|
|
|
if d.LogChannel != nil {
|
|
d.LogChannel <- fmt.Sprintf("removing %s", hostname)
|
|
}
|
|
|
|
newSet := []Discovery{}
|
|
for _, server := range d.activeServers {
|
|
if server.Hostname != hostname {
|
|
newSet = append(newSet, server)
|
|
}
|
|
}
|
|
d.activeServers = newSet
|
|
}
|
|
|
|
// Exist returns true if server with given hostname exists
|
|
func (d *Discoveries) Exist(hostname string) bool {
|
|
for _, server := range d.activeServers {
|
|
if server.Hostname == hostname {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
// Get returns Discovery struct with the given hostname but it can be also an empty struct if it's not found. Check if hostname is empty or use Exist first to be sure.
|
|
func (d *Discoveries) Get(hostname string) Discovery {
|
|
for _, server := range d.activeServers {
|
|
if server.Hostname == hostname {
|
|
return server
|
|
}
|
|
}
|
|
return Discovery{}
|
|
}
|
|
|
|
// GetAll returns copy of the internal storage
|
|
func (d *Discoveries) GetAll() []Discovery {
|
|
return d.activeServers
|
|
}
|
|
|
|
// Filter returns list of discoveries based on given labels
|
|
func (d *Discoveries) Filter(labelsFilter []string) []Discovery {
|
|
newSet := []Discovery{}
|
|
|
|
var found bool
|
|
if len(labelsFilter) > 0 {
|
|
for _, discovery := range d.activeServers {
|
|
found = false
|
|
for _, label := range discovery.Labels {
|
|
for _, labelFilter := range labelsFilter {
|
|
if label.String() == labelFilter {
|
|
newSet = append(newSet, discovery)
|
|
found = true
|
|
break
|
|
}
|
|
}
|
|
if found {
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
return newSet
|
|
}
|
|
|
|
// Filter returns list of discoveries based on given label prefixes.
|
|
func (d *Discoveries) FilterPrefix(prefixes []string) []Discovery {
|
|
newSet := []Discovery{}
|
|
|
|
var found bool
|
|
if len(prefixes) > 0 {
|
|
for _, discovery := range d.activeServers {
|
|
found = false
|
|
for _, label := range discovery.Labels {
|
|
for _, prefix := range prefixes {
|
|
if strings.HasPrefix(label.String(), prefix) {
|
|
newSet = append(newSet, discovery)
|
|
found = true
|
|
break
|
|
}
|
|
}
|
|
if found {
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
return newSet
|
|
}
|
|
|
|
// Clean checks loops over last check values for each discovery object and removes it if it's passed
|
|
func (d *Discoveries) Clean() {
|
|
newSet := []Discovery{}
|
|
for _, server := range d.activeServers {
|
|
server.TTL = d.TTL
|
|
if server.IsAlive() {
|
|
newSet = append(newSet, server)
|
|
} else {
|
|
if d.LogChannel != nil {
|
|
d.LogChannel <- fmt.Sprintf("%s not alive anymore", server.Hostname)
|
|
}
|
|
}
|
|
}
|
|
d.activeServers = newSet
|
|
}
|