Analytics client: non-blocking event queue, batching with retries and exponential backoff, local JSONL persistence for offline delivery, typed properties, session/device identity and lifecycle controls.
Kotlin Multiplatform analytics client for Grain.
Works on Android, iOS, and JVM.
// build.gradle.kts
dependencies {
implementation("com.grainql:grain-sdk:0.0.1")
}
[libraries]
grain-sdk = { module = "com.grainql:grain-sdk", version = "0.0.1" }
com.grainql.sdk.GrainAnalytics
com.grainql.sdk.GrainConfig
com.grainql.sdk.platform.AndroidKeyValueStore
com.grainql.sdk.platform.AndroidFileStore
GrainAnalytics.initialize(
config = GrainConfig(tenantAlias = ),
kvStore = AndroidKeyValueStore(applicationContext),
fileStore = AndroidFileStore(applicationContext),
)
GrainAnalytics.track(, mapOf(
to ,
to ,
))
GrainAnalytics.identify()
GrainAnalytics.track(, mapOf(
to ,
to ,
to ,
))
let kvStore = IosKeyValueStore()
let fileStore = IosFileStore()
GrainAnalytics.shared.initialize(
config: GrainConfig(tenantAlias: "your-tenant"),
kvStore: kvStore,
fileStore: fileStore
)
GrainAnalytics.shared.track(eventName: "screen_viewed", properties: ["screen": "settings"])
import com.grainql.sdk.platform.JvmKeyValueStore
import com.grainql.sdk.platform.JvmFileStore
GrainAnalytics.initialize(
config = GrainConfig(tenantAlias = "your-tenant"),
kvStore = JvmKeyValueStore(),
fileStore = JvmFileStore(),
)
GrainConfig(
tenantAlias = "your-tenant", // Required
apiUrl = ,
secret = ,
debug = ,
flushIntervalMs = ,
flushThreshold = ,
maxBatchSize = ,
maxQueueSize = ,
maxRetries = ,
enablePersistence = ,
)
GrainAnalytics.track(eventName, properties) // Track with current user
GrainAnalytics.track(eventName, userId, properties) // Track with explicit user
GrainAnalytics.identify(userId) // Set the user identity
GrainAnalytics.resetIdentity() // Clear identity, revert to device ID
GrainAnalytics.getDeviceId() // Stable device ID (persists across resets)
GrainAnalytics.getSessionId() // Current session ID (fresh per app launch)
GrainAnalytics.setUserProperties(mapOf("plan" to "pro", "source" to "organic"))
GrainAnalytics.setUserProperties(userId, properties) // For a specific user
GrainAnalytics.onForeground() // Resume periodic flushing
GrainAnalytics.onBackground() // Flush pending events, pause timer
GrainAnalytics.onNetworkConnected() // Flush immediately
GrainAnalytics.onNetworkDisconnected() // Pause sending
GrainAnalytics.flush() // Manual flush (suspend)
GrainAnalytics.shutdown() // Final flush and cleanup (suspend)
Events flow through a simple pipeline:
track() synchronously submits events into an unbounded channel — it never blocks.maxRetries are dropped.The SDK automatically attaches session_id, device_id, client_version, platform, and timestamp to every event. These match the conventions used by the Grain web SDK so all events participate in the same analytics pipeline.
./gradlew :library:jvmTest # Run tests
./gradlew :library:compileAndroidMain # Build Android
./gradlew :library:compileKotlinIosArm64 # Build iOS
See CONTRIBUTING.md.
Surfaced from shared tags and platforms — no rankings paid for.