whadmin

type Deps struct {
	Sources       Sources
	Tables        Tables
	Registrations Registrations
	Windows       Windows
	Objects       Objects
	Resources     Resources
	Bucket        string
	// Changed is called after every write, so this replica's receiver
	// serves the change at once rather than at its next refresh.
	Changed func()
	// PersonaExists reports whether a persona is defined, so a source cannot
	// name one nobody belongs to. Nil accepts any name.
	PersonaExists func(name string) bool
	NewID         func() (string, error)
	Logger        *slog.Logger
	Now           func() time.Time
}

type Health string

type Objects interface {
	ListKeys(ctx context.Context, bucket, prefix string) ([]string, error)
	DeleteObject(ctx context.Context, bucket, key string) error
}

type Overview struct {
	Now        time.Time
	Since      time.Time
	Step       time.Duration
	Sources    []SourceOverview
	Volume     []whstore.VolumePoint
	Rejections []whstore.Rejection
}

type Registrations interface {
	Insert(ctx context.Context, r tableregister.Registration) error
	ByName(ctx context.Context, connection, catalog, schema, table string) (*tableregister.Registration, error)
	BySource(ctx context.Context, kind, sourceID string) ([]tableregister.Registration, error)
	Delete(ctx context.Context, id string) error
}

type Resources interface {
	Delete(ctx context.Context, id string) error
}

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

type SourceOverview struct {
	Source  whsource.Source
	Health  Health
	Summary whstore.Summary
}

type Sources interface {
	List(ctx context.Context) ([]whsource.Source, error)
	Get(ctx context.Context, name string) (whsource.Source, error)
	Create(ctx context.Context, src whsource.Source) error
	Update(ctx context.Context, src whsource.Source) error
	Delete(ctx context.Context, name string) error
}

type Tables interface {
	TargetFor(connection string) (whtable.Target, error)
	S3Location(prefix string) string
	Create(ctx context.Context, tg whtable.Target, src whsource.Source) error
	Probe(ctx context.Context, tg whtable.Target, src whsource.Source) error
	Drop(ctx context.Context, tg whtable.Target, src whsource.Source) error
}

type Update struct {
	Enabled *bool
	Auth    whsource.Auth
	Config  whsource.Config
	// RotationOverlap keeps the previous secret valid this long when Auth
	// carries a new one. Zero ends it at once.
	RotationOverlap time.Duration
}

type Windows interface {
	Status(ctx context.Context, source string, now time.Time) (whstore.Status, error)
	Overview(ctx context.Context, now time.Time, span, step time.Duration) (whstore.Overview, error)
	ResourceIDs(ctx context.Context, source string) ([]string, error)
}