ingest

Documentation

Index

• Constants
• type IngestProcessor
  • func NewIngestProcessor(pool *disque.DisquePool, queueName string, database *dynamodb.DynamoDB) *IngestProcessor
  • func (i *IngestProcessor) Run()
  • func (i *IngestProcessor) Stop()

Constants

const (
	CONNECTION_POOL_ERROR_SLEEP_DURATION = 100 * time.Millisecond
)

Types

type IngestProcessor

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

func NewIngestProcessor

func NewIngestProcessor(pool *disque.DisquePool, queueName string, database *dynamodb.DynamoDB) *IngestProcessor

func (*IngestProcessor) Run

func (i *IngestProcessor) Run()

func (*IngestProcessor) Stop

func (i *IngestProcessor) Stop()