controller

type Async interface {
	Run()
	AddAsyncInstance(instanceInfo *InstanceRunInfo, persistent bool) error
	DeleteAsyncInstance(instanceID string) error
	UpdateAsyncInstance(instanceInfo *InstanceRunInfo) error
	GetAsyncInstance(instanceId string) *InstanceRunInfo
	GetAsyncBinding(instanceId, bindingID string) *BindRunInfo
	GetProvisionInstanceLastOperation(instanceInfo *InstanceRunInfo)
	GetDeprovisionInstanceLastOperation(instanceInfo *InstanceRunInfo)
	GetBindingLastOperation(instanceInfo *InstanceRunInfo, bindInfo *BindRunInfo)
	GetUnBindingLastOperation(instanceInfo *InstanceRunInfo, bindInfo *BindRunInfo)
}

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

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

type BindRunInfo struct {
	BindingId string
	Status    string
	Parameter map[string]interface{}
}

type BindingLastOperationPayload struct {
	InstanceID string
	BindingID  string
	Request    brokerapi.BindingLastOperationRequest
	Result     chan brokerapi.WorkerResponse
}

type BindingPayload struct {
	InstanceID string
	BindingID  string
	Request    brokerapi.BindingRequest
	Result     chan brokerapi.WorkerResponse
}

type CreateServiceInstancePayload struct {
	InstanceID string
	Request    brokerapi.CreateServiceInstanceRequest
	Result     chan brokerapi.WorkerResponse
}

type DeleteServiceInstancePayload struct {
	InstanceID string
	Request    brokerapi.DeleteServiceInstanceRequest
	Result     chan brokerapi.WorkerResponse
}

type InstanceLastOperationPayload struct {
	InstanceID string
	Request    brokerapi.LastOperationRequest
	Result     chan brokerapi.WorkerResponse
}

type InstanceRunInfo struct {
	InstanceId string
	ServiceID  string
	PlanID     string
	Bindings   map[string]*BindRunInfo
	Status     string
	BrokerName string
	Parameter  map[string]interface{}
}

type Storage interface {
	Init()
	WriteObject(instanceInfo InstanceRunInfo)
	GetObject(instanceID string) (InstanceRunInfo, error)
	DeleteObject(instanceID string)

	GetAllObject() ([]*InstanceRunInfo, error)
}

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

type UnBindingPayload struct {
	InstanceID string
	BindingID  string
	PlanID     string
	ServiceID  string
	Result     chan brokerapi.WorkerResponse
}