gistfile1.txt

// CreateService creates a service in pagerduty for the specified clusterid and returns the service key
func (data *Data) CreateService() (string, error) {
	client := pdApi.NewClient(data.APIKey)

	escalationPolicy, err := client.GetEscalationPolicy(string(data.escalationPolicyID), nil)
	if err != nil {
		return "", errors.New("Escalation policy not found in PagerDuty")
	}

	clusterService := pdApi.Service{
		Name:                   data.servicePrefix + "-" + data.ClusterID + "." + data.BaseDomain + "-hive-cluster",
		Description:            data.ClusterID + " - A managed hive created cluster",
		EscalationPolicy:       *escalationPolicy,
		AutoResolveTimeout:     &data.autoResolveTimeout,
		AcknowledgementTimeout: &data.acknowledgeTimeOut,
	}

	newSvc, err := client.CreateService(clusterService)
	if err != nil {
		return "", err
	}

	venderSearch, err := client.ListVendors(pdApi.ListVendorOptions{Query: "Prometheus"})
	if err != nil {
		return "", err
	}

	promVendor, err := client.GetVendor(venderSearch.Vendors[0].ID)
	if err != nil {
		return "", err
	}

	promIntergration := pdApi.Integration{}
	promIntergration.Vendor = &promVendor.APIObject
	promIntergration.Type = "derpv2"
	newIntergration, err := client.CreateIntegration(newSvc.ID, promIntergration)
	if err != nil {
		return "", err
	}

	return newIntergration.ID, nil
}