internal

package

v0.7.18 Latest Latest Go to latest Published: Jan 5, 2026 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(typ reflect.Type) func(reflect.Value) (reflect.Value, error)

func GetMergeFunc(typ reflect.Type) func([]any) (any, error)

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

func RegisterValuesMergeFunc[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
core
generic
gmap
gslice
mock Package mock provides mock implementations for testing purposes.	Package mock provides mock implementations for testing purposes.
adk Package adk is a generated GoMock package.	Package adk is a generated GoMock package.
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