handler

Documentation

Index

• type IngestHandler
  • func NewIngestHandler(indexer indexer.Interface, ingester *ingest.Ingester, ...) *IngestHandler
  • func (h *IngestHandler) Announce(an message.Message) error
  • func (h *IngestHandler) IndexContent(ctx context.Context, data []byte) error
  • func (h *IngestHandler) RegisterProvider(ctx context.Context, data []byte) error

Types

type IngestHandler

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

IngestHandler provides request handling functionality for the ingest server that is common to all protocols

func NewIngestHandler

func NewIngestHandler(indexer indexer.Interface, ingester *ingest.Ingester, registry *registry.Registry) *IngestHandler

func (*IngestHandler) Announce

func (h *IngestHandler) Announce(an message.Message) error

func (*IngestHandler) IndexContent

func (h *IngestHandler) IndexContent(ctx context.Context, data []byte) error

IndexContent handles an IngestRequest

Returning error is the same as return apierror.New(err, http.StatusBadRequest)

func (*IngestHandler) RegisterProvider

func (h *IngestHandler) RegisterProvider(ctx context.Context, data []byte) error