postgres

Documentation

Index

• type Filters
• type NamespaceRepository
  • func NewNamespaceRepository(db *gorm.DB) *NamespaceRepository
  • func (r NamespaceRepository) Create(namespace *domain.EncryptedNamespace) error
  • func (r NamespaceRepository) Delete(id uint64) error
  • func (r NamespaceRepository) Get(id uint64) (*domain.EncryptedNamespace, error)
  • func (r NamespaceRepository) List() ([]*domain.EncryptedNamespace, error)
  • func (r NamespaceRepository) Migrate() error
  • func (r NamespaceRepository) Update(namespace *domain.EncryptedNamespace) error
• type ProviderRepository
  • func NewProviderRepository(db *gorm.DB) *ProviderRepository
  • func (r ProviderRepository) Create(provider *domain.Provider) (*domain.Provider, error)
  • func (r ProviderRepository) Delete(id uint64) error
  • func (r ProviderRepository) Get(id uint64) (*domain.Provider, error)
  • func (r ProviderRepository) List(filters map[string]interface{}) ([]*domain.Provider, error)
  • func (r ProviderRepository) Migrate() error
  • func (r ProviderRepository) Update(provider *domain.Provider) (*domain.Provider, error)
• type ReceiverRepository
  • func NewReceiverRepository(db *gorm.DB) *ReceiverRepository
  • func (r ReceiverRepository) Create(receiver *domain.Receiver) error
  • func (r ReceiverRepository) Delete(id uint64) error
  • func (r ReceiverRepository) Get(id uint64) (*domain.Receiver, error)
  • func (r ReceiverRepository) List() ([]*domain.Receiver, error)
  • func (r ReceiverRepository) Migrate() error
  • func (r ReceiverRepository) Update(receiver *domain.Receiver) error
• type Repository
  • func NewAlertRepository(db *gorm.DB) *Repository
  • func (r Repository) Create(alert *domain.Alert) error
  • func (r Repository) Get(resourceName string, providerId, startTime, endTime uint64) ([]domain.Alert, error)
  • func (r Repository) Migrate() error
• type RuleRepository
  • func NewRuleRepository(db *gorm.DB) *RuleRepository
  • func (t RuleRepository) Commit(ctx context.Context) error
  • func (r *RuleRepository) Get(ctx context.Context, name, namespace, groupName, template string, ...) ([]domain.Rule, error)
  • func (r *RuleRepository) Migrate() error
  • func (t RuleRepository) Rollback(ctx context.Context) error
  • func (r *RuleRepository) Upsert(ctx context.Context, rule *domain.Rule) error
  • func (t RuleRepository) WithTransaction(ctx context.Context) context.Context
• type RuleResponse
• type SubscriptionRepository
  • func NewSubscriptionRepository(db *gorm.DB) *SubscriptionRepository
  • func (t SubscriptionRepository) Commit(ctx context.Context) error
  • func (r *SubscriptionRepository) Create(ctx context.Context, sub *domain.Subscription) error
  • func (r *SubscriptionRepository) Delete(ctx context.Context, id uint64) error
  • func (r *SubscriptionRepository) Get(ctx context.Context, id uint64) (*domain.Subscription, error)
  • func (r *SubscriptionRepository) List(ctx context.Context) ([]*domain.Subscription, error)
  • func (r *SubscriptionRepository) Migrate() error
  • func (t SubscriptionRepository) Rollback(ctx context.Context) error
  • func (r *SubscriptionRepository) Update(ctx context.Context, sub *domain.Subscription) error
  • func (t SubscriptionRepository) WithTransaction(ctx context.Context) context.Context
• type TemplateRepository
  • func NewTemplateRepository(db *gorm.DB) *TemplateRepository
  • func (r TemplateRepository) Delete(name string) error
  • func (r TemplateRepository) GetByName(name string) (*domain.Template, error)
  • func (r TemplateRepository) Index(tag string) ([]domain.Template, error)
  • func (r TemplateRepository) Migrate() error
  • func (r TemplateRepository) Render(name string, requestVariables map[string]string) (string, error)
  • func (r TemplateRepository) Upsert(template *domain.Template) error

Types

type Filters

type Filters struct {
	Urn  string `mapstructure:"urn" validate:"omitempty"`
	Type string `mapstructure:"type" validate:"omitempty"`
}

type NamespaceRepository

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

NamespaceRepository talks to the store to read or insert data

func NewNamespaceRepository

func NewNamespaceRepository(db *gorm.DB) *NamespaceRepository

NewNamespaceRepository returns repository struct

func (NamespaceRepository) Create

func (r NamespaceRepository) Create(namespace *domain.EncryptedNamespace) error

func (NamespaceRepository) Delete

func (r NamespaceRepository) Delete(id uint64) error

func (NamespaceRepository) Get

func (r NamespaceRepository) Get(id uint64) (*domain.EncryptedNamespace, error)

func (NamespaceRepository) List

func (r NamespaceRepository) List() ([]*domain.EncryptedNamespace, error)

func (NamespaceRepository) Migrate

func (r NamespaceRepository) Migrate() error

func (NamespaceRepository) Update

func (r NamespaceRepository) Update(namespace *domain.EncryptedNamespace) error

type ProviderRepository

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

ProviderRepository talks to the store to read or insert data

func NewProviderRepository

func NewProviderRepository(db *gorm.DB) *ProviderRepository

NewProviderRepository returns repository struct

func (ProviderRepository) Create

func (r ProviderRepository) Create(provider *domain.Provider) (*domain.Provider, error)

func (ProviderRepository) Delete

func (r ProviderRepository) Delete(id uint64) error

func (ProviderRepository) Get

func (r ProviderRepository) Get(id uint64) (*domain.Provider, error)

func (ProviderRepository) List

func (r ProviderRepository) List(filters map[string]interface{}) ([]*domain.Provider, error)

func (ProviderRepository) Migrate

func (r ProviderRepository) Migrate() error

func (ProviderRepository) Update

func (r ProviderRepository) Update(provider *domain.Provider) (*domain.Provider, error)

type ReceiverRepository

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

ReceiverRepository talks to the store to read or insert data

func NewReceiverRepository

func NewReceiverRepository(db *gorm.DB) *ReceiverRepository

NewReceiverRepository returns repository struct

func (ReceiverRepository) Create

func (r ReceiverRepository) Create(receiver *domain.Receiver) error

func (ReceiverRepository) Delete

func (r ReceiverRepository) Delete(id uint64) error

func (ReceiverRepository) Get

func (r ReceiverRepository) Get(id uint64) (*domain.Receiver, error)

func (ReceiverRepository) List

func (r ReceiverRepository) List() ([]*domain.Receiver, error)

func (ReceiverRepository) Migrate

func (r ReceiverRepository) Migrate() error

func (ReceiverRepository) Update

func (r ReceiverRepository) Update(receiver *domain.Receiver) error

type Repository

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

Repository talks to the store to read or insert data

func NewAlertRepository

func NewAlertRepository(db *gorm.DB) *Repository

NewAlertRepository returns repository struct

func (Repository) Create

func (r Repository) Create(alert *domain.Alert) error

func (Repository) Get

func (r Repository) Get(resourceName string, providerId, startTime, endTime uint64) ([]domain.Alert, error)

func (Repository) Migrate

func (r Repository) Migrate() error

type RuleRepository

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

RuleRepository talks to the store to read or insert data

func NewRuleRepository

func NewRuleRepository(db *gorm.DB) *RuleRepository

NewRuleRepository returns repository struct

func (RuleRepository) Commit

func (t RuleRepository) Commit(ctx context.Context) error

func (*RuleRepository) Get

func (r *RuleRepository) Get(ctx context.Context, name, namespace, groupName, template string, providerNamespace uint64) ([]domain.Rule, error)

func (*RuleRepository) Migrate

func (r *RuleRepository) Migrate() error

func (RuleRepository) Rollback

func (t RuleRepository) Rollback(ctx context.Context) error

func (*RuleRepository) Upsert

func (r *RuleRepository) Upsert(ctx context.Context, rule *domain.Rule) error

func (RuleRepository) WithTransaction

func (t RuleRepository) WithTransaction(ctx context.Context) context.Context

type RuleResponse

type RuleResponse struct {
	NamespaceUrn string
	ProviderUrn  string
	ProviderType string
	ProviderHost string
}

type SubscriptionRepository

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

SubscriptionRepository talks to the store to read or insert data

func NewSubscriptionRepository

func NewSubscriptionRepository(db *gorm.DB) *SubscriptionRepository

NewSubscriptionRepository returns SubscriptionRepository struct

func (SubscriptionRepository) Commit

func (t SubscriptionRepository) Commit(ctx context.Context) error

func (*SubscriptionRepository) Create

func (r *SubscriptionRepository) Create(ctx context.Context, sub *domain.Subscription) error

func (*SubscriptionRepository) Delete

func (r *SubscriptionRepository) Delete(ctx context.Context, id uint64) error

func (*SubscriptionRepository) Get

func (r *SubscriptionRepository) Get(ctx context.Context, id uint64) (*domain.Subscription, error)

func (*SubscriptionRepository) List

func (r *SubscriptionRepository) List(ctx context.Context) ([]*domain.Subscription, error)

func (*SubscriptionRepository) Migrate

func (r *SubscriptionRepository) Migrate() error

func (SubscriptionRepository) Rollback

func (t SubscriptionRepository) Rollback(ctx context.Context) error

func (*SubscriptionRepository) Update

func (r *SubscriptionRepository) Update(ctx context.Context, sub *domain.Subscription) error

func (SubscriptionRepository) WithTransaction

func (t SubscriptionRepository) WithTransaction(ctx context.Context) context.Context

type TemplateRepository

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

TemplateRepository talks to the store to read or insert data

func NewTemplateRepository

func NewTemplateRepository(db *gorm.DB) *TemplateRepository

NewTemplateRepository returns repository struct

func (TemplateRepository) Delete

func (r TemplateRepository) Delete(name string) error

func (TemplateRepository) GetByName

func (r TemplateRepository) GetByName(name string) (*domain.Template, error)

func (TemplateRepository) Index

func (r TemplateRepository) Index(tag string) ([]domain.Template, error)

func (TemplateRepository) Migrate

func (r TemplateRepository) Migrate() error

func (TemplateRepository) Render

func (r TemplateRepository) Render(name string, requestVariables map[string]string) (string, error)

func (TemplateRepository) Upsert

func (r TemplateRepository) Upsert(template *domain.Template) error