importqueue

Documentation

Index

• type ImportQueue
  • func CreateImportQueue(databakerQueue, v4Queue, cantabularQueue chan []byte) *ImportQueue
  • func (q *ImportQueue) Queue(ctx context.Context, job *models.ImportData) error

Types

type ImportQueue

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

ImportQueue used to send import jobs via kafka topic

func CreateImportQueue

func CreateImportQueue(databakerQueue, v4Queue, cantabularQueue chan []byte) *ImportQueue

CreateImportQueue used to queue data baker evenets and v4 files

func (*ImportQueue) Queue

func (q *ImportQueue) Queue(ctx context.Context, job *models.ImportData) error

Queue generates a kafka message for an import event, according to the provided job format