async

Documentation

Index

• Variables
• func New(ctx context.Context, storage linker.Storage) (linker.Linker, error)

Variables

var DocumentCountStat = stats.Int64("linker/documents/total", "Count of documents", "1")

DocumentCountStat .

var DocumentCountView = &view.View{
	Name:        "document/count",
	Measure:     DocumentCountStat,
	Description: "The number of documents stored in linker",
	TagKeys:     []tag.Key{},
	Aggregation: view.Count(),
}

DocumentCountView .

var DocumentQueuedCountStat = stats.Int64("linker/documents/queue/total", "Count of queued documents", "1")

DocumentQueuedCountStat .

var DocumentQueuedCountView = &view.View{
	Name:        "document/queue/count",
	Measure:     DocumentQueuedCountStat,
	Description: "The number of documents stored in linker",
	TagKeys:     []tag.Key{},
	Aggregation: view.Count(),
}

DocumentQueuedCountView .

Functions

func New

func New(ctx context.Context, storage linker.Storage) (linker.Linker, error)

New Linker for processing and persisting documents