Documentation
¶
Index ¶
- func ConcatItems[T any](items []T) (T, error)
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConcatItems ¶
ConcatItems the caller should ensure len(items) > 1
func GetConcatFunc ¶
func RegisterValuesMergeFunc ¶ added in v0.3.26
Types ¶
type UnboundedChan ¶ added in v0.3.23
type UnboundedChan[T any] struct { // contains filtered or unexported fields }
UnboundedChan represents a channel with unlimited capacity
func NewUnboundedChan ¶ added in v0.3.23
func NewUnboundedChan[T any]() *UnboundedChan[T]
NewUnboundedChan initializes and returns an UnboundedChan
func (*UnboundedChan[T]) Close ¶ added in v0.3.23
func (ch *UnboundedChan[T]) Close()
Close marks the channel as closed
func (*UnboundedChan[T]) Receive ¶ added in v0.3.23
func (ch *UnboundedChan[T]) Receive() (T, bool)
Receive gets an item from the channel (blocks if empty). Returns (value, true) if an item was received. Returns (zero, false) if the channel was closed with no data remaining.
func (*UnboundedChan[T]) Send ¶ added in v0.3.23
func (ch *UnboundedChan[T]) Send(value T)
Send puts an item into the channel
func (*UnboundedChan[T]) TrySend ¶
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.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
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. |
Click to show internal directories.
Click to hide internal directories.