iterator

Feb 10, 2026

Changes in this version

+ func Error[T any](err error) storage.Iterator[T]

+ func Validate[T any](base storage.Iterator[T], fn func(T) (bool, error)) storage.Iterator[T]

Nov 5, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Nov 5, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Nov 4, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Oct 14, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Sep 30, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Sep 22, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Sep 11, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Aug 15, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Aug 13, 2025 GO-2025-3894 +1 more

  GO-2025-3894: OpenFGA Authorization Bypass in github.com/openfga/openfga

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Aug 11, 2025 GO-2025-3894 +1 more

  GO-2025-3894: OpenFGA Authorization Bypass in github.com/openfga/openfga

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Jul 24, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Jul 3, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Jun 17, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Jun 11, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Changes in this version

+ func FanInIteratorChannels(ctx context.Context, chans []<-chan *Msg) <-chan *Msg

Jun 10, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

May 22, 2025 GO-2025-4150

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Changes in this version

+ func Drain(ch chan *Msg) *sync.WaitGroup

type FanIn

+ func (f *FanIn) Stop()

May 13, 2025 GO-2025-3707 +1 more

  GO-2025-3707: OpenFGA Authorization Bypass in github.com/openfga/openfga

  GO-2025-4150: OpenFGA Improper Policy Enforcement in github.com/openfga/openfga

Changes in this version

+ func NextItemInSliceStreams(ctx context.Context, streamSlices []*Stream, streamToProcess []int) (string, error)

+ type FanIn struct

+ func NewFanIn(ctx context.Context, limit int) *FanIn

+ func (f *FanIn) Add(ch chan *Msg)

+ func (f *FanIn) Close()

+ func (f *FanIn) Count() int

+ func (f *FanIn) Done()

+ func (f *FanIn) Out() chan *Msg

+ type Msg struct

+ Err error

+ Iter storage.Iterator[string]

+ type Stream struct

+ func NewStream(idx int, source chan *Msg) *Stream

+ func (s *Stream) Drain(ctx context.Context) ([]string, error)

+ func (s *Stream) Head(ctx context.Context) (string, error)

+ func (s *Stream) Idx() int

+ func (s *Stream) Next(ctx context.Context) (string, error)

+ func (s *Stream) SkipToTargetObject(ctx context.Context, target string) error

+ func (s *Stream) Stop()

+ type Streams struct

+ func NewStreams(streams []*Stream) *Streams

+ func (s *Streams) CleanDone(ctx context.Context) ([]*Stream, error)

+ func (s *Streams) GetActiveStreamsCount() int

+ func (s *Streams) Stop()