Versions in this module Expand all Collapse all v0 v0.0.1 Dec 26, 2019 Changes in this version + const All + const BuildVersion + const Count + const DefaultConfigFilePath + const Distinct + const EventCreate + const EventDelete + const EventStatusCancelled + const EventStatusFailed + const EventStatusIntent + const EventStatusProcessed + const EventStatusStaged + const EventUpdate + const GQL_COMPLETE + const GQL_CONNECTION_ACK + const GQL_CONNECTION_ERROR + const GQL_CONNECTION_INIT + const GQL_CONNECTION_KEEP_ALIVE + const GQL_CONNECTION_TERMINATE + const GQL_DATA + const GQL_ERROR + const GQL_START + const GQL_STOP + const InternalUserID + const MaxEventTokens + const One + const PayloadSize + const PortHTTP + const PortHTTPConnect + const PortHTTPSecure + const RealtimeDelete + const RealtimeInitial + const RealtimeInsert + const RealtimeUpdate + const SpaceCloudServiceName + const TypeRealtimeFeed + const TypeRealtimeSubscribe + const TypeRealtimeUnsubscribe + const Upsert + var ErrDatabaseConfigAbsent = errors.New("No such database found in SC config file") + var ErrDatabaseConnection = errors.New(...) + var ErrDatabaseDisabled = errors.New("Database is disabled. Please enable it") + var ErrInvalidParams = errors.New("Invalid parameter provided") + var ErrUnsupportedDatabase = errors.New("Unsupported database. Make sure your database type is correct") + func AcceptableIDType(id interface{}) (string, bool) + func Adjust(obj interface{}, state map[string]interface{}) interface + func CreateCorsObject() *cors.Cors + func DownloadFileFromURL(url, dest string) error + func GetIDVariable(dbType string) string + func GetTokenFromHeader(r *http.Request) string + func JoinLeading(s1 string, s2 string, ch string) string + func JoinLeadingTrailing(s1 string, s2 string, ch string) string + func JoinTrailing(s1 string, s2 string, ch string) string + func LoadBool(key interface{}, args map[string]interface{}) (bool, error) + func LoadNumber(key interface{}, args map[string]interface{}) (float64, error) + func LoadStringIfExists(value string, state map[string]interface{}) string + func LoadValue(key string, state map[string]interface{}) (interface{}, error) + func SingleLeading(s string, ch string) string + func SingleLeadingTrailing(s string, ch string) string + func SingleTrailing(s string, ch string) string + func Unzip(src string, dest string) error + func UserHomeDir() string + func Validate(where map[string]interface{}, obj interface{}) bool + type Array struct + func NewArray(length int) *Array + func (a *Array) GetAll() []interface{} + func (a *Array) Set(index int, value interface{}) + type Broker string + const Nats + type DBType string + const Mongo + const MySQL + const Postgres + const SqlServer + type DatabaseCollections struct + TableName string + type FieldType struct + FieldDefault *string + FieldExtra string + FieldKey string + FieldName string + FieldNull string + FieldType string + type FileOpType string + const FileCreate + const FileDelete + const FileRead + type FileStoreType string + const AmazonS3 + const GCPStorage + const Local + type ForeignKeysType struct + ColumnName string + ConstraintName string + RefColumnName string + RefTableName string + TableName string + type MakeHttpRequest func(ctx context.Context, method, url, token string, params, vPtr interface{}) error + type Object struct + func NewObject() *Object + func (obj *Object) Get(key string) (value interface{}, present bool) + func (obj *Object) GetAll() map[string]interface{} + func (obj *Object) Set(key string, value interface{}) + type OperationType string + const Aggregation + const Batch + const Create + const Delete + const Read + const Update + type OrchestratorType string + const Kubernetes + type RequestKind string + const RequestKindConsulConnect + const RequestKindDirect