internal

package

v0.3.24 Latest Latest Go to latest Published: Apr 17, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func ConcatItems[T any](items []T) (T, error)

ConcatItems the caller should ensure len(items) > 1

func GetConcatFunc(tpe reflect.Type) func(reflect.Value) (reflect.Value, error)

func RegisterStreamChunkConcatFunc[T any](fn func([]T) (T, error))

type UnboundedChan[T any] struct {
	// contains filtered or unexported fields
}

UnboundedChan represents a channel with unlimited capacity

func NewUnboundedChan[T any]() *UnboundedChan[T]

NewUnboundedChan initializes and returns an UnboundedChan

func (ch *UnboundedChan[T]) Close()

Close marks the channel as closed

func (ch *UnboundedChan[T]) Receive() (T, bool)

Receive gets an item from the channel (blocks if empty)

func (ch *UnboundedChan[T]) Send(value T)

Send puts an item into the channel

Path	Synopsis
callbacks
generic
gmap
gslice
mock Package mock provides mock implementations for testing purposes.	Package mock provides mock implementations for testing purposes.
components/document Package document is a generated GoMock package.	Package document is a generated GoMock package.
components/embedding Package embedding is a generated GoMock package.	Package embedding is a generated GoMock package.
components/indexer Package indexer is a generated GoMock package.	Package indexer is a generated GoMock package.
components/model Package model is a generated GoMock package.	Package model is a generated GoMock package.
components/retriever Package retriever is a generated GoMock package.	Package retriever is a generated GoMock package.
safe
serialization