datahub library

Classes

AggregateSelect
Select the result of an aggregation.
AmqpBrokerService
Implements BrokerService as an AMQP client.
ApiEndpoint
A RequestHandler with a RoutePattern to match against.
ApiRequest
ApiResource<TData>
ApiResponse
Defines a response to a api request.
ApiService
ApplicationHost
Hosts services and provides dependency injection.
AuthProvider
AuthProvider handles the authorization of requests.
BaseBrokerApiService
BaseBrokerClientService
BaseDao<TDao>
BaseService
Base class for all services.
BasicAuth
BasicAuthProvider
BasicAuthSession
BeanJoin<TDao>
BearerAuth
BearerAuthSession
BearerTokenAuthProvider
BrokerApi
Annotation for Broker APIs.
BrokerInterface
Annotation for Broker API interface contracts.
BrokerService
Interface for message broker connections.
ByteStreamResponse
Collection<Item>
Interface for collections.
CollectionAdapter<Item>
CollectionMapper<InternalItem, Item>
Maps collection elements while querying.
CompareFilter
ConfigPath
Represents a config value path.
ConfigService
Internal service parsing configuration files, command line arguments and environment variables.
ConsoleLogBackend
The default LogBackend implementation.
CopyWith
Annotation for generating copyWith methods.
CRUDRepository<TDao extends PrimaryKeyDao<TDao, TPrimaryKey>, TPrimaryKey>
Repository implementation for basic CRUD operations.
CustomSqlCondition
CustomSqlExpression
DailySchedule
DaoField
Annotation for dao fields.
DaoType
Annotation for dao classes.
DatabaseAdapter<TConnection extends DatabaseConnection>
Abstract interface for connecting to a database. TODO more docs
DatabaseConnection
Represents a single connection to a database.
DatabaseContext
Interface for performing operations / running queries on the database.
DataBean<TDao>
DataField
Definition a data object field inside a BaseDataBean.
DataSchema
DebugResponse
EmptyResponse
EventHubService
Expression
Represents an expression that is either static or evaluated for every individual dataset and evaluates into a value.
ExpressionSelect
ExpressionSort
FieldSelect
Select a specific column / field.
FileResponse
Filter
Representing filter arguments in a uniform, abstract way.
FilterGroup
Joins multiple Filter elements into a group using a FilterGroupType.
ForeignKey
ForeignKeyDaoField
Annotation for foreign key dao fields.
HttpAuth
HttpClient
HttpFormData
HttpHeaders
HttpRequest
HttpResponse
HttpServer
Hub
Annotation for Hub Interface class
HubClient<T>
Interface class for generated Hub client classes.
HubConsumerService<THub extends EventHubService>
A service consuming and processing EventHub events.
HubEvent<T>
HubEventSocket<T>
HubProvider<T>
Interface class for generated Hub provider classes.
HubResource
Annotation for Resources
JoinedQuerySource
JsonResponse
JWT
JWTAuthProvider
JWTSession
KeyService
This service provides a centralized cache for public keys.
ListApiResource<TData, TId>
LogBackend
Backend interface for LogService.
LogMessage
LogMiddleware
LogService
DataHubs logging solution.
MapTransferBean
Bean for use with simple Map<String, dynamic> objects.
Middleware
Migrator
Provides an interface for migrating between schema versions.
Mime
MinioService
Service for accessing a MinIO object storage.
MutableResource<T extends TransferObjectBase>
MutableResourceAdapter<T extends TransferObjectBase>
MutableResourceClient<T extends TransferObjectBase>
MutableResourceProvider<T extends TransferObjectBase>
MutableResourceRestClient<T extends TransferObjectBase>
ParameterizedCollection<Item>
ParamWrapper<Item>
Point
PostgreSQLDatabaseAdapter
DatabaseAdapter implementation for PostgreSQL databases.
PostgreSQLDatabaseConnection
PrimaryKey
PrimaryKeyDao<TDao, TPrimaryKey>
PrimaryKeyDaoField
Annotation for primary key dao fields.
PrimaryKeyDataBean<TDao, TPrimaryKey>
PushStreamResponse
QueryResult
QuerySelect
Representing query select targets in a uniform, abstract way.
QuerySource<T>
Defining a common base class among query sources.
RawResponse
RepeatSchedule
Repeated execution with interval Duration.
Repository
Base class for repository services.
Resource<T extends TransferObjectBase>
Base class for all Hub-Resources.
ResourceAdapter<T extends TransferObjectBase>
ResourceClient<T extends TransferObjectBase>
ResourceProvider<T extends TransferObjectBase>
ResourceRestClient<T extends TransferObjectBase>
ResourceRestEndpoint
RestClient
RestResponse<TResult>
Route
Represents a path which has been matched with a RoutePattern.
RoutePattern
Represents a route pattern against which request paths will be matched.
S3Service
Schedule
Defines the schedule for task execution in SchedulerService.
ScheduledTask
SchedulerService
Provides a pattern for creating scheduled execution of tasks.
ServiceHost
Base class for ServiceHosts.
ServiceResolver
Session
SingleObjectApiResource<TData>
Sort
Representing sort arguments in a uniform, abstract way.
SortGroup
StaticListApiResource<TData>
TextResponse
Token
TransferBean<T>
TransferCodec<T>
TransferId
Annotation for marking the ID-field of a TransferObject.
TransferObject
Transfer object class annotation.
TransferObjectBase<Id>
Interface used internally to detect transfer objects.
TripleJoinQuerySource<Ta, Tb, Tc>
TupleJoinQuerySource<Ta, Tb>
ValueExpression
WildcardSelect
Select every available column / field.

Enums

AggregateType
ApiRequestMethod
CompareType
ContentDisposition
Environment
FieldType
FilterGroupType
LogLevel
OverlapBehaviour
Defines how the SchedulerService should behave when a task is scheduled to run while a previous execution of the same task has not completed yet.

Extensions

DatabaseContextUtils on DatabaseContext
Utility methods that can be used on any DatabaseContext.
MapEquality on Map<K, V>
SeverityLogLevelExtension on LogLevel

Constants

metaTable → const String

Functions

addBase64Padding(String value) → String
buildQueryString(Map<String, String?> query) → String
decodeEnum<T extends Enum>(dynamic raw, List<T> values, {String? name}) → T
decodeEnumNullable<T extends Enum>(dynamic raw, List<T> values, {String? name}) → T?
decodeList<T extends List<E>?, E>(dynamic raw, E decode(dynamic, String?), {String? name}) → T
decodeListTyped<T extends List<E>?, E>(dynamic raw, {String? name}) → T
decodeMap<T extends Map<String, V>?, V>(dynamic raw, V decode(dynamic, String?), {String? name}) → T
decodeMapTyped<T extends Map<String, V>?, V>(dynamic raw, {String? name}) → T
decodeTyped<T>(dynamic raw, {TransferCodec<T>? codec, String? name}) → T
Decodes a typed value from its transfer representation. (JSON)
encodeList<T extends List<E>?, E>(T value, dynamic encode(E)) → dynamic
encodeListTyped<T extends List<E>?, E>(T value) → dynamic
encodeMap<T extends Map<String, V>?, V>(T value, dynamic encode(V)) → dynamic
encodeMapTyped<T extends Map<String, V>?, V>(T value) → dynamic
encodeTyped<T>(T value, {TransferCodec<T>? codec}) → dynamic
Encodes a typed value to its transfer representation. (JSON)
getHttpStatus(int statusCode) → String
parseMethod(String source) → ApiRequestMethod
randomHexId(int parts) → String
resolve<TService extends BaseService?>() → TService
Convenience method for injecting services.
stripBase64Padding(String value) → String
uuid() → String

Typedefs

HttpRequestHandler = Future<HttpResponse> Function(HttpRequest)
MiddlewareBuilder = RequestHandler Function(RequestHandler)
ResourceSelector<THub> = ResourceProvider<TransferObjectBase> Function(HubProvider<THub> hub)
Task = FutureOr<void> Function()

Exceptions / Errors

ApiError
Base error for when DataHub code APIs are used incorrectly by user code.
ApiException
Base exception for when things go wrong at runtime inside the DataHub API framework.
ApiRequestException
CodecException
ConfigException
ConfigPathException
ConfigTypeException
ConsumerException
Exception can be used to control message ack behaviour.
PersistenceException