indexer

Documentation

Index

• func InitAndRun(conf config.Reader, store store.Store, ds store.DataStore, nats nats.Client) error
• type ActionIDs
• type IDs
• type Indexer
  • func NewIndexer(store store.Store, ds store.DataStore, nats nats.Client, ...) Indexer
• type TenantActionIDs

Functions

func InitAndRun

func InitAndRun(conf config.Reader, store store.Store, ds store.DataStore, nats nats.Client) error

InitAndRun initializes the indexer and runs it

Types

type ActionIDs

type ActionIDs map[string]IDs

type IDs

type IDs map[string]bool

type Indexer

type Indexer interface {
	GetJobs(ctx context.Context, jobs chan model.Job) error
	ProcessJobs(ctx context.Context, jobs []model.Job)
}

func NewIndexer

func NewIndexer(
	store store.Store,
	ds store.DataStore,
	nats nats.Client,
	devClient deviceauth.Client,
	invClient inventory.Client,
	deplClient deployments.Client,
) Indexer

type TenantActionIDs

type TenantActionIDs map[string]ActionIDs