dcmgmt

Documentation

Index

• Constants
• Variables
• func ApplySubdomain(ctx context.Context, db *pgxpool.Pool, apihost, apitoken string, ...) error
• 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) error

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
}