core

Sep 15, 2025

Changes in this version

type ActionDef

+ func (a *ActionDef[In, Out, Stream]) RunJSONWithTelemetry(ctx context.Context, input json.RawMessage, cb StreamCallback[json.RawMessage]) (*api.ActionRunResult[json.RawMessage], error)

type Flow

+ func (f *Flow[In, Out, Stream]) RunJSONWithTelemetry(ctx context.Context, input json.RawMessage, cb StreamCallback[json.RawMessage]) (*api.ActionRunResult[json.RawMessage], error)

Sep 9, 2025

Changes in this version

+ func FlowNameFromContext(ctx context.Context) string

Aug 25, 2025

Changes in this version

+ func InferSchemaMap(value any) map[string]any

+ func NewKey(typ ActionType, provider, id string) string

+ func NewName(provider, id string) string

+ func ParseName(name string) (string, string)

type Action

+ Register func(r *registry.Registry)

type ActionDef

+ func NewStreamingAction[In, Out, Stream any](name string, atype ActionType, metadata map[string]any, ...) *ActionDef[In, Out, Stream]

+ func (a *ActionDef[In, Out, Stream]) Register(r *registry.Registry)

type ActionType

+ const ActionTypeResource

+ func ParseKey(key string) (ActionType, string, string)

type Flow

+ func (f *Flow[In, Out, Stream]) Register(r *registry.Registry)

Jul 2, 2025

Changes in this version

type ActionDef

+ func ResolveActionFor[In, Out, Stream any](r *registry.Registry, typ ActionType, provider, name string) *ActionDef[In, Out, Stream]

Jun 13, 2025

Changes in this version

type ActionDef

+ func NewAction[In, Out any](provider, name string, atype ActionType, metadata map[string]any, ...) *ActionDef[In, Out, struct{}]

+ func (a *ActionDef[In, Out, Stream]) SetTracingState(tstate *tracing.State)

+ type ActionDesc struct

+ Description string

+ InputSchema *jsonschema.Schema

+ Key string

+ Metadata map[string]any

+ Name string

+ OutputSchema *jsonschema.Schema

+ Type ActionType

+ type ActionType string

+ const ActionTypeCustom

+ const ActionTypeEmbedder

+ const ActionTypeEvaluator

+ const ActionTypeExecutablePrompt

+ const ActionTypeFlow

+ const ActionTypeIndexer

+ const ActionTypeModel

+ const ActionTypeRetriever

+ const ActionTypeTool

+ const ActionTypeUtil

type Flow

+ func (f *Flow[In, Out, Stream]) Desc() ActionDesc

+ func (f *Flow[In, Out, Stream]) SetTracingState(tstate *tracing.State)

May 1, 2025

Changes in this version

+ const CodeAborted

+ const CodeAlreadyExists

+ const CodeCancelled

+ const CodeDataLoss

+ const CodeDeadlineExceeded

+ const CodeFailedPrecondition

+ const CodeInternal

+ const CodeInvalidArgument

+ const CodeNotFound

+ const CodeOK

+ const CodeOutOfRange

+ const CodePermissionDenied

+ const CodeResourceExhausted

+ const CodeUnauthenticated

+ const CodeUnavailable

+ const CodeUnimplemented

+ const CodeUnknown

+ var StatusNameToCode = map[StatusName]int

+ func HTTPStatusCode(name StatusName) int

+ type GenkitError struct

+ Details map[string]any

+ HTTPCode int

+ Message string

+ Source *string

+ Status StatusName

+ func NewError(status StatusName, message string, args ...any) *GenkitError

+ func (e *GenkitError) Error() string

+ func (e *GenkitError) ToReflectionError() ReflectionError

+ type ReflectionError struct

+ Code int

+ Details *ReflectionErrorDetails

+ Message string

+ func ToReflectionError(err error) ReflectionError

+ type ReflectionErrorDetails struct

+ Stack *string

+ TraceID *string

+ type Status struct

+ Message string

+ Name StatusName

+ func NewStatus(name StatusName, message string) *Status

+ type StatusName string

+ const ABORTED

+ const ALREADY_EXISTS

+ const CANCELLED

+ const DATA_LOSS

+ const DEADLINE_EXCEEDED

+ const FAILED_PRECONDITION

+ const INTERNAL

+ const INVALID_ARGUMENT

+ const NOT_FOUND

+ const OK

+ const OUT_OF_RANGE

+ const PERMISSION_DENIED

+ const RESOURCE_EXHAUSTED

+ const UNAUTHENTICATED

+ const UNAVAILABLE

+ const UNIMPLEMENTED

+ const UNKNOWN

+ type UserFacingError struct

+ Details map[string]any

+ Message string

+ Status StatusName

+ func NewPublicError(status StatusName, message string, details map[string]any) *UserFacingError

+ func (e *UserFacingError) Error() string

Apr 8, 2025

Changes in this version

+ type StreamingFlowValue struct

+ Done bool

+ Output Out

+ Stream Stream

Mar 28, 2025

Changes in this version

+ func Run[Out any](ctx context.Context, name string, fn func() (Out, error)) (Out, error)

+ func WithActionContext(ctx context.Context, actionCtx ActionContext) context.Context

+ type ActionContext = map[string]any

+ func FromContext(ctx context.Context) ActionContext

+ type ActionDef struct

+ func (a *ActionDef[In, Out, Stream]) Desc() action.Desc

+ func (a *ActionDef[In, Out, Stream]) Name() string

+ func (a *ActionDef[In, Out, Stream]) Run(ctx context.Context, input In, cb StreamCallback[Stream]) (output Out, err error)

+ func (a *ActionDef[In, Out, Stream]) RunJSON(ctx context.Context, input json.RawMessage, cb StreamCallback[json.RawMessage]) (json.RawMessage, error)

+ type ContextProvider = func(ctx context.Context, req RequestData) (ActionContext, error)

type Flow

+ func DefineFlow[In, Out any](r *registry.Registry, name string, fn Func[In, Out]) *Flow[In, Out, struct{}]

+ func DefineStreamingFlow[In, Out, Stream any](r *registry.Registry, name string, fn StreamingFunc[In, Out, Stream]) *Flow[In, Out, Stream]

+ func (f *Flow[In, Out, Stream]) RunJSON(ctx context.Context, input json.RawMessage, cb StreamCallback[json.RawMessage]) (json.RawMessage, error)

+ type Middleware = func(StreamingFunc[In, Out, Stream]) StreamingFunc[In, Out, Stream]

+ func ChainMiddleware[In, Out, Stream any](middlewares ...Middleware[In, Out, Stream]) Middleware[In, Out, Stream]

+ func Middlewares[In, Out, Stream any](ms ...Middleware[In, Out, Stream]) []Middleware[In, Out, Stream]

+ type RequestData struct

+ Headers map[string]string

+ Input json.RawMessage

+ Method string

+ type StreamCallback = func(context.Context, Stream) error

+ type StreamingFunc = func(context.Context, In, StreamCallback[Stream]) (Out, error)

Jul 12, 2024

Changes in this version

type Action

+ func DefineActionInRegistry[In, Out, Stream any](r *registry.Registry, provider, name string, atype atype.ActionType, ...) *Action[In, Out, Stream]

+ func (a *Action[I, O, S]) Desc() action.Desc

+ func (a *Action[In, Out, Stream]) RunJSON(ctx context.Context, input json.RawMessage, ...) (json.RawMessage, error)

+ func (a *Action[In, Out, Stream]) SetTracingState(tstate *tracing.State)

Jul 1, 2024

Changes in this version

+ func InternalInit(ctx context.Context, opts *Options) error

+ func InternalRun[Out any](ctx context.Context, name string, f func() (Out, error)) (Out, error)

+ func NewFlowServeMux(flows []string) *http.ServeMux

+ func RegisterSpanProcessor(sp sdktrace.SpanProcessor)

+ func RegisterTraceStore(ts tracing.Store) (shutdown func(context.Context) error)

+ func ValidateRaw(dataBytes json.RawMessage, schemaBytes json.RawMessage) error

+ type Action struct

+ func DefineActionWithInputSchema[Out any](provider, name string, atype atype.ActionType, metadata map[string]any, ...) *Action[any, Out, struct{}]

+ func DefineAction[In, Out any](provider, name string, atype atype.ActionType, metadata map[string]any, ...) *Action[In, Out, struct{}]

+ func DefineCustomAction[In, Out, Stream any](provider, name string, metadata map[string]any, fn Func[In, Out, Stream]) *Action[In, Out, Stream]

+ func DefineStreamingAction[In, Out, Stream any](provider, name string, atype atype.ActionType, metadata map[string]any, ...) *Action[In, Out, Stream]

+ func LookupActionFor[In, Out, Stream any](typ atype.ActionType, provider, name string) *Action[In, Out, Stream]

+ func (a *Action[In, Out, Stream]) Name() string

+ func (a *Action[In, Out, Stream]) Run(ctx context.Context, input In, cb func(context.Context, Stream) error) (output Out, err error)

+ type Environment string

+ const EnvironmentDev

+ const EnvironmentProd

+ type FileFlowStateStore struct

+ func NewFileFlowStateStore(dir string) (*FileFlowStateStore, error)

+ func (s *FileFlowStateStore) Load(ctx context.Context, id string, pfs any) error

+ func (s *FileFlowStateStore) Save(ctx context.Context, id string, fs flowStater) error

+ type Flow struct

+ func InternalDefineFlow[In, Out, Stream any](name string, fn Func[In, Out, Stream]) *Flow[In, Out, Stream]

+ func (f *Flow[In, Out, Stream]) Name() string

+ func (f *Flow[In, Out, Stream]) Run(ctx context.Context, input In) (Out, error)

+ func (f *Flow[In, Out, Stream]) Stream(ctx context.Context, input In) func(func(*StreamFlowValue[Out, Stream], error) bool)

+ type FlowResult struct

+ Error string

+ Response Out

+ StackTrace string

+ type FlowStateStore interface

+ Load func(ctx context.Context, id string, pfs any) error

+ Save func(ctx context.Context, id string, fs flowStater) error

+ type Func func(context.Context, In, func(context.Context, Stream) error) (Out, error)

+ type NoStream = func(context.Context, struct{}) error

+ type Options struct

+ FlowAddr string

+ Flows []string

+ type StreamFlowValue struct

+ Done bool

+ Output Out

+ Stream Stream