 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PostStarRocksPipeline ¶
func PostStarRocksPipeline(input *core.ApiResourceInput) (*core.ApiResourceOutput, errors.Error)
@Summary pipelines plan for starrocks @Description pipelines plan for starrocks @Tags plugins/starrocks @Accept application/json @Param blueprint body StarRocksPipelinePlan true "json" @Router /pipelines/starrocks/pipeline-plan [post]
Types ¶
type StarRocksPipelinePlan ¶
type StarRocksPipelinePlan [][]struct {
	Plugin  string `json:"plugin"`
	Options struct {
		SourceType  string   `json:"source_type"`
		SourceDsn   string   `json:"source_dsn"`
		Host        string   `json:"host"`
		Port        int      `json:"port"`
		User        string   `json:"user"`
		Password    string   `json:"password"`
		Database    string   `json:"database"`
		BePort      int      `json:"be_port"`
		Tables      []string `json:"tables"`
		BatchSize   int      `json:"batch_size"`
		Extra       string   `json:"extra"`
		DomainLayer string   `json:"domain_layer"`
	} `json:"options"`
}
     Click to show internal directories. 
   Click to hide internal directories.