Documentation
¶
Index ¶
- func Init(logger *zap.Logger) base.IConnector
- type Connector
- func (c *Connector) CreateExecution(defUID uuid.UUID, task string, config *structpb.Struct, logger *zap.Logger) (base.IExecution, error)
- func (c *Connector) GetConnectorDefinitionByID(defID string, resourceConfig *structpb.Struct, ...) (*pipelinePB.ConnectorDefinition, error)
- func (c *Connector) GetConnectorDefinitionByUID(defUID uuid.UUID, resourceConfig *structpb.Struct, ...) (*pipelinePB.ConnectorDefinition, error)
- func (c *Connector) Test(_ uuid.UUID, config *structpb.Struct, logger *zap.Logger) (pipelinePB.Connector_State, error)
- type Execution
- type LLMInput
- type ModelsResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Connector ¶
func (*Connector) CreateExecution ¶
func (*Connector) GetConnectorDefinitionByID ¶
func (c *Connector) GetConnectorDefinitionByID(defID string, resourceConfig *structpb.Struct, component *pipelinePB.ConnectorComponent) (*pipelinePB.ConnectorDefinition, error)
func (*Connector) GetConnectorDefinitionByUID ¶
func (c *Connector) GetConnectorDefinitionByUID(defUID uuid.UUID, resourceConfig *structpb.Struct, component *pipelinePB.ConnectorComponent) (*pipelinePB.ConnectorDefinition, error)
Generate the model_name enum based on the task
type LLMInput ¶
type LLMInput struct {
// The prompt text
Prompt string
// The prompt images
PromptImages []*modelPB.PromptImage
// The chat history
ChatHistory []*modelPB.Message
// The system message
SystemMessage *string
// The maximum number of tokens for model to generate
MaxNewTokens *int32
// The temperature for sampling
Temperature *float32
// Top k for sampling
TopK *int32
// The seed
Seed *int32
// The extra parameters
ExtraParams *structpb.Struct
}
type ModelsResp ¶
Click to show internal directories.
Click to hide internal directories.