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
	Spools     []SpoolOverview
}

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 writes src and returns the updated_at it stamped.
	Update(ctx context.Context, src whsource.Source) (time.Time, error)
	Delete(ctx context.Context, name string) error
}

type SpoolOverview struct {
	State     whstore.SpoolState
	Reporting bool
}

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
	SyncRaw(ctx context.Context, tg whtable.Target, src whsource.Source) error
	PartitionReadTime(ctx context.Context, tg whtable.Target, src whsource.Source) (time.Duration, 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, source string, now time.Time, span, step time.Duration) (whstore.Overview, error)
	ResourceIDs(ctx context.Context, source string) ([]string, error)
	// SpoolStates reads every receiver's spool state (#2121).
	SpoolStates(ctx context.Context) ([]whstore.SpoolState, error)
}