postgres

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (NamespaceRepository) List

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 (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 (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 (*SubscriptionRepository) Delete

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

func (*SubscriptionRepository) Get

func (*SubscriptionRepository) List

func (*SubscriptionRepository) Migrate

func (r *SubscriptionRepository) Migrate() error

func (SubscriptionRepository) Rollback

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

func (*SubscriptionRepository) Update

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL