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) 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 ¶ added in v0.17.0
type MetricsWrapper struct { Store Store MetricsSender metricsSender }
func (*MetricsWrapper) All ¶ added in v0.17.0
func (mw *MetricsWrapper) All() ([]models.Policy, error)
func (*MetricsWrapper) ByGuids ¶ added in v0.17.0
func (mw *MetricsWrapper) ByGuids(srcGuids, dstGuids []string) ([]models.Policy, error)
func (*MetricsWrapper) Create ¶ added in v0.17.0
func (mw *MetricsWrapper) Create(policies []models.Policy) 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) }
func New ¶
func New(dbConnectionPool db, g GroupRepo, d DestinationRepo, p PolicyRepo, tl int) (Store, error)
Click to show internal directories.
Click to hide internal directories.