Method GetServiceInstancesForSpace

actor/v7action/service_instance_list.go:30–89

(spaceGUID string, omitApps bool)

}

func (actor Actor) GetServiceInstancesForSpace(spaceGUID string, omitApps bool) ([]ServiceInstance, Warnings, error) {
	var (
		instances []resources.ServiceInstance
		bindings  []resources.ServiceCredentialBinding
		included  ccv3.IncludedResources
	)

	warnings, err := railway.Sequentially(
		func() (warnings ccv3.Warnings, err error) {
			instances, included, warnings, err = actor.CloudControllerClient.GetServiceInstances(
				ccv3.Query{Key: ccv3.SpaceGUIDFilter, Values: []string{spaceGUID}},
				ccv3.Query{Key: ccv3.FieldsServicePlan, Values: []string{"guid", "name", "relationships.service_offering"}},
				ccv3.Query{Key: ccv3.FieldsServicePlanServiceOffering, Values: []string{"guid", "name", "relationships.service_broker"}},
				ccv3.Query{Key: ccv3.FieldsServicePlanServiceOfferingServiceBroker, Values: []string{"guid", "name"}},
				ccv3.Query{Key: ccv3.OrderBy, Values: []string{ccv3.NameOrder}},
				ccv3.Query{Key: ccv3.PerPage, Values: []string{ccv3.MaxPerPage}},
			)
			return
		},
		func() (warnings ccv3.Warnings, err error) {
			if !omitApps {
				return batcher.RequestByGUID(
					extract.UniqueList("GUID", instances),
					func(guids []string) (ccv3.Warnings, error) {
						batch, warnings, err := actor.CloudControllerClient.GetServiceCredentialBindings(
							ccv3.Query{Key: ccv3.ServiceInstanceGUIDFilter, Values: guids},
							ccv3.Query{Key: ccv3.Include, Values: []string{"app"}},
						)
						bindings = append(bindings, batch...)
						return warnings, err
					},
				)
			}
			return
		},
	)
	if err != nil {
		return nil, Warnings(warnings), err
	}

	planDetailsFromPlanGUIDLookup := buildPlanDetailsLookup(included)
	boundAppsNamesFromInstanceGUIDLookup := buildBoundAppsLookup(bindings, spaceGUID)

	result := make([]ServiceInstance, len(instances))
	for i, instance := range instances {
		names := planDetailsFromPlanGUIDLookup[instance.ServicePlanGUID]
		result[i] = ServiceInstance{
			Name:                instance.Name,
			Type:                instance.Type,
			UpgradeAvailable:    instance.UpgradeAvailable,
			ServicePlanName:     names.plan,
			ServiceOfferingName: names.offering,
			ServiceBrokerName:   names.broker,
			BoundApps:           boundAppsNamesFromInstanceGUIDLookup[instance.GUID],
			LastOperation:       lastOperation(instance.LastOperation),
		}
	}