程序包 cn.feiliu.taskflow.common.utils

接口 ExternalPayloadStorage

public interface ExternalPayloadStorage

Interface used to externalize the storage of large JSON payloads in workflow and task input/output

嵌套类概要

嵌套类

修饰符和类型	接口	说明
static class	ExternalPayloadStorage.Operation
static class	ExternalPayloadStorage.PayloadType

方法概要

修饰符和类型	方法	说明
InputStream	download(String path)	Download the json payload from the specified external storage location.
ExternalStorageLocation	getLocation(ExternalPayloadStorage.Operation operation, ExternalPayloadStorage.PayloadType payloadType, String path)	Obtain a uri used to store/access a json payload in external storage.
void	upload(String path, InputStream payload, long payloadSize)	Upload a json payload to the specified external storage location.

方法详细资料

getLocation

ExternalStorageLocation getLocation(ExternalPayloadStorage.Operation operation,
                                    ExternalPayloadStorage.PayloadType payloadType,
                                    String path)

Obtain a uri used to store/access a json payload in external storage.

参数:

operation - the type of ExternalPayloadStorage.Operation to be performed with the uri

payloadType - the ExternalPayloadStorage.PayloadType that is being accessed at the uri

path - (optional) the relative path for which the external storage location object is to be populated. If path is not specified, it will be computed and populated.

返回:

a ExternalStorageLocation object which contains the uri and the path for the json payload

upload

void upload(String path,
            InputStream payload,
            long payloadSize)

Upload a json payload to the specified external storage location.

参数:

path - the location to which the object is to be uploaded

payload - an InputStream containing the json payload which is to be uploaded

payloadSize - the size of the json payload in bytes

download

InputStream download(String path)

Download the json payload from the specified external storage location.

参数:

path - the location from where the object is to be downloaded

返回:

an InputStream of the json payload at the specified location