ai.whylabs.services.whylogs.core

BufferedLogRequest

data class BufferedLogRequest( val request: LogRequest, val sessionTime: Instant, val windowStartTime: Instant)

DebugActorOptions

data class DebugActorOptions( val maxErrors: Int, val env: IEnvVars, val profileStore: ProfileStore)

DebugInfoManager

class DebugInfoManager

DebugInfoMessage

sealed class DebugInfoMessage

LogRequest

data class LogRequest( val datasetId: String, val timestamp: Long? = null, val tags: Map<String, String>?, val single: Map<String, Any>?, val multiple: MultiLog?)

Message

data class Message( val attributes: Map<String, String>? = null, val data: String, val messageId: String, val publishTime: String, val orderingKey: String?)

MultiLog

data class MultiLog(val columns: List<String>, val data: List<List<Any>>)

ProfileEntry

data class ProfileEntry( val profile: DatasetProfile, val orgId: String, val datasetId: String)

Container class that caches the dataset profiles and associated metadata for each request.

ProfileKey

data class ProfileKey( val orgId: String, val datasetId: String, val normalizedTags: List<Pair<String, String>>, val sessionTime: Instant, val windowStartTime: Instant)

ProfileStore

class ProfileStore

PubSubEnvelope

data class PubSubEnvelope(val message: Message, val subscription: String)

SongbirdClientManager

class SongbirdClientManager(envVars: IEnvVars = EnvVars.instance)

WhyLogsController

class WhyLogsController( envVars: IEnvVars = EnvVars.instance, profileManager: WhyLogsProfileManager = WhyLogsProfileManager(envVars = envVars), debugInfo: DebugInfoManager = DebugInfoManager.instance)

WhyLogsProfileManager

class WhyLogsProfileManager( executorService: ScheduledExecutorService = Executors.newScheduledThreadPool(1), currentTime: Instant = Instant.now(), envVars: IEnvVars = EnvVars.instance, writer: Writer = envVars.getProfileWriter(), debugInfo: DebugInfoManager = DebugInfoManager.instance, profileStore: ProfileStore = ProfileStore.instance, writeOnStop: Boolean = true)

WriteProfilesResponse

data class WriteProfilesResponse(val profilesWritten: Int, val profilePaths: List<String>)

WriteProfilesResult

data class WriteProfilesResult(val profilesWritten: Int, val profilePaths: List<String>)

merge

fun DatasetProfile.merge(request: LogRequest, ignored: Set<String> = emptySet())

mergeNested

fun DatasetProfile.mergeNested( nestedValue: Map<String, Any>, ignored: Set<String>, prefix: String = "")

randomAlphaNumericId

fun randomAlphaNumericId(len: Int = 6): String

DatasetIdTag

const val DatasetIdTag: String

OrgIdTag

const val OrgIdTag: String

SegmentTagPrefix

const val SegmentTagPrefix: String

Package ai.whylabs.services.whylogs.core

Types

Functions

Properties