viewgen

Documentation

Index

• func ViewJobWorker(jobChannel chan ViewJob, cancelChannel chan bool, ...)
• type ModelView
  • func GetModelViews(cloud, service, resource string, model interface{}) ([]ModelView, error)
• type ViewJob
  • func NewViewJob(ctx context.Context, name, view, catalog, database, workgroup string, ...) ViewJob
• type ViewJobProcessor
  • func NewViewJobProcessor(numWorkers, jobBufferLength int) *ViewJobProcessor
  • func (a *ViewJobProcessor) AddJob(job ViewJob)
  • func (a *ViewJobProcessor) Cancel()
  • func (a *ViewJobProcessor) Start()
  • func (a *ViewJobProcessor) WaitForCompletion()

Functions

func ViewJobWorker

func ViewJobWorker(jobChannel chan ViewJob, cancelChannel chan bool, jobWaitGroup, workerWaitGroup *sync.WaitGroup)

Types

type ModelView

type ModelView struct {
	Filename string
	View     string
	Name     string
}

func GetModelViews

func GetModelViews(cloud, service, resource string, model interface{}) ([]ModelView, error)

type ViewJob

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

func NewViewJob

func NewViewJob(ctx context.Context, name, view, catalog, database, workgroup string, athenaClient *athena.Client, errorChan chan<- error) ViewJob

type ViewJobProcessor

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

func NewViewJobProcessor

func NewViewJobProcessor(numWorkers, jobBufferLength int) *ViewJobProcessor

func (*ViewJobProcessor) AddJob

func (a *ViewJobProcessor) AddJob(job ViewJob)

func (*ViewJobProcessor) Cancel

func (a *ViewJobProcessor) Cancel()

func (*ViewJobProcessor) Start

func (a *ViewJobProcessor) Start()

func (*ViewJobProcessor) WaitForCompletion

func (a *ViewJobProcessor) WaitForCompletion()