database

Documentation

Index

• Constants
• type ClusterDb
• type Db
  • func NewDb(appConfig *config.AppConfig, m monitoring.MetricsI) Db
• type DynamoDBFilter
  • func NewDynamoDBFilter() *DynamoDBFilter
  • func (f *DynamoDBFilter) AddCondition(condition *models.FilterCondition) *DynamoDBFilter
  • func (f *DynamoDBFilter) Build() (expression.ConditionBuilder, error)

Constants

const FieldPrefix = "crd.spec."

Types

type ClusterDb

type ClusterDb struct {
	TablePartitionKey string              `json:"name"`
	IndexPartitionKey string              `json:"kind"`
	Region            string              `json:"region"`
	Environment       string              `json:"environment"`
	Status            string              `json:"status"`
	LastUpdatedUnix   int64               `json:"lastUpdatedUnix"`
	Cluster           *registryv1.Cluster `json:"crd"`
}

ClusterDb encapsulates the Cluster CRD

type Db

type Db interface {
	GetCluster(name string) (*registryv1.Cluster, error)
	ListClusters(offset int, limit int, environment string, region string, status string, lastUpdated string) ([]registryv1.Cluster, int, bool, error)
	ListClustersWithFilter(offset int, limit int, filter *DynamoDBFilter) ([]registryv1.Cluster, int, bool, error)
	PutCluster(cluster *registryv1.Cluster) error
	DeleteCluster(name string) error
	Status() error
	Mock() *dynamock.DynaMock
	ListClustersWithService(serviceId string, offset int, limit int, environment string, region string, status string, lastUpdated string) ([]registryv1.Cluster, int, bool, error)
	ListClustersWithServiceAndFilter(serviceId string, offset int, limit int, filter *DynamoDBFilter) ([]registryv1.Cluster, int, bool, error)
	GetClusterWithService(serviceId string, clusterName string) (*registryv1.Cluster, error)
}

Db provides an interface for interacting with dynamoDb

func NewDb

func NewDb(appConfig *config.AppConfig, m monitoring.MetricsI) Db

NewDb func

type DynamoDBFilter

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

func NewDynamoDBFilter

func NewDynamoDBFilter() *DynamoDBFilter

func (*DynamoDBFilter) AddCondition

func (f *DynamoDBFilter) AddCondition(condition *models.FilterCondition) *DynamoDBFilter

func (*DynamoDBFilter) Build

func (f *DynamoDBFilter) Build() (expression.ConditionBuilder, error)