api

Documentation

Index

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

Types

type APIManager

type APIManager struct {
	Client                       *http.Client
	DestTransformURL             string
	OAuth                        oauth.Authorizer
	MaxOAuthRefreshRetryAttempts int
}

func (*APIManager) Delete

func (api *APIManager) Delete(ctx context.Context, job model.Job, destination model.Destination) 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 (*APIManager) GetSupportedDestinations() []string

type JobRespSchema

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

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.Status