service

Documentation

Overview

*

• Copyright (c) 2015 Intel Corporation *
• Licensed under the Apache License, Version 2.0 (the "License");
• you may not use this file except in compliance with the License.
• You may obtain a copy of the License at *
• http://www.apache.org/licenses/LICENSE-2.0 *
• Unless required by applicable law or agreed to in writing, software
• distributed under the License is distributed on an "AS IS" BASIS,
• WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
• See the License for the specific language governing permissions and
• limitations under the License.

*

• Copyright (c) 2015 Intel Corporation *
• Licensed under the Apache License, Version 2.0 (the "License");
• you may not use this file except in compliance with the License.
• You may obtain a copy of the License at *
• http://www.apache.org/licenses/LICENSE-2.0 *
• Unless required by applicable law or agreed to in writing, software
• distributed under the License is distributed on an "AS IS" BASIS,
• WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
• See the License for the specific language governing permissions and
• limitations under the License.

Index

• type CfMock
  • func (c *CfMock) CheckIfServiceExists(serviceName string) error
  • func (c *CfMock) Deprovision(appGUID string) error
  • func (c *CfMock) Provision(sourceAppGUID string, servicesConfiguration []*extension.ServiceConfiguration, ...) (*extension.ServiceCreationResponse, error)
  • func (c *CfMock) UpdateBroker(brokerName string, brokerUri string, username string, password string) error
• type CreationStatusFactory
  • func (f CreationStatusFactory) NewServiceStatus(name string, stype string, org string, msg string) messagebus.Message
• type LaunchingService
  • func New(db dao.Facade, cloud cloud.API, natsInstance messagebus.MessageBus, ...) *LaunchingService
  • func (p *LaunchingService) BindService(r *cf.ServiceBindingRequest) (*types.ServiceBindingResponse, error)
  • func (p *LaunchingService) CreateService(r *cf.ServiceCreationRequest) (*cf.ServiceCreationResponse, error)
  • func (p *LaunchingService) DeleteFromCatalog(serviceID string) error
  • func (p *LaunchingService) DeleteService(instanceID string) error
  • func (p *LaunchingService) GetCatalog() (*extension.CatalogExtension, error)
  • func (p *LaunchingService) InsertToCatalog(svc *extension.ServiceExtension) error
  • func (p *LaunchingService) UpdateBroker() error
  • func (p *LaunchingService) UpdateCatalog(svc *extension.ServiceExtension) error
• type ServiceCreationStatus

Types

type CfMock

type CfMock struct {
	mock.Mock
}

func (*CfMock) CheckIfServiceExists

func (c *CfMock) CheckIfServiceExists(serviceName string) error

func (*CfMock) Deprovision

func (c *CfMock) Deprovision(appGUID string) error

func (*CfMock) Provision

func (c *CfMock) Provision(sourceAppGUID string,
	servicesConfiguration []*extension.ServiceConfiguration,
	request *cf.ServiceCreationRequest) (*extension.ServiceCreationResponse, error)

func (*CfMock) UpdateBroker

func (c *CfMock) UpdateBroker(brokerName string, brokerUri string, username string, password string) error

type CreationStatusFactory

type CreationStatusFactory struct {
}

func (CreationStatusFactory) NewServiceStatus

func (f CreationStatusFactory) NewServiceStatus(name string, stype string, org string, msg string) messagebus.Message

type LaunchingService

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

LaunchingService wraps access to db, cloud controller and messagebus

func New

func New(db dao.Facade, cloud cloud.API, natsInstance messagebus.MessageBus, messageFactory messagebus.MessageFactory) *LaunchingService

New creates an instance of the LaunchingService

func (*LaunchingService) BindService

func (p *LaunchingService) BindService(r *cf.ServiceBindingRequest) (*types.ServiceBindingResponse, error)

BindService creates a (service instance <-> application) binding

func (*LaunchingService) CreateService

func (p *LaunchingService) CreateService(r *cf.ServiceCreationRequest) (*cf.ServiceCreationResponse, error)

CreateService creates a service instance

func (*LaunchingService) DeleteFromCatalog

func (p *LaunchingService) DeleteFromCatalog(serviceID string) error

DeleteFromCatalog deletes data pointing to reference application from internal storage

func (*LaunchingService) DeleteService

func (p *LaunchingService) DeleteService(instanceID string) error

DeleteService deletes service instance and its dependencies

func (*LaunchingService) GetCatalog

func (p *LaunchingService) GetCatalog() (*extension.CatalogExtension, error)

GetCatalog parses catalog response

func (*LaunchingService) InsertToCatalog

func (p *LaunchingService) InsertToCatalog(svc *extension.ServiceExtension) error

InsertToCatalog adds new application description that can be spawned/duplicated on demand Description is stored in underlying implementation of Catalog interface

func (*LaunchingService) UpdateBroker

func (p *LaunchingService) UpdateBroker() error

func (*LaunchingService) UpdateCatalog

func (p *LaunchingService) UpdateCatalog(svc *extension.ServiceExtension) error

UpdateCatalog update application description that can be spawned/duplicated on demand Description is stored in underlying implementation of Catalog interface

type ServiceCreationStatus

type ServiceCreationStatus struct {
	ServiceName string
	ServiceType string
	OrgGuid     string
	Message     string
	Timestamp   int64
}