jobs

Documentation

Index

• func RegisterDataRetentionInterface(newInterface DataRetentionInterface)
• func RegisterElasticsearchAggregatorInterface(newInterface ElasticsearchAggregatorInterface)
• func RegisterElasticsearchIndexerInterface(newInterface ElasticsearchIndexerInterface)
• type DataRetentionInterface
  • func GetDataRetentionInterface() DataRetentionInterface
• type ElasticsearchAggregatorInterface
  • func GetElasticsearchAggregatorInterface() ElasticsearchAggregatorInterface
• type ElasticsearchIndexerInterface
  • func GetElasticsearchIndexerInterface() ElasticsearchIndexerInterface

Functions

func RegisterDataRetentionInterface

func RegisterDataRetentionInterface(newInterface DataRetentionInterface)

func RegisterElasticsearchAggregatorInterface

func RegisterElasticsearchAggregatorInterface(newInterface ElasticsearchAggregatorInterface)

func RegisterElasticsearchIndexerInterface

func RegisterElasticsearchIndexerInterface(newInterface ElasticsearchIndexerInterface)

Types

type DataRetentionInterface

type DataRetentionInterface interface {
	MakeWorker() model.Worker
	MakeScheduler() model.Scheduler
}

func GetDataRetentionInterface

func GetDataRetentionInterface() DataRetentionInterface

type ElasticsearchAggregatorInterface

type ElasticsearchAggregatorInterface interface {
	MakeWorker() model.Worker
	MakeScheduler() model.Scheduler
}

func GetElasticsearchAggregatorInterface

func GetElasticsearchAggregatorInterface() ElasticsearchAggregatorInterface

type ElasticsearchIndexerInterface

type ElasticsearchIndexerInterface interface {
	MakeWorker() model.Worker
}

func GetElasticsearchIndexerInterface

func GetElasticsearchIndexerInterface() ElasticsearchIndexerInterface