models

type EncryptedData struct {
	Type string `json:"type"`
	Data string `json:"data"`
}

type EncryptedStorage interface {
	Encrypt(ctx context.Context, data any) (EncryptedData, error)
	Decrypt(ctx context.Context, data EncryptedData, v any) error
}

type Endpoint struct {
	ID string `json:"id"` // ID of this endpoint (starting with vip-)

	// Full IP with mask (i.e. 10.0.0.1/32)
	// Deprecated: The IP is now stored in the ARP Plugin config. This field is kept for backward compatibility
	IP string `json:"ip"`

	Checks              HealthChecks `json:"checks,omitempty"`     // Health check configured with this Endpoint
	HealthCheckInterval int          `json:"healthcheck_interval"` // Health check Intervals for this Endpoint

	Plugin       string          `json:"plugin,omitempty"`        // Plugin to use for this Endpoint
	PluginConfig json.RawMessage `json:"plugin_config,omitempty"` // Plugin configuration
}

type EndpointLink struct {
	UpdatedAt time.Time `json:"updated_at"`
}

type Endpoints []Endpoint

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

type HealthCheck struct {
	Type api.HealthCheckType `json:"type"`
	Host string              `json:"host"`
	Port int                 `json:"port"`
}

type HealthChecks []HealthCheck

type Host struct {
	Hostname string `json:"hostname"` // Hostname of this host
	LeaseID  int64  `json:"lease_id"` // LeaseID current lease ID of this host
	// DataVersion is the version number of how the data is stored in etcd for this host. This field is introduced in 2.0.0. But the data format version v0 correspond to the format before v1.9.0.
	DataVersion int `json:"data_version,omitempty"`
}

type Storage interface {
	GetEndpoints(ctx context.Context) (Endpoints, error) // GetEndpoints configured for this host
	AddEndpoint(ctx context.Context, endpoint Endpoint) (Endpoint, error)
	UpdateEndpoint(ctx context.Context, endpoint Endpoint) error
	RemoveEndpoint(ctx context.Context, id string) error

	GetCurrentHost(ctx context.Context) (Host, error) // Get host configuration for the current host
	SaveHost(ctx context.Context, host Host) error    // Save host modifications

	LinkEndpointWithCurrentHost(ctx context.Context, key string) error   // Link an Endpoint to the current host
	UnlinkEndpointFromCurrentHost(ctx context.Context, key string) error // Unlink an Endpoint from the current host
	GetEndpointHosts(ctx context.Context, key string) ([]string, error)  // List all hosts linked to the Endpoint
}