interfaces

Documentation

Index

• Variables
• type Api
• type GcpHandler
• type GcpInteractor
• type GcpRepo
• type LocalFileSystemRepo
  • func NewLocalRepo(localHandlers map[string]LocalHandler) *LocalFileSystemRepo
  • func (repo *LocalFileSystemRepo) FileExists(fileName string) (fileExists bool, err error)
• type LocalHandler
• type LocalInteractor
• type LocalRepo
• type SinkBucketRepo
  • func NewSinkBucketRepo(gcpHandlers map[string]GcpHandler) *SinkBucketRepo
  • func (repo *SinkBucketRepo) DownloadFile(fileName string) (success bool, err error)
  • func (repo *SinkBucketRepo) FileExists(fileName string) (fileExists bool, err error)
  • func (repo *SinkBucketRepo) List(projectId string) (buckets []domain.Bucket, err error)
  • func (repo *SinkBucketRepo) ListFileNamesToFetch(fileName string) (cloudFiles domain.CloudFiles, err error)
  • func (repo *SinkBucketRepo) UploadFile(fileName string) (success bool, err error)
• type SourceBucketRepo
  • func NewSourceBucketRepo(gcpHandlers map[string]GcpHandler) *SourceBucketRepo
  • func (repo *SourceBucketRepo) DownloadFile(fileName string) (success bool, err error)
  • func (repo *SourceBucketRepo) FileExists(fileName string) (fileExists bool, err error)
  • func (repo *SourceBucketRepo) List(projectId string) (buckets []domain.Bucket, err error)
  • func (repo *SourceBucketRepo) UploadFile(fileName string) (success bool, err error)
• type WebserviceHandler
  • func (handler WebserviceHandler) DownloadFile(res http.ResponseWriter, req *http.Request)
  • func (handler WebserviceHandler) Health(res http.ResponseWriter, req *http.Request)
  • func (handler WebserviceHandler) ListSinkBuckets(res http.ResponseWriter, req *http.Request)
  • func (handler WebserviceHandler) ListSourceBuckets(res http.ResponseWriter, req *http.Request)
  • func (handler WebserviceHandler) LocalFileExists(res http.ResponseWriter, req *http.Request)
  • func (handler WebserviceHandler) SourceFileExists(res http.ResponseWriter, req *http.Request)
  • func (handler WebserviceHandler) UploadFile(res http.ResponseWriter, req *http.Request)

Variables

var ErrorResponse = []byte("Error")

Types

type Api

type Api struct {
	Handler func(res http.ResponseWriter, req *http.Request)
	Url     string
}

type GcpHandler

type GcpHandler interface {
	ListBuckets(flowType domain.FlowType, projectId string) (buckets []domain.Bucket, err error)
	FileExists(fileName string) (fileExists bool, err error)
	DownloadFile(fileName string) (success bool, err error)
	UploadFile(fileName string) (success bool, err error)
}

type GcpInteractor

type GcpInteractor interface {
	ListSourceBuckets(projectId string) (buckets []domain.Bucket, err error)
	ListSinkBuckets(projectId string) (buckets []domain.Bucket, err error)
	SourceFileExists(fileName string) (fileExists bool, err error)
	DownloadFile(fileName string) (success bool, err error)
	UploadFile(fileName string) (success bool, err error)
}

type GcpRepo

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

type LocalFileSystemRepo

type LocalFileSystemRepo LocalRepo

func NewLocalRepo

func NewLocalRepo(localHandlers map[string]LocalHandler) *LocalFileSystemRepo

func (*LocalFileSystemRepo) FileExists

func (repo *LocalFileSystemRepo) FileExists(fileName string) (fileExists bool, err error)

type LocalHandler

type LocalHandler interface {
	FileExists(fileName string) (fileExists bool, err error)
}

type LocalInteractor

type LocalInteractor interface {
	LocalFileExists(fileName string) (fileExists bool, err error)
}

type LocalRepo

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

type SinkBucketRepo

type SinkBucketRepo GcpRepo

func NewSinkBucketRepo

func NewSinkBucketRepo(gcpHandlers map[string]GcpHandler) *SinkBucketRepo

func (*SinkBucketRepo) DownloadFile

func (repo *SinkBucketRepo) DownloadFile(fileName string) (success bool, err error)

DownloadFile is not operational for a sink bucket

func (*SinkBucketRepo) FileExists

func (repo *SinkBucketRepo) FileExists(fileName string) (fileExists bool, err error)

func (*SinkBucketRepo) List

func (repo *SinkBucketRepo) List(projectId string) (buckets []domain.Bucket, err error)

func (*SinkBucketRepo) ListFileNamesToFetch

func (repo *SinkBucketRepo) ListFileNamesToFetch(fileName string) (cloudFiles domain.CloudFiles, err error)

ListFileNamesToFetch is not operational for a sink bucket

func (*SinkBucketRepo) UploadFile

func (repo *SinkBucketRepo) UploadFile(fileName string) (success bool, err error)

type SourceBucketRepo

type SourceBucketRepo GcpRepo

func NewSourceBucketRepo

func NewSourceBucketRepo(gcpHandlers map[string]GcpHandler) *SourceBucketRepo

func (*SourceBucketRepo) DownloadFile

func (repo *SourceBucketRepo) DownloadFile(fileName string) (success bool, err error)

func (*SourceBucketRepo) FileExists

func (repo *SourceBucketRepo) FileExists(fileName string) (fileExists bool, err error)

func (*SourceBucketRepo) List

func (repo *SourceBucketRepo) List(projectId string) (buckets []domain.Bucket, err error)

func (*SourceBucketRepo) UploadFile

func (repo *SourceBucketRepo) UploadFile(fileName string) (success bool, err error)

UploadFile is not operational for a source bucket

type WebserviceHandler

type WebserviceHandler struct {
	LocalInteractor LocalInteractor
	GcpInteractor   GcpInteractor
}

func (WebserviceHandler) DownloadFile

func (handler WebserviceHandler) DownloadFile(res http.ResponseWriter, req *http.Request)

func (WebserviceHandler) Health

func (handler WebserviceHandler) Health(res http.ResponseWriter, req *http.Request)

func (WebserviceHandler) ListSinkBuckets

func (handler WebserviceHandler) ListSinkBuckets(res http.ResponseWriter, req *http.Request)

func (WebserviceHandler) ListSourceBuckets

func (handler WebserviceHandler) ListSourceBuckets(res http.ResponseWriter, req *http.Request)

func (WebserviceHandler) LocalFileExists

func (handler WebserviceHandler) LocalFileExists(res http.ResponseWriter, req *http.Request)

func (WebserviceHandler) SourceFileExists

func (handler WebserviceHandler) SourceFileExists(res http.ResponseWriter, req *http.Request)

func (WebserviceHandler) UploadFile

func (handler WebserviceHandler) UploadFile(res http.ResponseWriter, req *http.Request)