interfaces

type ConsumerCallback func(Messages, ConsumerCallbackIsDone)

type ConsumerCallbackIsDone struct {
	Done       context.CancelFunc
	EndRequest func()
}

type Database interface {
	Init(logger.Logger)
	SetTracer(tracing.Tracing)
	LoadRabbitMQ(string, RabbitMQProviderConfig) RabbitMQ
	LoadSQL(string, SQLConfig) SQL
	LoadRedis(string, RedisProviderConfig) Redis
	LoadEmbedded(EmbeddedOptions) Embedded
	LoadKafka(string, KafkaProviderConfig) Kafka
	LoadMongo(tag string, config MongoProviderConfig) Mongo
}

type Embedded interface {
	DB() *nutsdb.DB
	Set(bucket string, key string, value interface{}, encoding Encoding) (err error)
	Get(bucket string, key string, value interface{}, encoding Encoding) (err error)
	Delete(bucket string, key string) (err error)
	GetAllKeys(bucket string) (keys []string, err error)
}

type EmbeddedOptions struct {
	Directory string
}

type Encoder struct {
	Raw      io.Reader
	Encoding Encoding
	// contains filtered or unexported fields
}

type Encoding int

type GoogleServicesKey struct {
	Type                    string `json:"type"`
	ProjectId               string `json:"project_id"`
	PrivateKeyId            string `json:"private_key_id"`
	PrivateKey              string `json:"private_key"`
	ClientEmail             string `json:"client_email"`
	ClientId                string `json:"client_id"`
	AuthUri                 string `json:"auth_uri"`
	TokenUri                string `json:"token_uri"`
	AuthProviderX509CertUrl string `json:"auth_provider_x509_cert_url"`
	ClientX509CertUrl       string `json:"client_x509_cert_url"`
}

type Kafka interface {
	Consumer(KafkaOptions, ConsumerCallback)
	Producer(ProducerIsReady)
	Push(ctx context.Context, id string, options KafkaOptions, body interface{}, cb ConsumerCallback) error
}

type KafkaOptions struct {
	Topic          string
	RegistryValue  string
	Group          string
	SchemeVersion  int
	SchemeID       int
	Encoding       Encoding
	MultipleThread bool
	Limiter        int
}

type KafkaProviderConfig struct {
	Enable           bool   `yaml:"enable" default:"false" desc:"config:kafka:enable"`
	Host             string `yaml:"host" default:"127.0.0.1:9092" desc:"config:kafka:host"`
	Registry         string `yaml:"registry" default:"" desc:"config:kafka:registry"`
	Username         string `yaml:"username" default:""  desc:"config:kafka:username"`
	Password         string `yaml:"password" default:"" desc:"config:kafka:password"`
	SecurityProtocol string `yaml:"securityProtocol" default:"SASL_SSL"  desc:"config:kafka:securityProtocol"`
	Mechanisms       string `yaml:"mechanisms" default:"PLAIN"  desc:"config:kafka:mechanisms"`
	Debug            string `yaml:"debug" default:"consumer"  desc:"config:kafka:debug"`
}

type Kms interface {
	Init() error
	Keys() (res string)
	CurrentVersion() string
	CurrentKey() string
	GetKeyVersion(v int) string
	Len() int
	SwitchNextVersion(version int) error
	KeyId() string
}

type Messages interface {
	Exchange() string
	RoutingKey() string
	Decode(interface{}) error
	SetContext(context.Context)
	Context() context.Context
}

type Mongo interface {
	Get(encOption *options.AutoEncryptionOptions) (client *mongo.Client, err error)
	CreateEncryptedKeys(keys []string, bypassAutoEncryption, bypassQueryAnalysis bool) (enc *MongoEncrypted, err error)
	GetEncrypted(schemaMap map[string]interface{}, enc *MongoEncrypted, bypassAutoEncryption, bypassQueryAnalysis bool) (en *MongoEncrypted, err error)
	GetQueryableEncrypted(encryptedFieldsMap map[string]interface{}, enc *MongoEncrypted, bypassAutoEncryption, bypassQueryAnalysis bool) (res *MongoEncrypted, err error)
	DropQueryableEncryptedCollection(dbName, collName string, enc *MongoEncrypted) error
	DefaultClient() (err error)
	Client() *mongo.Client
	AddKms(name string, kms Kms)
	GetKms(name string) (kms Kms)
	GetConfig() MongoProviderConfig
}

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

type MongoEncrypted struct {
	Client           *mongo.Client
	ClientEncryption *mongo.ClientEncryption
	DataKeyID        map[string]primitive.Binary
	KmsProvider      map[string]map[string]interface{}
}

type MongoKeyProviderConfig struct {
	SecretKey             string            `yaml:"secretkey" default:"" desc:"config:mongo:secretkey"`
	KMIpAddress           string            `yaml:"kMIpAddress" default:"" desc:"config:mongo:kMIpAddress"`
	AccessKeyId           string            `yaml:"accessKeyId" default:"" desc:"config:mongo:accessKeyId"`
	SecretAccessKey       string            `yaml:"secretAccessKey" default:"" desc:"config:mongo:secretAccessKey"`
	Key                   string            `yaml:"key" default:"" desc:"config:mongo:key"`
	Region                string            `yaml:"region" default:"" desc:"config:mongo:region"`
	GoogleServicesKey     GoogleServicesKey `yaml:"googleServicesKey" default:"" desc:"config:mongo:googleServicesKey"`
	Location              string            `yaml:"location" default:"" desc:"config:mongo:location"`
	KeyRing               string            `yaml:"keyRing" default:"" desc:"config:mongo:keyRing"`
	KeyName               string            `yaml:"keyName" default:"" desc:"config:mongo:keyName"`
	TlsCertificateKeyFile string            `yaml:"tlsCertificateKeyFile" default:"" desc:"config:mongo:tlsCertificateKeyFile"`
	TlsCAFile             string            `yaml:"tlsCAFile" default:"" desc:"config:mongo:tlsCAFile"`
	Vault                 VaultConfig       `yaml:"vault" default:""  desc:"config:mongo:vault"`
}

type MongoProviderConfig struct {
	Enable            bool                   `yaml:"enable" default:"false" desc:"config:mongo:enable"`
	Uri               string                 `yaml:"uri" default:"" desc:"config:mongo:uri"`
	Host              string                 `yaml:"host" default:"127.0.0.1" desc:"config:mongo:host"`
	Port              int                    `yaml:"port" default:"27017" desc:"config:mongo:port"`
	UserName          string                 `yaml:"username" default:"root" desc:"config:mongo:username"`
	Password          string                 `yaml:"password" default:"root" desc:"config:mongo:password"`
	Database          string                 `yaml:"database" default:"sample_database" desc:"config:mongo:database"`
	Options           string                 `yaml:"options" default:"options" desc:"config:mongo:options"`
	AutoReconnect     bool                   `yaml:"autoreconnect" default:"false"  desc:"config:autoreconnect"`
	StartInterval     int                    `yaml:"startinterval" default:"2"  desc:"config:startinterval"`
	MaxError          int                    `yaml:"maxerror" default:"5"  desc:"config:maxerror"`
	MongodCryptdPort  int                    `yaml:"mongodCryptdPort" default:"27020" desc:"config:mongo:mongodCryptdPort"`
	KeyProvider       string                 `yaml:"keyProvider" default:"local" desc:"config:mongo:keyProvider"`
	KeyProviderConfig MongoKeyProviderConfig `yaml:"keyProviderConfig" desc:"config:mongo:keyProviderConfig"`
}

type MongoSecureField struct {
	Version  int                             `json:"version"`
	KeyId    string                          `json:"keyId"`
	Encoding string                          `json:"encoding"`
	Data     map[string]MongoSecureFieldData `json:"data"`
	// contains filtered or unexported fields
}

type MongoSecureFieldData struct {
	Hash  string `json:"hash"`
	Crypt string `json:"crypt"`
}

type ProducerIsReady func()

type Provider int

type RabbitMQ interface {
	Consumer(RabbitMQOptions, ConsumerCallback)
	Producer(RabbitMQOptions)
	Push(ctx context.Context,
		id, exchange,
		key string,
		body interface{},
		cb ConsumerCallback) error
}

type RabbitMQOptions struct {
	Exchange     string
	ExchangeType string
	RoutingKey   string
	Durable      bool
	AutoDeleted  bool
	NoWait       bool
	Encoding     Encoding
}

type RabbitMQProviderConfig struct {
	Enable              bool   `yaml:"enable" default:"false" desc:"config:rabbitmq:enable"`
	Host                string `yaml:"host" default:"127.0.0.1" desc:"config:rabbitmq:host"`
	Port                int    `yaml:"port" default:"5672" desc:"config:rabbitmq:port"`
	Username            string `yaml:"username" default:"guest"  desc:"config:rabbitmq:username"`
	Password            string `yaml:"password" default:"guest" desc:"config:rabbitmq:password"`
	ReconnectDuration   int    `yaml:"reconnectDuration" default:"5" desc:"config:rabbitmq:reconnectDuration"`
	DedicatedConnection bool   `yaml:"dedicatedConnection" default:"false" desc:"config:rabbitmq:dedicatedConnection"`
}

type Redis interface {
	Init() error
	GetPool() (pool *radix.Pool)
}

type RedisProviderConfig struct {
	Enable        bool   `yaml:"enable" default:"false" desc:"config:redis:enable"`
	Host          string `yaml:"host" default:"127.0.0.1" desc:"config:redis:host"`
	Port          int    `yaml:"port" default:"6379" desc:"config:redis:port"`
	Password      string `yaml:"password" default:"" desc:"config:redis:password"`
	Pool          int    `yaml:"pool" default:"10" desc:"config:redis:pool"`
	AutoReconnect bool   `yaml:"autoreconnect" default:"false"  desc:"config:autoreconnect"`
	StartInterval int    `yaml:"startinterval" default:"2"  desc:"config:startinterval"`
	MaxError      int    `yaml:"maxerror" default:"5"  desc:"config:maxerror"`
}

type SQL interface {
	Config() SQLConfig
	Start() error
	Orm() *gorm.DB
	SQLite() error
	MySQL() error
	Close() error
}

type SQLConfig struct {
	Driver             string `yaml:"driver" default:"mysql" desc:"config:sql:enable"`
	Enable             bool   `yaml:"enable" default:"false" desc:"config:sql:enable"`
	Host               string `yaml:"host" default:"127.0.0.1" desc:"config:sql:host"`
	Port               int    `yaml:"port" default:"3306" desc:"config:sql:port"`
	Username           string `yaml:"username" default:"root"  desc:"config:sql:username"`
	Password           string `yaml:"password" default:"root" desc:"config:sql:password"`
	Database           string `yaml:"database" default:"sample_database" desc:"config:sql:database"`
	Options            string `yaml:"options" default:"" desc:"config:sql:options"`
	Connection         string `yaml:"connection" default:"" desc:"config:sql:connection"`
	AutoReconnect      bool   `yaml:"autoreconnect" default:"false"  desc:"config:autoreconnect"`
	StartInterval      int    `yaml:"startinterval" default:"2"  desc:"config:startinterval"`
	MaxError           int    `yaml:"maxerror" default:"5"  desc:"config:maxerror"`
	DBPath             string `yaml:"dbpath" default:"./sqlite.db" desc:"config:sql:dbpath"`
	Sslmode            string `yaml:"sslmode" default:"disable" desc:"config:sql:sslmode"`
	TimeoutConnection  int    `yaml:"timeoutConnection" default:"5000" desc:"config:sql:timeoutConnection"`
	TimeoutTransaction int    `yaml:"timeoutTransaction" default:"5000" desc:"config:sql:timeoutTransaction"`
}

type SqlEncryptType int

type SqlEncrypted struct {
	Kms Kms
	// contains filtered or unexported fields
}

type SqlEncryptedField struct {
	Raw interface{} `json:"Raw"`
	// contains filtered or unexported fields
}

type SqlEncryptedList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type VaultConfig struct {
	Enable     bool   `yaml:"enable"`
	Address    string `yaml:"address"`
	Token      string `yaml:"token"`
	Engine     string `yaml:"engine"`
	Secret     string `yaml:"secret"`
	Key        string `yaml:"key"`
	AutoReload bool   `yaml:"autoReload"`
}