qdb

package

Go to main page

Versions in this module

v1

v1.2.87

Dec 3, 2024

v1.2.86

Nov 17, 2024

v1.2.85

Nov 14, 2024

Changes in this version

type ILeaderState

+ OnEnterState func(w *LeaderElectionWorker, previousState ILeaderState)

v1.2.84

Nov 13, 2024

Changes in this version

+ const MaxCandidates

type IDatabase

+ SortedSetAdd func(key string, member string, score float64) int64

+ SortedSetRangeByScoreWithScores func(key string, min, max string) []SortedSetMember

+ SortedSetRemove func(key string, member string) int64

+ SortedSetRemoveRangeByRank func(key string, start, stop int64) int64

+ type ILeaderState interface

+ DoWork func(w *LeaderElectionWorker)

+ Name func() LeaderStates

type RedisDatabase

+ func (db *RedisDatabase) SortedSetAdd(key string, member string, score float64) int64

+ func (db *RedisDatabase) SortedSetRangeByScoreWithScores(key string, min, max string) []SortedSetMember

+ func (db *RedisDatabase) SortedSetRemove(key string, member string) int64

+ func (db *RedisDatabase) SortedSetRemoveRangeByRank(key string, start, stop int64) int64

+ type SortedSetMember struct

+ Member string

+ Score float64

v1.2.83

Nov 12, 2024

v1.2.82

Nov 12, 2024

v1.2.81

Nov 12, 2024

v1.2.80

Nov 12, 2024

v1.2.79

Nov 12, 2024

v1.2.78

Nov 12, 2024

Changes in this version

type ITengoDatabase

+ PopAvailableJobs func() []*TengoJob

+ Schedule func(...tengo.Object) (tengo.Object, error)

type ITransformer

+ ProcessPending func()

+ Transform func(*Transformation, IField)

+ type JobQueue []*TengoJob

+ func (pq *JobQueue) Pop() any

+ func (pq *JobQueue) Push(x any)

+ func (pq *JobQueue) Update(job *TengoJob, task *tengo.UserFunction, deadline time.Time)

+ func (pq JobQueue) Len() int

+ func (pq JobQueue) Less(i, j int) bool

+ func (pq JobQueue) Swap(i, j int)

type TengoDatabase

+ func (tdb *TengoDatabase) PopAvailableJobs() []*TengoJob

+ func (tdb *TengoDatabase) Schedule(args ...tengo.Object) (tengo.Object, error)

+ type TengoJob struct

+ type TengoTransformer struct

+ func (t *TengoTransformer) ProcessPending()

+ func (t *TengoTransformer) Transform(transformation *Transformation, field IField)

v1.2.77

Nov 11, 2024

Changes in this version

+ func NewTransformationValue(value string) *anypb.Any

type Field

+ func (f *Field) GetTransformation() string

+ func (f *Field) PullTransformation() string

+ func (f *Field) PushTransformation(args ...interface{}) bool

type IField

+ GetTransformation func() string

+ PullTransformation func() string

+ PushTransformation func(...interface{}) bool

+ type ITengoDatabase interface

+ Find func(...tengo.Object) (tengo.Object, error)

+ GetEntity func(...tengo.Object) (tengo.Object, error)

+ ToTengoMap func() tengo.Object

+ func NewTengoDatabase(db IDatabase) ITengoDatabase

+ type ITengoEntity interface

+ GetChildren func(...tengo.Object) (tengo.Object, error)

+ GetField func(...tengo.Object) (tengo.Object, error)

+ GetId func(...tengo.Object) (tengo.Object, error)

+ GetParent func(...tengo.Object) (tengo.Object, error)

+ GetType func(...tengo.Object) (tengo.Object, error)

+ ToTengoMap func() tengo.Object

+ func NewTengoEntity(entity IEntity) ITengoEntity

+ type ITengoField interface

+ GetBinaryFile func(...tengo.Object) (tengo.Object, error)

+ GetBool func(...tengo.Object) (tengo.Object, error)

+ GetEntityReference func(...tengo.Object) (tengo.Object, error)

+ GetFloat func(...tengo.Object) (tengo.Object, error)

+ GetId func(...tengo.Object) (tengo.Object, error)

+ GetInt func(...tengo.Object) (tengo.Object, error)

+ GetName func(...tengo.Object) (tengo.Object, error)

+ GetString func(...tengo.Object) (tengo.Object, error)

+ GetTimestamp func(...tengo.Object) (tengo.Object, error)

+ GetWriteTime func(...tengo.Object) (tengo.Object, error)

+ GetWriter func(...tengo.Object) (tengo.Object, error)

+ PullBinaryFile func(...tengo.Object) (tengo.Object, error)

+ PullBool func(...tengo.Object) (tengo.Object, error)

+ PullEntityReference func(...tengo.Object) (tengo.Object, error)

+ PullFloat func(...tengo.Object) (tengo.Object, error)

+ PullInt func(...tengo.Object) (tengo.Object, error)

+ PullString func(...tengo.Object) (tengo.Object, error)

+ PullTimestamp func(...tengo.Object) (tengo.Object, error)

+ PullWriteTime func(...tengo.Object) (tengo.Object, error)

+ PullWriter func(...tengo.Object) (tengo.Object, error)

+ PushBinaryFile func(...tengo.Object) (tengo.Object, error)

+ PushBool func(...tengo.Object) (tengo.Object, error)

+ PushEntityReference func(...tengo.Object) (tengo.Object, error)

+ PushFloat func(...tengo.Object) (tengo.Object, error)

+ PushInt func(...tengo.Object) (tengo.Object, error)

+ PushString func(...tengo.Object) (tengo.Object, error)

+ PushTimestamp func(...tengo.Object) (tengo.Object, error)

+ ToTengoMap func() tengo.Object

+ func NewTengoField(field IField) ITengoField

+ type ITransformer interface

+ Exec func(*Transformation, IField)

+ func NewTransformer(db IDatabase) ITransformer

+ type TengoDatabase struct

+ func (tdb *TengoDatabase) Find(args ...tengo.Object) (tengo.Object, error)

+ func (tdb *TengoDatabase) GetEntity(args ...tengo.Object) (tengo.Object, error)

+ func (tdb *TengoDatabase) ToTengoMap() tengo.Object

+ type TengoEntity struct

+ func (te *TengoEntity) GetChildren(...tengo.Object) (tengo.Object, error)

+ func (te *TengoEntity) GetField(args ...tengo.Object) (tengo.Object, error)

+ func (te *TengoEntity) GetId(...tengo.Object) (tengo.Object, error)

+ func (te *TengoEntity) GetParent(...tengo.Object) (tengo.Object, error)

+ func (te *TengoEntity) GetType(...tengo.Object) (tengo.Object, error)

+ func (te *TengoEntity) ToTengoMap() tengo.Object

+ type TengoField struct

+ func (tf *TengoField) GetBinaryFile(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetBool(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetEntityReference(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetFloat(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetId(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetInt(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetName(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetString(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetTimestamp(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetWriteTime(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) GetWriter(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullBinaryFile(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullBool(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullEntityReference(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullFloat(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullInt(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullString(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullTimestamp(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullWriteTime(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PullWriter(...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushBinaryFile(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushBool(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushEntityReference(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushFloat(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushInt(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushString(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) PushTimestamp(args ...tengo.Object) (tengo.Object, error)

+ func (tf *TengoField) ToTengoMap() tengo.Object

+ type Transformation struct

+ Raw string

+ func (*Transformation) Descriptor() ([]byte, []int)

+ func (*Transformation) ProtoMessage()

+ func (x *Transformation) GetRaw() string

+ func (x *Transformation) ProtoReflect() protoreflect.Message

+ func (x *Transformation) Reset()

+ func (x *Transformation) String() string

+ type Transformer struct

+ func (t *Transformer) Exec(transformation *Transformation, field IField)

v1.2.76

Nov 5, 2024

v1.2.75

Nov 5, 2024

v1.2.74

Nov 5, 2024

Changes in this version

+ func GetApplicationName() string

+ func SetApplicationName(name string)

v1.2.73

Nov 5, 2024

Changes in this version

+ func GetSetAppName() (func() string, func(string))

v1.2.72

Nov 5, 2024

v1.2.71

Nov 5, 2024

Changes in this version

type DatabaseNotificationConfig

+ ServiceId string

+ func (x *DatabaseNotificationConfig) GetServiceId() string

type RedisDatabaseConfig

+ ServiceID string

v1.2.70

Oct 16, 2024

v1.2.69

Oct 14, 2024

Changes in this version

type Field

+ func (f *Field) GetBinaryFile() string

+ func (f *Field) GetBool() bool

+ func (f *Field) GetEntityReference() string

+ func (f *Field) GetFloat() float64

+ func (f *Field) GetId() string

+ func (f *Field) GetInt() int64

+ func (f *Field) GetName() string

+ func (f *Field) GetString() string

+ func (f *Field) GetTimestamp() time.Time

+ func (f *Field) GetValue(m proto.Message) proto.Message

+ func (f *Field) GetWriteTime() time.Time

+ func (f *Field) GetWriter() string

+ func (f *Field) PullWriteTime() time.Time

+ func (f *Field) PullWriter() string

type IField

+ GetBinaryFile func() string

+ GetBool func() bool

+ GetEntityReference func() string

+ GetFloat func() float64

+ GetId func() string

+ GetInt func() int64

+ GetName func() string

+ GetString func() string

+ GetTimestamp func() time.Time

+ GetValue func(m proto.Message) proto.Message

+ GetWriteTime func() time.Time

+ GetWriter func() string

+ PullWriteTime func() time.Time

+ PullWriter func() string

v1.2.68

Oct 14, 2024

Changes in this version

type Field

+ func (f *Field) PullTimestamp() time.Time

+ func (f *Field) PushTimestamp(args ...interface{}) bool

type IField

+ PullTimestamp func() time.Time

+ PushTimestamp func(...interface{}) bool

v1.2.67

Oct 14, 2024

Changes in this version

+ type PushOpt int

+ const PushIfNotEqual

+ const PushNormal

v1.2.66

Oct 13, 2024

v1.2.65

Sep 22, 2024

v1.2.64

Sep 22, 2024

v1.2.63

Sep 15, 2024

v1.2.62

Sep 15, 2024

Changes in this version

+ func NewBinaryFileValue(value string) *anypb.Any

+ func NewBoolValue(value bool) *anypb.Any

+ func NewEntityReferenceValue(value string) *anypb.Any

+ func NewFloatValue(value float64) *anypb.Any

+ func NewIntValue(value int64) *anypb.Any

+ func NewStringValue(value string) *anypb.Any

+ func NewTimestampValue(value time.Time) *anypb.Any

v1.2.61

Sep 14, 2024

v1.2.60

Aug 6, 2024

Changes in this version

+ var WebHeader_AuthenticationStatusEnum_name = map[int32]string

+ var WebHeader_AuthenticationStatusEnum_value = map[string]int32

type WebHeader

+ AuthenticationStatus WebHeader_AuthenticationStatusEnum

+ func (x *WebHeader) GetAuthenticationStatus() WebHeader_AuthenticationStatusEnum

+ type WebHeader_AuthenticationStatusEnum int32

+ const WebHeader_AUTHENTICATED

+ const WebHeader_UNAUTHENTICATED

+ const WebHeader_UNSPECIFIED

+ func (WebHeader_AuthenticationStatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebHeader_AuthenticationStatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebHeader_AuthenticationStatusEnum) Type() protoreflect.EnumType

+ func (x WebHeader_AuthenticationStatusEnum) Enum() *WebHeader_AuthenticationStatusEnum

+ func (x WebHeader_AuthenticationStatusEnum) Number() protoreflect.EnumNumber

+ func (x WebHeader_AuthenticationStatusEnum) String() string

v1.2.59

Aug 2, 2024

v1.2.58

Jul 26, 2024

Changes in this version

type ISchemaValidator

+ ValidationRequired func()

type SchemaValidator

+ func (v *SchemaValidator) ValidationRequired()

v1.2.57

Jul 21, 2024

v1.2.56

Jul 20, 2024

v1.2.55

Jul 20, 2024

v1.2.54

Jul 19, 2024

v1.2.53

Jul 19, 2024

Changes in this version

+ func Register_web_handler_database_interactor()

v1.2.52

Jul 19, 2024

v1.2.51

Jul 19, 2024

Changes in this version

+ type WebRuntimeGetEntitiesRequest struct

+ EntityType string

+ func (*WebRuntimeGetEntitiesRequest) Descriptor() ([]byte, []int)

+ func (*WebRuntimeGetEntitiesRequest) ProtoMessage()

+ func (x *WebRuntimeGetEntitiesRequest) GetEntityType() string

+ func (x *WebRuntimeGetEntitiesRequest) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeGetEntitiesRequest) Reset()

+ func (x *WebRuntimeGetEntitiesRequest) String() string

+ type WebRuntimeGetEntitiesResponse struct

+ Entities []*DatabaseEntity

+ func (*WebRuntimeGetEntitiesResponse) Descriptor() ([]byte, []int)

+ func (*WebRuntimeGetEntitiesResponse) ProtoMessage()

+ func (x *WebRuntimeGetEntitiesResponse) GetEntities() []*DatabaseEntity

+ func (x *WebRuntimeGetEntitiesResponse) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeGetEntitiesResponse) Reset()

+ func (x *WebRuntimeGetEntitiesResponse) String() string

v1.2.50

Jul 18, 2024

v1.2.49

Jul 18, 2024

v1.2.48

Jul 18, 2024

Changes in this version

+ func ValueEquals(a *anypb.Any, b *anypb.Any) bool

v1.2.47

Jul 18, 2024

Changes in this version

+ func ValueCast[T proto.Message](value *anypb.Any) T

v1.2.46

Jul 16, 2024

Changes in this version

+ type FCReference = FieldCondition[*EntityReference, string, string]

+ func NewReferenceCondition() *FCReference

v1.2.45

Jul 14, 2024

Changes in this version

type INotificationToken

+ Id func() string

type NotificationToken

+ func (t *NotificationToken) Id() string

v1.2.44

Jul 14, 2024

Changes in this version

type IDatabase

+ UnnotifyCallback func(subscriptionId string, callback INotificationCallback)

+ type INotificationCallback interface

+ Fn func(*DatabaseNotification)

+ Id func() string

+ func NewNotificationCallback(fn func(*DatabaseNotification)) INotificationCallback

+ type INotificationToken interface

+ Unbind func()

+ type NotificationCallback struct

+ func (c *NotificationCallback) Fn(n *DatabaseNotification)

+ func (c *NotificationCallback) Id() string

+ type NotificationToken struct

+ func (t *NotificationToken) Unbind()

type RedisDatabase

+ func (db *RedisDatabase) UnnotifyCallback(e string, c INotificationCallback)

v1.2.43

Jul 11, 2024

Changes in this version

type Field

+ func (f *Field) PullBinaryFile() string

+ func (f *Field) PullBool() bool

+ func (f *Field) PullEntityReference() string

+ func (f *Field) PullFloat() float64

+ func (f *Field) PullInt() int64

+ func (f *Field) PullString() string

+ func (f *Field) PushBinaryFile(value string) bool

+ func (f *Field) PushBool(value bool) bool

+ func (f *Field) PushEntityReference(value string) bool

+ func (f *Field) PushFloat(value float64) bool

+ func (f *Field) PushInt(value int64) bool

+ func (f *Field) PushString(value string) bool

type IField

+ PullBinaryFile func() string

+ PullBool func() bool

+ PullEntityReference func() string

+ PullFloat func() float64

+ PullInt func() int64

+ PullString func() string

+ PushBinaryFile func(string) bool

+ PushBool func(bool) bool

+ PushEntityReference func(string) bool

+ PushFloat func(float64) bool

+ PushInt func(int64) bool

+ PushString func(string) bool

v1.2.42

Jul 2, 2024

v1.2.41

Jul 2, 2024

v1.2.40

Jul 2, 2024

v1.2.39

Jul 1, 2024

Changes in this version

+ func DefaultCaster[A any, B any](in A) B

+ type FCBool = FieldCondition[*Bool, int, bool]

+ func NewBoolCondition() *FCBool

+ type FCEnum struct

+ func NewEnumCondition[T ~int32]() *FCEnum[T]

+ type FCFloat = FieldCondition[*Float, float64, float64]

+ func NewFloatCondition() *FCFloat

+ type FCInt = FieldCondition[*Int, int64, int64]

+ func NewIntCondition() *FCInt

+ type FCString = FieldCondition[*String, string, string]

+ func NewStringCondition() *FCString

+ type FCTimestamp = FieldCondition[*Timestamp, int64, *timestamppb.Timestamp]

+ func NewTimestampCondition() *FCTimestamp

type FieldCondition

+ Caster func(K) C

+ type ISchemaValidator interface

+ AddEntity func(entityId string, fields ...string)

+ IsValid func() bool

+ OnSchemaUpdated func()

+ Validate func() bool

+ func NewSchemaValidator(db IDatabase) ISchemaValidator

+ type SchemaValidator struct

+ func (v *SchemaValidator) AddEntity(entityType string, fields ...string)

+ func (v *SchemaValidator) IsValid() bool

+ func (v *SchemaValidator) OnSchemaUpdated()

+ func (v *SchemaValidator) Validate() bool

v1.2.38

Jun 29, 2024

Changes in this version

+ func Truncate(text string, width int) string

v1.2.37

Jun 29, 2024

Changes in this version

+ func FileDecode(encoded string) []byte

+ func FileEncode(content []byte) string

v1.2.36

Jun 29, 2024

v1.2.35

Jun 27, 2024

v1.2.34

Jun 27, 2024

v1.2.33

Jun 27, 2024

v1.2.32

Jun 27, 2024

v1.2.31

Jun 27, 2024

Changes in this version

+ const LeaderLeaseTimeout

type DatabaseWorker

+ func (w *DatabaseWorker) IsConnected() bool

+ func (w *DatabaseWorker) OnSchemaUpdated(*DatabaseNotification)

type DatabaseWorkerSignals

+ SchemaUpdated Signal

type IDatabase

+ TempDel func(key string)

+ TempExpire func(key string, expiration time.Duration)

+ TempGet func(key string) string

+ TempScan func(key string) []string

+ TempSet func(key string, value string, expiration time.Duration) bool

+ type LeaderAvailabilityCriteria func() bool

+ type LeaderElectionKeyGenerator struct

+ func (g *LeaderElectionKeyGenerator) GetLeaderCandidatesKey(app string, instanceId string) string

+ func (g *LeaderElectionKeyGenerator) GetLeaderKey(app string) string

+ type LeaderElectionWorker struct

+ Signals LeaderElectionWorkerSignals

+ func NewLeaderElectionWorker(db IDatabase) *LeaderElectionWorker

+ func (w *LeaderElectionWorker) AddAvailabilityCriteria(criteria LeaderAvailabilityCriteria)

+ func (w *LeaderElectionWorker) Deinit()

+ func (w *LeaderElectionWorker) DoWork()

+ func (w *LeaderElectionWorker) Init()

+ func (w *LeaderElectionWorker) OnDatabaseConnected()

+ func (w *LeaderElectionWorker) OnDatabaseDisconnected()

+ func (w *LeaderElectionWorker) OnSchemaUpdated()

+ type LeaderElectionWorkerSignals struct

+ BecameFollower Signal

+ BecameLeader Signal

+ BecameUnavailable Signal

+ LosingLeadership Signal

+ type LeaderStates int

+ const Follower

+ const Leader

+ const Unavailable

type RedisDatabase

+ func (db *RedisDatabase) TempDel(key string)

+ func (db *RedisDatabase) TempExpire(key string, expiration time.Duration)

+ func (db *RedisDatabase) TempGet(key string) string

+ func (db *RedisDatabase) TempScan(key string) []string

+ func (db *RedisDatabase) TempSet(key, value string, expiration time.Duration) bool

v1.2.30

Jun 25, 2024

Changes in this version

+ var ConnectionState_ConnectionStateEnum_name = map[int32]string

+ var ConnectionState_ConnectionStateEnum_value = map[string]int32

+ var File_src_protobufs_proto protoreflect.FileDescriptor

+ var GarageDoorState_GarageDoorStateEnum_name = map[int32]string

+ var GarageDoorState_GarageDoorStateEnum_value = map[string]int32

+ var LogMessage_LogLevelEnum_name = map[int32]string

+ var LogMessage_LogLevelEnum_value = map[string]int32

+ var WebConfigCreateEntityResponse_StatusEnum_name = map[int32]string

+ var WebConfigCreateEntityResponse_StatusEnum_value = map[string]int32

+ var WebConfigCreateSnapshotResponse_StatusEnum_name = map[int32]string

+ var WebConfigCreateSnapshotResponse_StatusEnum_value = map[string]int32

+ var WebConfigDeleteEntityResponse_StatusEnum_name = map[int32]string

+ var WebConfigDeleteEntityResponse_StatusEnum_value = map[string]int32

+ var WebConfigGetEntityResponse_StatusEnum_name = map[int32]string

+ var WebConfigGetEntityResponse_StatusEnum_value = map[string]int32

+ var WebConfigGetEntitySchemaResponse_StatusEnum_name = map[int32]string

+ var WebConfigGetEntitySchemaResponse_StatusEnum_value = map[string]int32

+ var WebConfigGetFieldSchemaResponse_StatusEnum_name = map[int32]string

+ var WebConfigGetFieldSchemaResponse_StatusEnum_value = map[string]int32

+ var WebConfigRestoreSnapshotResponse_StatusEnum_name = map[int32]string

+ var WebConfigRestoreSnapshotResponse_StatusEnum_value = map[string]int32

+ var WebConfigSetEntitySchemaResponse_StatusEnum_name = map[int32]string

+ var WebConfigSetEntitySchemaResponse_StatusEnum_value = map[string]int32

+ var WebConfigSetFieldSchemaResponse_StatusEnum_name = map[int32]string

+ var WebConfigSetFieldSchemaResponse_StatusEnum_value = map[string]int32

+ var WebRuntimeDatabaseRequest_RequestTypeEnum_name = map[int32]string

+ var WebRuntimeDatabaseRequest_RequestTypeEnum_value = map[string]int32

+ var WebRuntimeUnregisterNotificationResponse_StatusEnum_name = map[int32]string

+ var WebRuntimeUnregisterNotificationResponse_StatusEnum_value = map[string]int32

+ func Debug(message string, args ...interface{})

+ func Error(message string, args ...interface{})

+ func Info(message string, args ...interface{})

+ func Log(level LogMessage_LogLevelEnum, message string, args ...interface{})

+ func Panic(message string, args ...interface{})

+ func Register_web_handler_app()

+ func Register_web_handler_server_interactor()

+ func Register_web_handler_utils()

+ func Trace(message string, args ...interface{})

+ func Warn(message string, args ...interface{})

+ type Application struct

+ func (a *Application) Execute()

+ func (a *Application) Quit()

+ type ApplicationConfig struct

+ Name string

+ Workers []IWorker

+ type BinaryFile struct

+ Raw string

+ func (*BinaryFile) Descriptor() ([]byte, []int)

+ func (*BinaryFile) ProtoMessage()

+ func (x *BinaryFile) GetRaw() string

+ func (x *BinaryFile) ProtoReflect() protoreflect.Message

+ func (x *BinaryFile) Reset()

+ func (x *BinaryFile) String() string

+ type Bool struct

+ Raw bool

+ func (*Bool) Descriptor() ([]byte, []int)

+ func (*Bool) ProtoMessage()

+ func (x *Bool) GetRaw() bool

+ func (x *Bool) ProtoReflect() protoreflect.Message

+ func (x *Bool) Reset()

+ func (x *Bool) String() string

+ type ConnectionState struct

+ Raw ConnectionState_ConnectionStateEnum

+ func (*ConnectionState) Descriptor() ([]byte, []int)

+ func (*ConnectionState) ProtoMessage()

+ func (x *ConnectionState) GetRaw() ConnectionState_ConnectionStateEnum

+ func (x *ConnectionState) ProtoReflect() protoreflect.Message

+ func (x *ConnectionState) Reset()

+ func (x *ConnectionState) String() string

+ type ConnectionState_ConnectionStateEnum int32

+ const ConnectionState_CONNECTED

+ const ConnectionState_DISCONNECTED

+ const ConnectionState_UNSPECIFIED

+ func (ConnectionState_ConnectionStateEnum) Descriptor() protoreflect.EnumDescriptor

+ func (ConnectionState_ConnectionStateEnum) EnumDescriptor() ([]byte, []int)

+ func (ConnectionState_ConnectionStateEnum) Type() protoreflect.EnumType

+ func (x ConnectionState_ConnectionStateEnum) Enum() *ConnectionState_ConnectionStateEnum

+ func (x ConnectionState_ConnectionStateEnum) Number() protoreflect.EnumNumber

+ func (x ConnectionState_ConnectionStateEnum) String() string

+ type DatabaseEntity struct

+ Children []*EntityReference

+ Id string

+ Name string

+ Parent *EntityReference

+ Type string

+ func (*DatabaseEntity) Descriptor() ([]byte, []int)

+ func (*DatabaseEntity) ProtoMessage()

+ func (x *DatabaseEntity) GetChildren() []*EntityReference

+ func (x *DatabaseEntity) GetId() string

+ func (x *DatabaseEntity) GetName() string

+ func (x *DatabaseEntity) GetParent() *EntityReference

+ func (x *DatabaseEntity) GetType() string

+ func (x *DatabaseEntity) ProtoReflect() protoreflect.Message

+ func (x *DatabaseEntity) Reset()

+ func (x *DatabaseEntity) String() string

+ type DatabaseEntitySchema struct

+ Fields []string

+ Name string

+ func (*DatabaseEntitySchema) Descriptor() ([]byte, []int)

+ func (*DatabaseEntitySchema) ProtoMessage()

+ func (x *DatabaseEntitySchema) GetFields() []string

+ func (x *DatabaseEntitySchema) GetName() string

+ func (x *DatabaseEntitySchema) ProtoReflect() protoreflect.Message

+ func (x *DatabaseEntitySchema) Reset()

+ func (x *DatabaseEntitySchema) String() string

+ type DatabaseField struct

+ Id string

+ Name string

+ Value *anypb.Any

+ WriteTime *timestamppb.Timestamp

+ WriterId string

+ func (*DatabaseField) Descriptor() ([]byte, []int)

+ func (*DatabaseField) ProtoMessage()

+ func (f *DatabaseField) FromRequest(request *DatabaseRequest) *DatabaseField

+ func (x *DatabaseField) GetId() string

+ func (x *DatabaseField) GetName() string

+ func (x *DatabaseField) GetValue() *anypb.Any

+ func (x *DatabaseField) GetWriteTime() *timestamppb.Timestamp

+ func (x *DatabaseField) GetWriterId() string

+ func (x *DatabaseField) ProtoReflect() protoreflect.Message

+ func (x *DatabaseField) Reset()

+ func (x *DatabaseField) String() string

+ type DatabaseFieldSchema struct

+ Name string

+ Type string

+ func (*DatabaseFieldSchema) Descriptor() ([]byte, []int)

+ func (*DatabaseFieldSchema) ProtoMessage()

+ func (x *DatabaseFieldSchema) GetName() string

+ func (x *DatabaseFieldSchema) GetType() string

+ func (x *DatabaseFieldSchema) ProtoReflect() protoreflect.Message

+ func (x *DatabaseFieldSchema) Reset()

+ func (x *DatabaseFieldSchema) String() string

+ type DatabaseNotification struct

+ Context []*DatabaseField

+ Current *DatabaseField

+ Previous *DatabaseField

+ Token string

+ func (*DatabaseNotification) Descriptor() ([]byte, []int)

+ func (*DatabaseNotification) ProtoMessage()

+ func (x *DatabaseNotification) GetContext() []*DatabaseField

+ func (x *DatabaseNotification) GetCurrent() *DatabaseField

+ func (x *DatabaseNotification) GetPrevious() *DatabaseField

+ func (x *DatabaseNotification) GetToken() string

+ func (x *DatabaseNotification) ProtoReflect() protoreflect.Message

+ func (x *DatabaseNotification) Reset()

+ func (x *DatabaseNotification) String() string

+ type DatabaseNotificationConfig struct

+ ContextFields []string

+ Field string

+ Id string

+ NotifyOnChange bool

+ Type string

+ func (*DatabaseNotificationConfig) Descriptor() ([]byte, []int)

+ func (*DatabaseNotificationConfig) ProtoMessage()

+ func (x *DatabaseNotificationConfig) GetContextFields() []string

+ func (x *DatabaseNotificationConfig) GetField() string

+ func (x *DatabaseNotificationConfig) GetId() string

+ func (x *DatabaseNotificationConfig) GetNotifyOnChange() bool

+ func (x *DatabaseNotificationConfig) GetType() string

+ func (x *DatabaseNotificationConfig) ProtoReflect() protoreflect.Message

+ func (x *DatabaseNotificationConfig) Reset()

+ func (x *DatabaseNotificationConfig) String() string

+ type DatabaseRequest struct

+ Field string

+ Id string

+ Success bool

+ Value *anypb.Any

+ WriteTime *Timestamp

+ WriterId *String

+ func (*DatabaseRequest) Descriptor() ([]byte, []int)

+ func (*DatabaseRequest) ProtoMessage()

+ func (r *DatabaseRequest) FromField(field *DatabaseField) *DatabaseRequest

+ func (x *DatabaseRequest) GetField() string

+ func (x *DatabaseRequest) GetId() string

+ func (x *DatabaseRequest) GetSuccess() bool

+ func (x *DatabaseRequest) GetValue() *anypb.Any

+ func (x *DatabaseRequest) GetWriteTime() *Timestamp

+ func (x *DatabaseRequest) GetWriterId() *String

+ func (x *DatabaseRequest) ProtoReflect() protoreflect.Message

+ func (x *DatabaseRequest) Reset()

+ func (x *DatabaseRequest) String() string

+ type DatabaseSnapshot struct

+ Entities []*DatabaseEntity

+ EntitySchemas []*DatabaseEntitySchema

+ FieldSchemas []*DatabaseFieldSchema

+ Fields []*DatabaseField

+ func (*DatabaseSnapshot) Descriptor() ([]byte, []int)

+ func (*DatabaseSnapshot) ProtoMessage()

+ func (x *DatabaseSnapshot) GetEntities() []*DatabaseEntity

+ func (x *DatabaseSnapshot) GetEntitySchemas() []*DatabaseEntitySchema

+ func (x *DatabaseSnapshot) GetFieldSchemas() []*DatabaseFieldSchema

+ func (x *DatabaseSnapshot) GetFields() []*DatabaseField

+ func (x *DatabaseSnapshot) ProtoReflect() protoreflect.Message

+ func (x *DatabaseSnapshot) Reset()

+ func (x *DatabaseSnapshot) String() string

+ type DatabaseWorker struct

+ Signals DatabaseWorkerSignals

+ func NewDatabaseWorker(db IDatabase) *DatabaseWorker

+ func (w *DatabaseWorker) Deinit()

+ func (w *DatabaseWorker) DoWork()

+ func (w *DatabaseWorker) Init()

+ type DatabaseWorkerSignals struct

+ Connected Signal

+ Disconnected Signal

+ type Entity struct

+ func NewEntity(db IDatabase, entityId string) *Entity

+ func (e *Entity) GetChildren() []*EntityReference

+ func (e *Entity) GetField(fieldName string) IField

+ func (e *Entity) GetId() string

+ func (e *Entity) GetName() string

+ func (e *Entity) GetParent() *EntityReference

+ func (e *Entity) GetType() string

+ type EntityFinder struct

+ func NewEntityFinder(db IDatabase) *EntityFinder

+ func (f *EntityFinder) Find(criteria SearchCriteria) []IEntity

+ type EntityReference struct

+ Raw string

+ func (*EntityReference) Descriptor() ([]byte, []int)

+ func (*EntityReference) ProtoMessage()

+ func (x *EntityReference) GetRaw() string

+ func (x *EntityReference) ProtoReflect() protoreflect.Message

+ func (x *EntityReference) Reset()

+ func (x *EntityReference) String() string

+ type Field struct

+ func NewField(db IDatabase, entityId string, fieldName string) *Field

+ func (f *Field) PullValue(m proto.Message) proto.Message

+ func (f *Field) PushValue(m proto.Message) bool

+ type FieldCondition struct

+ Lhs string

+ LhsValue T

+ func (f *FieldCondition[C, T]) IsBetween(lower T, upper T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsEqualTo(rhs T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsGreaterThan(rhs T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsGreaterThanOrEqualTo(rhs T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsIn(values []T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsLessThan(rhs T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsLessThanOrEqualTo(rhs T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsNotEqualTo(rhs T) FieldConditionEval

+ func (f *FieldCondition[C, T]) IsNotIn(values []T) FieldConditionEval

+ func (f *FieldCondition[C, T]) Where(lhs string) *FieldCondition[C, T]

+ type FieldConditionEval func(IDatabase, string) bool

+ type Float struct

+ Raw float64

+ func (*Float) Descriptor() ([]byte, []int)

+ func (*Float) ProtoMessage()

+ func (x *Float) GetRaw() float64

+ func (x *Float) ProtoReflect() protoreflect.Message

+ func (x *Float) Reset()

+ func (x *Float) String() string

+ type GarageDoorState struct

+ Raw GarageDoorState_GarageDoorStateEnum

+ func (*GarageDoorState) Descriptor() ([]byte, []int)

+ func (*GarageDoorState) ProtoMessage()

+ func (x *GarageDoorState) GetRaw() GarageDoorState_GarageDoorStateEnum

+ func (x *GarageDoorState) ProtoReflect() protoreflect.Message

+ func (x *GarageDoorState) Reset()

+ func (x *GarageDoorState) String() string

+ type GarageDoorState_GarageDoorStateEnum int32

+ const GarageDoorState_CLOSED

+ const GarageDoorState_OPENED

+ const GarageDoorState_UNSPECIFIED

+ func (GarageDoorState_GarageDoorStateEnum) Descriptor() protoreflect.EnumDescriptor

+ func (GarageDoorState_GarageDoorStateEnum) EnumDescriptor() ([]byte, []int)

+ func (GarageDoorState_GarageDoorStateEnum) Type() protoreflect.EnumType

+ func (x GarageDoorState_GarageDoorStateEnum) Enum() *GarageDoorState_GarageDoorStateEnum

+ func (x GarageDoorState_GarageDoorStateEnum) Number() protoreflect.EnumNumber

+ func (x GarageDoorState_GarageDoorStateEnum) String() string

+ type IApplication interface

+ Execute func()

+ Quit func()

+ func NewApplication(config ApplicationConfig) IApplication

+ type IDatabase interface

+ Connect func()

+ CreateEntity func(entityType, parentId, name string)

+ CreateSnapshot func() *DatabaseSnapshot

+ DeleteEntity func(entityId string)

+ Disconnect func()

+ EntityExists func(entityId string) bool

+ FieldExists func(fieldName, entityType string) bool

+ FindEntities func(entityType string) []string

+ GetEntity func(entityId string) *DatabaseEntity

+ GetEntitySchema func(entityType string) *DatabaseEntitySchema

+ GetEntityTypes func() []string

+ GetFieldSchema func(fieldName string) *DatabaseFieldSchema

+ GetFieldSchemas func() []*DatabaseFieldSchema

+ IsConnected func() bool

+ Notify func(config *DatabaseNotificationConfig, callback func(*DatabaseNotification)) string

+ ProcessNotifications func()

+ Read func(requests []*DatabaseRequest)

+ RestoreSnapshot func(snapshot *DatabaseSnapshot)

+ SetEntity func(entityId string, value *DatabaseEntity)

+ SetEntitySchema func(entityType string, value *DatabaseEntitySchema)

+ SetFieldSchema func(fieldName string, value *DatabaseFieldSchema)

+ Unnotify func(subscriptionId string)

+ Write func(requests []*DatabaseRequest)

+ func NewRedisDatabase(config RedisDatabaseConfig) IDatabase

+ type IEntity interface

+ GetChildren func() []*EntityReference

+ GetField func(string) IField

+ GetId func() string

+ GetName func() string

+ GetParent func() *EntityReference

+ GetType func() string

+ type IEntityFinder interface

+ Find func(SearchCriteria) []IEntity

+ type IField interface

+ PullValue func(m proto.Message) proto.Message

+ PushValue func(m proto.Message) bool

+ type IFieldProto interface

+ GetRaw func() T

+ type ISignal interface

+ Connect func(ISlot)

+ Disconnect func(ISlot)

+ DisconnectAll func()

+ Emit func(...interface{})

+ type ISlot interface

+ Invoke func(...interface{})

+ func Slot(fn func()) ISlot

+ func SlotWithArgs(fn func(...interface{})) ISlot

+ type IWebClient interface

+ Close func()

+ Id func() string

+ Read func() *WebMessage

+ Write func(message *WebMessage)

+ type IWorker interface

+ Deinit func()

+ DoWork func()

+ Init func()

+ type Int struct

+ Raw int64

+ func (*Int) Descriptor() ([]byte, []int)

+ func (*Int) ProtoMessage()

+ func (x *Int) GetRaw() int64

+ func (x *Int) ProtoReflect() protoreflect.Message

+ func (x *Int) Reset()

+ func (x *Int) String() string

+ type LogMessage struct

+ Application string

+ Level LogMessage_LogLevelEnum

+ Message string

+ Timestamp *timestamppb.Timestamp

+ func (*LogMessage) Descriptor() ([]byte, []int)

+ func (*LogMessage) ProtoMessage()

+ func (x *LogMessage) GetApplication() string

+ func (x *LogMessage) GetLevel() LogMessage_LogLevelEnum

+ func (x *LogMessage) GetMessage() string

+ func (x *LogMessage) GetTimestamp() *timestamppb.Timestamp

+ func (x *LogMessage) ProtoReflect() protoreflect.Message

+ func (x *LogMessage) Reset()

+ func (x *LogMessage) String() string

+ type LogMessage_LogLevelEnum int32

+ const LogMessage_DEBUG

+ const LogMessage_ERROR

+ const LogMessage_INFO

+ const LogMessage_PANIC

+ const LogMessage_TRACE

+ const LogMessage_UNSPECIFIED

+ const LogMessage_WARN

+ func (LogMessage_LogLevelEnum) Descriptor() protoreflect.EnumDescriptor

+ func (LogMessage_LogLevelEnum) EnumDescriptor() ([]byte, []int)

+ func (LogMessage_LogLevelEnum) Type() protoreflect.EnumType

+ func (x LogMessage_LogLevelEnum) Enum() *LogMessage_LogLevelEnum

+ func (x LogMessage_LogLevelEnum) Number() protoreflect.EnumNumber

+ func (x LogMessage_LogLevelEnum) String() string

+ type RedisDatabase struct

+ func (db *RedisDatabase) Connect()

+ func (db *RedisDatabase) CreateEntity(entityType, parentId, name string)

+ func (db *RedisDatabase) CreateSnapshot() *DatabaseSnapshot

+ func (db *RedisDatabase) DeleteEntity(entityId string)

+ func (db *RedisDatabase) Disconnect()

+ func (db *RedisDatabase) EntityExists(entityId string) bool

+ func (db *RedisDatabase) FieldExists(fieldName, entityTypeOrId string) bool

+ func (db *RedisDatabase) FindEntities(entityType string) []string

+ func (db *RedisDatabase) GetEntity(entityId string) *DatabaseEntity

+ func (db *RedisDatabase) GetEntitySchema(entityType string) *DatabaseEntitySchema

+ func (db *RedisDatabase) GetEntityTypes() []string

+ func (db *RedisDatabase) GetFieldSchema(fieldName string) *DatabaseFieldSchema

+ func (db *RedisDatabase) GetFieldSchemas() []*DatabaseFieldSchema

+ func (db *RedisDatabase) IsConnected() bool

+ func (db *RedisDatabase) Notify(notification *DatabaseNotificationConfig, callback func(*DatabaseNotification)) string

+ func (db *RedisDatabase) ProcessNotifications()

+ func (db *RedisDatabase) Read(requests []*DatabaseRequest)

+ func (db *RedisDatabase) ResolveIndirection(indirectField, entityId string) (string, string)

+ func (db *RedisDatabase) RestoreSnapshot(snapshot *DatabaseSnapshot)

+ func (db *RedisDatabase) SetEntity(entityId string, value *DatabaseEntity)

+ func (db *RedisDatabase) SetEntitySchema(entityType string, value *DatabaseEntitySchema)

+ func (db *RedisDatabase) SetFieldSchema(fieldName string, value *DatabaseFieldSchema)

+ func (db *RedisDatabase) Unnotify(e string)

+ func (db *RedisDatabase) Write(requests []*DatabaseRequest)

+ type RedisDatabaseConfig struct

+ Address string

+ Password string

+ type RedisDatabaseKeyGenerator struct

+ func (g *RedisDatabaseKeyGenerator) GetEntityIdNotificationConfigKey(entityId, fieldName string) string

+ func (g *RedisDatabaseKeyGenerator) GetEntityKey(entityId string) string

+ func (g *RedisDatabaseKeyGenerator) GetEntitySchemaKey(entityType string) string

+ func (g *RedisDatabaseKeyGenerator) GetEntityTypeKey(entityType string) string

+ func (g *RedisDatabaseKeyGenerator) GetEntityTypeNotificationConfigKey(entityType, fieldName string) string

+ func (g *RedisDatabaseKeyGenerator) GetFieldKey(fieldName, entityId string) string

+ func (g *RedisDatabaseKeyGenerator) GetFieldSchemaKey(fieldName string) string

+ func (g *RedisDatabaseKeyGenerator) GetNotificationChannelKey(marshalledNotificationConfig string) string

+ type SearchCriteria struct

+ Conditions []FieldConditionEval

+ EntityType string

+ type Signal struct

+ func (s *Signal) Connect(slot ISlot)

+ func (s *Signal) Disconnect(slot ISlot)

+ func (s *Signal) DisconnectAll()

+ func (s *Signal) Emit(args ...interface{})

+ type SlotDefinition struct

+ Fn func(...interface{})

+ func (s *SlotDefinition) Invoke(args ...interface{})

+ type String struct

+ Raw string

+ func (*String) Descriptor() ([]byte, []int)

+ func (*String) ProtoMessage()

+ func (x *String) GetRaw() string

+ func (x *String) ProtoReflect() protoreflect.Message

+ func (x *String) Reset()

+ func (x *String) String() string

+ type Timestamp struct

+ Raw *timestamppb.Timestamp

+ func (*Timestamp) Descriptor() ([]byte, []int)

+ func (*Timestamp) ProtoMessage()

+ func (x *Timestamp) GetRaw() *timestamppb.Timestamp

+ func (x *Timestamp) ProtoReflect() protoreflect.Message

+ func (x *Timestamp) Reset()

+ func (x *Timestamp) String() string

+ type WebClient struct

+ func NewWebClient(connection *websocket.Conn, onClose func(string)) *WebClient

+ func (c *WebClient) Close()

+ func (c *WebClient) Id() string

+ func (c *WebClient) Read() *WebMessage

+ func (c *WebClient) Write(message *WebMessage)

+ type WebConfigCreateEntityRequest struct

+ Name string

+ ParentId string

+ Type string

+ func (*WebConfigCreateEntityRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigCreateEntityRequest) ProtoMessage()

+ func (x *WebConfigCreateEntityRequest) GetName() string

+ func (x *WebConfigCreateEntityRequest) GetParentId() string

+ func (x *WebConfigCreateEntityRequest) GetType() string

+ func (x *WebConfigCreateEntityRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigCreateEntityRequest) Reset()

+ func (x *WebConfigCreateEntityRequest) String() string

+ type WebConfigCreateEntityResponse struct

+ Id string

+ Status WebConfigCreateEntityResponse_StatusEnum

+ func (*WebConfigCreateEntityResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigCreateEntityResponse) ProtoMessage()

+ func (x *WebConfigCreateEntityResponse) GetId() string

+ func (x *WebConfigCreateEntityResponse) GetStatus() WebConfigCreateEntityResponse_StatusEnum

+ func (x *WebConfigCreateEntityResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigCreateEntityResponse) Reset()

+ func (x *WebConfigCreateEntityResponse) String() string

+ type WebConfigCreateEntityResponse_StatusEnum int32

+ const WebConfigCreateEntityResponse_FAILURE

+ const WebConfigCreateEntityResponse_SUCCESS

+ const WebConfigCreateEntityResponse_UNSPECIFIED

+ func (WebConfigCreateEntityResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigCreateEntityResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigCreateEntityResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigCreateEntityResponse_StatusEnum) Enum() *WebConfigCreateEntityResponse_StatusEnum

+ func (x WebConfigCreateEntityResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigCreateEntityResponse_StatusEnum) String() string

+ type WebConfigCreateSnapshotRequest struct

+ func (*WebConfigCreateSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigCreateSnapshotRequest) ProtoMessage()

+ func (x *WebConfigCreateSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigCreateSnapshotRequest) Reset()

+ func (x *WebConfigCreateSnapshotRequest) String() string

+ type WebConfigCreateSnapshotResponse struct

+ Snapshot *DatabaseSnapshot

+ Status WebConfigCreateSnapshotResponse_StatusEnum

+ func (*WebConfigCreateSnapshotResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigCreateSnapshotResponse) ProtoMessage()

+ func (x *WebConfigCreateSnapshotResponse) GetSnapshot() *DatabaseSnapshot

+ func (x *WebConfigCreateSnapshotResponse) GetStatus() WebConfigCreateSnapshotResponse_StatusEnum

+ func (x *WebConfigCreateSnapshotResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigCreateSnapshotResponse) Reset()

+ func (x *WebConfigCreateSnapshotResponse) String() string

+ type WebConfigCreateSnapshotResponse_StatusEnum int32

+ const WebConfigCreateSnapshotResponse_FAILURE

+ const WebConfigCreateSnapshotResponse_SUCCESS

+ const WebConfigCreateSnapshotResponse_UNSPECIFIED

+ func (WebConfigCreateSnapshotResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigCreateSnapshotResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigCreateSnapshotResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigCreateSnapshotResponse_StatusEnum) Enum() *WebConfigCreateSnapshotResponse_StatusEnum

+ func (x WebConfigCreateSnapshotResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigCreateSnapshotResponse_StatusEnum) String() string

+ type WebConfigDeleteEntityRequest struct

+ Id string

+ func (*WebConfigDeleteEntityRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigDeleteEntityRequest) ProtoMessage()

+ func (x *WebConfigDeleteEntityRequest) GetId() string

+ func (x *WebConfigDeleteEntityRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigDeleteEntityRequest) Reset()

+ func (x *WebConfigDeleteEntityRequest) String() string

+ type WebConfigDeleteEntityResponse struct

+ Status WebConfigDeleteEntityResponse_StatusEnum

+ func (*WebConfigDeleteEntityResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigDeleteEntityResponse) ProtoMessage()

+ func (x *WebConfigDeleteEntityResponse) GetStatus() WebConfigDeleteEntityResponse_StatusEnum

+ func (x *WebConfigDeleteEntityResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigDeleteEntityResponse) Reset()

+ func (x *WebConfigDeleteEntityResponse) String() string

+ type WebConfigDeleteEntityResponse_StatusEnum int32

+ const WebConfigDeleteEntityResponse_FAILURE

+ const WebConfigDeleteEntityResponse_SUCCESS

+ const WebConfigDeleteEntityResponse_UNSPECIFIED

+ func (WebConfigDeleteEntityResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigDeleteEntityResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigDeleteEntityResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigDeleteEntityResponse_StatusEnum) Enum() *WebConfigDeleteEntityResponse_StatusEnum

+ func (x WebConfigDeleteEntityResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigDeleteEntityResponse_StatusEnum) String() string

+ type WebConfigGetAllFieldsRequest struct

+ func (*WebConfigGetAllFieldsRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigGetAllFieldsRequest) ProtoMessage()

+ func (x *WebConfigGetAllFieldsRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetAllFieldsRequest) Reset()

+ func (x *WebConfigGetAllFieldsRequest) String() string

+ type WebConfigGetAllFieldsResponse struct

+ Fields []string

+ func (*WebConfigGetAllFieldsResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigGetAllFieldsResponse) ProtoMessage()

+ func (x *WebConfigGetAllFieldsResponse) GetFields() []string

+ func (x *WebConfigGetAllFieldsResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetAllFieldsResponse) Reset()

+ func (x *WebConfigGetAllFieldsResponse) String() string

+ type WebConfigGetEntityRequest struct

+ Id string

+ func (*WebConfigGetEntityRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigGetEntityRequest) ProtoMessage()

+ func (x *WebConfigGetEntityRequest) GetId() string

+ func (x *WebConfigGetEntityRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetEntityRequest) Reset()

+ func (x *WebConfigGetEntityRequest) String() string

+ type WebConfigGetEntityResponse struct

+ Entity *DatabaseEntity

+ Status WebConfigGetEntityResponse_StatusEnum

+ func (*WebConfigGetEntityResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigGetEntityResponse) ProtoMessage()

+ func (x *WebConfigGetEntityResponse) GetEntity() *DatabaseEntity

+ func (x *WebConfigGetEntityResponse) GetStatus() WebConfigGetEntityResponse_StatusEnum

+ func (x *WebConfigGetEntityResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetEntityResponse) Reset()

+ func (x *WebConfigGetEntityResponse) String() string

+ type WebConfigGetEntityResponse_StatusEnum int32

+ const WebConfigGetEntityResponse_FAILURE

+ const WebConfigGetEntityResponse_SUCCESS

+ const WebConfigGetEntityResponse_UNSPECIFIED

+ func (WebConfigGetEntityResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigGetEntityResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigGetEntityResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigGetEntityResponse_StatusEnum) Enum() *WebConfigGetEntityResponse_StatusEnum

+ func (x WebConfigGetEntityResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigGetEntityResponse_StatusEnum) String() string

+ type WebConfigGetEntitySchemaRequest struct

+ Type string

+ func (*WebConfigGetEntitySchemaRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigGetEntitySchemaRequest) ProtoMessage()

+ func (x *WebConfigGetEntitySchemaRequest) GetType() string

+ func (x *WebConfigGetEntitySchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetEntitySchemaRequest) Reset()

+ func (x *WebConfigGetEntitySchemaRequest) String() string

+ type WebConfigGetEntitySchemaResponse struct

+ Schema *DatabaseEntitySchema

+ Status WebConfigGetEntitySchemaResponse_StatusEnum

+ func (*WebConfigGetEntitySchemaResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigGetEntitySchemaResponse) ProtoMessage()

+ func (x *WebConfigGetEntitySchemaResponse) GetSchema() *DatabaseEntitySchema

+ func (x *WebConfigGetEntitySchemaResponse) GetStatus() WebConfigGetEntitySchemaResponse_StatusEnum

+ func (x *WebConfigGetEntitySchemaResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetEntitySchemaResponse) Reset()

+ func (x *WebConfigGetEntitySchemaResponse) String() string

+ type WebConfigGetEntitySchemaResponse_StatusEnum int32

+ const WebConfigGetEntitySchemaResponse_FAILURE

+ const WebConfigGetEntitySchemaResponse_SUCCESS

+ const WebConfigGetEntitySchemaResponse_UNSPECIFIED

+ func (WebConfigGetEntitySchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigGetEntitySchemaResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigGetEntitySchemaResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigGetEntitySchemaResponse_StatusEnum) Enum() *WebConfigGetEntitySchemaResponse_StatusEnum

+ func (x WebConfigGetEntitySchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigGetEntitySchemaResponse_StatusEnum) String() string

+ type WebConfigGetEntityTypesRequest struct

+ func (*WebConfigGetEntityTypesRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigGetEntityTypesRequest) ProtoMessage()

+ func (x *WebConfigGetEntityTypesRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetEntityTypesRequest) Reset()

+ func (x *WebConfigGetEntityTypesRequest) String() string

+ type WebConfigGetEntityTypesResponse struct

+ Types []string

+ func (*WebConfigGetEntityTypesResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigGetEntityTypesResponse) ProtoMessage()

+ func (x *WebConfigGetEntityTypesResponse) GetTypes() []string

+ func (x *WebConfigGetEntityTypesResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetEntityTypesResponse) Reset()

+ func (x *WebConfigGetEntityTypesResponse) String() string

+ type WebConfigGetFieldSchemaRequest struct

+ Field string

+ func (*WebConfigGetFieldSchemaRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigGetFieldSchemaRequest) ProtoMessage()

+ func (x *WebConfigGetFieldSchemaRequest) GetField() string

+ func (x *WebConfigGetFieldSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetFieldSchemaRequest) Reset()

+ func (x *WebConfigGetFieldSchemaRequest) String() string

+ type WebConfigGetFieldSchemaResponse struct

+ Schema *DatabaseFieldSchema

+ Status WebConfigGetFieldSchemaResponse_StatusEnum

+ func (*WebConfigGetFieldSchemaResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigGetFieldSchemaResponse) ProtoMessage()

+ func (x *WebConfigGetFieldSchemaResponse) GetSchema() *DatabaseFieldSchema

+ func (x *WebConfigGetFieldSchemaResponse) GetStatus() WebConfigGetFieldSchemaResponse_StatusEnum

+ func (x *WebConfigGetFieldSchemaResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetFieldSchemaResponse) Reset()

+ func (x *WebConfigGetFieldSchemaResponse) String() string

+ type WebConfigGetFieldSchemaResponse_StatusEnum int32

+ const WebConfigGetFieldSchemaResponse_FAILURE

+ const WebConfigGetFieldSchemaResponse_SUCCESS

+ const WebConfigGetFieldSchemaResponse_UNSPECIFIED

+ func (WebConfigGetFieldSchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigGetFieldSchemaResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigGetFieldSchemaResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigGetFieldSchemaResponse_StatusEnum) Enum() *WebConfigGetFieldSchemaResponse_StatusEnum

+ func (x WebConfigGetFieldSchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigGetFieldSchemaResponse_StatusEnum) String() string

+ type WebConfigGetRootRequest struct

+ func (*WebConfigGetRootRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigGetRootRequest) ProtoMessage()

+ func (x *WebConfigGetRootRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetRootRequest) Reset()

+ func (x *WebConfigGetRootRequest) String() string

+ type WebConfigGetRootResponse struct

+ RootId string

+ func (*WebConfigGetRootResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigGetRootResponse) ProtoMessage()

+ func (x *WebConfigGetRootResponse) GetRootId() string

+ func (x *WebConfigGetRootResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigGetRootResponse) Reset()

+ func (x *WebConfigGetRootResponse) String() string

+ type WebConfigRestoreSnapshotRequest struct

+ Snapshot *DatabaseSnapshot

+ func (*WebConfigRestoreSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigRestoreSnapshotRequest) ProtoMessage()

+ func (x *WebConfigRestoreSnapshotRequest) GetSnapshot() *DatabaseSnapshot

+ func (x *WebConfigRestoreSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigRestoreSnapshotRequest) Reset()

+ func (x *WebConfigRestoreSnapshotRequest) String() string

+ type WebConfigRestoreSnapshotResponse struct

+ Status WebConfigRestoreSnapshotResponse_StatusEnum

+ func (*WebConfigRestoreSnapshotResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigRestoreSnapshotResponse) ProtoMessage()

+ func (x *WebConfigRestoreSnapshotResponse) GetStatus() WebConfigRestoreSnapshotResponse_StatusEnum

+ func (x *WebConfigRestoreSnapshotResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigRestoreSnapshotResponse) Reset()

+ func (x *WebConfigRestoreSnapshotResponse) String() string

+ type WebConfigRestoreSnapshotResponse_StatusEnum int32

+ const WebConfigRestoreSnapshotResponse_FAILURE

+ const WebConfigRestoreSnapshotResponse_SUCCESS

+ const WebConfigRestoreSnapshotResponse_UNSPECIFIED

+ func (WebConfigRestoreSnapshotResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigRestoreSnapshotResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigRestoreSnapshotResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigRestoreSnapshotResponse_StatusEnum) Enum() *WebConfigRestoreSnapshotResponse_StatusEnum

+ func (x WebConfigRestoreSnapshotResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigRestoreSnapshotResponse_StatusEnum) String() string

+ type WebConfigSetEntitySchemaRequest struct

+ Fields []string

+ Name string

+ func (*WebConfigSetEntitySchemaRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigSetEntitySchemaRequest) ProtoMessage()

+ func (x *WebConfigSetEntitySchemaRequest) GetFields() []string

+ func (x *WebConfigSetEntitySchemaRequest) GetName() string

+ func (x *WebConfigSetEntitySchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigSetEntitySchemaRequest) Reset()

+ func (x *WebConfigSetEntitySchemaRequest) String() string

+ type WebConfigSetEntitySchemaResponse struct

+ Status WebConfigSetEntitySchemaResponse_StatusEnum

+ func (*WebConfigSetEntitySchemaResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigSetEntitySchemaResponse) ProtoMessage()

+ func (x *WebConfigSetEntitySchemaResponse) GetStatus() WebConfigSetEntitySchemaResponse_StatusEnum

+ func (x *WebConfigSetEntitySchemaResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigSetEntitySchemaResponse) Reset()

+ func (x *WebConfigSetEntitySchemaResponse) String() string

+ type WebConfigSetEntitySchemaResponse_StatusEnum int32

+ const WebConfigSetEntitySchemaResponse_FAILURE

+ const WebConfigSetEntitySchemaResponse_SUCCESS

+ const WebConfigSetEntitySchemaResponse_UNSPECIFIED

+ func (WebConfigSetEntitySchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigSetEntitySchemaResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigSetEntitySchemaResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigSetEntitySchemaResponse_StatusEnum) Enum() *WebConfigSetEntitySchemaResponse_StatusEnum

+ func (x WebConfigSetEntitySchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigSetEntitySchemaResponse_StatusEnum) String() string

+ type WebConfigSetFieldSchemaRequest struct

+ Field string

+ Schema *DatabaseFieldSchema

+ func (*WebConfigSetFieldSchemaRequest) Descriptor() ([]byte, []int)

+ func (*WebConfigSetFieldSchemaRequest) ProtoMessage()

+ func (x *WebConfigSetFieldSchemaRequest) GetField() string

+ func (x *WebConfigSetFieldSchemaRequest) GetSchema() *DatabaseFieldSchema

+ func (x *WebConfigSetFieldSchemaRequest) ProtoReflect() protoreflect.Message

+ func (x *WebConfigSetFieldSchemaRequest) Reset()

+ func (x *WebConfigSetFieldSchemaRequest) String() string

+ type WebConfigSetFieldSchemaResponse struct

+ Status WebConfigSetFieldSchemaResponse_StatusEnum

+ func (*WebConfigSetFieldSchemaResponse) Descriptor() ([]byte, []int)

+ func (*WebConfigSetFieldSchemaResponse) ProtoMessage()

+ func (x *WebConfigSetFieldSchemaResponse) GetStatus() WebConfigSetFieldSchemaResponse_StatusEnum

+ func (x *WebConfigSetFieldSchemaResponse) ProtoReflect() protoreflect.Message

+ func (x *WebConfigSetFieldSchemaResponse) Reset()

+ func (x *WebConfigSetFieldSchemaResponse) String() string

+ type WebConfigSetFieldSchemaResponse_StatusEnum int32

+ const WebConfigSetFieldSchemaResponse_FAILURE

+ const WebConfigSetFieldSchemaResponse_SUCCESS

+ const WebConfigSetFieldSchemaResponse_UNSPECIFIED

+ func (WebConfigSetFieldSchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebConfigSetFieldSchemaResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebConfigSetFieldSchemaResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebConfigSetFieldSchemaResponse_StatusEnum) Enum() *WebConfigSetFieldSchemaResponse_StatusEnum

+ func (x WebConfigSetFieldSchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebConfigSetFieldSchemaResponse_StatusEnum) String() string

+ type WebHeader struct

+ Id string

+ Timestamp *timestamppb.Timestamp

+ func (*WebHeader) Descriptor() ([]byte, []int)

+ func (*WebHeader) ProtoMessage()

+ func (x *WebHeader) GetId() string

+ func (x *WebHeader) GetTimestamp() *timestamppb.Timestamp

+ func (x *WebHeader) ProtoReflect() protoreflect.Message

+ func (x *WebHeader) Reset()

+ func (x *WebHeader) String() string

+ type WebMessage struct

+ Header *WebHeader

+ Payload *anypb.Any

+ func (*WebMessage) Descriptor() ([]byte, []int)

+ func (*WebMessage) ProtoMessage()

+ func (x *WebMessage) GetHeader() *WebHeader

+ func (x *WebMessage) GetPayload() *anypb.Any

+ func (x *WebMessage) ProtoReflect() protoreflect.Message

+ func (x *WebMessage) Reset()

+ func (x *WebMessage) String() string

+ type WebRuntimeDatabaseRequest struct

+ RequestType WebRuntimeDatabaseRequest_RequestTypeEnum

+ Requests []*DatabaseRequest

+ func (*WebRuntimeDatabaseRequest) Descriptor() ([]byte, []int)

+ func (*WebRuntimeDatabaseRequest) ProtoMessage()

+ func (x *WebRuntimeDatabaseRequest) GetRequestType() WebRuntimeDatabaseRequest_RequestTypeEnum

+ func (x *WebRuntimeDatabaseRequest) GetRequests() []*DatabaseRequest

+ func (x *WebRuntimeDatabaseRequest) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeDatabaseRequest) Reset()

+ func (x *WebRuntimeDatabaseRequest) String() string

+ type WebRuntimeDatabaseRequest_RequestTypeEnum int32

+ const WebRuntimeDatabaseRequest_READ

+ const WebRuntimeDatabaseRequest_UNSPECIFIED

+ const WebRuntimeDatabaseRequest_WRITE

+ func (WebRuntimeDatabaseRequest_RequestTypeEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebRuntimeDatabaseRequest_RequestTypeEnum) EnumDescriptor() ([]byte, []int)

+ func (WebRuntimeDatabaseRequest_RequestTypeEnum) Type() protoreflect.EnumType

+ func (x WebRuntimeDatabaseRequest_RequestTypeEnum) Enum() *WebRuntimeDatabaseRequest_RequestTypeEnum

+ func (x WebRuntimeDatabaseRequest_RequestTypeEnum) Number() protoreflect.EnumNumber

+ func (x WebRuntimeDatabaseRequest_RequestTypeEnum) String() string

+ type WebRuntimeDatabaseResponse struct

+ Response []*DatabaseRequest

+ func (*WebRuntimeDatabaseResponse) Descriptor() ([]byte, []int)

+ func (*WebRuntimeDatabaseResponse) ProtoMessage()

+ func (x *WebRuntimeDatabaseResponse) GetResponse() []*DatabaseRequest

+ func (x *WebRuntimeDatabaseResponse) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeDatabaseResponse) Reset()

+ func (x *WebRuntimeDatabaseResponse) String() string

+ type WebRuntimeGetDatabaseConnectionStatusRequest struct

+ func (*WebRuntimeGetDatabaseConnectionStatusRequest) Descriptor() ([]byte, []int)

+ func (*WebRuntimeGetDatabaseConnectionStatusRequest) ProtoMessage()

+ func (x *WebRuntimeGetDatabaseConnectionStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeGetDatabaseConnectionStatusRequest) Reset()

+ func (x *WebRuntimeGetDatabaseConnectionStatusRequest) String() string

+ type WebRuntimeGetDatabaseConnectionStatusResponse struct

+ Status *ConnectionState

+ func (*WebRuntimeGetDatabaseConnectionStatusResponse) Descriptor() ([]byte, []int)

+ func (*WebRuntimeGetDatabaseConnectionStatusResponse) ProtoMessage()

+ func (x *WebRuntimeGetDatabaseConnectionStatusResponse) GetStatus() *ConnectionState

+ func (x *WebRuntimeGetDatabaseConnectionStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeGetDatabaseConnectionStatusResponse) Reset()

+ func (x *WebRuntimeGetDatabaseConnectionStatusResponse) String() string

+ type WebRuntimeGetNotificationsRequest struct

+ func (*WebRuntimeGetNotificationsRequest) Descriptor() ([]byte, []int)

+ func (*WebRuntimeGetNotificationsRequest) ProtoMessage()

+ func (x *WebRuntimeGetNotificationsRequest) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeGetNotificationsRequest) Reset()

+ func (x *WebRuntimeGetNotificationsRequest) String() string

+ type WebRuntimeGetNotificationsResponse struct

+ Notifications []*DatabaseNotification

+ func (*WebRuntimeGetNotificationsResponse) Descriptor() ([]byte, []int)

+ func (*WebRuntimeGetNotificationsResponse) ProtoMessage()

+ func (x *WebRuntimeGetNotificationsResponse) GetNotifications() []*DatabaseNotification

+ func (x *WebRuntimeGetNotificationsResponse) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeGetNotificationsResponse) Reset()

+ func (x *WebRuntimeGetNotificationsResponse) String() string

+ type WebRuntimeRegisterNotificationRequest struct

+ Requests []*DatabaseNotificationConfig

+ func (*WebRuntimeRegisterNotificationRequest) Descriptor() ([]byte, []int)

+ func (*WebRuntimeRegisterNotificationRequest) ProtoMessage()

+ func (x *WebRuntimeRegisterNotificationRequest) GetRequests() []*DatabaseNotificationConfig

+ func (x *WebRuntimeRegisterNotificationRequest) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeRegisterNotificationRequest) Reset()

+ func (x *WebRuntimeRegisterNotificationRequest) String() string

+ type WebRuntimeRegisterNotificationResponse struct

+ Tokens []string

+ func (*WebRuntimeRegisterNotificationResponse) Descriptor() ([]byte, []int)

+ func (*WebRuntimeRegisterNotificationResponse) ProtoMessage()

+ func (x *WebRuntimeRegisterNotificationResponse) GetTokens() []string

+ func (x *WebRuntimeRegisterNotificationResponse) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeRegisterNotificationResponse) Reset()

+ func (x *WebRuntimeRegisterNotificationResponse) String() string

+ type WebRuntimeUnregisterNotificationRequest struct

+ Tokens []string

+ func (*WebRuntimeUnregisterNotificationRequest) Descriptor() ([]byte, []int)

+ func (*WebRuntimeUnregisterNotificationRequest) ProtoMessage()

+ func (x *WebRuntimeUnregisterNotificationRequest) GetTokens() []string

+ func (x *WebRuntimeUnregisterNotificationRequest) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeUnregisterNotificationRequest) Reset()

+ func (x *WebRuntimeUnregisterNotificationRequest) String() string

+ type WebRuntimeUnregisterNotificationResponse struct

+ Status WebRuntimeUnregisterNotificationResponse_StatusEnum

+ func (*WebRuntimeUnregisterNotificationResponse) Descriptor() ([]byte, []int)

+ func (*WebRuntimeUnregisterNotificationResponse) ProtoMessage()

+ func (x *WebRuntimeUnregisterNotificationResponse) GetStatus() WebRuntimeUnregisterNotificationResponse_StatusEnum

+ func (x *WebRuntimeUnregisterNotificationResponse) ProtoReflect() protoreflect.Message

+ func (x *WebRuntimeUnregisterNotificationResponse) Reset()

+ func (x *WebRuntimeUnregisterNotificationResponse) String() string

+ type WebRuntimeUnregisterNotificationResponse_StatusEnum int32

+ const WebRuntimeUnregisterNotificationResponse_FAILURE

+ const WebRuntimeUnregisterNotificationResponse_SUCCESS

+ const WebRuntimeUnregisterNotificationResponse_UNSPECIFIED

+ func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

+ func (WebRuntimeUnregisterNotificationResponse_StatusEnum) EnumDescriptor() ([]byte, []int)

+ func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Type() protoreflect.EnumType

+ func (x WebRuntimeUnregisterNotificationResponse_StatusEnum) Enum() *WebRuntimeUnregisterNotificationResponse_StatusEnum

+ func (x WebRuntimeUnregisterNotificationResponse_StatusEnum) Number() protoreflect.EnumNumber

+ func (x WebRuntimeUnregisterNotificationResponse_StatusEnum) String() string

+ type WebServiceWorker struct

+ Signals WebServiceWorkerSignals

+ func NewWebServiceWorker() *WebServiceWorker

+ func (w *WebServiceWorker) Broadcast(p *anypb.Any)

+ func (w *WebServiceWorker) Deinit()

+ func (w *WebServiceWorker) DoWork()

+ func (w *WebServiceWorker) Init()

+ func (w *WebServiceWorker) Send(clientId string, p *anypb.Any)

+ func (w *WebServiceWorker) ServeHTTP(wr http.ResponseWriter, req *http.Request)

+ type WebServiceWorkerSignals struct

+ ClientConnected Signal

+ ClientDisconnected Signal

+ Received Signal

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL