hubro-connect/no.hubroplatform.hubroconnect

Package-level declarations

Types

AmbientTemperatureMeasurement

@Serializable

data class AmbientTemperatureMeasurement(val time: Instant, val temperature: Temperature) : InstantaneousMeasurement, KoinComponent

Captures the ambient temperature.

AndroidSensorManager

class AndroidSensorManager(context: Context) : SensorManager, KoinComponent

ApplicationContextHolder

object ApplicationContextHolder

ApplicationContextHolderInitializer

class ApplicationContextHolderInitializer : Initializer<ApplicationContextHolder>

AuthorizationRequest

@Serializable

data class AuthorizationRequest(val username: String, val password: String)

AuthorizationResponse

@Serializable

data class AuthorizationResponse(val transactionId: String)

BGFetchDataSyncManager

class BGFetchDataSyncManager

data class ClientMessage(val msg: ClientMessage.Msg<*>? = null, val unknownFields: Map<Int, UnknownField> = emptyMap()) : Message

sealed class Code : Message.Enum

DataSyncManager

interface DataSyncManager

class DataSyncWorker(appContext: Context, workerParams: WorkerParameters) : CoroutineWorker, KoinComponent

DefaultActionAsync

typealias DefaultActionAsync = suspend () -> Unit

FakeNonEmptyMap

class FakeNonEmptyMap<K, V> : HashMap<K, V>

This map always returns false when isEmpty is called to bypass TFLite interpreter's stupid empty check on the input argument of runSignature.

FederatedJobWorker

class FederatedJobWorker(appContext: Context, workerParams: WorkerParameters) : CoroutineWorker

FederatedLearningImports

class FederatedLearningImports

FederatedLearningManager

class FederatedLearningManager(context: Context, hubroSession: HubroSessionBuilder) : FederatedManager

FederatedManager

interface FederatedManager

class FlowerClient<X : Any, Y : Any>(tfliteFileBuffer: MappedByteBuffer, val layersSizes: IntArray, val spec: SampleSpec<X, Y>) : AutoCloseable

Flower client that handles TensorFlow Lite model Interpreter and sample data.

FlowerServiceRunnable

class FlowerServiceRunnable<X : Any, Y : Any>(val flowerClient: FlowerClient<X, Y>, val callback: (String) -> Unit)

Start communication with Flower server and training in the background. Note: constructing an instance of this class immediately starts training.

ForbiddenException

class ForbiddenException(exception: String) : Throwable

HealthConnectManager

class HealthConnectManager(context: Context) : HealthManager

sealed interface HealthDataType

interface HealthManager

@Serializable

sealed interface HealthRecord

Common interface shared by readable or writable records.

class HubroSession(baseUrl: String, tokenVerifier: String)

HubroSessionBuilder

class HubroSessionBuilder(baseUrl: String, tokenVerifier: String) : KoinComponent

This is a KDoc comment.

class InMemoryCache

InstantaneousMeasurement

@Serializable

sealed interface InstantaneousMeasurement : SensorMeasurement

InstantaneousRecord

@Serializable

sealed interface InstantaneousRecord : HealthRecord

A record that contains an instantaneous measurement.

@Serializable

sealed interface IntervalRecord : HealthRecord

A record that contains a measurement with a time interval.

IOSDataSyncManager

class IOSDataSyncManager(hubroSession: <Error class: unknown class>)

LocationMeasurement

@Serializable

data class LocationMeasurement(val time: Instant, val latitude: Double, val longitude: Double, val altitude: Double? = null) : InstantaneousMeasurement, KoinComponent

actual class ManagerFactory

expect class ManagerFactory

actual class ManagerFactory

actual class ManagerFactory

actual class ManagerFactory

actual class ManagerFactory

NumberOfRecordsRequest

class NumberOfRecordsRequest(val type: Number, val from: Number, val to: Number)

@Serializable

data class Observation(val device: String, val type: String, val value: String, val dateTime: String)

data class Parameters(val tensors: List<ByteArr> = emptyList(), val tensorType: String = "", val unknownFields: Map<Int, UnknownField> = emptyMap()) : Message

PbandkErrorDetailParser

object PbandkErrorDetailParser : ErrorDetailParser

PbandkProtoAdapter

class PbandkProtoAdapter<E : Message>(clazz: KClass<E>) : Codec<E>

class PbandkStrategy : SerializationStrategy

@Serializable

data class Questionnaire(val name: String, val accessLink: String)

sealed class Reason : Message.Enum

class RecordsRequest(val type: Number, val from: Number, val to: Number)

RefreshTokenRequest

@Serializable

data class RefreshTokenRequest(val accessToken: String, val refreshToken: String)

class RPCWrapper

data class Sample<X, Y>(val bottleneck: X, val label: Y)

One sample data point (bottleneck, label).

data class SampleSpec<X, Y>(val convertX: (List<X>) -> Array<X>, val convertY: (List<Y>) -> Array<Y>, val emptyY: (Int) -> Array<Y>, val loss: (MutableList<Sample<X, Y>>, Array<Y>) -> Float, val accuracy: (MutableList<Sample<X, Y>>, Array<Y>) -> Float)

data class Scalar(val scalar: Scalar.Scalar<*>? = null, val unknownFields: Map<Int, UnknownField> = emptyMap()) : Message

sealed interface SensorDataType

SensorKitManager

class SensorKitManager : KoinComponent

class SensorListener : SensorEventListener, KoinComponent

interface SensorManager

SensorMeasurement

@Serializable

sealed interface SensorMeasurement

data class ServerMessage(val msg: ServerMessage.Msg<*>? = null, val unknownFields: Map<Int, UnknownField> = emptyMap()) : Message

data class Status(val code: Code = no.hubroplatform.hubroconnect.Code.fromValue(0), val message: String = "", val unknownFields: Map<Int, UnknownField> = emptyMap()) : Message

@Serializable

data class StepsRecord(val startTime: Instant, val endTime: Instant, val count: Int) : IntervalRecord

Captures the number of steps taken since the last reading. Each step is only reported once so records shouldn't have overlapping time. The start time of each record should represent the start of the interval in which steps were taken.

SystemPermissionActivity

class SystemPermissionActivity : ComponentActivity

@Serializable

data class TokenResponse(val accessToken: String, val refreshToken: String)

VerificationRequest

@Serializable

data class VerificationRequest(val transactionId: String, val code: String)

data class WeightRecord(val time: Instant, val weight: Mass) : InstantaneousRecord

Captures the user's weight.

WorkManagerDataSyncManager

class WorkManagerDataSyncManager(context: Context, hubroSession: HubroSessionBuilder) : DataSyncManager

class WorkManagerDataSyncManager : KoinComponent

Properties

HUNDRED_MEBIBYTE

const val HUNDRED_MEBIBYTE: Int

Functions

evaluateResAsProto

fun evaluateResAsProto(accuracy: Float, testing_size: Int): ClientMessage

fun fitResAsProto(weights: Array<ByteBuffer>, training_size: Int): ClientMessage

fun ClientMessage.DisconnectRes?.orDefault(): ClientMessage.DisconnectRes

fun ClientMessage.EvaluateRes.MetricsEntry?.orDefault(): ClientMessage.EvaluateRes.MetricsEntry

fun ClientMessage.EvaluateRes?.orDefault(): ClientMessage.EvaluateRes

fun ClientMessage.FitRes.MetricsEntry?.orDefault(): ClientMessage.FitRes.MetricsEntry

fun ClientMessage.FitRes?.orDefault(): ClientMessage.FitRes

fun ClientMessage.GetParametersRes?.orDefault(): ClientMessage.GetParametersRes

fun ClientMessage.GetPropertiesRes.PropertiesEntry?.orDefault(): ClientMessage.GetPropertiesRes.PropertiesEntry

fun ClientMessage.GetPropertiesRes?.orDefault(): ClientMessage.GetPropertiesRes

fun ClientMessage?.orDefault(): ClientMessage

fun Parameters?.orDefault(): Parameters

fun Scalar?.orDefault(): Scalar

fun ServerMessage.EvaluateIns.ConfigEntry?.orDefault(): ServerMessage.EvaluateIns.ConfigEntry

fun ServerMessage.EvaluateIns?.orDefault(): ServerMessage.EvaluateIns

fun ServerMessage.FitIns.ConfigEntry?.orDefault(): ServerMessage.FitIns.ConfigEntry

fun ServerMessage.FitIns?.orDefault(): ServerMessage.FitIns

fun ServerMessage.GetParametersIns.ConfigEntry?.orDefault(): ServerMessage.GetParametersIns.ConfigEntry

fun ServerMessage.GetParametersIns?.orDefault(): ServerMessage.GetParametersIns

fun ServerMessage.GetPropertiesIns.ConfigEntry?.orDefault(): ServerMessage.GetPropertiesIns.ConfigEntry

fun ServerMessage.GetPropertiesIns?.orDefault(): ServerMessage.GetPropertiesIns

fun ServerMessage.ReconnectIns?.orDefault(): ServerMessage.ReconnectIns

fun ServerMessage?.orDefault(): ServerMessage

fun Status?.orDefault(): Status

requestLocation

suspend fun requestLocation(): <Error class: unknown class>

fun ByteArray.toHexString(): String

fun weightsAsProto(weights: Array<ByteBuffer>): ClientMessage