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
	}

	clusterIntegration := pdApi.Integration{
		Name: "Test",
		Type: "events_api_v2_inbound_integration_reference",
	}

	newInt, err := client.CreateIntegration(newSvc.ID, clusterIntegration)
	if err != nil {
		return "", err
	}

	return newInt.ID, nil
}