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 Objects interface {
	ListKeys(ctx context.Context, bucket, prefix string) ([]string, error)
	DeleteObject(ctx context.Context, bucket, key string) error
}

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 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)
	ResourceIDs(ctx context.Context, source string) ([]string, error)
}