handler

Documentation

Overview

Package handler provides an eventsocket.Handler which creates JSON files in response to UUID Open events.

Index

• type ThreadedHandler
  • func New(datadir string, buffersize int, annotators []annotator.Annotator) ThreadedHandler

Types

type ThreadedHandler

type ThreadedHandler interface {
	eventsocket.Handler
	ProcessIncomingRequests(ctx context.Context)
}

ThreadedHandler is an eventsocket.Handler that has a separate method for handling incoming requests in a separate goroutine, to ensure that event notifications are not missed.

func New

func New(datadir string, buffersize int, annotators []annotator.Annotator) ThreadedHandler

New creates an eventsocket.Handler that saves the metadata for each file. The actual handling of each event is in a separate goroutine that should be started by calling ProcessIncomingRequests. This two-part handling is there to ensure that events arriving close together are not missed, even if disk IO latency is high.