interfaces

Aug 10, 2023

Changes in this version

type SQLConfig

+ SsLMode string

Jul 1, 2023

Changes in this version

type Redis

+ GetClient func() (pool radix.Client)

+ GetConfig func() RedisProviderConfig

Jun 5, 2023

Changes in this version

type Mongo

+ Start func() (err error)

Feb 6, 2023

Changes in this version

type Mongo

+ Id func() string

type MongoProviderConfig

+ Name string

type RedisProviderConfig

+ Name string

type SQL

+ Id func() string

type SQLConfig

+ Name string

Jan 16, 2023

Changes in this version

+ const MongoDefaultSecureField

type Kms

+ GetKeyVersion func(v int) string

+ Init func() error

+ KeyId func() string

+ Len func() int

+ SwitchNextVersion func(version int) error

type Mongo

+ AddKms func(name string, kms Kms)

+ Client func() *mongo.Client

+ DefaultClient func() (err error)

+ GetConfig func() MongoProviderConfig

+ GetKms func(name string) (kms Kms)

+ type MongoClientEncrypted struct

+ func NewMongoClientEncrypted(keyName string, db Mongo, encoding string) *MongoClientEncrypted

+ func (c *MongoClientEncrypted) Decrypt(raw bson.Raw, desc interface{}) error

+ func (c *MongoClientEncrypted) Encrypt(data interface{}) interface{}

type MongoKeyProviderConfig

+ TlsCAFile string

+ TlsCertificateKeyFile string

+ Vault VaultConfig

+ type MongoSecureField struct

+ Data map[string]MongoSecureFieldData

+ Encoding string

+ KeyId string

+ Version int

+ func NewMongoSecureField(kms Kms, encoding string) *MongoSecureField

+ func (c *MongoSecureField) AddData(name string, data interface{})

+ type MongoSecureFieldData struct

+ Crypt string

+ Hash string

type SqlEncrypted

+ Kms Kms

+ func (c *SqlEncrypted) EncryptedIndexWhere(col string, cond string, params interface{}) clause.Expr

+ type SqlEncryptedList struct

+ func NewSqlEncryptedList() *SqlEncryptedList

+ func (c *SqlEncryptedList) Get(key string) *SqlEncrypted

+ func (c *SqlEncryptedList) Store(key string, d *SqlEncrypted)

+ type VaultConfig struct

+ Address string

+ AutoReload bool

+ Enable bool

+ Engine string

+ Key string

+ Secret string

+ Token string

Jan 1, 2023

Changes in this version

+ const MongoDefaultAlg

+ const MongoDefaultDataKey

+ const MongoKeyVaultColl

+ const MongoRandomAlg

+ func BuildSqlSelect(params ...interface{}) string

type Database

+ LoadMongo func(tag string, config MongoProviderConfig) Mongo

+ type GoogleServicesKey struct

+ AuthProviderX509CertUrl string

+ AuthUri string

+ ClientEmail string

+ ClientId string

+ ClientX509CertUrl string

+ PrivateKey string

+ PrivateKeyId string

+ ProjectId string

+ TokenUri string

+ Type string

+ type Kms interface

+ CurrentKey func() string

+ CurrentVersion func() string

+ Keys func() (res string)

+ type Mongo interface

+ CreateEncryptedKeys func(keys []string, bypassAutoEncryption, bypassQueryAnalysis bool) (enc *MongoEncrypted, err error)

+ DropQueryableEncryptedCollection func(dbName, collName string, enc *MongoEncrypted) error

+ Get func(encOption *options.AutoEncryptionOptions) (client *mongo.Client, err error)

+ GetEncrypted func(schemaMap map[string]interface{}, enc *MongoEncrypted, ...) (en *MongoEncrypted, err error)

+ GetQueryableEncrypted func(encryptedFieldsMap map[string]interface{}, enc *MongoEncrypted, ...) (res *MongoEncrypted, err error)

+ type MongoEncrypted struct

+ Client *mongo.Client

+ ClientEncryption *mongo.ClientEncryption

+ DataKeyID map[string]primitive.Binary

+ KmsProvider map[string]map[string]interface{}

+ type MongoKeyProviderConfig struct

+ AccessKeyId string

+ GoogleServicesKey GoogleServicesKey

+ KMIpAddress string

+ Key string

+ KeyName string

+ KeyRing string

+ Location string

+ Region string

+ SecretAccessKey string

+ SecretKey string

+ type MongoProviderConfig struct

+ AutoReconnect bool

+ Database string

+ Enable bool

+ Host string

+ KeyProvider string

+ KeyProviderConfig MongoKeyProviderConfig

+ MaxError int

+ MongodCryptdPort int

+ Options string

+ Password string

+ Port int

+ StartInterval int

+ Uri string

+ UserName string

+ type SqlEncryptType int

+ const EncryptTypeCustom

+ const EncryptTypeNative

+ type SqlEncrypted struct

+ func NewSqlEncrypted(kms Kms, tp SqlEncryptType) *SqlEncrypted

+ func (c *SqlEncrypted) Encrypt(data interface{}) SqlEncryptedField

+ func (c *SqlEncrypted) EncryptedSelect(params ...string) []string

+ func (c *SqlEncrypted) EncryptedWhere(col string, cond string, params string) clause.Expr

+ func (c *SqlEncrypted) SelfEncrypt(data interface{}) SqlEncryptedField

+ type SqlEncryptedField struct

+ Raw interface{}

+ func (c *SqlEncryptedField) Scan(value interface{}) error

+ func (c SqlEncryptedField) GormDBDataType(db *gorm.DB, field *schema.Field) string

+ func (c SqlEncryptedField) GormDataType() string

+ func (c SqlEncryptedField) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

+ func (c SqlEncryptedField) Int() (res int64)

+ func (c SqlEncryptedField) String() (res string)

Oct 13, 2022

Changes in this version

+ var RecordNotFound = errors.New("record not found in database")

+ type ConsumerCallbackIsDone struct

+ Done context.CancelFunc

+ EndRequest func()

type Database

+ LoadKafka func(string, KafkaProviderConfig) Kafka

type Encoding

+ const EncodingJSON

+ type Kafka interface

+ Consumer func(KafkaOptions, ConsumerCallback)

+ Producer func(ProducerIsReady)

+ Push func(ctx context.Context, id string, options KafkaOptions, body interface{}, ...) error

+ type KafkaOptions struct

+ Encoding Encoding

+ Group string

+ Limiter int

+ MultipleThread bool

+ RegistryValue string

+ SchemeID int

+ SchemeVersion int

+ Topic string

+ type KafkaProviderConfig struct

+ Debug string

+ Enable bool

+ Host string

+ Mechanisms string

+ Password string

+ Registry string

+ SecurityProtocol string

+ Username string

+ type ProducerIsReady func()

type Provider

+ const ProviderKafka

Feb 28, 2022

Changes in this version

type Database

+ LoadRedis func(string, RedisProviderConfig) Redis

type Provider

+ const ProviderRabbitMQ

+ const ProviderRedis

+ type Redis interface

+ GetPool func() (pool *radix.Pool)

+ Init func() error

+ type RedisProviderConfig struct

+ AutoReconnect bool

+ Enable bool

+ Host string

+ MaxError int

+ Password string

+ Pool int

+ Port int

+ StartInterval int

type SQL

+ Clickhouse func() error

+ Config func() SQLConfig

+ SQLite func() error

+ Start func() error

type SQLConfig

+ AutoReconnect bool

+ DBPath string

+ Driver string

+ MaxError int

+ Sslmode string

+ StartInterval int

+ TimeoutConnection int

+ TimeoutTransaction int

Dec 29, 2021

Changes in this version

+ var ConfigManual = map[string]string

+ func SetManual(man map[string]string) map[string]string

+ type ConsumerCallbacIsDone struct

+ Done context.CancelFunc

+ EndRequest func()

+ type ConsumerCallback func(Messages, ConsumerCallbacIsDone)

+ type Database interface

+ Init func(logger.Logger)

+ LoadEmbedded func(EmbeddedOptions) Embedded

+ LoadRabbitMQ func(string, RabbitMQProviderConfig) RabbitMQ

+ LoadSQL func(string, SQLConfig) SQL

+ NewSQL func(SQLConfig) SQL

+ SetTracer func(tracing.Tracing)

+ type Embedded interface

+ DB func() *nutsdb.DB

+ Delete func(bucket string, key string) (err error)

+ Get func(bucket string, key string, value interface{}, encoding Encoding) (err error)

+ GetAllKeys func(bucket string) (keys []string, err error)

+ Set func(bucket string, key string, value interface{}, encoding Encoding) (err error)

+ type EmbeddedOptions struct

+ Directory string

+ type Encoder struct

+ Encoding Encoding

+ Raw io.Reader

+ func (c *Encoder) Context() context.Context

+ func (c *Encoder) Decode(data interface{}) error

+ func (c *Encoder) Encode(data interface{}) (res []byte, err error)

+ func (c *Encoder) Exchange() string

+ func (c *Encoder) RoutingKey() string

+ func (c *Encoder) SetContext(ctx context.Context)

+ type Encoding int

+ const EncodingBase64Gob

+ const EncodingGob

+ const EncodingNone

+ const EncodingProto

+ type Messages interface

+ Context func() context.Context

+ Decode func(interface{}) error

+ Exchange func() string

+ RoutingKey func() string

+ SetContext func(context.Context)

+ func NewEncoder(raw io.Reader, exchange, routingKey string, enc Encoding) Messages

+ type Provider int

+ const ProviderMysql

+ type RabbitMQ interface

+ Consumer func(RabbitMQOptions, ConsumerCallback)

+ Producer func(RabbitMQOptions)

+ Push func(ctx context.Context, id, exchange, key string, body interface{}, ...) error

+ type RabbitMQOptions struct

+ AutoDeleted bool

+ Durable bool

+ Encoding Encoding

+ Exchange string

+ ExchangeType string

+ NoWait bool

+ RoutingKey string

+ type RabbitMQProviderConfig struct

+ DedicatedConnection bool

+ Enable bool

+ Host string

+ Password string

+ Port int

+ ReconnectDuration int

+ Username string

+ type SQL interface

+ Close func() error

+ MySQL func() error

+ Orm func() *gorm.DB

+ SQLServer func() error

+ type SQLConfig struct

+ Connection string

+ Database string

+ Enable bool

+ Host string

+ Options string

+ Password string

+ Port int

+ Username string