application

Documentation

Index

• func InitNode(ctx context.Context, appNamespace, name string, ...) (n base.Node, err error)
• type Application
  • func NewAppOrGetFromCache(ctx context.Context, app *arcadiav1alpha1.Application, cli dynamic.Interface) (*Application, error)
  • func (a *Application) Init(ctx context.Context, cli dynamic.Interface) (err error)
  • func (a *Application) Run(ctx context.Context, cli dynamic.Interface, respStream chan string, ...) (output Output, err error)
• type Input
• type Output

Functions

func InitNode

func InitNode(ctx context.Context, appNamespace, name string, ref arcadiav1alpha1.TypedObjectReference, cli dynamic.Interface) (n base.Node, err error)

Types

type Application

type Application struct {
	Namespace     string
	Spec          arcadiav1alpha1.ApplicationSpec
	Inited        bool
	Nodes         map[string]base.Node
	StartingNodes []base.Node
	EndingNode    base.Node
}

func NewAppOrGetFromCache

func NewAppOrGetFromCache(ctx context.Context, app *arcadiav1alpha1.Application, cli dynamic.Interface) (*Application, error)

func (*Application) Init

func (a *Application) Init(ctx context.Context, cli dynamic.Interface) (err error)

todo 防止无限循环，需要找一下是不是成环

func (*Application) Run

func (a *Application) Run(ctx context.Context, cli dynamic.Interface, respStream chan string, input Input) (output Output, err error)

type Input

type Input struct {
	Question string
	// overrideConfig
	NeedStream bool
	History    langchaingoschema.ChatMessageHistory
}

type Output

type Output struct {
	Answer     string
	References []retriever.Reference
}