qdb

package
v1.2.87 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 3, 2024 License: Apache-2.0 Imports: 29 Imported by: 2

Documentation

Overview

THIS IS AN AUTOGENERATED FILE... See gen_web_handlers.sh for details.

THIS IS AN AUTOGENERATED FILE... See gen_web_handlers.sh for details.

THIS IS AN AUTOGENERATED FILE... See gen_web_handlers.sh for details.

THIS IS AN AUTOGENERATED FILE... See gen_web_handlers.sh for details.

Index

Constants

View Source 
const LeaderLeaseTimeout = 15 * time.Second
View Source 
const MaxCandidates = 5

Variables

View Source 
var (
	WebHeader_AuthenticationStatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "AUTHENTICATED",
		2: "UNAUTHENTICATED",
	}
	WebHeader_AuthenticationStatusEnum_value = map[string]int32{
		"UNSPECIFIED":     0,
		"AUTHENTICATED":   1,
		"UNAUTHENTICATED": 2,
	}
)

Enum value maps for WebHeader_AuthenticationStatusEnum.

View Source 
var (
	WebConfigCreateEntityResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigCreateEntityResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigCreateEntityResponse_StatusEnum.

View Source 
var (
	WebConfigDeleteEntityResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigDeleteEntityResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigDeleteEntityResponse_StatusEnum.

View Source 
var (
	WebConfigGetEntityResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigGetEntityResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigGetEntityResponse_StatusEnum.

View Source 
var (
	WebConfigGetFieldSchemaResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigGetFieldSchemaResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigGetFieldSchemaResponse_StatusEnum.

View Source 
var (
	WebConfigSetFieldSchemaResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigSetFieldSchemaResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigSetFieldSchemaResponse_StatusEnum.

View Source 
var (
	WebConfigGetEntitySchemaResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigGetEntitySchemaResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigGetEntitySchemaResponse_StatusEnum.

View Source 
var (
	WebConfigSetEntitySchemaResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigSetEntitySchemaResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigSetEntitySchemaResponse_StatusEnum.

View Source 
var (
	WebConfigCreateSnapshotResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigCreateSnapshotResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigCreateSnapshotResponse_StatusEnum.

View Source 
var (
	WebConfigRestoreSnapshotResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebConfigRestoreSnapshotResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebConfigRestoreSnapshotResponse_StatusEnum.

View Source 
var (
	WebRuntimeDatabaseRequest_RequestTypeEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "READ",
		2: "WRITE",
	}
	WebRuntimeDatabaseRequest_RequestTypeEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"READ":        1,
		"WRITE":       2,
	}
)

Enum value maps for WebRuntimeDatabaseRequest_RequestTypeEnum.

View Source 
var (
	WebRuntimeUnregisterNotificationResponse_StatusEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	WebRuntimeUnregisterNotificationResponse_StatusEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"SUCCESS":     1,
		"FAILURE":     2,
	}
)

Enum value maps for WebRuntimeUnregisterNotificationResponse_StatusEnum.

View Source 
var (
	LogMessage_LogLevelEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "TRACE",
		2: "DEBUG",
		3: "INFO",
		4: "WARN",
		5: "ERROR",
		6: "PANIC",
	}
	LogMessage_LogLevelEnum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"TRACE":       1,
		"DEBUG":       2,
		"INFO":        3,
		"WARN":        4,
		"ERROR":       5,
		"PANIC":       6,
	}
)

Enum value maps for LogMessage_LogLevelEnum.

View Source 
var (
	ConnectionState_ConnectionStateEnum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "CONNECTED",
		2: "DISCONNECTED",
	}
	ConnectionState_ConnectionStateEnum_value = map[string]int32{
		"UNSPECIFIED":  0,
		"CONNECTED":    1,
		"DISCONNECTED": 2,
	}
)

Enum value maps for ConnectionState_ConnectionStateEnum.

View Source 
var File_src_protobufs_proto protoreflect.FileDescriptor

Functions

func Debug 

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

func DefaultCaster added in v1.2.39 

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

func Error 

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

func FileDecode added in v1.2.37 

func FileDecode(encoded string) []byte

func FileEncode added in v1.2.37 

func FileEncode(content []byte) string

func GetApplicationName added in v1.2.74 

func GetApplicationName() string

func Info 

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

func Log 

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

func NewBinaryFileValue added in v1.2.62 

func NewBinaryFileValue(value string) *anypb.Any

func NewBoolValue added in v1.2.62 

func NewBoolValue(value bool) *anypb.Any

func NewEntityReferenceValue added in v1.2.62 

func NewEntityReferenceValue(value string) *anypb.Any

func NewFloatValue added in v1.2.62 

func NewFloatValue(value float64) *anypb.Any

func NewIntValue added in v1.2.62 

func NewIntValue(value int64) *anypb.Any

func NewStringValue added in v1.2.62 

func NewStringValue(value string) *anypb.Any

func NewTimestampValue added in v1.2.62 

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

func NewTransformationValue added in v1.2.77 

func NewTransformationValue(value string) *anypb.Any

func Panic 

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

func Register_web_handler_app 

func Register_web_handler_app()

func Register_web_handler_database_interactor added in v1.2.53 

func Register_web_handler_database_interactor()

func Register_web_handler_server_interactor 

func Register_web_handler_server_interactor()

func Register_web_handler_utils 

func Register_web_handler_utils()

func SetApplicationName added in v1.2.74 

func SetApplicationName(name string)

func Trace 

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

func Truncate added in v1.2.38 

func Truncate(text string, width int) string

func ValueCast added in v1.2.47 

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

func Warn 

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

Types

type Application 

type Application struct {
	// contains filtered or unexported fields
}

func (*Application) Execute 

func (a *Application) Execute()

func (*Application) Quit 

func (a *Application) Quit()

type ApplicationConfig 

type ApplicationConfig struct {
	Name    string
	Workers []IWorker
}

type BinaryFile 

type BinaryFile struct {
	Raw string `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*BinaryFile) Descriptor deprecated 

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

Deprecated: Use BinaryFile.ProtoReflect.Descriptor instead.

func (*BinaryFile) GetRaw 

func (x *BinaryFile) GetRaw() string

func (*BinaryFile) ProtoMessage 

func (*BinaryFile) ProtoMessage()

func (*BinaryFile) ProtoReflect 

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

func (*BinaryFile) Reset 

func (x *BinaryFile) Reset()

func (*BinaryFile) String 

func (x *BinaryFile) String() string

type Bool 

type Bool struct {
	Raw bool `protobuf:"varint,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Bool) Descriptor deprecated 

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

Deprecated: Use Bool.ProtoReflect.Descriptor instead.

func (*Bool) GetRaw 

func (x *Bool) GetRaw() bool

func (*Bool) ProtoMessage 

func (*Bool) ProtoMessage()

func (*Bool) ProtoReflect 

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

func (*Bool) Reset 

func (x *Bool) Reset()

func (*Bool) String 

func (x *Bool) String() string

type ConnectionState 

type ConnectionState struct {
	Raw ConnectionState_ConnectionStateEnum `protobuf:"varint,1,opt,name=raw,proto3,enum=qdb.ConnectionState_ConnectionStateEnum" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionState) Descriptor deprecated 

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

Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.

func (*ConnectionState) GetRaw 

func (x *ConnectionState) GetRaw() ConnectionState_ConnectionStateEnum

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) ProtoReflect 

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

func (*ConnectionState) Reset 

func (x *ConnectionState) Reset()

func (*ConnectionState) String 

func (x *ConnectionState) String() string

type ConnectionState_ConnectionStateEnum 

type ConnectionState_ConnectionStateEnum int32
const (
	ConnectionState_UNSPECIFIED  ConnectionState_ConnectionStateEnum = 0
	ConnectionState_CONNECTED    ConnectionState_ConnectionStateEnum = 1
	ConnectionState_DISCONNECTED ConnectionState_ConnectionStateEnum = 2
)

func (ConnectionState_ConnectionStateEnum) Descriptor 

func (ConnectionState_ConnectionStateEnum) Descriptor() protoreflect.EnumDescriptor

func (ConnectionState_ConnectionStateEnum) Enum 

func (x ConnectionState_ConnectionStateEnum) Enum() *ConnectionState_ConnectionStateEnum

func (ConnectionState_ConnectionStateEnum) EnumDescriptor deprecated 

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

Deprecated: Use ConnectionState_ConnectionStateEnum.Descriptor instead.

func (ConnectionState_ConnectionStateEnum) Number 

func (x ConnectionState_ConnectionStateEnum) Number() protoreflect.EnumNumber

func (ConnectionState_ConnectionStateEnum) String 

func (x ConnectionState_ConnectionStateEnum) String() string

func (ConnectionState_ConnectionStateEnum) Type 

func (ConnectionState_ConnectionStateEnum) Type() protoreflect.EnumType

type DatabaseEntity 

type DatabaseEntity struct {
	Id       string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type     string             `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Name     string             `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Parent   *EntityReference   `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
	Children []*EntityReference `protobuf:"bytes,5,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseEntity) Descriptor deprecated 

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

Deprecated: Use DatabaseEntity.ProtoReflect.Descriptor instead.

func (*DatabaseEntity) GetChildren 

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

func (*DatabaseEntity) GetId 

func (x *DatabaseEntity) GetId() string

func (*DatabaseEntity) GetName 

func (x *DatabaseEntity) GetName() string

func (*DatabaseEntity) GetParent 

func (x *DatabaseEntity) GetParent() *EntityReference

func (*DatabaseEntity) GetType 

func (x *DatabaseEntity) GetType() string

func (*DatabaseEntity) ProtoMessage 

func (*DatabaseEntity) ProtoMessage()

func (*DatabaseEntity) ProtoReflect 

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

func (*DatabaseEntity) Reset 

func (x *DatabaseEntity) Reset()

func (*DatabaseEntity) String 

func (x *DatabaseEntity) String() string

type DatabaseEntitySchema 

type DatabaseEntitySchema struct {
	Name   string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseEntitySchema) Descriptor deprecated 

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

Deprecated: Use DatabaseEntitySchema.ProtoReflect.Descriptor instead.

func (*DatabaseEntitySchema) GetFields 

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

func (*DatabaseEntitySchema) GetName 

func (x *DatabaseEntitySchema) GetName() string

func (*DatabaseEntitySchema) ProtoMessage 

func (*DatabaseEntitySchema) ProtoMessage()

func (*DatabaseEntitySchema) ProtoReflect 

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

func (*DatabaseEntitySchema) Reset 

func (x *DatabaseEntitySchema) Reset()

func (*DatabaseEntitySchema) String 

func (x *DatabaseEntitySchema) String() string

type DatabaseField 

type DatabaseField struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value     *anypb.Any             `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	WriteTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=writeTime,proto3" json:"writeTime,omitempty"`
	WriterId  string                 `protobuf:"bytes,5,opt,name=writerId,proto3" json:"writerId,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseField) Descriptor deprecated 

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

Deprecated: Use DatabaseField.ProtoReflect.Descriptor instead.

func (*DatabaseField) FromRequest 

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

func (*DatabaseField) GetId 

func (x *DatabaseField) GetId() string

func (*DatabaseField) GetName 

func (x *DatabaseField) GetName() string

func (*DatabaseField) GetValue 

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

func (*DatabaseField) GetWriteTime 

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

func (*DatabaseField) GetWriterId 

func (x *DatabaseField) GetWriterId() string

func (*DatabaseField) ProtoMessage 

func (*DatabaseField) ProtoMessage()

func (*DatabaseField) ProtoReflect 

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

func (*DatabaseField) Reset 

func (x *DatabaseField) Reset()

func (*DatabaseField) String 

func (x *DatabaseField) String() string

type DatabaseFieldSchema 

type DatabaseFieldSchema struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseFieldSchema) Descriptor deprecated 

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

Deprecated: Use DatabaseFieldSchema.ProtoReflect.Descriptor instead.

func (*DatabaseFieldSchema) GetName 

func (x *DatabaseFieldSchema) GetName() string

func (*DatabaseFieldSchema) GetType 

func (x *DatabaseFieldSchema) GetType() string

func (*DatabaseFieldSchema) ProtoMessage 

func (*DatabaseFieldSchema) ProtoMessage()

func (*DatabaseFieldSchema) ProtoReflect 

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

func (*DatabaseFieldSchema) Reset 

func (x *DatabaseFieldSchema) Reset()

func (*DatabaseFieldSchema) String 

func (x *DatabaseFieldSchema) String() string

type DatabaseNotification 

type DatabaseNotification struct {
	Token    string           `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Current  *DatabaseField   `protobuf:"bytes,2,opt,name=current,proto3" json:"current,omitempty"`
	Previous *DatabaseField   `protobuf:"bytes,3,opt,name=previous,proto3" json:"previous,omitempty"`
	Context  []*DatabaseField `protobuf:"bytes,4,rep,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseNotification) Descriptor deprecated 

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

Deprecated: Use DatabaseNotification.ProtoReflect.Descriptor instead.

func (*DatabaseNotification) GetContext 

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

func (*DatabaseNotification) GetCurrent 

func (x *DatabaseNotification) GetCurrent() *DatabaseField

func (*DatabaseNotification) GetPrevious 

func (x *DatabaseNotification) GetPrevious() *DatabaseField

func (*DatabaseNotification) GetToken 

func (x *DatabaseNotification) GetToken() string

func (*DatabaseNotification) ProtoMessage 

func (*DatabaseNotification) ProtoMessage()

func (*DatabaseNotification) ProtoReflect 

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

func (*DatabaseNotification) Reset 

func (x *DatabaseNotification) Reset()

func (*DatabaseNotification) String 

func (x *DatabaseNotification) String() string

type DatabaseNotificationConfig 

type DatabaseNotificationConfig struct {
	Id             string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type           string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Field          string   `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
	ContextFields  []string `protobuf:"bytes,4,rep,name=contextFields,proto3" json:"contextFields,omitempty"`
	NotifyOnChange bool     `protobuf:"varint,5,opt,name=notifyOnChange,proto3" json:"notifyOnChange,omitempty"`
	ServiceId      string   `protobuf:"bytes,6,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseNotificationConfig) Descriptor deprecated 

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

Deprecated: Use DatabaseNotificationConfig.ProtoReflect.Descriptor instead.

func (*DatabaseNotificationConfig) GetContextFields 

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

func (*DatabaseNotificationConfig) GetField 

func (x *DatabaseNotificationConfig) GetField() string

func (*DatabaseNotificationConfig) GetId 

func (x *DatabaseNotificationConfig) GetId() string

func (*DatabaseNotificationConfig) GetNotifyOnChange 

func (x *DatabaseNotificationConfig) GetNotifyOnChange() bool

func (*DatabaseNotificationConfig) GetServiceId added in v1.2.71 

func (x *DatabaseNotificationConfig) GetServiceId() string

func (*DatabaseNotificationConfig) GetType 

func (x *DatabaseNotificationConfig) GetType() string

func (*DatabaseNotificationConfig) ProtoMessage 

func (*DatabaseNotificationConfig) ProtoMessage()

func (*DatabaseNotificationConfig) ProtoReflect 

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

func (*DatabaseNotificationConfig) Reset 

func (x *DatabaseNotificationConfig) Reset()

func (*DatabaseNotificationConfig) String 

func (x *DatabaseNotificationConfig) String() string

type DatabaseRequest 

type DatabaseRequest struct {
	Id        string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Field     string     `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	Value     *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	WriteTime *Timestamp `protobuf:"bytes,4,opt,name=writeTime,proto3" json:"writeTime,omitempty"`
	WriterId  *String    `protobuf:"bytes,5,opt,name=writerId,proto3" json:"writerId,omitempty"`
	Success   bool       `protobuf:"varint,6,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseRequest) Descriptor deprecated 

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

Deprecated: Use DatabaseRequest.ProtoReflect.Descriptor instead.

func (*DatabaseRequest) FromField 

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

func (*DatabaseRequest) GetField 

func (x *DatabaseRequest) GetField() string

func (*DatabaseRequest) GetId 

func (x *DatabaseRequest) GetId() string

func (*DatabaseRequest) GetSuccess 

func (x *DatabaseRequest) GetSuccess() bool

func (*DatabaseRequest) GetValue 

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

func (*DatabaseRequest) GetWriteTime 

func (x *DatabaseRequest) GetWriteTime() *Timestamp

func (*DatabaseRequest) GetWriterId 

func (x *DatabaseRequest) GetWriterId() *String

func (*DatabaseRequest) ProtoMessage 

func (*DatabaseRequest) ProtoMessage()

func (*DatabaseRequest) ProtoReflect 

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

func (*DatabaseRequest) Reset 

func (x *DatabaseRequest) Reset()

func (*DatabaseRequest) String 

func (x *DatabaseRequest) String() string

type DatabaseSnapshot 

type DatabaseSnapshot struct {
	Entities      []*DatabaseEntity       `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	Fields        []*DatabaseField        `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	EntitySchemas []*DatabaseEntitySchema `protobuf:"bytes,3,rep,name=entitySchemas,proto3" json:"entitySchemas,omitempty"`
	FieldSchemas  []*DatabaseFieldSchema  `protobuf:"bytes,4,rep,name=fieldSchemas,proto3" json:"fieldSchemas,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseSnapshot) Descriptor deprecated 

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

Deprecated: Use DatabaseSnapshot.ProtoReflect.Descriptor instead.

func (*DatabaseSnapshot) GetEntities 

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

func (*DatabaseSnapshot) GetEntitySchemas 

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

func (*DatabaseSnapshot) GetFieldSchemas 

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

func (*DatabaseSnapshot) GetFields 

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

func (*DatabaseSnapshot) ProtoMessage 

func (*DatabaseSnapshot) ProtoMessage()

func (*DatabaseSnapshot) ProtoReflect 

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

func (*DatabaseSnapshot) Reset 

func (x *DatabaseSnapshot) Reset()

func (*DatabaseSnapshot) String 

func (x *DatabaseSnapshot) String() string

type DatabaseWorker 

type DatabaseWorker struct {
	Signals DatabaseWorkerSignals
	// contains filtered or unexported fields
}

func NewDatabaseWorker 

func NewDatabaseWorker(db IDatabase) *DatabaseWorker

func (*DatabaseWorker) Deinit 

func (w *DatabaseWorker) Deinit()

func (*DatabaseWorker) DoWork 

func (w *DatabaseWorker) DoWork()

func (*DatabaseWorker) Init 

func (w *DatabaseWorker) Init()

func (*DatabaseWorker) IsConnected added in v1.2.31 

func (w *DatabaseWorker) IsConnected() bool

func (*DatabaseWorker) OnSchemaUpdated added in v1.2.31 

func (w *DatabaseWorker) OnSchemaUpdated(*DatabaseNotification)

type DatabaseWorkerSignals 

type DatabaseWorkerSignals struct {
	Connected     Signal
	Disconnected  Signal
	SchemaUpdated Signal
}

type Entity 

type Entity struct {
	// contains filtered or unexported fields
}

func NewEntity 

func NewEntity(db IDatabase, entityId string) *Entity

func (*Entity) GetChildren 

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

func (*Entity) GetField 

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

func (*Entity) GetId 

func (e *Entity) GetId() string

func (*Entity) GetName 

func (e *Entity) GetName() string

func (*Entity) GetParent 

func (e *Entity) GetParent() *EntityReference

func (*Entity) GetType 

func (e *Entity) GetType() string

type EntityFinder 

type EntityFinder struct {
	// contains filtered or unexported fields
}

func NewEntityFinder 

func NewEntityFinder(db IDatabase) *EntityFinder

func (*EntityFinder) Find 

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

type EntityReference 

type EntityReference struct {
	Raw string `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityReference) Descriptor deprecated 

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

Deprecated: Use EntityReference.ProtoReflect.Descriptor instead.

func (*EntityReference) GetRaw 

func (x *EntityReference) GetRaw() string

func (*EntityReference) ProtoMessage 

func (*EntityReference) ProtoMessage()

func (*EntityReference) ProtoReflect 

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

func (*EntityReference) Reset 

func (x *EntityReference) Reset()

func (*EntityReference) String 

func (x *EntityReference) String() string

type FCBool added in v1.2.39 

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

func NewBoolCondition added in v1.2.39 

func NewBoolCondition() *FCBool

type FCEnum added in v1.2.39 

type FCEnum[T ~int32] struct {
	FieldCondition[IFieldProto[T], T, T]
}

func NewEnumCondition added in v1.2.39 

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

type FCFloat added in v1.2.39 

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

func NewFloatCondition added in v1.2.39 

func NewFloatCondition() *FCFloat

type FCInt added in v1.2.39 

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

func NewIntCondition added in v1.2.39 

func NewIntCondition() *FCInt

type FCReference added in v1.2.46 

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

func NewReferenceCondition added in v1.2.46 

func NewReferenceCondition() *FCReference

type FCString added in v1.2.39 

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

func NewStringCondition added in v1.2.39 

func NewStringCondition() *FCString

type FCTimestamp added in v1.2.39 

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

func NewTimestampCondition added in v1.2.39 

func NewTimestampCondition() *FCTimestamp

type Field 

type Field struct {
	// contains filtered or unexported fields
}

func NewField 

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

func (*Field) GetBinaryFile added in v1.2.69 

func (f *Field) GetBinaryFile() string

func (*Field) GetBool added in v1.2.69 

func (f *Field) GetBool() bool

func (*Field) GetEntityReference added in v1.2.69 

func (f *Field) GetEntityReference() string

func (*Field) GetFloat added in v1.2.69 

func (f *Field) GetFloat() float64

func (*Field) GetId added in v1.2.69 

func (f *Field) GetId() string

func (*Field) GetInt added in v1.2.69 

func (f *Field) GetInt() int64

func (*Field) GetName added in v1.2.69 

func (f *Field) GetName() string

func (*Field) GetString added in v1.2.69 

func (f *Field) GetString() string

func (*Field) GetTimestamp added in v1.2.69 

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

func (*Field) GetTransformation added in v1.2.77 

func (f *Field) GetTransformation() string

func (*Field) GetValue added in v1.2.69 

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

func (*Field) GetWriteTime added in v1.2.69 

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

func (*Field) GetWriter added in v1.2.69 

func (f *Field) GetWriter() string

func (*Field) PullBinaryFile added in v1.2.43 

func (f *Field) PullBinaryFile() string

func (*Field) PullBool added in v1.2.43 

func (f *Field) PullBool() bool

func (*Field) PullEntityReference added in v1.2.43 

func (f *Field) PullEntityReference() string

func (*Field) PullFloat added in v1.2.43 

func (f *Field) PullFloat() float64

func (*Field) PullInt added in v1.2.43 

func (f *Field) PullInt() int64

func (*Field) PullString added in v1.2.43 

func (f *Field) PullString() string

func (*Field) PullTimestamp added in v1.2.68 

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

func (*Field) PullTransformation added in v1.2.77 

func (f *Field) PullTransformation() string

func (*Field) PullValue 

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

func (*Field) PullWriteTime added in v1.2.69 

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

func (*Field) PullWriter added in v1.2.69 

func (f *Field) PullWriter() string

func (*Field) PushBinaryFile added in v1.2.43 

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

func (*Field) PushBool added in v1.2.43 

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

func (*Field) PushEntityReference added in v1.2.43 

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

func (*Field) PushFloat added in v1.2.43 

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

func (*Field) PushInt added in v1.2.43 

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

func (*Field) PushString added in v1.2.43 

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

func (*Field) PushTimestamp added in v1.2.68 

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

func (*Field) PushTransformation added in v1.2.77 

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

func (*Field) PushValue 

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

type FieldCondition 

type FieldCondition[T IFieldProto[K], C cmp.Ordered, K comparable] struct {
	Lhs      string
	LhsValue T
	Caster   func(K) C
}

func (*FieldCondition[T, C, K]) IsBetween 

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

func (*FieldCondition[T, C, K]) IsEqualTo 

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

func (*FieldCondition[T, C, K]) IsGreaterThan 

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

func (*FieldCondition[T, C, K]) IsGreaterThanOrEqualTo 

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

func (*FieldCondition[T, C, K]) IsIn 

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

func (*FieldCondition[T, C, K]) IsLessThan 

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

func (*FieldCondition[T, C, K]) IsLessThanOrEqualTo 

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

func (*FieldCondition[T, C, K]) IsNotEqualTo 

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

func (*FieldCondition[T, C, K]) IsNotIn 

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

func (*FieldCondition[T, C, K]) Where 

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

type FieldConditionEval 

type FieldConditionEval func(IDatabase, string) bool

type Float 

type Float struct {
	Raw float64 `protobuf:"fixed64,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Float) Descriptor deprecated 

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

Deprecated: Use Float.ProtoReflect.Descriptor instead.

func (*Float) GetRaw 

func (x *Float) GetRaw() float64

func (*Float) ProtoMessage 

func (*Float) ProtoMessage()

func (*Float) ProtoReflect 

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

func (*Float) Reset 

func (x *Float) Reset()

func (*Float) String 

func (x *Float) String() string

type IApplication 

type IApplication interface {
	Execute()
	Quit()
}

func NewApplication 

func NewApplication(config ApplicationConfig) IApplication

type IDatabase 

type IDatabase interface {
	Connect()
	Disconnect()
	IsConnected() bool

	CreateSnapshot() *DatabaseSnapshot
	RestoreSnapshot(snapshot *DatabaseSnapshot)

	CreateEntity(entityType, parentId, name string)
	GetEntity(entityId string) *DatabaseEntity
	SetEntity(entityId string, value *DatabaseEntity)
	DeleteEntity(entityId string)

	FindEntities(entityType string) []string
	GetEntityTypes() []string

	EntityExists(entityId string) bool
	FieldExists(fieldName, entityType string) bool

	GetFieldSchemas() []*DatabaseFieldSchema
	GetFieldSchema(fieldName string) *DatabaseFieldSchema
	SetFieldSchema(fieldName string, value *DatabaseFieldSchema)

	GetEntitySchema(entityType string) *DatabaseEntitySchema
	SetEntitySchema(entityType string, value *DatabaseEntitySchema)

	Read(requests []*DatabaseRequest)
	Write(requests []*DatabaseRequest)

	TempSet(key string, value string, expiration time.Duration) bool
	TempGet(key string) string
	TempExpire(key string, expiration time.Duration)
	TempDel(key string)

	Notify(config *DatabaseNotificationConfig, callback INotificationCallback) INotificationToken
	Unnotify(subscriptionId string)
	UnnotifyCallback(subscriptionId string, callback INotificationCallback)
	ProcessNotifications()

	SortedSetAdd(key string, member string, score float64) int64
	SortedSetRemove(key string, member string) int64
	SortedSetRemoveRangeByRank(key string, start, stop int64) int64
	SortedSetRangeByScoreWithScores(key string, min, max string) []SortedSetMember
}

func NewRedisDatabase 

func NewRedisDatabase(config RedisDatabaseConfig) IDatabase

type IEntity 

type IEntity interface {
	GetId() string
	GetType() string
	GetName() string
	GetChildren() []*EntityReference
	GetParent() *EntityReference
	GetField(string) IField
}

type IEntityFinder 

type IEntityFinder interface {
	Find(SearchCriteria) []IEntity
}

type IField 

type IField interface {
	PullValue(m proto.Message) proto.Message
	PullInt() int64
	PullFloat() float64
	PullString() string
	PullBool() bool
	PullBinaryFile() string
	PullEntityReference() string
	PullTimestamp() time.Time
	PullTransformation() string
	PullWriteTime() time.Time
	PullWriter() string

	GetValue(m proto.Message) proto.Message
	GetInt() int64
	GetFloat() float64
	GetString() string
	GetBool() bool
	GetBinaryFile() string
	GetEntityReference() string
	GetTimestamp() time.Time
	GetTransformation() string
	GetWriteTime() time.Time
	GetWriter() string
	GetId() string
	GetName() string

	PushValue(m proto.Message) bool
	PushInt(...interface{}) bool
	PushFloat(...interface{}) bool
	PushString(...interface{}) bool
	PushBool(...interface{}) bool
	PushBinaryFile(...interface{}) bool
	PushEntityReference(...interface{}) bool
	PushTimestamp(...interface{}) bool
	PushTransformation(...interface{}) bool
}

type IFieldProto 

type IFieldProto[T comparable] interface {
	protoreflect.ProtoMessage
	GetRaw() T
}

type ILeaderState added in v1.2.84 

type ILeaderState interface {
	DoWork(w *LeaderElectionWorker)
	OnEnterState(w *LeaderElectionWorker, previousState ILeaderState)
	Name() LeaderStates
}

ILeaderState interface defines the behavior for each state

type INotificationCallback added in v1.2.44 

type INotificationCallback interface {
	Fn(*DatabaseNotification)
	Id() string
}

func NewNotificationCallback added in v1.2.44 

func NewNotificationCallback(fn func(*DatabaseNotification)) INotificationCallback

type INotificationToken added in v1.2.44 

type INotificationToken interface {
	Id() string
	Unbind()
}

type ISchemaValidator added in v1.2.39 

type ISchemaValidator interface {
	AddEntity(entityId string, fields ...string)
	IsValid() bool
	Validate() bool
	ValidationRequired()
}

func NewSchemaValidator added in v1.2.39 

func NewSchemaValidator(db IDatabase) ISchemaValidator

type ISignal 

type ISignal interface {
	Connect(ISlot)
	Disconnect(ISlot)
	DisconnectAll()
	Emit(...interface{})
}

type ISlot 

type ISlot interface {
	Invoke(...interface{})
}

func Slot 

func Slot(fn func()) ISlot

func SlotWithArgs 

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

type ITengoDatabase added in v1.2.77 

type ITengoDatabase interface {
	ToTengoMap() tengo.Object
	GetEntity(...tengo.Object) (tengo.Object, error)
	Find(...tengo.Object) (tengo.Object, error)
	Schedule(...tengo.Object) (tengo.Object, error)
	PopAvailableJobs() []*TengoJob
}

func NewTengoDatabase added in v1.2.77 

func NewTengoDatabase(db IDatabase) ITengoDatabase

type ITengoEntity added in v1.2.77 

type ITengoEntity interface {
	ToTengoMap() tengo.Object
	GetId(...tengo.Object) (tengo.Object, error)
	GetType(...tengo.Object) (tengo.Object, error)
	GetChildren(...tengo.Object) (tengo.Object, error)
	GetParent(...tengo.Object) (tengo.Object, error)
	GetField(...tengo.Object) (tengo.Object, error)
}

func NewTengoEntity added in v1.2.77 

func NewTengoEntity(entity IEntity) ITengoEntity

type ITengoField added in v1.2.77 

type ITengoField interface {
	ToTengoMap() tengo.Object

	PullInt(...tengo.Object) (tengo.Object, error)
	PullFloat(...tengo.Object) (tengo.Object, error)
	PullString(...tengo.Object) (tengo.Object, error)
	PullBool(...tengo.Object) (tengo.Object, error)
	PullBinaryFile(...tengo.Object) (tengo.Object, error)
	PullEntityReference(...tengo.Object) (tengo.Object, error)
	PullTimestamp(...tengo.Object) (tengo.Object, error)
	PullWriteTime(...tengo.Object) (tengo.Object, error)
	PullWriter(...tengo.Object) (tengo.Object, error)

	GetInt(...tengo.Object) (tengo.Object, error)
	GetFloat(...tengo.Object) (tengo.Object, error)
	GetString(...tengo.Object) (tengo.Object, error)
	GetBool(...tengo.Object) (tengo.Object, error)
	GetBinaryFile(...tengo.Object) (tengo.Object, error)
	GetEntityReference(...tengo.Object) (tengo.Object, error)
	GetTimestamp(...tengo.Object) (tengo.Object, error)
	GetWriteTime(...tengo.Object) (tengo.Object, error)
	GetWriter(...tengo.Object) (tengo.Object, error)
	GetId(...tengo.Object) (tengo.Object, error)
	GetName(...tengo.Object) (tengo.Object, error)

	PushInt(...tengo.Object) (tengo.Object, error)
	PushFloat(...tengo.Object) (tengo.Object, error)
	PushString(...tengo.Object) (tengo.Object, error)
	PushBool(...tengo.Object) (tengo.Object, error)
	PushBinaryFile(...tengo.Object) (tengo.Object, error)
	PushEntityReference(...tengo.Object) (tengo.Object, error)
	PushTimestamp(...tengo.Object) (tengo.Object, error)
}

func NewTengoField added in v1.2.77 

func NewTengoField(field IField) ITengoField

type ITransformer added in v1.2.77 

type ITransformer interface {
	Transform(*Transformation, IField)
	ProcessPending()
}

func NewTransformer added in v1.2.77 

func NewTransformer(db IDatabase) ITransformer

type IWebClient 

type IWebClient interface {
	Id() string
	Read() *WebMessage
	Write(message *WebMessage)
	Close()
}

type IWorker 

type IWorker interface {
	Deinit()
	DoWork()
	Init()
}

type Int 

type Int struct {
	Raw int64 `protobuf:"varint,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Int) Descriptor deprecated 

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

Deprecated: Use Int.ProtoReflect.Descriptor instead.

func (*Int) GetRaw 

func (x *Int) GetRaw() int64

func (*Int) ProtoMessage 

func (*Int) ProtoMessage()

func (*Int) ProtoReflect 

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

func (*Int) Reset 

func (x *Int) Reset()

func (*Int) String 

func (x *Int) String() string

type JobQueue added in v1.2.78 

type JobQueue []*TengoJob

func (JobQueue) Len added in v1.2.78 

func (pq JobQueue) Len() int

Len returns the length of the queue.

func (JobQueue) Less added in v1.2.78 

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

Less compares two items based on their timestamps (earlier timestamp = higher priority).

func (*JobQueue) Pop added in v1.2.78 

func (pq *JobQueue) Pop() any

Pop removes the highest-priority element from the queue.

func (*JobQueue) Push added in v1.2.78 

func (pq *JobQueue) Push(x any)

Push adds an element to the queue.

func (JobQueue) Swap added in v1.2.78 

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

Swap swaps the elements at the specified indices.

func (*JobQueue) Update added in v1.2.78 

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

update modifies the timestamp and value of an Item in the queue.

type LeaderAvailabilityCriteria added in v1.2.31 

type LeaderAvailabilityCriteria func() bool

type LeaderElectionKeyGenerator added in v1.2.31 

type LeaderElectionKeyGenerator struct{}

leader:<appName>:current leader:<appName>:candidates

func (*LeaderElectionKeyGenerator) GetLeaderCandidatesKey added in v1.2.31 

func (g *LeaderElectionKeyGenerator) GetLeaderCandidatesKey(app string) string

func (*LeaderElectionKeyGenerator) GetLeaderKey added in v1.2.31 

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

type LeaderElectionWorker added in v1.2.31 

type LeaderElectionWorker struct {
	Signals LeaderElectionWorkerSignals
	// contains filtered or unexported fields
}

Modify LeaderElectionWorker struct

func NewLeaderElectionWorker added in v1.2.31 

func NewLeaderElectionWorker(db IDatabase) *LeaderElectionWorker

Update initialization

func (*LeaderElectionWorker) AddAvailabilityCriteria added in v1.2.31 

func (w *LeaderElectionWorker) AddAvailabilityCriteria(criteria LeaderAvailabilityCriteria)

func (*LeaderElectionWorker) Deinit added in v1.2.31 

func (w *LeaderElectionWorker) Deinit()

func (*LeaderElectionWorker) DoWork added in v1.2.31 

func (w *LeaderElectionWorker) DoWork()

func (*LeaderElectionWorker) Init added in v1.2.31 

func (w *LeaderElectionWorker) Init()

func (*LeaderElectionWorker) OnDatabaseConnected added in v1.2.31 

func (w *LeaderElectionWorker) OnDatabaseConnected()

func (*LeaderElectionWorker) OnDatabaseDisconnected added in v1.2.31 

func (w *LeaderElectionWorker) OnDatabaseDisconnected()

func (*LeaderElectionWorker) OnSchemaUpdated added in v1.2.31 

func (w *LeaderElectionWorker) OnSchemaUpdated()

type LeaderElectionWorkerSignals added in v1.2.31 

type LeaderElectionWorkerSignals struct {
	BecameLeader      Signal // Is the current leader
	LosingLeadership  Signal // Is the current leader, but is about to lose leadership status
	BecameFollower    Signal // Is available to become a leader, but not elected as a leader
	BecameUnavailable Signal // Is not available to become a leader
}

type LeaderStates added in v1.2.31 

type LeaderStates int
const (
	Unavailable LeaderStates = iota
	Follower
	Leader
)

type LogMessage 

type LogMessage struct {
	Application string                  `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
	Level       LogMessage_LogLevelEnum `protobuf:"varint,2,opt,name=level,proto3,enum=qdb.LogMessage_LogLevelEnum" json:"level,omitempty"`
	Message     string                  `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp   *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated 

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetApplication 

func (x *LogMessage) GetApplication() string

func (*LogMessage) GetLevel 

func (x *LogMessage) GetLevel() LogMessage_LogLevelEnum

func (*LogMessage) GetMessage 

func (x *LogMessage) GetMessage() string

func (*LogMessage) GetTimestamp 

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

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect 

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

func (*LogMessage) Reset 

func (x *LogMessage) Reset()

func (*LogMessage) String 

func (x *LogMessage) String() string

type LogMessage_LogLevelEnum 

type LogMessage_LogLevelEnum int32
const (
	LogMessage_UNSPECIFIED LogMessage_LogLevelEnum = 0
	LogMessage_TRACE       LogMessage_LogLevelEnum = 1
	LogMessage_DEBUG       LogMessage_LogLevelEnum = 2
	LogMessage_INFO        LogMessage_LogLevelEnum = 3
	LogMessage_WARN        LogMessage_LogLevelEnum = 4
	LogMessage_ERROR       LogMessage_LogLevelEnum = 5
	LogMessage_PANIC       LogMessage_LogLevelEnum = 6
)

func (LogMessage_LogLevelEnum) Descriptor 

func (LogMessage_LogLevelEnum) Descriptor() protoreflect.EnumDescriptor

func (LogMessage_LogLevelEnum) Enum 

func (x LogMessage_LogLevelEnum) Enum() *LogMessage_LogLevelEnum

func (LogMessage_LogLevelEnum) EnumDescriptor deprecated 

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

Deprecated: Use LogMessage_LogLevelEnum.Descriptor instead.

func (LogMessage_LogLevelEnum) Number 

func (x LogMessage_LogLevelEnum) Number() protoreflect.EnumNumber

func (LogMessage_LogLevelEnum) String 

func (x LogMessage_LogLevelEnum) String() string

func (LogMessage_LogLevelEnum) Type 

func (LogMessage_LogLevelEnum) Type() protoreflect.EnumType

type NotificationCallback added in v1.2.44 

type NotificationCallback struct {
	// contains filtered or unexported fields
}

func (*NotificationCallback) Fn added in v1.2.44 

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

func (*NotificationCallback) Id added in v1.2.44 

func (c *NotificationCallback) Id() string

type NotificationToken added in v1.2.44 

type NotificationToken struct {
	// contains filtered or unexported fields
}

func (*NotificationToken) Id added in v1.2.45 

func (t *NotificationToken) Id() string

func (*NotificationToken) Unbind added in v1.2.44 

func (t *NotificationToken) Unbind()

type PushOpt added in v1.2.67 

type PushOpt int
const (
	PushNormal PushOpt = iota
	PushIfNotEqual
)

type RedisDatabase 

type RedisDatabase struct {
	// contains filtered or unexported fields
}

func (*RedisDatabase) Connect 

func (db *RedisDatabase) Connect()

func (*RedisDatabase) CreateEntity 

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

func (*RedisDatabase) CreateSnapshot 

func (db *RedisDatabase) CreateSnapshot() *DatabaseSnapshot

func (*RedisDatabase) DeleteEntity 

func (db *RedisDatabase) DeleteEntity(entityId string)

func (*RedisDatabase) Disconnect 

func (db *RedisDatabase) Disconnect()

func (*RedisDatabase) EntityExists 

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

func (*RedisDatabase) FieldExists 

func (db *RedisDatabase) FieldExists(fieldName, entityType string) bool

func (*RedisDatabase) FindEntities 

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

func (*RedisDatabase) GetEntity 

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

func (*RedisDatabase) GetEntitySchema 

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

func (*RedisDatabase) GetEntityTypes 

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

func (*RedisDatabase) GetFieldSchema 

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

func (*RedisDatabase) GetFieldSchemas 

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

func (*RedisDatabase) IsConnected 

func (db *RedisDatabase) IsConnected() bool

func (*RedisDatabase) Notify 

func (db *RedisDatabase) Notify(notification *DatabaseNotificationConfig, callback INotificationCallback) INotificationToken

func (*RedisDatabase) ProcessNotifications 

func (db *RedisDatabase) ProcessNotifications()

func (*RedisDatabase) Read 

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

func (*RedisDatabase) ResolveIndirection 

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

func (*RedisDatabase) RestoreSnapshot 

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

func (*RedisDatabase) SetEntity 

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

func (*RedisDatabase) SetEntitySchema 

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

func (*RedisDatabase) SetFieldSchema 

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

func (*RedisDatabase) SortedSetAdd added in v1.2.84 

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

func (*RedisDatabase) SortedSetRangeByScoreWithScores added in v1.2.84 

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

func (*RedisDatabase) SortedSetRemove added in v1.2.84 

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

func (*RedisDatabase) SortedSetRemoveRangeByRank added in v1.2.84 

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

func (*RedisDatabase) TempDel added in v1.2.31 

func (db *RedisDatabase) TempDel(key string)

func (*RedisDatabase) TempExpire added in v1.2.31 

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

func (*RedisDatabase) TempGet added in v1.2.31 

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

func (*RedisDatabase) TempSet added in v1.2.31 

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

func (*RedisDatabase) Unnotify 

func (db *RedisDatabase) Unnotify(e string)

func (*RedisDatabase) UnnotifyCallback added in v1.2.44 

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

func (*RedisDatabase) Write 

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

type RedisDatabaseConfig 

type RedisDatabaseConfig struct {
	Address   string
	Password  string
	ServiceID func() string
}

type RedisDatabaseKeyGenerator 

type RedisDatabaseKeyGenerator struct{}

schema:entity:<type> -> DatabaseEntitySchema schema:field:<name> -> DatabaseFieldSchema instance:entity:<entityId> -> DatabaseEntity instance:field:<name>:<entityId> -> DatabaseField instance:type:<entityType> -> []string{entityId...} instance:notification-config:<entityId>:<fieldName> -> []string{subscriptionId...} instance:notification-config:<entityType>:<fieldName> -> []string{subscriptionId...}

func (*RedisDatabaseKeyGenerator) GetEntityIdNotificationConfigKey 

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

func (*RedisDatabaseKeyGenerator) GetEntityKey 

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

func (*RedisDatabaseKeyGenerator) GetEntitySchemaKey 

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

func (*RedisDatabaseKeyGenerator) GetEntityTypeKey 

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

func (*RedisDatabaseKeyGenerator) GetEntityTypeNotificationConfigKey 

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

func (*RedisDatabaseKeyGenerator) GetFieldKey 

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

func (*RedisDatabaseKeyGenerator) GetFieldSchemaKey 

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

func (*RedisDatabaseKeyGenerator) GetNotificationChannelKey 

func (g *RedisDatabaseKeyGenerator) GetNotificationChannelKey(serviceId string) string

type SchemaValidator added in v1.2.39 

type SchemaValidator struct {
	// contains filtered or unexported fields
}

func (*SchemaValidator) AddEntity added in v1.2.39 

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

func (*SchemaValidator) IsValid added in v1.2.39 

func (v *SchemaValidator) IsValid() bool

func (*SchemaValidator) Validate added in v1.2.39 

func (v *SchemaValidator) Validate() bool

func (*SchemaValidator) ValidationRequired added in v1.2.58 

func (v *SchemaValidator) ValidationRequired()

type SearchCriteria 

type SearchCriteria struct {
	EntityType string
	Conditions []FieldConditionEval
}

type Signal 

type Signal struct {
	// contains filtered or unexported fields
}

func (*Signal) Connect 

func (s *Signal) Connect(slot ISlot)

func (*Signal) Disconnect 

func (s *Signal) Disconnect(slot ISlot)

func (*Signal) DisconnectAll 

func (s *Signal) DisconnectAll()

func (*Signal) Emit 

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

type SlotDefinition 

type SlotDefinition struct {
	Fn func(...interface{})
}

func (*SlotDefinition) Invoke 

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

type SortedSetMember added in v1.2.84 

type SortedSetMember struct {
	Score  float64
	Member string
}

type String 

type String struct {
	Raw string `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*String) Descriptor deprecated 

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

Deprecated: Use String.ProtoReflect.Descriptor instead.

func (*String) GetRaw 

func (x *String) GetRaw() string

func (*String) ProtoMessage 

func (*String) ProtoMessage()

func (*String) ProtoReflect 

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

func (*String) Reset 

func (x *String) Reset()

func (*String) String 

func (x *String) String() string

type TengoDatabase added in v1.2.77 

type TengoDatabase struct {
	// contains filtered or unexported fields
}

func (*TengoDatabase) Find added in v1.2.77 

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

func (*TengoDatabase) GetEntity added in v1.2.77 

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

func (*TengoDatabase) PopAvailableJobs added in v1.2.78 

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

func (*TengoDatabase) Schedule added in v1.2.78 

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

func (*TengoDatabase) ToTengoMap added in v1.2.77 

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

type TengoEntity added in v1.2.77 

type TengoEntity struct {
	// contains filtered or unexported fields
}

func (*TengoEntity) GetChildren added in v1.2.77 

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

func (*TengoEntity) GetField added in v1.2.77 

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

func (*TengoEntity) GetId added in v1.2.77 

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

func (*TengoEntity) GetParent added in v1.2.77 

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

func (*TengoEntity) GetType added in v1.2.77 

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

func (*TengoEntity) ToTengoMap added in v1.2.77 

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

type TengoField added in v1.2.77 

type TengoField struct {
	// contains filtered or unexported fields
}

func (*TengoField) GetBinaryFile added in v1.2.77 

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

func (*TengoField) GetBool added in v1.2.77 

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

func (*TengoField) GetEntityReference added in v1.2.77 

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

func (*TengoField) GetFloat added in v1.2.77 

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

func (*TengoField) GetId added in v1.2.77 

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

func (*TengoField) GetInt added in v1.2.77 

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

func (*TengoField) GetName added in v1.2.77 

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

func (*TengoField) GetString added in v1.2.77 

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

func (*TengoField) GetTimestamp added in v1.2.77 

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

func (*TengoField) GetWriteTime added in v1.2.77 

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

func (*TengoField) GetWriter added in v1.2.77 

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

func (*TengoField) PullBinaryFile added in v1.2.77 

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

func (*TengoField) PullBool added in v1.2.77 

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

func (*TengoField) PullEntityReference added in v1.2.77 

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

func (*TengoField) PullFloat added in v1.2.77 

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

func (*TengoField) PullInt added in v1.2.77 

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

func (*TengoField) PullString added in v1.2.77 

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

func (*TengoField) PullTimestamp added in v1.2.77 

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

func (*TengoField) PullWriteTime added in v1.2.77 

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

func (*TengoField) PullWriter added in v1.2.77 

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

func (*TengoField) PushBinaryFile added in v1.2.77 

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

func (*TengoField) PushBool added in v1.2.77 

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

func (*TengoField) PushEntityReference added in v1.2.77 

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

func (*TengoField) PushFloat added in v1.2.77 

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

func (*TengoField) PushInt added in v1.2.77 

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

func (*TengoField) PushString added in v1.2.77 

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

func (*TengoField) PushTimestamp added in v1.2.77 

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

func (*TengoField) ToTengoMap added in v1.2.77 

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

type TengoJob added in v1.2.78 

type TengoJob struct {
	// contains filtered or unexported fields
}

type TengoTransformer added in v1.2.78 

type TengoTransformer struct {
	// contains filtered or unexported fields
}

func (*TengoTransformer) ProcessPending added in v1.2.78 

func (t *TengoTransformer) ProcessPending()

func (*TengoTransformer) Transform added in v1.2.78 

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

type Timestamp 

type Timestamp struct {
	Raw *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Timestamp) Descriptor deprecated 

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

Deprecated: Use Timestamp.ProtoReflect.Descriptor instead.

func (*Timestamp) GetRaw 

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

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) ProtoReflect 

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

func (*Timestamp) Reset 

func (x *Timestamp) Reset()

func (*Timestamp) String 

func (x *Timestamp) String() string

type Transformation added in v1.2.77 

type Transformation struct {
	Raw string `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

func (*Transformation) Descriptor deprecated added in v1.2.77 

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

Deprecated: Use Transformation.ProtoReflect.Descriptor instead.

func (*Transformation) GetRaw added in v1.2.77 

func (x *Transformation) GetRaw() string

func (*Transformation) ProtoMessage added in v1.2.77 

func (*Transformation) ProtoMessage()

func (*Transformation) ProtoReflect added in v1.2.77 

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

func (*Transformation) Reset added in v1.2.77 

func (x *Transformation) Reset()

func (*Transformation) String added in v1.2.77 

func (x *Transformation) String() string

type WebClient 

type WebClient struct {
	// contains filtered or unexported fields
}

func NewWebClient 

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

func (*WebClient) Close 

func (c *WebClient) Close()

func (*WebClient) Id 

func (c *WebClient) Id() string

func (*WebClient) Read 

func (c *WebClient) Read() *WebMessage

func (*WebClient) Write 

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

type WebConfigCreateEntityRequest 

type WebConfigCreateEntityRequest struct {
	Type     string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ParentId string `protobuf:"bytes,3,opt,name=parentId,proto3" json:"parentId,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigCreateEntityRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigCreateEntityRequest.ProtoReflect.Descriptor instead.

func (*WebConfigCreateEntityRequest) GetName 

func (x *WebConfigCreateEntityRequest) GetName() string

func (*WebConfigCreateEntityRequest) GetParentId 

func (x *WebConfigCreateEntityRequest) GetParentId() string

func (*WebConfigCreateEntityRequest) GetType 

func (x *WebConfigCreateEntityRequest) GetType() string

func (*WebConfigCreateEntityRequest) ProtoMessage 

func (*WebConfigCreateEntityRequest) ProtoMessage()

func (*WebConfigCreateEntityRequest) ProtoReflect 

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

func (*WebConfigCreateEntityRequest) Reset 

func (x *WebConfigCreateEntityRequest) Reset()

func (*WebConfigCreateEntityRequest) String 

func (x *WebConfigCreateEntityRequest) String() string

type WebConfigCreateEntityResponse 

type WebConfigCreateEntityResponse struct {
	Status WebConfigCreateEntityResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigCreateEntityResponse_StatusEnum" json:"status,omitempty"`
	Id     string                                   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigCreateEntityResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigCreateEntityResponse.ProtoReflect.Descriptor instead.

func (*WebConfigCreateEntityResponse) GetId 

func (x *WebConfigCreateEntityResponse) GetId() string

func (*WebConfigCreateEntityResponse) GetStatus 

func (x *WebConfigCreateEntityResponse) GetStatus() WebConfigCreateEntityResponse_StatusEnum

func (*WebConfigCreateEntityResponse) ProtoMessage 

func (*WebConfigCreateEntityResponse) ProtoMessage()

func (*WebConfigCreateEntityResponse) ProtoReflect 

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

func (*WebConfigCreateEntityResponse) Reset 

func (x *WebConfigCreateEntityResponse) Reset()

func (*WebConfigCreateEntityResponse) String 

func (x *WebConfigCreateEntityResponse) String() string

type WebConfigCreateEntityResponse_StatusEnum 

type WebConfigCreateEntityResponse_StatusEnum int32
const (
	WebConfigCreateEntityResponse_UNSPECIFIED WebConfigCreateEntityResponse_StatusEnum = 0
	WebConfigCreateEntityResponse_SUCCESS     WebConfigCreateEntityResponse_StatusEnum = 1
	WebConfigCreateEntityResponse_FAILURE     WebConfigCreateEntityResponse_StatusEnum = 2
)

func (WebConfigCreateEntityResponse_StatusEnum) Descriptor 

func (WebConfigCreateEntityResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigCreateEntityResponse_StatusEnum) Enum 

func (x WebConfigCreateEntityResponse_StatusEnum) Enum() *WebConfigCreateEntityResponse_StatusEnum

func (WebConfigCreateEntityResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigCreateEntityResponse_StatusEnum.Descriptor instead.

func (WebConfigCreateEntityResponse_StatusEnum) Number 

func (x WebConfigCreateEntityResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigCreateEntityResponse_StatusEnum) String 

func (x WebConfigCreateEntityResponse_StatusEnum) String() string

func (WebConfigCreateEntityResponse_StatusEnum) Type 

func (WebConfigCreateEntityResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigCreateSnapshotRequest 

type WebConfigCreateSnapshotRequest struct {
	// contains filtered or unexported fields
}

func (*WebConfigCreateSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigCreateSnapshotRequest.ProtoReflect.Descriptor instead.

func (*WebConfigCreateSnapshotRequest) ProtoMessage 

func (*WebConfigCreateSnapshotRequest) ProtoMessage()

func (*WebConfigCreateSnapshotRequest) ProtoReflect 

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

func (*WebConfigCreateSnapshotRequest) Reset 

func (x *WebConfigCreateSnapshotRequest) Reset()

func (*WebConfigCreateSnapshotRequest) String 

func (x *WebConfigCreateSnapshotRequest) String() string

type WebConfigCreateSnapshotResponse 

type WebConfigCreateSnapshotResponse struct {
	Status   WebConfigCreateSnapshotResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigCreateSnapshotResponse_StatusEnum" json:"status,omitempty"`
	Snapshot *DatabaseSnapshot                          `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigCreateSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigCreateSnapshotResponse.ProtoReflect.Descriptor instead.

func (*WebConfigCreateSnapshotResponse) GetSnapshot 

func (x *WebConfigCreateSnapshotResponse) GetSnapshot() *DatabaseSnapshot

func (*WebConfigCreateSnapshotResponse) GetStatus 

func (x *WebConfigCreateSnapshotResponse) GetStatus() WebConfigCreateSnapshotResponse_StatusEnum

func (*WebConfigCreateSnapshotResponse) ProtoMessage 

func (*WebConfigCreateSnapshotResponse) ProtoMessage()

func (*WebConfigCreateSnapshotResponse) ProtoReflect 

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

func (*WebConfigCreateSnapshotResponse) Reset 

func (x *WebConfigCreateSnapshotResponse) Reset()

func (*WebConfigCreateSnapshotResponse) String 

func (x *WebConfigCreateSnapshotResponse) String() string

type WebConfigCreateSnapshotResponse_StatusEnum 

type WebConfigCreateSnapshotResponse_StatusEnum int32
const (
	WebConfigCreateSnapshotResponse_UNSPECIFIED WebConfigCreateSnapshotResponse_StatusEnum = 0
	WebConfigCreateSnapshotResponse_SUCCESS     WebConfigCreateSnapshotResponse_StatusEnum = 1
	WebConfigCreateSnapshotResponse_FAILURE     WebConfigCreateSnapshotResponse_StatusEnum = 2
)

func (WebConfigCreateSnapshotResponse_StatusEnum) Descriptor 

func (WebConfigCreateSnapshotResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigCreateSnapshotResponse_StatusEnum) Enum 

func (x WebConfigCreateSnapshotResponse_StatusEnum) Enum() *WebConfigCreateSnapshotResponse_StatusEnum

func (WebConfigCreateSnapshotResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigCreateSnapshotResponse_StatusEnum.Descriptor instead.

func (WebConfigCreateSnapshotResponse_StatusEnum) Number 

func (x WebConfigCreateSnapshotResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigCreateSnapshotResponse_StatusEnum) String 

func (x WebConfigCreateSnapshotResponse_StatusEnum) String() string

func (WebConfigCreateSnapshotResponse_StatusEnum) Type 

func (WebConfigCreateSnapshotResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigDeleteEntityRequest 

type WebConfigDeleteEntityRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigDeleteEntityRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigDeleteEntityRequest.ProtoReflect.Descriptor instead.

func (*WebConfigDeleteEntityRequest) GetId 

func (x *WebConfigDeleteEntityRequest) GetId() string

func (*WebConfigDeleteEntityRequest) ProtoMessage 

func (*WebConfigDeleteEntityRequest) ProtoMessage()

func (*WebConfigDeleteEntityRequest) ProtoReflect 

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

func (*WebConfigDeleteEntityRequest) Reset 

func (x *WebConfigDeleteEntityRequest) Reset()

func (*WebConfigDeleteEntityRequest) String 

func (x *WebConfigDeleteEntityRequest) String() string

type WebConfigDeleteEntityResponse 

type WebConfigDeleteEntityResponse struct {
	Status WebConfigDeleteEntityResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigDeleteEntityResponse_StatusEnum" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigDeleteEntityResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigDeleteEntityResponse.ProtoReflect.Descriptor instead.

func (*WebConfigDeleteEntityResponse) GetStatus 

func (x *WebConfigDeleteEntityResponse) GetStatus() WebConfigDeleteEntityResponse_StatusEnum

func (*WebConfigDeleteEntityResponse) ProtoMessage 

func (*WebConfigDeleteEntityResponse) ProtoMessage()

func (*WebConfigDeleteEntityResponse) ProtoReflect 

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

func (*WebConfigDeleteEntityResponse) Reset 

func (x *WebConfigDeleteEntityResponse) Reset()

func (*WebConfigDeleteEntityResponse) String 

func (x *WebConfigDeleteEntityResponse) String() string

type WebConfigDeleteEntityResponse_StatusEnum 

type WebConfigDeleteEntityResponse_StatusEnum int32
const (
	WebConfigDeleteEntityResponse_UNSPECIFIED WebConfigDeleteEntityResponse_StatusEnum = 0
	WebConfigDeleteEntityResponse_SUCCESS     WebConfigDeleteEntityResponse_StatusEnum = 1
	WebConfigDeleteEntityResponse_FAILURE     WebConfigDeleteEntityResponse_StatusEnum = 2
)

func (WebConfigDeleteEntityResponse_StatusEnum) Descriptor 

func (WebConfigDeleteEntityResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigDeleteEntityResponse_StatusEnum) Enum 

func (x WebConfigDeleteEntityResponse_StatusEnum) Enum() *WebConfigDeleteEntityResponse_StatusEnum

func (WebConfigDeleteEntityResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigDeleteEntityResponse_StatusEnum.Descriptor instead.

func (WebConfigDeleteEntityResponse_StatusEnum) Number 

func (x WebConfigDeleteEntityResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigDeleteEntityResponse_StatusEnum) String 

func (x WebConfigDeleteEntityResponse_StatusEnum) String() string

func (WebConfigDeleteEntityResponse_StatusEnum) Type 

func (WebConfigDeleteEntityResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigGetAllFieldsRequest 

type WebConfigGetAllFieldsRequest struct {
	// contains filtered or unexported fields
}

func (*WebConfigGetAllFieldsRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigGetAllFieldsRequest.ProtoReflect.Descriptor instead.

func (*WebConfigGetAllFieldsRequest) ProtoMessage 

func (*WebConfigGetAllFieldsRequest) ProtoMessage()

func (*WebConfigGetAllFieldsRequest) ProtoReflect 

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

func (*WebConfigGetAllFieldsRequest) Reset 

func (x *WebConfigGetAllFieldsRequest) Reset()

func (*WebConfigGetAllFieldsRequest) String 

func (x *WebConfigGetAllFieldsRequest) String() string

type WebConfigGetAllFieldsResponse 

type WebConfigGetAllFieldsResponse struct {
	Fields []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetAllFieldsResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigGetAllFieldsResponse.ProtoReflect.Descriptor instead.

func (*WebConfigGetAllFieldsResponse) GetFields 

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

func (*WebConfigGetAllFieldsResponse) ProtoMessage 

func (*WebConfigGetAllFieldsResponse) ProtoMessage()

func (*WebConfigGetAllFieldsResponse) ProtoReflect 

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

func (*WebConfigGetAllFieldsResponse) Reset 

func (x *WebConfigGetAllFieldsResponse) Reset()

func (*WebConfigGetAllFieldsResponse) String 

func (x *WebConfigGetAllFieldsResponse) String() string

type WebConfigGetEntityRequest 

type WebConfigGetEntityRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetEntityRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigGetEntityRequest.ProtoReflect.Descriptor instead.

func (*WebConfigGetEntityRequest) GetId 

func (x *WebConfigGetEntityRequest) GetId() string

func (*WebConfigGetEntityRequest) ProtoMessage 

func (*WebConfigGetEntityRequest) ProtoMessage()

func (*WebConfigGetEntityRequest) ProtoReflect 

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

func (*WebConfigGetEntityRequest) Reset 

func (x *WebConfigGetEntityRequest) Reset()

func (*WebConfigGetEntityRequest) String 

func (x *WebConfigGetEntityRequest) String() string

type WebConfigGetEntityResponse 

type WebConfigGetEntityResponse struct {
	Status WebConfigGetEntityResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigGetEntityResponse_StatusEnum" json:"status,omitempty"`
	Entity *DatabaseEntity                       `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetEntityResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigGetEntityResponse.ProtoReflect.Descriptor instead.

func (*WebConfigGetEntityResponse) GetEntity 

func (x *WebConfigGetEntityResponse) GetEntity() *DatabaseEntity

func (*WebConfigGetEntityResponse) GetStatus 

func (x *WebConfigGetEntityResponse) GetStatus() WebConfigGetEntityResponse_StatusEnum

func (*WebConfigGetEntityResponse) ProtoMessage 

func (*WebConfigGetEntityResponse) ProtoMessage()

func (*WebConfigGetEntityResponse) ProtoReflect 

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

func (*WebConfigGetEntityResponse) Reset 

func (x *WebConfigGetEntityResponse) Reset()

func (*WebConfigGetEntityResponse) String 

func (x *WebConfigGetEntityResponse) String() string

type WebConfigGetEntityResponse_StatusEnum 

type WebConfigGetEntityResponse_StatusEnum int32
const (
	WebConfigGetEntityResponse_UNSPECIFIED WebConfigGetEntityResponse_StatusEnum = 0
	WebConfigGetEntityResponse_SUCCESS     WebConfigGetEntityResponse_StatusEnum = 1
	WebConfigGetEntityResponse_FAILURE     WebConfigGetEntityResponse_StatusEnum = 2
)

func (WebConfigGetEntityResponse_StatusEnum) Descriptor 

func (WebConfigGetEntityResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigGetEntityResponse_StatusEnum) Enum 

func (x WebConfigGetEntityResponse_StatusEnum) Enum() *WebConfigGetEntityResponse_StatusEnum

func (WebConfigGetEntityResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigGetEntityResponse_StatusEnum.Descriptor instead.

func (WebConfigGetEntityResponse_StatusEnum) Number 

func (x WebConfigGetEntityResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigGetEntityResponse_StatusEnum) String 

func (x WebConfigGetEntityResponse_StatusEnum) String() string

func (WebConfigGetEntityResponse_StatusEnum) Type 

func (WebConfigGetEntityResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigGetEntitySchemaRequest 

type WebConfigGetEntitySchemaRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetEntitySchemaRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigGetEntitySchemaRequest.ProtoReflect.Descriptor instead.

func (*WebConfigGetEntitySchemaRequest) GetType 

func (x *WebConfigGetEntitySchemaRequest) GetType() string

func (*WebConfigGetEntitySchemaRequest) ProtoMessage 

func (*WebConfigGetEntitySchemaRequest) ProtoMessage()

func (*WebConfigGetEntitySchemaRequest) ProtoReflect 

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

func (*WebConfigGetEntitySchemaRequest) Reset 

func (x *WebConfigGetEntitySchemaRequest) Reset()

func (*WebConfigGetEntitySchemaRequest) String 

func (x *WebConfigGetEntitySchemaRequest) String() string

type WebConfigGetEntitySchemaResponse 

type WebConfigGetEntitySchemaResponse struct {
	Status WebConfigGetEntitySchemaResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigGetEntitySchemaResponse_StatusEnum" json:"status,omitempty"`
	Schema *DatabaseEntitySchema                       `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetEntitySchemaResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigGetEntitySchemaResponse.ProtoReflect.Descriptor instead.

func (*WebConfigGetEntitySchemaResponse) GetSchema 

func (x *WebConfigGetEntitySchemaResponse) GetSchema() *DatabaseEntitySchema

func (*WebConfigGetEntitySchemaResponse) GetStatus 

func (x *WebConfigGetEntitySchemaResponse) GetStatus() WebConfigGetEntitySchemaResponse_StatusEnum

func (*WebConfigGetEntitySchemaResponse) ProtoMessage 

func (*WebConfigGetEntitySchemaResponse) ProtoMessage()

func (*WebConfigGetEntitySchemaResponse) ProtoReflect 

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

func (*WebConfigGetEntitySchemaResponse) Reset 

func (x *WebConfigGetEntitySchemaResponse) Reset()

func (*WebConfigGetEntitySchemaResponse) String 

func (x *WebConfigGetEntitySchemaResponse) String() string

type WebConfigGetEntitySchemaResponse_StatusEnum 

type WebConfigGetEntitySchemaResponse_StatusEnum int32
const (
	WebConfigGetEntitySchemaResponse_UNSPECIFIED WebConfigGetEntitySchemaResponse_StatusEnum = 0
	WebConfigGetEntitySchemaResponse_SUCCESS     WebConfigGetEntitySchemaResponse_StatusEnum = 1
	WebConfigGetEntitySchemaResponse_FAILURE     WebConfigGetEntitySchemaResponse_StatusEnum = 2
)

func (WebConfigGetEntitySchemaResponse_StatusEnum) Descriptor 

func (WebConfigGetEntitySchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigGetEntitySchemaResponse_StatusEnum) Enum 

func (x WebConfigGetEntitySchemaResponse_StatusEnum) Enum() *WebConfigGetEntitySchemaResponse_StatusEnum

func (WebConfigGetEntitySchemaResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigGetEntitySchemaResponse_StatusEnum.Descriptor instead.

func (WebConfigGetEntitySchemaResponse_StatusEnum) Number 

func (x WebConfigGetEntitySchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigGetEntitySchemaResponse_StatusEnum) String 

func (x WebConfigGetEntitySchemaResponse_StatusEnum) String() string

func (WebConfigGetEntitySchemaResponse_StatusEnum) Type 

func (WebConfigGetEntitySchemaResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigGetEntityTypesRequest 

type WebConfigGetEntityTypesRequest struct {
	// contains filtered or unexported fields
}

func (*WebConfigGetEntityTypesRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigGetEntityTypesRequest.ProtoReflect.Descriptor instead.

func (*WebConfigGetEntityTypesRequest) ProtoMessage 

func (*WebConfigGetEntityTypesRequest) ProtoMessage()

func (*WebConfigGetEntityTypesRequest) ProtoReflect 

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

func (*WebConfigGetEntityTypesRequest) Reset 

func (x *WebConfigGetEntityTypesRequest) Reset()

func (*WebConfigGetEntityTypesRequest) String 

func (x *WebConfigGetEntityTypesRequest) String() string

type WebConfigGetEntityTypesResponse 

type WebConfigGetEntityTypesResponse struct {
	Types []string `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetEntityTypesResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigGetEntityTypesResponse.ProtoReflect.Descriptor instead.

func (*WebConfigGetEntityTypesResponse) GetTypes 

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

func (*WebConfigGetEntityTypesResponse) ProtoMessage 

func (*WebConfigGetEntityTypesResponse) ProtoMessage()

func (*WebConfigGetEntityTypesResponse) ProtoReflect 

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

func (*WebConfigGetEntityTypesResponse) Reset 

func (x *WebConfigGetEntityTypesResponse) Reset()

func (*WebConfigGetEntityTypesResponse) String 

func (x *WebConfigGetEntityTypesResponse) String() string

type WebConfigGetFieldSchemaRequest 

type WebConfigGetFieldSchemaRequest struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetFieldSchemaRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigGetFieldSchemaRequest.ProtoReflect.Descriptor instead.

func (*WebConfigGetFieldSchemaRequest) GetField 

func (x *WebConfigGetFieldSchemaRequest) GetField() string

func (*WebConfigGetFieldSchemaRequest) ProtoMessage 

func (*WebConfigGetFieldSchemaRequest) ProtoMessage()

func (*WebConfigGetFieldSchemaRequest) ProtoReflect 

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

func (*WebConfigGetFieldSchemaRequest) Reset 

func (x *WebConfigGetFieldSchemaRequest) Reset()

func (*WebConfigGetFieldSchemaRequest) String 

func (x *WebConfigGetFieldSchemaRequest) String() string

type WebConfigGetFieldSchemaResponse 

type WebConfigGetFieldSchemaResponse struct {
	Status WebConfigGetFieldSchemaResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigGetFieldSchemaResponse_StatusEnum" json:"status,omitempty"`
	Schema *DatabaseFieldSchema                       `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetFieldSchemaResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigGetFieldSchemaResponse.ProtoReflect.Descriptor instead.

func (*WebConfigGetFieldSchemaResponse) GetSchema 

func (x *WebConfigGetFieldSchemaResponse) GetSchema() *DatabaseFieldSchema

func (*WebConfigGetFieldSchemaResponse) GetStatus 

func (x *WebConfigGetFieldSchemaResponse) GetStatus() WebConfigGetFieldSchemaResponse_StatusEnum

func (*WebConfigGetFieldSchemaResponse) ProtoMessage 

func (*WebConfigGetFieldSchemaResponse) ProtoMessage()

func (*WebConfigGetFieldSchemaResponse) ProtoReflect 

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

func (*WebConfigGetFieldSchemaResponse) Reset 

func (x *WebConfigGetFieldSchemaResponse) Reset()

func (*WebConfigGetFieldSchemaResponse) String 

func (x *WebConfigGetFieldSchemaResponse) String() string

type WebConfigGetFieldSchemaResponse_StatusEnum 

type WebConfigGetFieldSchemaResponse_StatusEnum int32
const (
	WebConfigGetFieldSchemaResponse_UNSPECIFIED WebConfigGetFieldSchemaResponse_StatusEnum = 0
	WebConfigGetFieldSchemaResponse_SUCCESS     WebConfigGetFieldSchemaResponse_StatusEnum = 1
	WebConfigGetFieldSchemaResponse_FAILURE     WebConfigGetFieldSchemaResponse_StatusEnum = 2
)

func (WebConfigGetFieldSchemaResponse_StatusEnum) Descriptor 

func (WebConfigGetFieldSchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigGetFieldSchemaResponse_StatusEnum) Enum 

func (x WebConfigGetFieldSchemaResponse_StatusEnum) Enum() *WebConfigGetFieldSchemaResponse_StatusEnum

func (WebConfigGetFieldSchemaResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigGetFieldSchemaResponse_StatusEnum.Descriptor instead.

func (WebConfigGetFieldSchemaResponse_StatusEnum) Number 

func (x WebConfigGetFieldSchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigGetFieldSchemaResponse_StatusEnum) String 

func (x WebConfigGetFieldSchemaResponse_StatusEnum) String() string

func (WebConfigGetFieldSchemaResponse_StatusEnum) Type 

func (WebConfigGetFieldSchemaResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigGetRootRequest 

type WebConfigGetRootRequest struct {
	// contains filtered or unexported fields
}

func (*WebConfigGetRootRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigGetRootRequest.ProtoReflect.Descriptor instead.

func (*WebConfigGetRootRequest) ProtoMessage 

func (*WebConfigGetRootRequest) ProtoMessage()

func (*WebConfigGetRootRequest) ProtoReflect 

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

func (*WebConfigGetRootRequest) Reset 

func (x *WebConfigGetRootRequest) Reset()

func (*WebConfigGetRootRequest) String 

func (x *WebConfigGetRootRequest) String() string

type WebConfigGetRootResponse 

type WebConfigGetRootResponse struct {
	RootId string `protobuf:"bytes,1,opt,name=rootId,proto3" json:"rootId,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigGetRootResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigGetRootResponse.ProtoReflect.Descriptor instead.

func (*WebConfigGetRootResponse) GetRootId 

func (x *WebConfigGetRootResponse) GetRootId() string

func (*WebConfigGetRootResponse) ProtoMessage 

func (*WebConfigGetRootResponse) ProtoMessage()

func (*WebConfigGetRootResponse) ProtoReflect 

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

func (*WebConfigGetRootResponse) Reset 

func (x *WebConfigGetRootResponse) Reset()

func (*WebConfigGetRootResponse) String 

func (x *WebConfigGetRootResponse) String() string

type WebConfigRestoreSnapshotRequest 

type WebConfigRestoreSnapshotRequest struct {
	Snapshot *DatabaseSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigRestoreSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigRestoreSnapshotRequest.ProtoReflect.Descriptor instead.

func (*WebConfigRestoreSnapshotRequest) GetSnapshot 

func (x *WebConfigRestoreSnapshotRequest) GetSnapshot() *DatabaseSnapshot

func (*WebConfigRestoreSnapshotRequest) ProtoMessage 

func (*WebConfigRestoreSnapshotRequest) ProtoMessage()

func (*WebConfigRestoreSnapshotRequest) ProtoReflect 

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

func (*WebConfigRestoreSnapshotRequest) Reset 

func (x *WebConfigRestoreSnapshotRequest) Reset()

func (*WebConfigRestoreSnapshotRequest) String 

func (x *WebConfigRestoreSnapshotRequest) String() string

type WebConfigRestoreSnapshotResponse 

type WebConfigRestoreSnapshotResponse struct {
	Status WebConfigRestoreSnapshotResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigRestoreSnapshotResponse_StatusEnum" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigRestoreSnapshotResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigRestoreSnapshotResponse.ProtoReflect.Descriptor instead.

func (*WebConfigRestoreSnapshotResponse) GetStatus 

func (x *WebConfigRestoreSnapshotResponse) GetStatus() WebConfigRestoreSnapshotResponse_StatusEnum

func (*WebConfigRestoreSnapshotResponse) ProtoMessage 

func (*WebConfigRestoreSnapshotResponse) ProtoMessage()

func (*WebConfigRestoreSnapshotResponse) ProtoReflect 

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

func (*WebConfigRestoreSnapshotResponse) Reset 

func (x *WebConfigRestoreSnapshotResponse) Reset()

func (*WebConfigRestoreSnapshotResponse) String 

func (x *WebConfigRestoreSnapshotResponse) String() string

type WebConfigRestoreSnapshotResponse_StatusEnum 

type WebConfigRestoreSnapshotResponse_StatusEnum int32
const (
	WebConfigRestoreSnapshotResponse_UNSPECIFIED WebConfigRestoreSnapshotResponse_StatusEnum = 0
	WebConfigRestoreSnapshotResponse_SUCCESS     WebConfigRestoreSnapshotResponse_StatusEnum = 1
	WebConfigRestoreSnapshotResponse_FAILURE     WebConfigRestoreSnapshotResponse_StatusEnum = 2
)

func (WebConfigRestoreSnapshotResponse_StatusEnum) Descriptor 

func (WebConfigRestoreSnapshotResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigRestoreSnapshotResponse_StatusEnum) Enum 

func (x WebConfigRestoreSnapshotResponse_StatusEnum) Enum() *WebConfigRestoreSnapshotResponse_StatusEnum

func (WebConfigRestoreSnapshotResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigRestoreSnapshotResponse_StatusEnum.Descriptor instead.

func (WebConfigRestoreSnapshotResponse_StatusEnum) Number 

func (x WebConfigRestoreSnapshotResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigRestoreSnapshotResponse_StatusEnum) String 

func (x WebConfigRestoreSnapshotResponse_StatusEnum) String() string

func (WebConfigRestoreSnapshotResponse_StatusEnum) Type 

func (WebConfigRestoreSnapshotResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigSetEntitySchemaRequest 

type WebConfigSetEntitySchemaRequest struct {
	Name   string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigSetEntitySchemaRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigSetEntitySchemaRequest.ProtoReflect.Descriptor instead.

func (*WebConfigSetEntitySchemaRequest) GetFields 

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

func (*WebConfigSetEntitySchemaRequest) GetName 

func (x *WebConfigSetEntitySchemaRequest) GetName() string

func (*WebConfigSetEntitySchemaRequest) ProtoMessage 

func (*WebConfigSetEntitySchemaRequest) ProtoMessage()

func (*WebConfigSetEntitySchemaRequest) ProtoReflect 

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

func (*WebConfigSetEntitySchemaRequest) Reset 

func (x *WebConfigSetEntitySchemaRequest) Reset()

func (*WebConfigSetEntitySchemaRequest) String 

func (x *WebConfigSetEntitySchemaRequest) String() string

type WebConfigSetEntitySchemaResponse 

type WebConfigSetEntitySchemaResponse struct {
	Status WebConfigSetEntitySchemaResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigSetEntitySchemaResponse_StatusEnum" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigSetEntitySchemaResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigSetEntitySchemaResponse.ProtoReflect.Descriptor instead.

func (*WebConfigSetEntitySchemaResponse) GetStatus 

func (x *WebConfigSetEntitySchemaResponse) GetStatus() WebConfigSetEntitySchemaResponse_StatusEnum

func (*WebConfigSetEntitySchemaResponse) ProtoMessage 

func (*WebConfigSetEntitySchemaResponse) ProtoMessage()

func (*WebConfigSetEntitySchemaResponse) ProtoReflect 

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

func (*WebConfigSetEntitySchemaResponse) Reset 

func (x *WebConfigSetEntitySchemaResponse) Reset()

func (*WebConfigSetEntitySchemaResponse) String 

func (x *WebConfigSetEntitySchemaResponse) String() string

type WebConfigSetEntitySchemaResponse_StatusEnum 

type WebConfigSetEntitySchemaResponse_StatusEnum int32
const (
	WebConfigSetEntitySchemaResponse_UNSPECIFIED WebConfigSetEntitySchemaResponse_StatusEnum = 0
	WebConfigSetEntitySchemaResponse_SUCCESS     WebConfigSetEntitySchemaResponse_StatusEnum = 1
	WebConfigSetEntitySchemaResponse_FAILURE     WebConfigSetEntitySchemaResponse_StatusEnum = 2
)

func (WebConfigSetEntitySchemaResponse_StatusEnum) Descriptor 

func (WebConfigSetEntitySchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigSetEntitySchemaResponse_StatusEnum) Enum 

func (x WebConfigSetEntitySchemaResponse_StatusEnum) Enum() *WebConfigSetEntitySchemaResponse_StatusEnum

func (WebConfigSetEntitySchemaResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigSetEntitySchemaResponse_StatusEnum.Descriptor instead.

func (WebConfigSetEntitySchemaResponse_StatusEnum) Number 

func (x WebConfigSetEntitySchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigSetEntitySchemaResponse_StatusEnum) String 

func (x WebConfigSetEntitySchemaResponse_StatusEnum) String() string

func (WebConfigSetEntitySchemaResponse_StatusEnum) Type 

func (WebConfigSetEntitySchemaResponse_StatusEnum) Type() protoreflect.EnumType

type WebConfigSetFieldSchemaRequest 

type WebConfigSetFieldSchemaRequest struct {
	Field  string               `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Schema *DatabaseFieldSchema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigSetFieldSchemaRequest) Descriptor deprecated 

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

Deprecated: Use WebConfigSetFieldSchemaRequest.ProtoReflect.Descriptor instead.

func (*WebConfigSetFieldSchemaRequest) GetField 

func (x *WebConfigSetFieldSchemaRequest) GetField() string

func (*WebConfigSetFieldSchemaRequest) GetSchema 

func (x *WebConfigSetFieldSchemaRequest) GetSchema() *DatabaseFieldSchema

func (*WebConfigSetFieldSchemaRequest) ProtoMessage 

func (*WebConfigSetFieldSchemaRequest) ProtoMessage()

func (*WebConfigSetFieldSchemaRequest) ProtoReflect 

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

func (*WebConfigSetFieldSchemaRequest) Reset 

func (x *WebConfigSetFieldSchemaRequest) Reset()

func (*WebConfigSetFieldSchemaRequest) String 

func (x *WebConfigSetFieldSchemaRequest) String() string

type WebConfigSetFieldSchemaResponse 

type WebConfigSetFieldSchemaResponse struct {
	Status WebConfigSetFieldSchemaResponse_StatusEnum `protobuf:"varint,1,opt,name=status,proto3,enum=qdb.WebConfigSetFieldSchemaResponse_StatusEnum" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WebConfigSetFieldSchemaResponse) Descriptor deprecated 

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

Deprecated: Use WebConfigSetFieldSchemaResponse.ProtoReflect.Descriptor instead.

func (*WebConfigSetFieldSchemaResponse) GetStatus 

func (x *WebConfigSetFieldSchemaResponse) GetStatus() WebConfigSetFieldSchemaResponse_StatusEnum

func (*WebConfigSetFieldSchemaResponse) ProtoMessage 

func (*WebConfigSetFieldSchemaResponse) ProtoMessage()

func (*WebConfigSetFieldSchemaResponse) ProtoReflect 

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

func (*WebConfigSetFieldSchemaResponse) Reset 

func (x *WebConfigSetFieldSchemaResponse) Reset()

func (*WebConfigSetFieldSchemaResponse) String 

func (x *WebConfigSetFieldSchemaResponse) String() string

type WebConfigSetFieldSchemaResponse_StatusEnum 

type WebConfigSetFieldSchemaResponse_StatusEnum int32
const (
	WebConfigSetFieldSchemaResponse_UNSPECIFIED WebConfigSetFieldSchemaResponse_StatusEnum = 0
	WebConfigSetFieldSchemaResponse_SUCCESS     WebConfigSetFieldSchemaResponse_StatusEnum = 1
	WebConfigSetFieldSchemaResponse_FAILURE     WebConfigSetFieldSchemaResponse_StatusEnum = 2
)

func (WebConfigSetFieldSchemaResponse_StatusEnum) Descriptor 

func (WebConfigSetFieldSchemaResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebConfigSetFieldSchemaResponse_StatusEnum) Enum 

func (x WebConfigSetFieldSchemaResponse_StatusEnum) Enum() *WebConfigSetFieldSchemaResponse_StatusEnum

func (WebConfigSetFieldSchemaResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebConfigSetFieldSchemaResponse_StatusEnum.Descriptor instead.

func (WebConfigSetFieldSchemaResponse_StatusEnum) Number 

func (x WebConfigSetFieldSchemaResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebConfigSetFieldSchemaResponse_StatusEnum) String 

func (x WebConfigSetFieldSchemaResponse_StatusEnum) String() string

func (WebConfigSetFieldSchemaResponse_StatusEnum) Type 

func (WebConfigSetFieldSchemaResponse_StatusEnum) Type() protoreflect.EnumType

type WebHeader 

type WebHeader struct {
	Id                   string                             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Timestamp            *timestamppb.Timestamp             `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	AuthenticationStatus WebHeader_AuthenticationStatusEnum `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WebHeader) Descriptor deprecated 

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

Deprecated: Use WebHeader.ProtoReflect.Descriptor instead.

func (*WebHeader) GetAuthenticationStatus added in v1.2.60 

func (x *WebHeader) GetAuthenticationStatus() WebHeader_AuthenticationStatusEnum

func (*WebHeader) GetId 

func (x *WebHeader) GetId() string

func (*WebHeader) GetTimestamp 

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

func (*WebHeader) ProtoMessage 

func (*WebHeader) ProtoMessage()

func (*WebHeader) ProtoReflect 

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

func (*WebHeader) Reset 

func (x *WebHeader) Reset()

func (*WebHeader) String 

func (x *WebHeader) String() string

type WebHeader_AuthenticationStatusEnum added in v1.2.60 

type WebHeader_AuthenticationStatusEnum int32
const (
	WebHeader_UNSPECIFIED     WebHeader_AuthenticationStatusEnum = 0
	WebHeader_AUTHENTICATED   WebHeader_AuthenticationStatusEnum = 1
	WebHeader_UNAUTHENTICATED WebHeader_AuthenticationStatusEnum = 2
)

func (WebHeader_AuthenticationStatusEnum) Descriptor added in v1.2.60 

func (WebHeader_AuthenticationStatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebHeader_AuthenticationStatusEnum) Enum added in v1.2.60 

func (x WebHeader_AuthenticationStatusEnum) Enum() *WebHeader_AuthenticationStatusEnum

func (WebHeader_AuthenticationStatusEnum) EnumDescriptor deprecated added in v1.2.60 

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

Deprecated: Use WebHeader_AuthenticationStatusEnum.Descriptor instead.

func (WebHeader_AuthenticationStatusEnum) Number added in v1.2.60 

func (x WebHeader_AuthenticationStatusEnum) Number() protoreflect.EnumNumber

func (WebHeader_AuthenticationStatusEnum) String added in v1.2.60 

func (x WebHeader_AuthenticationStatusEnum) String() string

func (WebHeader_AuthenticationStatusEnum) Type added in v1.2.60 

func (WebHeader_AuthenticationStatusEnum) Type() protoreflect.EnumType

type WebMessage 

type WebMessage struct {
	Header  *WebHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payload *anypb.Any `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*WebMessage) Descriptor deprecated 

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

Deprecated: Use WebMessage.ProtoReflect.Descriptor instead.

func (*WebMessage) GetHeader 

func (x *WebMessage) GetHeader() *WebHeader

func (*WebMessage) GetPayload 

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

func (*WebMessage) ProtoMessage 

func (*WebMessage) ProtoMessage()

func (*WebMessage) ProtoReflect 

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

func (*WebMessage) Reset 

func (x *WebMessage) Reset()

func (*WebMessage) String 

func (x *WebMessage) String() string

type WebRuntimeDatabaseRequest 

type WebRuntimeDatabaseRequest struct {
	RequestType WebRuntimeDatabaseRequest_RequestTypeEnum `` /* 127-byte string literal not displayed */
	Requests    []*DatabaseRequest                        `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeDatabaseRequest) Descriptor deprecated 

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

Deprecated: Use WebRuntimeDatabaseRequest.ProtoReflect.Descriptor instead.

func (*WebRuntimeDatabaseRequest) GetRequestType 

func (x *WebRuntimeDatabaseRequest) GetRequestType() WebRuntimeDatabaseRequest_RequestTypeEnum

func (*WebRuntimeDatabaseRequest) GetRequests 

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

func (*WebRuntimeDatabaseRequest) ProtoMessage 

func (*WebRuntimeDatabaseRequest) ProtoMessage()

func (*WebRuntimeDatabaseRequest) ProtoReflect 

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

func (*WebRuntimeDatabaseRequest) Reset 

func (x *WebRuntimeDatabaseRequest) Reset()

func (*WebRuntimeDatabaseRequest) String 

func (x *WebRuntimeDatabaseRequest) String() string

type WebRuntimeDatabaseRequest_RequestTypeEnum 

type WebRuntimeDatabaseRequest_RequestTypeEnum int32
const (
	WebRuntimeDatabaseRequest_UNSPECIFIED WebRuntimeDatabaseRequest_RequestTypeEnum = 0
	WebRuntimeDatabaseRequest_READ        WebRuntimeDatabaseRequest_RequestTypeEnum = 1
	WebRuntimeDatabaseRequest_WRITE       WebRuntimeDatabaseRequest_RequestTypeEnum = 2
)

func (WebRuntimeDatabaseRequest_RequestTypeEnum) Descriptor 

func (WebRuntimeDatabaseRequest_RequestTypeEnum) Descriptor() protoreflect.EnumDescriptor

func (WebRuntimeDatabaseRequest_RequestTypeEnum) Enum 

func (x WebRuntimeDatabaseRequest_RequestTypeEnum) Enum() *WebRuntimeDatabaseRequest_RequestTypeEnum

func (WebRuntimeDatabaseRequest_RequestTypeEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebRuntimeDatabaseRequest_RequestTypeEnum.Descriptor instead.

func (WebRuntimeDatabaseRequest_RequestTypeEnum) Number 

func (x WebRuntimeDatabaseRequest_RequestTypeEnum) Number() protoreflect.EnumNumber

func (WebRuntimeDatabaseRequest_RequestTypeEnum) String 

func (x WebRuntimeDatabaseRequest_RequestTypeEnum) String() string

func (WebRuntimeDatabaseRequest_RequestTypeEnum) Type 

func (WebRuntimeDatabaseRequest_RequestTypeEnum) Type() protoreflect.EnumType

type WebRuntimeDatabaseResponse 

type WebRuntimeDatabaseResponse struct {
	Response []*DatabaseRequest `protobuf:"bytes,2,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeDatabaseResponse) Descriptor deprecated 

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

Deprecated: Use WebRuntimeDatabaseResponse.ProtoReflect.Descriptor instead.

func (*WebRuntimeDatabaseResponse) GetResponse 

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

func (*WebRuntimeDatabaseResponse) ProtoMessage 

func (*WebRuntimeDatabaseResponse) ProtoMessage()

func (*WebRuntimeDatabaseResponse) ProtoReflect 

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

func (*WebRuntimeDatabaseResponse) Reset 

func (x *WebRuntimeDatabaseResponse) Reset()

func (*WebRuntimeDatabaseResponse) String 

func (x *WebRuntimeDatabaseResponse) String() string

type WebRuntimeGetDatabaseConnectionStatusRequest 

type WebRuntimeGetDatabaseConnectionStatusRequest struct {
	// contains filtered or unexported fields
}

func (*WebRuntimeGetDatabaseConnectionStatusRequest) Descriptor deprecated 

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

Deprecated: Use WebRuntimeGetDatabaseConnectionStatusRequest.ProtoReflect.Descriptor instead.

func (*WebRuntimeGetDatabaseConnectionStatusRequest) ProtoMessage 

func (*WebRuntimeGetDatabaseConnectionStatusRequest) ProtoMessage()

func (*WebRuntimeGetDatabaseConnectionStatusRequest) ProtoReflect 

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

func (*WebRuntimeGetDatabaseConnectionStatusRequest) Reset 

func (x *WebRuntimeGetDatabaseConnectionStatusRequest) Reset()

func (*WebRuntimeGetDatabaseConnectionStatusRequest) String 

func (x *WebRuntimeGetDatabaseConnectionStatusRequest) String() string

type WebRuntimeGetDatabaseConnectionStatusResponse 

type WebRuntimeGetDatabaseConnectionStatusResponse struct {
	Status *ConnectionState `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeGetDatabaseConnectionStatusResponse) Descriptor deprecated 

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

Deprecated: Use WebRuntimeGetDatabaseConnectionStatusResponse.ProtoReflect.Descriptor instead.

func (*WebRuntimeGetDatabaseConnectionStatusResponse) GetStatus 

func (x *WebRuntimeGetDatabaseConnectionStatusResponse) GetStatus() *ConnectionState

func (*WebRuntimeGetDatabaseConnectionStatusResponse) ProtoMessage 

func (*WebRuntimeGetDatabaseConnectionStatusResponse) ProtoMessage()

func (*WebRuntimeGetDatabaseConnectionStatusResponse) ProtoReflect 

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

func (*WebRuntimeGetDatabaseConnectionStatusResponse) Reset 

func (x *WebRuntimeGetDatabaseConnectionStatusResponse) Reset()

func (*WebRuntimeGetDatabaseConnectionStatusResponse) String 

func (x *WebRuntimeGetDatabaseConnectionStatusResponse) String() string

type WebRuntimeGetEntitiesRequest added in v1.2.51 

type WebRuntimeGetEntitiesRequest struct {
	EntityType string `protobuf:"bytes,1,opt,name=entityType,proto3" json:"entityType,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeGetEntitiesRequest) Descriptor deprecated added in v1.2.51 

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

Deprecated: Use WebRuntimeGetEntitiesRequest.ProtoReflect.Descriptor instead.

func (*WebRuntimeGetEntitiesRequest) GetEntityType added in v1.2.51 

func (x *WebRuntimeGetEntitiesRequest) GetEntityType() string

func (*WebRuntimeGetEntitiesRequest) ProtoMessage added in v1.2.51 

func (*WebRuntimeGetEntitiesRequest) ProtoMessage()

func (*WebRuntimeGetEntitiesRequest) ProtoReflect added in v1.2.51 

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

func (*WebRuntimeGetEntitiesRequest) Reset added in v1.2.51 

func (x *WebRuntimeGetEntitiesRequest) Reset()

func (*WebRuntimeGetEntitiesRequest) String added in v1.2.51 

func (x *WebRuntimeGetEntitiesRequest) String() string

type WebRuntimeGetEntitiesResponse added in v1.2.51 

type WebRuntimeGetEntitiesResponse struct {
	Entities []*DatabaseEntity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeGetEntitiesResponse) Descriptor deprecated added in v1.2.51 

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

Deprecated: Use WebRuntimeGetEntitiesResponse.ProtoReflect.Descriptor instead.

func (*WebRuntimeGetEntitiesResponse) GetEntities added in v1.2.51 

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

func (*WebRuntimeGetEntitiesResponse) ProtoMessage added in v1.2.51 

func (*WebRuntimeGetEntitiesResponse) ProtoMessage()

func (*WebRuntimeGetEntitiesResponse) ProtoReflect added in v1.2.51 

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

func (*WebRuntimeGetEntitiesResponse) Reset added in v1.2.51 

func (x *WebRuntimeGetEntitiesResponse) Reset()

func (*WebRuntimeGetEntitiesResponse) String added in v1.2.51 

func (x *WebRuntimeGetEntitiesResponse) String() string

type WebRuntimeGetNotificationsRequest 

type WebRuntimeGetNotificationsRequest struct {
	// contains filtered or unexported fields
}

func (*WebRuntimeGetNotificationsRequest) Descriptor deprecated 

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

Deprecated: Use WebRuntimeGetNotificationsRequest.ProtoReflect.Descriptor instead.

func (*WebRuntimeGetNotificationsRequest) ProtoMessage 

func (*WebRuntimeGetNotificationsRequest) ProtoMessage()

func (*WebRuntimeGetNotificationsRequest) ProtoReflect 

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

func (*WebRuntimeGetNotificationsRequest) Reset 

func (x *WebRuntimeGetNotificationsRequest) Reset()

func (*WebRuntimeGetNotificationsRequest) String 

func (x *WebRuntimeGetNotificationsRequest) String() string

type WebRuntimeGetNotificationsResponse 

type WebRuntimeGetNotificationsResponse struct {
	Notifications []*DatabaseNotification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeGetNotificationsResponse) Descriptor deprecated 

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

Deprecated: Use WebRuntimeGetNotificationsResponse.ProtoReflect.Descriptor instead.

func (*WebRuntimeGetNotificationsResponse) GetNotifications 

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

func (*WebRuntimeGetNotificationsResponse) ProtoMessage 

func (*WebRuntimeGetNotificationsResponse) ProtoMessage()

func (*WebRuntimeGetNotificationsResponse) ProtoReflect 

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

func (*WebRuntimeGetNotificationsResponse) Reset 

func (x *WebRuntimeGetNotificationsResponse) Reset()

func (*WebRuntimeGetNotificationsResponse) String 

func (x *WebRuntimeGetNotificationsResponse) String() string

type WebRuntimeRegisterNotificationRequest 

type WebRuntimeRegisterNotificationRequest struct {
	Requests []*DatabaseNotificationConfig `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeRegisterNotificationRequest) Descriptor deprecated 

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

Deprecated: Use WebRuntimeRegisterNotificationRequest.ProtoReflect.Descriptor instead.

func (*WebRuntimeRegisterNotificationRequest) GetRequests 

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

func (*WebRuntimeRegisterNotificationRequest) ProtoMessage 

func (*WebRuntimeRegisterNotificationRequest) ProtoMessage()

func (*WebRuntimeRegisterNotificationRequest) ProtoReflect 

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

func (*WebRuntimeRegisterNotificationRequest) Reset 

func (x *WebRuntimeRegisterNotificationRequest) Reset()

func (*WebRuntimeRegisterNotificationRequest) String 

func (x *WebRuntimeRegisterNotificationRequest) String() string

type WebRuntimeRegisterNotificationResponse 

type WebRuntimeRegisterNotificationResponse struct {
	Tokens []string `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeRegisterNotificationResponse) Descriptor deprecated 

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

Deprecated: Use WebRuntimeRegisterNotificationResponse.ProtoReflect.Descriptor instead.

func (*WebRuntimeRegisterNotificationResponse) GetTokens 

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

func (*WebRuntimeRegisterNotificationResponse) ProtoMessage 

func (*WebRuntimeRegisterNotificationResponse) ProtoMessage()

func (*WebRuntimeRegisterNotificationResponse) ProtoReflect 

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

func (*WebRuntimeRegisterNotificationResponse) Reset 

func (x *WebRuntimeRegisterNotificationResponse) Reset()

func (*WebRuntimeRegisterNotificationResponse) String 

func (x *WebRuntimeRegisterNotificationResponse) String() string

type WebRuntimeUnregisterNotificationRequest 

type WebRuntimeUnregisterNotificationRequest struct {
	Tokens []string `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*WebRuntimeUnregisterNotificationRequest) Descriptor deprecated 

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

Deprecated: Use WebRuntimeUnregisterNotificationRequest.ProtoReflect.Descriptor instead.

func (*WebRuntimeUnregisterNotificationRequest) GetTokens 

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

func (*WebRuntimeUnregisterNotificationRequest) ProtoMessage 

func (*WebRuntimeUnregisterNotificationRequest) ProtoMessage()

func (*WebRuntimeUnregisterNotificationRequest) ProtoReflect 

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

func (*WebRuntimeUnregisterNotificationRequest) Reset 

func (x *WebRuntimeUnregisterNotificationRequest) Reset()

func (*WebRuntimeUnregisterNotificationRequest) String 

func (x *WebRuntimeUnregisterNotificationRequest) String() string

type WebRuntimeUnregisterNotificationResponse 

type WebRuntimeUnregisterNotificationResponse struct {
	Status WebRuntimeUnregisterNotificationResponse_StatusEnum `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WebRuntimeUnregisterNotificationResponse) Descriptor deprecated 

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

Deprecated: Use WebRuntimeUnregisterNotificationResponse.ProtoReflect.Descriptor instead.

func (*WebRuntimeUnregisterNotificationResponse) GetStatus 

func (x *WebRuntimeUnregisterNotificationResponse) GetStatus() WebRuntimeUnregisterNotificationResponse_StatusEnum

func (*WebRuntimeUnregisterNotificationResponse) ProtoMessage 

func (*WebRuntimeUnregisterNotificationResponse) ProtoMessage()

func (*WebRuntimeUnregisterNotificationResponse) ProtoReflect 

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

func (*WebRuntimeUnregisterNotificationResponse) Reset 

func (x *WebRuntimeUnregisterNotificationResponse) Reset()

func (*WebRuntimeUnregisterNotificationResponse) String 

func (x *WebRuntimeUnregisterNotificationResponse) String() string

type WebRuntimeUnregisterNotificationResponse_StatusEnum 

type WebRuntimeUnregisterNotificationResponse_StatusEnum int32
const (
	WebRuntimeUnregisterNotificationResponse_UNSPECIFIED WebRuntimeUnregisterNotificationResponse_StatusEnum = 0
	WebRuntimeUnregisterNotificationResponse_SUCCESS     WebRuntimeUnregisterNotificationResponse_StatusEnum = 1
	WebRuntimeUnregisterNotificationResponse_FAILURE     WebRuntimeUnregisterNotificationResponse_StatusEnum = 2
)

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Descriptor 

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Descriptor() protoreflect.EnumDescriptor

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Enum 

func (x WebRuntimeUnregisterNotificationResponse_StatusEnum) Enum() *WebRuntimeUnregisterNotificationResponse_StatusEnum

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) EnumDescriptor deprecated 

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

Deprecated: Use WebRuntimeUnregisterNotificationResponse_StatusEnum.Descriptor instead.

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Number 

func (x WebRuntimeUnregisterNotificationResponse_StatusEnum) Number() protoreflect.EnumNumber

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) String 

func (x WebRuntimeUnregisterNotificationResponse_StatusEnum) String() string

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Type 

func (WebRuntimeUnregisterNotificationResponse_StatusEnum) Type() protoreflect.EnumType

type WebServiceWorker 

type WebServiceWorker struct {
	Signals WebServiceWorkerSignals
	// contains filtered or unexported fields
}

func NewWebServiceWorker 

func NewWebServiceWorker(addr string) *WebServiceWorker

func (*WebServiceWorker) Broadcast 

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

func (*WebServiceWorker) Deinit 

func (w *WebServiceWorker) Deinit()

func (*WebServiceWorker) DoWork 

func (w *WebServiceWorker) DoWork()

func (*WebServiceWorker) Init 

func (w *WebServiceWorker) Init()

func (*WebServiceWorker) Send 

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

func (*WebServiceWorker) ServeHTTP 

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

type WebServiceWorkerSignals 

type WebServiceWorkerSignals struct {
	ClientConnected    Signal
	ClientDisconnected Signal
	Received           Signal
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.