common

type Caller interface {
	Execute(request RpcReqComponent) RpcResComponent

	Prepare(request RpcReqComponent) RpcResComponent

	Rollback(request RpcReqComponent) RpcResComponent

	Commit(request RpcReqComponent) RpcResComponent
}

type CallerPlugin struct {
	// Impl Injection
	Impl Caller
}

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

type CallerRPCServer struct {
	// This is the real implementation
	Impl Caller
}

type Component struct {
	FileClient fileClient
	// contains filtered or unexported fields
}

type ComponentFileInfo struct {
	Type  string    `json:"type"`
	Disk  DiskInfo  `json:"disk"`
	FTP   FTPInfo   `json:"ftp"`
	MinIO MinIOInfo `json:"minio"`
}

type Context struct {
	/**
	 * 子组件名称
	 */
	Name string `json:"name"`
	/**
	 * 子组件版本
	 */
	Version string `json:"version"`
	/**
	 * 设置事务ID, commit和rollback可以获取使用
	 */
	TransactionId string `json:"transactionId"`
	/**
	 * 请求id，用于链路追踪
	 */
	RequestId string `json:"requestId"`

	Logger hclog.Logger

	FileClient fileClient
}

type DiskInfo struct {
	RootDir string `json:"rootDir"`
}

type FTPInfo struct {
	Host     string `json:"host"`
	Username string `json:"username"`
	Password string `json:"password"`
	RootDir  string `json:"rootDir"`
}

type Handler interface {
	/**
	 * 执行逻辑
	 */
	Invoke(config []byte, input []byte, output []byte, context Context) ([]byte, error)
}

type MinIOInfo struct {
	Endpoint  string `json:"endpoint"`
	AccessKey string `json:"accessKey"`
	SecretKey string `json:"secretKey"`
	Bucket    string `json:"bucket"`
}

type RpcComponentContext struct {
	/**
	 * 子组件名称
	 */
	Name string `json:"name"`
	/**
	 * 子组件版本
	 */
	Version string `json:"version"`
	/**
	 * 设置事务ID, commit和rollback可以获取使用
	 */
	TransactionId string `json:"transactionId"`
	/**
	 * 请求id，用于链路追踪
	 */
	RequestId string `json:"requestId"`
}

type RpcReqComponent struct {
	Config           []byte              `json:"config"`
	Input            []byte              `json:"input"`
	Output           []byte              `json:"output"`
	ComponentContext RpcComponentContext `json:"componentContext"`
}

type RpcResComponent struct {
	Output       []byte `json:"output"`
	ErrorMessage string `json:"errorMessage"`
}