Documentation ¶ Index ¶ type Slice func NewSlice() *Slice func (s *Slice) In() chan<- flow.StreamRecord func (s *Slice) Setup(ctx context.Context) error func (s *Slice) Teardown(ctx context.Context) error func (s *Slice) Value() []interface{} Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Slice ¶ type Slice struct { sync.RWMutex flow.ComponentState // contains filtered or unexported fields } func NewSlice ¶ func NewSlice() *Slice func (*Slice) In ¶ func (s *Slice) In() chan<- flow.StreamRecord func (*Slice) Setup ¶ func (s *Slice) Setup(ctx context.Context) error func (*Slice) Teardown ¶ func (s *Slice) Teardown(ctx context.Context) error func (*Slice) Value ¶ func (s *Slice) Value() []interface{} Source Files ¶ View all Source files slice.go Click to show internal directories. Click to hide internal directories.