aaliflowkitgrpc

type ExternalFunctionsClient interface {
	// Lists all available functions with description, inputs and outputs.
	ListFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*ListFunctionsResponse, error)
	// Runs a specified function with provided inputs and returns the function outputs.
	RunFunction(ctx context.Context, in *FunctionInputs, opts ...grpc.CallOption) (*FunctionOutputs, error)
	// Runs a specified function with provided inputs and returns the function output as a stream.
	StreamFunction(ctx context.Context, in *FunctionInputs, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamOutput], error)
}

type ExternalFunctionsServer interface {
	// Lists all available functions with description, inputs and outputs.
	ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)
	// Runs a specified function with provided inputs and returns the function outputs.
	RunFunction(context.Context, *FunctionInputs) (*FunctionOutputs, error)
	// Runs a specified function with provided inputs and returns the function output as a stream.
	StreamFunction(*FunctionInputs, grpc.ServerStreamingServer[StreamOutput]) error
	// contains filtered or unexported methods
}

type ExternalFunctions_StreamFunctionClient = grpc.ServerStreamingClient[StreamOutput]

type ExternalFunctions_StreamFunctionServer = grpc.ServerStreamingServer[StreamOutput]

type FunctionDefinition struct {

	// Name of the function.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the function.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Category of the function.
	Category string `protobuf:"bytes,3,opt,name=category,proto3" json:"category,omitempty"`
	// Display name of the function;
	DisplayName string `protobuf:"bytes,4,opt,name=displayName,proto3" json:"displayName,omitempty"`
	// List of input definitions for the function.
	Input []*FunctionInputDefinition `protobuf:"bytes,5,rep,name=input,proto3" json:"input,omitempty"`
	// List of output definitions for the function.
	Output []*FunctionOutputDefinition `protobuf:"bytes,6,rep,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

type FunctionInput struct {

	// Name of the input.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Go language type of the input.
	GoType string `protobuf:"bytes,2,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
	// Value of the input.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type FunctionInputDefinition struct {

	// Name of the input.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the input.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Go language type of the input.
	GoType string `protobuf:"bytes,3,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
	// List of options for the input, if applicable.
	Options []string `protobuf:"bytes,4,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type FunctionInputs struct {

	// Name of the function to run.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// List of inputs for the function.
	Inputs []*FunctionInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

type FunctionOutput struct {

	// Name of the output.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Go language type of the output.
	GoType string `protobuf:"bytes,2,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
	// Value of the output.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Code validation of the output. Only relevant for code generation.
	CodeValidation string `protobuf:"bytes,4,opt,name=code_validation,json=codeValidation,proto3" json:"code_validation,omitempty"`
	// contains filtered or unexported fields
}

type FunctionOutputDefinition struct {

	// Name of the output.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the output.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Go language type of the output.
	GoType string `protobuf:"bytes,3,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
	// contains filtered or unexported fields
}

type FunctionOutputs struct {

	// Name of the function that was run.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// List of outputs from the function.
	Outputs []*FunctionOutput `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

type ListFunctionsRequest struct {
	// contains filtered or unexported fields
}

type ListFunctionsResponse struct {

	// Map of function names to their definitions.
	Functions map[string]*FunctionDefinition `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

type StreamOutput struct {

	// Counter for the message in the stream.
	MessageCounter int32 `protobuf:"varint,1,opt,name=message_counter,json=messageCounter,proto3" json:"message_counter,omitempty"`
	// Indicates if this is the last message in the stream.
	IsLast bool `protobuf:"varint,2,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
	// Value of the output.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Code validation of the output. Only relevant for code generation.
	CodeValidation string `protobuf:"bytes,4,opt,name=code_validation,json=codeValidation,proto3" json:"code_validation,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedExternalFunctionsServer struct{}

type UnsafeExternalFunctionsServer interface {
	// contains filtered or unexported methods
}