api

Documentation

Index

• type APIManager
  • func (api *APIManager) Delete(ctx context.Context, job model.Job, destConfig map[string]interface{}, ...) model.JobStatus
  • func (bm *APIManager) GetSupportedDestinations() []string
• type JobRespSchema
• type Mock_apiWorker
  • func (d *Mock_apiWorker) Delete(ctx context.Context, job model.Job, destConfig map[string]interface{}, ...) model.JobStatus

Types

type APIManager

type APIManager struct {
	Client           *http.Client
	DestTransformURL string
}

func (*APIManager) Delete

func (api *APIManager) Delete(ctx context.Context, job model.Job, destConfig map[string]interface{}, destName string) model.JobStatus

prepares payload based on (job,destDetail) & make an API call to transformer. gets (status, failure_reason) which is converted to appropriate model.Error & returned to caller.

func (*APIManager) GetSupportedDestinations

func (bm *APIManager) GetSupportedDestinations() []string

type JobRespSchema

type JobRespSchema struct {
	Status string `json:"status"`
	Error  error  `json:"error"`
}

type Mock_apiWorker

type Mock_apiWorker struct {
}

func (*Mock_apiWorker) Delete

func (d *Mock_apiWorker) Delete(ctx context.Context, job model.Job, destConfig map[string]interface{}, destName string) model.JobStatus