Struct S3 

pub struct S3 { /* private fields */ }

S3 models the shared Gestalt S3-provider protocol.

Client for the gestalt.provider.v1.S3 service.

Implementations

impl S3

pub fn new(channel: Channel) -> Self

Creates a client over an established channel.

pub fn with_timeout(self, timeout: Duration) -> Self

Sets a deadline applied to every unary call; calls that run past it fail with DEADLINE_EXCEEDED. Streaming calls are unaffected.

pub async fn connect() -> Result<Self, GestaltError>

Connects to the s3 host service described by the environment.

pub async fn connect_named(name: &str) -> Result<Self, GestaltError>

Connects to the named s3 host-service binding.

pub async fn head_object( &mut self, ref: Option<S3ObjectRef>, ) -> Result<HeadObjectResponse, GestaltError>

Calls gestalt.provider.v1.S3.HeadObject.

pub async fn head_object_raw( &mut self, request: HeadObjectRequest, ) -> Result<HeadObjectResponse, GestaltError>

Calls gestalt.provider.v1.S3.HeadObject with the full request and response messages.

pub async fn read_object( &mut self, request: ReadObjectRequest, ) -> Result<(S3ObjectMeta, S3ReadObjectData), GestaltError>

The first response frame carries object metadata. All subsequent frames carry byte chunks. Zero-byte objects therefore emit exactly one frame.

Calls gestalt.provider.v1.S3.ReadObject, returning the meta header and a payload stream.

pub async fn read_object_raw( &mut self, request: ReadObjectRequest, ) -> Result<S3ReadObjectStream, GestaltError>

The first response frame carries object metadata. All subsequent frames carry byte chunks. Zero-byte objects therefore emit exactly one frame.

Calls gestalt.provider.v1.S3.ReadObject, returning a stream of converted frames.

pub async fn write_object( &mut self, open: WriteObjectOpen, data: impl Stream<Item = Vec<u8>> + Send + 'static, ) -> Result<WriteObjectResponse, GestaltError>

The first request frame must carry WriteObjectOpen metadata. All subsequent frames carry raw bytes. The response is emitted only after the object has been durably committed by the provider.

Calls gestalt.provider.v1.S3.WriteObject, sending the open header frame and then one frame per data chunk.

pub async fn write_object_raw( &mut self, requests: impl Stream<Item = WriteObjectRequest> + Send + 'static, ) -> Result<WriteObjectResponse, GestaltError>

The first request frame must carry WriteObjectOpen metadata. All subsequent frames carry raw bytes. The response is emitted only after the object has been durably committed by the provider.

Calls gestalt.provider.v1.S3.WriteObject with the full request and response messages.

pub async fn delete_object( &mut self, ref: Option<S3ObjectRef>, ) -> Result<(), GestaltError>

Calls gestalt.provider.v1.S3.DeleteObject.

pub async fn delete_object_raw( &mut self, request: DeleteObjectRequest, ) -> Result<(), GestaltError>

Calls gestalt.provider.v1.S3.DeleteObject with the full request and response messages.

pub async fn list_objects( &mut self, prefix: String, delimiter: String, continuation_token: String, start_after: String, max_keys: i32, ) -> Result<ListObjectsResponse, GestaltError>

Calls gestalt.provider.v1.S3.ListObjects.

pub async fn list_objects_raw( &mut self, request: ListObjectsRequest, ) -> Result<ListObjectsResponse, GestaltError>

Calls gestalt.provider.v1.S3.ListObjects with the full request and response messages.

pub async fn copy_object( &mut self, if_match: String, if_none_match: String, source: Option<S3ObjectRef>, destination: Option<S3ObjectRef>, ) -> Result<CopyObjectResponse, GestaltError>

Calls gestalt.provider.v1.S3.CopyObject.

pub async fn copy_object_raw( &mut self, request: CopyObjectRequest, ) -> Result<CopyObjectResponse, GestaltError>

Calls gestalt.provider.v1.S3.CopyObject with the full request and response messages.

pub async fn presign_object( &mut self, method: PresignMethod, expires_seconds: i64, ref: Option<S3ObjectRef>, options: S3PresignObjectOptions, ) -> Result<PresignObjectResponse, GestaltError>

Calls gestalt.provider.v1.S3.PresignObject.

pub async fn presign_object_raw( &mut self, request: PresignObjectRequest, ) -> Result<PresignObjectResponse, GestaltError>

Calls gestalt.provider.v1.S3.PresignObject with the full request and response messages.