eqldbsync

Documentation

Overview

Package eqldbsync uploads durable parser observations independently of any frontend. It does not participate in logfile replay or UI representation.

Index

• type API
• type Runner
  • func Default(onError func(error)) (*Runner, error)
  • func (r *Runner) Run(ctx context.Context)
  • func (r *Runner) Trigger()

Types

type API

type API interface {
	SubmitPlaneOfSkyEvents(context.Context, string, string, string, []eqldb.PlaneOfSkyEvent) error
	SubmitKillObservations(context.Context, string, []eqldb.KillObservation) error
	SubmitDropObservations(context.Context, string, []eqldb.DropObservation) error
}

type Runner

type Runner struct {
	Client  API
	Store   eqldb.Store
	Queue   *eqldbqueue.Queue
	OnError func(error)
	// contains filtered or unexported fields
}

func Default

func Default(onError func(error)) (*Runner, error)

func (*Runner) Run

func (r *Runner) Run(ctx context.Context)

func (*Runner) Trigger

func (r *Runner) Trigger()

Trigger asks the background runner to retry immediately. The buffered wake channel deliberately coalesces repeated queue and connection notifications.