sink

package

v0.2.0 Latest Latest Go to latest Published: Nov 5, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Slice struct {
	sync.RWMutex
	flow.ComponentState
	// contains filtered or unexported fields
}

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{}