Add endpoint

refs #4

configobject/objecttypes/endpoint/endpoint.go

@@ -0,0 +1,77 @@
+package endpoint
+
+import (
+	"git.icinga.com/icingadb/icingadb-main/configobject"
+	"git.icinga.com/icingadb/icingadb-main/connection"
+	"git.icinga.com/icingadb/icingadb-main/utils"
+)
+
+var (
+	ObjectInformation configobject.ObjectInformation
+	Fields         = []string{
+		"id",
+		"env_id",
+		"name_checksum",
+		"properties_checksum",
+		"name",
+		"name_ci",
+		"zone_id",
+	}
+)
+
+type Endpoint struct {
+	Id                  string  `json:"id"`
+	EnvId               string  `json:"environment_id"`
+	NameChecksum        string  `json:"name_checksum"`
+	PropertiesChecksum  string  `json:"properties_checksum"`
+	Name                string  `json:"name"`
+	NameCi              *string `json:"name_ci"`
+	ZoneId            	string  `json:"zone_id"`
+}
+
+func NewEndpoint() connection.Row {
+	e := Endpoint{}
+	e.NameCi = &e.Name
+
+	return &e
+}
+
+func (e *Endpoint) InsertValues() []interface{} {
+	v := e.UpdateValues()
+
+	return append([]interface{}{utils.Checksum(e.Id)}, v...)
+}
+
+func (e *Endpoint) UpdateValues() []interface{} {
+	v := make([]interface{}, 0)
+
+	v = append(
+		v,
+		utils.Checksum(e.EnvId),
+		utils.Checksum(e.NameChecksum),
+		utils.Checksum(e.PropertiesChecksum),
+		e.Name,
+		e.NameCi,
+		utils.Checksum(e.ZoneId),
+	)
+
+	return v
+}
+
+func (e *Endpoint) GetId() string {
+	return e.Id
+}
+
+func (e *Endpoint) SetId(id string) {
+	e.Id = id
+}
+
+func init() {
+	ObjectInformation = configobject.ObjectInformation{
+		ObjectType: "endpoint",
+		Factory: NewEndpoint,
+		BulkInsertStmt: connection.NewBulkInsertStmt("endpoint", Fields),
+		BulkDeleteStmt: connection.NewBulkDeleteStmt("endpoint"),
+		BulkUpdateStmt: connection.NewBulkUpdateStmt("endpoint", Fields),
+	}
+}

main.go

@@ -88,6 +88,7 @@ func startConfigSyncOperators(super *supervisor.Supervisor, haInstance *ha.HA) {
 		&servicegroup.ObjectInformation,
 		&user.ObjectInformation,
 		&zone.ObjectInformation,
+		&endpoint.ObjectInformation,
 	}
 
 	for _, objectInformation := range objectTypes {