internal

package

v0.9.0-alpha.10 Latest Latest Go to latest Published: Mar 27, 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 ConcatSliceValue(val reflect.Value) (reflect.Value, error)

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]) PushFront(values []T)

PushFront adds values to the front of the channel. This is useful for recovering values that need to be reprocessed. Does nothing if values is empty.

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

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

TakeAll removes and returns all values from the channel atomically. Returns nil if the channel is empty.

func (ch *UnboundedChan[T]) TrySend(value T) bool

TrySend attempts to put an item into the channel. Returns false if the channel is closed, true otherwise.

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