stream.h

Go to the documentation of this file.

/*
 * Copyright (c) 2023 Golioth, Inc.
 *
 * SPDX-License-Identifier: Apache-2.0
 */
 
#ifdef __cplusplus
extern "C"
{
#endif
 
#pragma once
 
#include <golioth/golioth_status.h>
#include <golioth/client.h>
 
 
enum golioth_status golioth_stream_set_async(struct golioth_client *client,
                                             const char *path,
                                             enum golioth_content_type content_type,
                                             const uint8_t *buf,
                                             size_t buf_len,
                                             golioth_set_cb_fn callback,
                                             void *callback_arg);
 
enum golioth_status golioth_stream_set_sync(struct golioth_client *client,
                                            const char *path,
                                            enum golioth_content_type content_type,
                                            const uint8_t *buf,
                                            size_t buf_len,
                                            int32_t timeout_s);
 
typedef enum golioth_status (*stream_read_block_cb)(uint32_t block_idx,
                                                    uint8_t *block_buffer,
                                                    size_t *block_size,
                                                    bool *is_last,
                                                    void *arg);
 
enum golioth_status golioth_stream_set_blockwise_sync(struct golioth_client *client,
                                                      const char *path,
                                                      enum golioth_content_type content_type,
                                                      stream_read_block_cb cb,
                                                      void *arg);
 
struct blockwise_transfer *golioth_stream_blockwise_start(struct golioth_client *client,
                                                          const char *path,
                                                          enum golioth_content_type content_type);
 
void golioth_stream_blockwise_finish(struct blockwise_transfer *ctx);
 
enum golioth_status golioth_stream_blockwise_set_block_async(struct blockwise_transfer *ctx,
                                                             uint32_t block_idx,
                                                             const uint8_t *block_buffer,
                                                             size_t data_len,
                                                             bool is_last,
                                                             golioth_set_block_cb_fn callback,
                                                             void *callback_arg);
 
 
#ifdef __cplusplus
}
#endif