BootemLoop listens for permission changes, updates the PublisherSet to signal to boot streamers, returns an error in the event of a failure to listen.

ModelCollectStartupMsgs collects ModelMsg's that were missed prior to startup.

ModelMakeFilter creates a ModelMsg filter based on the given ModelSubscriptionSpec.

ModelMakeHydrator returns a function that gets properties of a model by its id.

ModelMakePermissionFilter returns a function that checks if a ModelMsg is in scope of the user permissions.

ModelVersionCollectStartupMsgs collects ModelVersionMsg's that were missed prior to startup.

ModelVersionMakeFilter creates a ModelVersionMsg filter based on the given ModelVersionSubscriptionSpec.

ModelVersionMakeHydrator returns a function that gets properties of a model version by its id.

ModelVersionMakePermissionFilter returns a function that checks if a ModelVersionMsg is in scope of the user permissions.

NewPublisherSet constructor for PublisherSet.

NewSubscriptionSet constructor for SubscriptionSet.

NewSupervisor creates a new Supervisor.

ProjectCollectStartupMsgs collects ProjectMsg's that were missed prior to startup.

ProjectMakeFilter creates a ProjectMsg filter based on the given ProjectSubscriptionSpec.

ProjectMakeHydrator returns a function that gets properties of a project by its id.

ProjectMakePermissionFilter returns a function that checks if a ProjectMsg is in scope of the user permissions.

WriteAll attempts to write all provided messages.

ModelsDeleteKey specifies the key for delete models.

ModelsUpsertKey specifies the key for upsert models.

ModelVersionsDeleteKey specifies the key for delete model_versions.

ModelVersionsUpsertKey specifies the key for upsert model_versions.

ProjectsDeleteKey specifies the key for delete projects.

ProjectsUpsertKey specifies the key for upsert projects.

AuthZProvider provides StreamAuthZ implementations.

KnownKeySet allows a client to describe which primary keys it knows of as existing, so the server can respond with which client-known keys have been deleted or disappeared, and also which server-known keys are not yet known to the client (appearances).

ModelMsg is a stream.Msg.

ModelSubscriptionSpec is what a user submits to define a Model subscription.

ModelVersionMsg is a stream.Msg.

ModelVersionSubscriptionSpec is what a user submits to define a model_version subscription.

ProjectMsg is a stream.Msg.

ProjectSubscriptionSpec is what a user submits to define a project subscription.

PublisherSet contains all publishers, and handles all websockets.

StartupMsg is the first message a streaming client sends.

StreamAuthZBasic is classic OSS Determined authentication for streaming clients.

SubscriptionSet is a set of all subscribers for this PublisherSet.

SubscriptionSpecSet is the set of subscription specs that can be sent in startup message.

Supervisor manages the context for underlying PublisherSet.

WrappedWebsocket is a simple wrapper on a websocket connection.

JSONB is the golang equivalent of the postgres jsonb column type.

StreamAuthZ is the interface for streaming authorization.

WebsocketLike is an interface to describe a websocket and its dummy implementations.

CollectStartupMsgsFunc collects messages that were missed prior to startup.