store

Documentation

Index

• Constants
• Variables
• type Destination
  • func (d *Destination) CountWhereGroupID(ctx context.Context, tx Transaction, group_id int) (int, error)
  • func (d *Destination) Create(ctx context.Context, tx Transaction, destination_group_id int, port int, ...) (int, error)
  • func (d *Destination) Delete(ctx context.Context, tx Transaction, id int) error
  • func (d *Destination) GetID(ctx context.Context, tx Transaction, destination_group_id int, port int, ...) (int, error)
• type DestinationRepo
• type Group
  • func (g *Group) Create(ctx context.Context, tx Transaction, guid string) (int, error)
  • func (g *Group) Delete(ctx context.Context, tx Transaction, id int) error
  • func (g *Group) GetID(ctx context.Context, tx Transaction, guid string) (int, error)
• 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(ctx context.Context, policies []models.Policy) error
  • func (mw *MetricsWrapper) Delete(ctx context.Context, policies []models.Policy) error
  • func (mw *MetricsWrapper) Tags() ([]models.Tag, error)
• type Policy
  • func (p *Policy) CountWhereDestinationID(ctx context.Context, tx Transaction, destination_id int) (int, error)
  • func (p *Policy) CountWhereGroupID(ctx context.Context, tx Transaction, source_group_id int) (int, error)
  • func (p *Policy) Create(ctx context.Context, tx Transaction, source_group_id int, destination_id int) error
  • func (p *Policy) Delete(ctx context.Context, tx Transaction, source_group_id int, destination_id int) error
• type PolicyRepo
• type Store
  • func New(dbConnectionPool db, g GroupRepo, d DestinationRepo, p PolicyRepo, tl int) (Store, error)
• type Transaction

Constants

const MAX_TAG_LENGTH = 3

const MIN_TAG_LENGTH = 1

Variables

var RecordNotFoundError = errors.New("record not found")

Types

type Destination

type Destination struct {
}

func (*Destination) CountWhereGroupID

func (d *Destination) CountWhereGroupID(ctx context.Context, tx Transaction, group_id int) (int, error)

func (*Destination) Create

func (d *Destination) Create(ctx context.Context, tx Transaction, destination_group_id int, port int, protocol string) (int, error)

func (*Destination) Delete

func (d *Destination) Delete(ctx context.Context, tx Transaction, id int) error

func (*Destination) GetID

func (d *Destination) GetID(ctx context.Context, tx Transaction, destination_group_id int, port int, protocol string) (int, error)

type DestinationRepo

type DestinationRepo interface {
	Create(context.Context, Transaction, int, int, string) (int, error)
	Delete(context.Context, Transaction, int) error
	GetID(context.Context, Transaction, int, int, string) (int, error)
	CountWhereGroupID(context.Context, Transaction, int) (int, error)
}

type Group

type Group struct {
}

func (*Group) Create

func (g *Group) Create(ctx context.Context, tx Transaction, guid string) (int, error)

func (*Group) Delete

func (g *Group) Delete(ctx context.Context, tx Transaction, id int) error

func (*Group) GetID

func (g *Group) GetID(ctx context.Context, tx Transaction, guid string) (int, error)

type GroupRepo

type GroupRepo interface {
	Create(context.Context, Transaction, string) (int, error)
	Delete(context.Context, Transaction, int) error
	GetID(context.Context, Transaction, string) (int, error)
}

type MetricsWrapper

type MetricsWrapper struct {
	Store         Store
	MetricsSender metricsSender
}

func (*MetricsWrapper) All

func (mw *MetricsWrapper) All() ([]models.Policy, error)

func (*MetricsWrapper) ByGuids

func (mw *MetricsWrapper) ByGuids(srcGuids, dstGuids []string) ([]models.Policy, error)

func (*MetricsWrapper) Create

func (mw *MetricsWrapper) Create(ctx context.Context, policies []models.Policy) error

func (*MetricsWrapper) Delete

func (mw *MetricsWrapper) Delete(ctx context.Context, policies []models.Policy) error

func (*MetricsWrapper) Tags

func (mw *MetricsWrapper) Tags() ([]models.Tag, error)

type Policy

type Policy struct {
}

func (*Policy) CountWhereDestinationID

func (p *Policy) CountWhereDestinationID(ctx context.Context, tx Transaction, destination_id int) (int, error)

func (*Policy) CountWhereGroupID

func (p *Policy) CountWhereGroupID(ctx context.Context, tx Transaction, source_group_id int) (int, error)

func (*Policy) Create

func (p *Policy) Create(ctx context.Context, tx Transaction, source_group_id int, destination_id int) error

func (*Policy) Delete

func (p *Policy) Delete(ctx context.Context, tx Transaction, source_group_id int, destination_id int) error

type PolicyRepo

type PolicyRepo interface {
	Create(context.Context, Transaction, int, int) error
	Delete(context.Context, Transaction, int, int) error
	CountWhereGroupID(context.Context, Transaction, int) (int, error)
	CountWhereDestinationID(context.Context, Transaction, int) (int, error)
}

type Store

type Store interface {
	Create(context.Context, []models.Policy) error
	All() ([]models.Policy, error)
	Delete(context.Context, []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)

type Transaction

type Transaction interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	Commit() error
	Rollback() error
	Rebind(string) string
}