dcmgmt

Documentation

Index

• Constants
• Variables
• func ApplySubdomain(ctx context.Context, db *pgxpool.Pool, apihost, apitoken string, ...) error
• func AssembleAppPath(app string, zone string) string
• func CheckForPresence(fqdn string, ip netip.Addr, nameservers ...string) (bool, error)
• func NewDelegationList(ctx context.Context, db *pgxpool.Pool, schema string) (string, error)
• func NewKdAddrList(ctx context.Context, db *pgxpool.Pool, schema string) (string, error)
• func ParseConnEnv(connenv string) (string, string, error)
• func ParseDCNameEnv() (string, string, error)
• func ParseNSEnv(nsenv string) ([]string, error)
• func RandomCGNAT24Net() (netip.Prefix, error)
• func RandomKeydesk() (netip.Addr, error)
• func RandomULA64Net() (netip.Prefix, error)
• func RevokeSubdomain(ctx context.Context, db *pgxpool.Pool, apihost, apitoken string, domain string) error
• func SyncDelegationList(sshconf *ssh.ClientConfig, delegationSyncServer, ident, kdAddrList string) (func(string), error)
• func SyncKdAddrList(sshconf *ssh.ClientConfig, kdAddrSyncServer, ident, kdAddrList string) (func(string), error)
• func VgsCheckOrderStatus(ctx context.Context, _ *slog.Logger, db *pgxpool.Pool, ...) (string, int64, error)
• func VgsCreateBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) error
• func VgsCreatePair(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) error
• func VgsDeleteBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) error
• func VgsDeletePair(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) error
• func VgsOrderCreateBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) (uuid.UUID, string, int64, error)
• func VgsOrderDeleteBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) (uuid.UUID, string, int64, error)
• func VgsPopOrder(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, ...) (uuid.UUID, error)
• func WaitForDelegation(fqdn string, ip netip.Addr, ns ...string) (bool, error)
• type VgsPairsResult
• type VpnCfgs

Constants

const (
	DelegationSyncFilename       = "domain-generate-%s.csv"
	DelegationSyncReloadFilename = "domain-generate.reload"
)

const (
	DomainCheckPause         = 5 * time.Second
	DomainDelegationWaitTime = 120 * time.Second
)

const (
	KdAddrSyncFilename       = "vpn-works-%s.csv"
	KdAddrSyncReloadFilename = "vpn-works-keydesks.reload"
)

const (
	BrigadeCgnatPrefix = 24
	BrigadeUlaPrefix   = 64
)

const (
	VgsOrderStatusAccepted   = "accepted"
	VgsOrderStatusProcessing = "processing"
	VgsOrderStatusFailed     = "failed"
	VgsOrderStatusCompleted  = "completed"
)

const (
	VgsOrderPopStatusAccepted         = "accepted"
	VgsOrderPopStatusPairCompleted    = "pair_completed"
	VgsOrderPopStatusBrigadeCompleted = "brigade_completed"
	VgsOrderPopStatusFailed           = "failed"
	VgsOrderPopStatusCompleted        = "completed"
)

const DefaultRandomAttemts = 10000

const (
	DefaultVgsOrderRetryAfter = 300 // seconds
)

const MAX_DNS_RETRIES = 3

const NoUseSubdomainAPIToken = "-"

const VgsActionCreateBrigade = "create_brigade"

const VgsActionDeleteBrigade = "delete_brigade"

Variables

var (
	ErrUnknownIP       = errors.New("unknown ip address")
	ErrNegativeRcode   = errors.New("negative rcode")
	ErrRetriesExceeded = errors.New("retries exceeded")
)

var (
	ErrEmptyConnString   = errors.New("empty sync connect string")
	ErrInvalidConnString = errors.New("invalid sync connect string")
	ErrInvalidServerHost = errors.New("invalid sync server host")
	ErrInvalidServerPort = errors.New("invalid sync server port")
	ErrEmptyIdent        = errors.New("empty ident")
	ErrEmptyID           = errors.New("empty id")
)

var (
	ErrInvalidStatus = fmt.Errorf("invalid status")
	ErrInvalidAction = fmt.Errorf("invalid action")
)

var ErrCheckAttemptExceeded = errors.New("check attempt exceeded")

var ErrDeleteAttemptsCountExceeded = errors.New("delete attempts count exceeded")

var ErrEmptyNSString = errors.New("empty ns connect string")

var ErrNotDelegated = errors.New("not delegated")

var ErrRandomAttemptsExceeded = errors.New("random attempts exceeded")

Functions

func ApplySubdomain

func ApplySubdomain(ctx context.Context, db *pgxpool.Pool, apihost, apitoken string, brigadeID string, endpointIPv4 netip.Addr, srvZone string) error

func AssembleAppPath

func AssembleAppPath(app string, zone string) string

func CheckForPresence

func CheckForPresence(fqdn string, ip netip.Addr, nameservers ...string) (bool, error)

Check for the presence of a record in the NS-servers

func NewDelegationList

func NewDelegationList(ctx context.Context, db *pgxpool.Pool, schema string) (string, error)

func NewKdAddrList

func NewKdAddrList(ctx context.Context, db *pgxpool.Pool, schema string) (string, error)

func ParseConnEnv

func ParseConnEnv(connenv string) (string, string, error)

func ParseDCNameEnv

func ParseDCNameEnv() (string, string, error)

func ParseNSEnv

func ParseNSEnv(nsenv string) ([]string, error)

func RandomCGNAT24Net

func RandomCGNAT24Net() (netip.Prefix, error)

func RandomKeydesk

func RandomKeydesk() (netip.Addr, error)

func RandomULA64Net

func RandomULA64Net() (netip.Prefix, error)

func RevokeSubdomain

func RevokeSubdomain(ctx context.Context, db *pgxpool.Pool, apihost, apitoken string, domain string) error

func SyncDelegationList

func SyncDelegationList(sshconf *ssh.ClientConfig, delegationSyncServer, ident, kdAddrList string) (func(string), error)

func SyncKdAddrList

func SyncKdAddrList(sshconf *ssh.ClientConfig, kdAddrSyncServer, ident, kdAddrList string) (func(string), error)

func VgsCheckOrderStatus

func VgsCheckOrderStatus(ctx context.Context, _ *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	orderID uuid.UUID,
) (string, int64, error)

func VgsCreateBrigade

func VgsCreateBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	orderID uuid.UUID,
	dcident string,
	host, token string,
	sshkey, sshuser, server string,
	ns []string, vpnCfgs *VpnCfgs,
	maxusers int,
	doNotCreatePhy bool,
) error

func VgsCreatePair

func VgsCreatePair(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	app string, orderID uuid.UUID, doNotCreatePhy bool,
) error

func VgsDeleteBrigade

func VgsDeleteBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	orderID uuid.UUID,
	dcident string,
	host, token string,
	sshkey, sshuser, server string,
	doNotCreatePhy bool,
) error

func VgsDeletePair

func VgsDeletePair(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	app string, orderID uuid.UUID, doNotCreatePhy bool,
) error

func VgsOrderCreateBrigade

func VgsOrderCreateBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	brigadeID uuid.UUID, brigadeName string, zone string,
) (uuid.UUID, string, int64, error)

VgsOrderCreateBrigade creates an order to create a brigade.

func VgsOrderDeleteBrigade

func VgsOrderDeleteBrigade(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	brigadeID uuid.UUID,
) (uuid.UUID, string, int64, error)

VgsOrderDeleteBrigade creates an order to create a brigade.

func VgsPopOrder

func VgsPopOrder(ctx context.Context, logger *slog.Logger, db *pgxpool.Pool, sqfmt sq.StatementBuilderType,
	action, status string,
) (uuid.UUID, error)

VgsPopOrder - pop order from the queue action: - vgsActionCreateBrigade

• status: accepted, pair_completed, failed, completed

- vgsActionDeleteBrigade

• status: accepted, processing, failed, completed

func WaitForDelegation

func WaitForDelegation(fqdn string, ip netip.Addr, ns ...string) (bool, error)

Types

type VgsPairsResult

type VgsPairsResult struct {
	Status  string `json:"status"`
	Result  string `json:"result,omitempty"`
	Control struct {
		IP netip.Addr `json:"ip"`
	} `json:"control,omitempty"`
	Endpoint struct {
		IP netip.Addr `json:"ip"`
	} `json:"endpoint,omitempty"`
}

type VpnCfgs

type VpnCfgs struct {
	Wg      string
	Ovc     string
	Ipsec   string
	Outline string
}