cosmosdb

Documentation

Index

• Constants
• type CertStorageCosmosDB
  • func NewCertStorageCosmosDB(connectionString string, encryptionKey []byte, encryptionEnabled bool) (*CertStorageCosmosDB, error)
  • func (c *CertStorageCosmosDB) Delete(ctx context.Context, key string) error
  • func (c *CertStorageCosmosDB) Get(ctx context.Context, key string) ([]byte, error)
  • func (c *CertStorageCosmosDB) Put(ctx context.Context, key string, data []byte) error
• type CosmosDB
  • func NewCosmosDB(connectionString string, encryptionKey []byte) (*CosmosDB, error)
  • func (c *CosmosDB) ActivateSessionKey(userID []byte, active bool) error
  • func (c *CosmosDB) AddAccount(userID []byte, accountAddress []byte, signature []byte, ...) error
  • func (c *CosmosDB) AddSessionKey(userID []byte, key common.GWSessionKey) error
  • func (c *CosmosDB) AddUser(userID []byte, privateKey []byte) error
  • func (c *CosmosDB) DeleteUser(userID []byte) error
  • func (c *CosmosDB) GetEncryptionKey() []byte
  • func (c *CosmosDB) GetUser(userID []byte) (*common.GWUser, error)
  • func (c *CosmosDB) RemoveSessionKey(userID []byte) error
• type EncryptedCertDocument
• type EncryptedDocument
• type MetricsDocument
• type MetricsStorage
  • func NewNoOpMetricsStorage() MetricsStorage
• type MetricsStorageCosmosDB
  • func NewMetricsStorage(connectionString string) (*MetricsStorageCosmosDB, error)
  • func (m *MetricsStorageCosmosDB) LoadMetrics() (*MetricsDocument, error)
  • func (m *MetricsStorageCosmosDB) SaveMetrics(metrics *MetricsDocument) error

Constants

const (
	DATABASE_NAME        = "gatewayDB"
	USERS_CONTAINER_NAME = "users"
)

Constants for the CosmosDB database and container names

const (
	METRICS_CONTAINER_NAME = "metrics"
	METRICS_DOC_ID         = "global_metrics"
)

const (
	CERT_CONTAINER_NAME = "certificates"
)

const MAX_RETRIES = 3

Types

type CertStorageCosmosDB

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

CertStorageCosmosDB implements autocert.Cache interface using CosmosDB

func NewCertStorageCosmosDB

func NewCertStorageCosmosDB(connectionString string, encryptionKey []byte, encryptionEnabled bool) (*CertStorageCosmosDB, error)

NewCertStorageCosmosDB creates a new CosmosDB-based certificate storage

func (*CertStorageCosmosDB) Delete

func (c *CertStorageCosmosDB) Delete(ctx context.Context, key string) error

Delete removes certificate data for the given key

func (*CertStorageCosmosDB) Get

func (c *CertStorageCosmosDB) Get(ctx context.Context, key string) ([]byte, error)

Get retrieves a certificate data for the given key

func (*CertStorageCosmosDB) Put

func (c *CertStorageCosmosDB) Put(ctx context.Context, key string, data []byte) error

Put stores certificate data with the given key

type CosmosDB

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

CosmosDB struct represents the CosmosDB storage implementation

func NewCosmosDB

func NewCosmosDB(connectionString string, encryptionKey []byte) (*CosmosDB, error)

func (*CosmosDB) ActivateSessionKey

func (c *CosmosDB) ActivateSessionKey(userID []byte, active bool) error

Sets the ActiveSK flag for the user, with retries on ETag mismatch

func (*CosmosDB) AddAccount

func (c *CosmosDB) AddAccount(userID []byte, accountAddress []byte, signature []byte, signatureType viewingkey.SignatureType) error

Adds a new account for the user, with retries on ETag mismatch

func (*CosmosDB) AddSessionKey

func (c *CosmosDB) AddSessionKey(userID []byte, key common.GWSessionKey) error

Adds or updates a session key for the user, with retries on ETag mismatch

func (*CosmosDB) AddUser

func (c *CosmosDB) AddUser(userID []byte, privateKey []byte) error

func (*CosmosDB) DeleteUser

func (c *CosmosDB) DeleteUser(userID []byte) error

func (*CosmosDB) GetEncryptionKey

func (c *CosmosDB) GetEncryptionKey() []byte

GetEncryptionKey returns the encryption key used by the CosmosDB instance

func (*CosmosDB) GetUser

func (c *CosmosDB) GetUser(userID []byte) (*common.GWUser, error)

func (*CosmosDB) RemoveSessionKey

func (c *CosmosDB) RemoveSessionKey(userID []byte) error

Removes the session key for the user, with retries on ETag mismatch

type EncryptedCertDocument

type EncryptedCertDocument struct {
	ID   string `json:"id"`
	Data []byte `json:"data"`
}

EncryptedCertDocument represents the structure of a certificate document in CosmosDB

type EncryptedDocument

type EncryptedDocument struct {
	ID   string `json:"id"`
	Data []byte `json:"data"`
}

EncryptedDocument struct is used to store encrypted user data in CosmosDB We use this structure to add an extra layer of security by encrypting the actual user data The 'ID' field is used as the document ID and partition key in CosmosDB The 'Data' field contains the base64-encoded encrypted user data

type MetricsDocument

type MetricsDocument struct {
	ID                 string            `json:"id"`
	TotalUsers         uint64            `json:"totalUsers"`
	AccountsRegistered uint64            `json:"accountsRegistered"`
	ActiveUsers        map[string]string `json:"activeUsers"` // double-hashed userID -> ISO timestamp
	ActiveUsersCount   int               `json:"activeUsersCount"`
	LastUpdated        string            `json:"lastUpdated"`
}

type MetricsStorage

type MetricsStorage interface {
	LoadMetrics() (*MetricsDocument, error)
	SaveMetrics(*MetricsDocument) error
}

MetricsStorage interface defines the metrics storage operations

func NewNoOpMetricsStorage

func NewNoOpMetricsStorage() MetricsStorage

type MetricsStorageCosmosDB

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

MetricsStorageCosmosDB handles metrics persistence in CosmosDB

func NewMetricsStorage

func NewMetricsStorage(connectionString string) (*MetricsStorageCosmosDB, error)

func (*MetricsStorageCosmosDB) LoadMetrics

func (m *MetricsStorageCosmosDB) LoadMetrics() (*MetricsDocument, error)

func (*MetricsStorageCosmosDB) SaveMetrics

func (m *MetricsStorageCosmosDB) SaveMetrics(metrics *MetricsDocument) error