layers

type DatasetRequest struct {
	DatasetName string
	Since       string
	Limit       int64
}

type Layer struct {
	Repo *Repository //exported because it needs to deferred from main
	// contains filtered or unexported fields
}

type PostLayer struct {
	PostRepo *PostRepository //exported because it needs to deferred from main??
	// contains filtered or unexported fields
}

type PostRepository struct {
	DB *pgxpool.Pool
	// contains filtered or unexported fields
}

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

type ReadableDataset interface {
	Read(ctx context.Context, entities chan<- *uda.Entity) error
	ReadChanges(ctx context.Context, since string, entities chan<- *uda.Entity) (string, error)
}

type Repository struct {
	DB *pgxpool.Pool
	// contains filtered or unexported fields
}

type WriteableDataset interface {
	Write(ctx context.Context, entities <-chan *uda.Entity, entityContext *uda.Context) error
}