configsnapshot

type AuthReader interface {
	List(ctx context.Context, filter authdomain.ListFilter) ([]*authdomain.Auth, int, error)
}

type CatalogReader interface {
	ListProviders(ctx context.Context) ([]catalogdomain.Provider, error)
	ListModelsByProviderCode(ctx context.Context, providerCode string) ([]catalogdomain.Model, error)
}

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

type ConsumerReader interface {
	ListByGateway(ctx context.Context, gatewayID ids.GatewayID) ([]*consumerdomain.Consumer, error)
}

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

type DispatcherConfig struct {
	Debounce  time.Duration
	Backstop  time.Duration
	Retention time.Duration
	MaxRows   int
}

type GatewayReader interface {
	List(ctx context.Context, filter gatewaydomain.ListFilter) ([]*gatewaydomain.Gateway, int, error)
}

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

type PartitionedCompiler interface {
	CompileAll(ctx context.Context) (*readmodel.Snapshot, map[string]*readmodel.Snapshot, error)
}

type PolicyReader interface {
	ListByGateway(ctx context.Context, gatewayID ids.GatewayID) ([]*policydomain.Policy, error)
}

type RegistryReader interface {
	List(ctx context.Context, filter registrydomain.ListFilter) ([]*registrydomain.Registry, int, error)
}

type RoleReader interface {
	ListByGateway(ctx context.Context, gatewayID ids.GatewayID) ([]*roledomain.Role, error)
}

type ScopedSnapshot struct {
	Raw     []byte
	Version string
}

type Signaler interface {
	Signal()
}

type SnapshotCompiler interface {
	Compile(ctx context.Context) (*readmodel.Snapshot, error)
}

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