node

type CleanableResource interface {
	GetResources() map[string]*ServiceEntry
}

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

type Command struct {
	Type string `json:"type"`
	Key  string `json:"key"`
	// some commands don't have a value such as `DELETE` and `GET`
	Value string `json:"value,omitempty"`
}

type DelRequest struct {
	Name     string
	Instance InstanceEntry
}

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

type Instance struct {
	Port   uint16 `json:"port"`
	Host   string `json:"host"`
	Uptime uint64 `json:"uptime"`
}

type InstanceEntry struct {
	Port       uint16
	Host       string
	LastBeatMs uint64
	Created    time.Time
}

type InstanceRegistration struct {
	ServiceName string `json:"service"`
	Host        string `json:"host"`
	Port        uint16 `json:"port"`
}

type JoinRequest struct {
	Id   string `json:"id"`
	Addr string `json:"addr"`
}

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

type Service struct {
	Name      string     `json:"name"`
	Instances []Instance `json:"instances"`
}

type ServiceEntry struct {
	Name      string
	Instances []*InstanceEntry
}

type ServicesResponse struct {
	Services []Service
}

type StorageEngine interface {
	// Inherit the behaviour of a Raft state machine.
	raft.FSM

	// Inherit the CleanableReource
	CleanableResource

	// Put the key-value pair into the underlying storage, and return an error if it's not possible to
	// finish the operation.
	Put(string, string) error

	// Get the value identified by the given key.
	Get(string) (string, error)

	// Delete the value identifier by the given key from the underlying storage,
	// and return it.
	Delete(string) (string, error)

	// GetServices will return the list of known live services to the heartbeat service
	// at query time.
	GetServices() *ServicesResponse

	// RegisterInstance will update the store's service list with the new
	// instance, This is usually resulting from a new service starting somewhere,
	// and doing a heartbeat request.
	RegisterInstance(InstanceRegistration)

	// DeleteInstance will delete the corresponding entry (instance) from the replicated
	// state machine
	DeleteInstance(string, InstanceEntry)
}