Documentation
¶
Index ¶
- Constants
- Variables
- type Destination
- func (d *Destination) CountWhereGroupID(tx Transaction, group_id int) (int, error)
- func (d *Destination) Create(tx Transaction, destination_group_id int, port int, protocol string) (int, error)
- func (d *Destination) Delete(tx Transaction, id int) error
- func (d *Destination) GetID(tx Transaction, destination_group_id int, port int, protocol string) (int, error)
- type DestinationRepo
- type Group
- type GroupRepo
- type MetricsWrapper
- func (mw *MetricsWrapper) All() ([]models.Policy, error)
- func (mw *MetricsWrapper) ByGuids(srcGuids, dstGuids []string) ([]models.Policy, error)
- func (mw *MetricsWrapper) CheckDatabase() error
- func (mw *MetricsWrapper) Create(policies []models.Policy) error
- func (mw *MetricsWrapper) Delete(policies []models.Policy) error
- func (mw *MetricsWrapper) Tags() ([]models.Tag, error)
- type Policy
- func (p *Policy) CountWhereDestinationID(tx Transaction, destination_id int) (int, error)
- func (p *Policy) CountWhereGroupID(tx Transaction, source_group_id int) (int, error)
- func (p *Policy) Create(tx Transaction, source_group_id int, destination_id int) error
- func (p *Policy) Delete(tx Transaction, source_group_id int, destination_id int) error
- type PolicyRepo
- type Store
- type Transaction
Constants ¶
View Source
const MAX_TAG_LENGTH = 3
View Source
const MIN_TAG_LENGTH = 1
Variables ¶
View Source
var RecordNotFoundError = errors.New("record not found")
Functions ¶
This section is empty.
Types ¶
type Destination ¶
type Destination struct {
}
func (*Destination) CountWhereGroupID ¶
func (d *Destination) CountWhereGroupID(tx Transaction, group_id int) (int, error)
func (*Destination) Create ¶
func (d *Destination) Create(tx Transaction, destination_group_id int, port int, protocol string) (int, error)
func (*Destination) Delete ¶
func (d *Destination) Delete(tx Transaction, id int) error
func (*Destination) GetID ¶
func (d *Destination) GetID(tx Transaction, destination_group_id int, port int, protocol string) (int, error)
type DestinationRepo ¶
type DestinationRepo interface {
Create(Transaction, int, int, string) (int, error)
Delete(Transaction, int) error
GetID(Transaction, int, int, string) (int, error)
CountWhereGroupID(Transaction, int) (int, error)
}
type GroupRepo ¶
type GroupRepo interface {
Create(Transaction, string) (int, error)
Delete(Transaction, int) error
GetID(Transaction, string) (int, error)
}
type MetricsWrapper ¶
type MetricsWrapper struct {
Store Store
MetricsSender metricsSender
}
func (*MetricsWrapper) ByGuids ¶
func (mw *MetricsWrapper) ByGuids(srcGuids, dstGuids []string) ([]models.Policy, error)
func (*MetricsWrapper) CheckDatabase ¶
func (mw *MetricsWrapper) CheckDatabase() error
type Policy ¶
type Policy struct {
}
func (*Policy) CountWhereDestinationID ¶
func (p *Policy) CountWhereDestinationID(tx Transaction, destination_id int) (int, error)
func (*Policy) CountWhereGroupID ¶
func (p *Policy) CountWhereGroupID(tx Transaction, source_group_id int) (int, error)
type PolicyRepo ¶
type PolicyRepo interface {
Create(Transaction, int, int) error
Delete(Transaction, int, int) error
CountWhereGroupID(Transaction, int) (int, error)
CountWhereDestinationID(Transaction, int) (int, error)
}
type Store ¶
type Store interface {
Create([]models.Policy) error
All() ([]models.Policy, error)
Delete([]models.Policy) error
Tags() ([]models.Tag, error)
ByGuids([]string, []string) ([]models.Policy, error)
CheckDatabase() error
}
func New ¶
func New(dbConnectionPool db, g GroupRepo, d DestinationRepo, p PolicyRepo, tl int, t time.Duration) (Store, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.