engine

type ApplyAction string

type ApplyFailure struct {
	RuleID   string `json:"rule_id,omitempty"`
	Revision int64  `json:"revision,omitempty"`
	Error    string `json:"error"`
}

type ApplyItemResult struct {
	RuleID   string      `json:"rule_id"`
	Revision int64       `json:"revision,omitempty"`
	Action   ApplyAction `json:"action"`
	Status   string      `json:"status"`
	Error    string      `json:"error,omitempty"`
}

type ApplyResult struct {
	AppliedRules int               `json:"applied_rules"`
	StoppedRules int               `json:"stopped_rules"`
	FailedRules  int               `json:"failed_rules"`
	TotalRules   int               `json:"total_rules"`
	Items        []ApplyItemResult `json:"items"`
}

type ApplySnapshotOptions struct {
	ReplaceAll bool `json:"replace_all"`
}

type BandwidthLimit struct {
	Rate     ByteRate `json:"rate,omitempty" yaml:"rate,omitempty"`
	Upload   ByteRate `json:"upload,omitempty" yaml:"upload,omitempty"`
	Download ByteRate `json:"download,omitempty" yaml:"download,omitempty"`
}

type ByteRate int64

type ByteSize int64

type CertProvider interface {
	GetCertificate(hello *tls.ClientHelloInfo) (*tls.Certificate, error)
	Obtain(ctx context.Context, domains []string) error
}

type Collector struct {
	// contains filtered or unexported fields
}

type Manager struct {
	// contains filtered or unexported fields
}

type ManagerOptions struct {
	// UDPMaxSessions uses DefaultUDPGlobalMaxSessions when non-positive and is
	// clamped to MaxUDPGlobalMaxSessions when larger than the supported bound.
	UDPMaxSessions int

	// QuotaLedger supplies calendar-period accounting and optional strict
	// persistence. Nil uses an in-memory ledger.
	QuotaLedger *QuotaLedger

	// Resolver controls outbound target name resolution. Nil uses vmflow's
	// automatic system-first failover policy.
	Resolver *dnsresolver.Resolver
}

type Protocol string

type QuotaLedger struct {
	// contains filtered or unexported fields
}

type QuotaPeriodSnapshot struct {
	Period         string `json:"period"`
	UsedBytes      int64  `json:"used_bytes"`
	LimitBytes     int64  `json:"limit_bytes"`
	RemainingBytes int64  `json:"remaining_bytes"`
	ResetTime      int64  `json:"reset_time"`
	Exhausted      bool   `json:"exhausted"`
}

type QuotaPersistentState struct {
	RuleID  string           `json:"rule_id"`
	Daily   map[string]int64 `json:"daily,omitempty"`
	Monthly map[string]int64 `json:"monthly,omitempty"`
}

type QuotaStateStore interface {
	LoadQuotaState() ([]QuotaPersistentState, error)
	SaveQuotaState([]QuotaPersistentState) error
}

type RollbackItemResult struct {
	RuleID string      `json:"rule_id"`
	Action ApplyAction `json:"action"`
	Status string      `json:"status"`
	Error  string      `json:"error,omitempty"`
}

type RollbackResult struct {
	Attempted bool                 `json:"attempted"`
	Failed    bool                 `json:"failed"`
	Items     []RollbackItemResult `json:"items,omitempty"`
}

type Rule struct {
	RuleID       string          `json:"rule_id" yaml:"rule_id"`
	Name         string          `json:"name" yaml:"name"`
	Protocol     Protocol        `json:"protocol" yaml:"protocol"`
	ListenAddr   string          `json:"listen_addr" yaml:"listen_addr"`
	ListenPort   int             `json:"listen_port" yaml:"listen_port"`
	TargetAddr   string          `json:"target_addr" yaml:"target_addr"`
	TargetPort   int             `json:"target_port" yaml:"target_port"`
	Enabled      bool            `json:"enabled" yaml:"enabled"`
	SpeedLimit   int64           `json:"speed_limit" yaml:"speed_limit"`
	Bandwidth    *BandwidthLimit `json:"bandwidth_limit,omitempty" yaml:"bandwidth_limit,omitempty"`
	TrafficQuota *TrafficQuota   `json:"traffic_quota,omitempty" yaml:"traffic_quota,omitempty"`
	MaxConn      int             `json:"max_conn" yaml:"max_conn"`
	IdleTimeout  int             `json:"idle_timeout,omitempty" yaml:"idle_timeout,omitempty"`
	SourceIPMode SourceIPMode    `json:"source_ip_mode,omitempty" yaml:"source_ip_mode,omitempty"`
	SourceIPs    []string        `json:"source_ips,omitempty" yaml:"source_ips,omitempty"`
	Domains      []string        `json:"domains,omitempty" yaml:"domains,omitempty"`
	Remark       string          `json:"remark,omitempty" yaml:"remark,omitempty"`
	Revision     int64           `json:"revision,omitempty" yaml:"revision,omitempty"`
	CreatedTime  int64           `json:"created_time,omitempty" yaml:"created_time,omitempty"`
	UpdatedTime  int64           `json:"updated_time,omitempty" yaml:"updated_time,omitempty"`
}

type Runner interface {
	Start() error
	Stop()
}

type SnapshotApplyTransaction struct {
	// contains filtered or unexported fields
}

type SourceIPMode string

type TrafficQuota struct {
	Daily    ByteSize `json:"daily,omitempty" yaml:"daily,omitempty"`
	Monthly  ByteSize `json:"monthly,omitempty" yaml:"monthly,omitempty"`
	Timezone string   `json:"timezone,omitempty" yaml:"timezone,omitempty"`
	Action   string   `json:"action,omitempty" yaml:"action,omitempty"`
}

type TrafficQuotaSnapshot struct {
	Daily   *QuotaPeriodSnapshot `json:"daily,omitempty"`
	Monthly *QuotaPeriodSnapshot `json:"monthly,omitempty"`
	Blocked bool                 `json:"blocked"`
}

type TrafficSnapshot struct {
	RuleID             string                `json:"rule_id"`
	UploadBytes        int64                 `json:"upload_bytes"`
	DownloadBytes      int64                 `json:"download_bytes"`
	Conns              int64                 `json:"conns"`
	SourceIPDenied     int64                 `json:"source_ip_denied_total,omitempty"`
	UDPSessionRejected int64                 `json:"udp_session_rejected_total,omitempty"`
	UDPPacketsDropped  int64                 `json:"udp_packets_dropped_total,omitempty"`
	QuotaRejectedBytes int64                 `json:"quota_rejected_bytes_total,omitempty"`
	Quota              *TrafficQuotaSnapshot `json:"quota,omitempty"`
	UpdatedTime        int64                 `json:"updated_time"`
}

type TransactionalApplyResult struct {
	Apply        ApplyResult    `json:"apply"`
	ApplyFailure *ApplyFailure  `json:"apply_failure,omitempty"`
	Rollback     RollbackResult `json:"rollback"`
}