gopxgrid

type ANCApplyPolicyRequest struct {
	Policy       string `json:"policy"`
	MACAddress   string `json:"macAddress"`
	NASIPAddress string `json:"nasIpAddress"`
	SessionID    string `json:"sessionId,omitempty"`
	NASPortID    string `json:"nasPortId,omitempty"`
	IPAddress    string `json:"ipAddress,omitempty"`
	UserName     string `json:"userName,omitempty"`
}

type ANCAsset struct {
	AssetId               string        `json:"assetId"`
	AssetName             string        `json:"assetName"`
	AssetIPAddress        string        `json:"assetIpAddress"`
	AssetMACAddress       string        `json:"assetMacAddress"`
	AssetVendor           string        `json:"assetVendor"`
	AssetProductID        string        `json:"assetProductId"`
	AssetSerialNumber     string        `json:"assetSerialNumber"`
	AssetDeviceType       string        `json:"assetDeviceType"`
	AssetSWRevision       string        `json:"assetSwRevision"`
	AssetHWRevision       string        `json:"assetHwRevision"`
	AssetProtocol         string        `json:"assetProtocol"`
	AssetCustomAttributes []ANCKeyValue `json:"assetCustomAttributes"`
	AssetConnectedLinks   []ANCKeyValue `json:"assetConnectedLinks"`
}

type ANCAssetTopicMessage struct {
	OperationType OperationType `json:"opType"`
	Asset         ANCAsset      `json:"asset"`
}

type ANCClearPolicyRequest struct {
	MACAddress   string `json:"macAddress"`
	NASIPAddress string `json:"nasIpAddress"`
}

type ANCConfig interface {
	PxGridService

	Rest() ANCRest

	ANCConfigSubscriber

	Properties() ANCConfigPropsProvider
}

type ANCConfigPropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	StatusTopic() (string, error)
}

type ANCConfigSubscriber interface {
	OnStatusTopic() Subscriber[ANCOperationStatus]
}

type ANCConfigTopic string

type ANCEndpoint struct {
	MACAddress string `json:"macAddress"`
	PolicyName string `json:"policyName"`
	ID         string `json:"id"`
}

type ANCKeyValue struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type ANCOperationStatus struct {
	ID            string    `json:"operationId"`
	Status        ANCStatus `json:"status"`
	MACAddress    string    `json:"macAddress,omitempty"`
	NASIPAddress  string    `json:"nasIpAddress,omitempty"`
	FailureReason string    `json:"failureReason,omitempty"`
}

type ANCPolicy struct {
	Name    string            `json:"name"`
	Actions []ANCPolicyAction `json:"actions"`
	ID      string            `json:"id"`
}

type ANCPolicyAction string

type ANCRest interface {
	GetPolicies() CallFinalizer[*[]ANCPolicy]
	GetPolicyByName(name string) CallFinalizer[*ANCPolicy]
	CreatePolicy(policy ANCPolicy) NoResultCallFinalizer
	DeletePolicyByName(name string) NoResultCallFinalizer

	GetEndpoints() CallFinalizer[*[]ANCEndpoint]
	GetEndpointPolicies() CallFinalizer[*[]ANCEndpoint]
	GetEndpointByMAC(mac string) CallFinalizer[*ANCEndpoint]
	GetEndpointByNasIPAddress(mac, nasIP string) CallFinalizer[*ANCEndpoint]
	ApplyEndpointByIPAddress(ip, policyName string) CallFinalizer[*ANCOperationStatus]
	ApplyEndpointByMACAddress(mac, policyName string) CallFinalizer[*ANCOperationStatus]
	ClearEndpointByIPAddress(ip, policyName string) CallFinalizer[*ANCOperationStatus]
	ClearEndpointByMACAddress(mac, policyName string) CallFinalizer[*ANCOperationStatus]

	ApplyEndpointPolicy(request ANCApplyPolicyRequest) CallFinalizer[*ANCOperationStatus]
	ClearEndpointPolicy(request ANCClearPolicyRequest) CallFinalizer[*ANCOperationStatus]

	GetOperationStatus(operationID string) CallFinalizer[*ANCOperationStatus]
}

type ANCStatus string

type AccountActivateResponse struct {
	AccountState AccountState `json:"accountState"`
	Version      string       `json:"version"`
}

type AccountCreateResponse struct {
	NodeName string `json:"nodeName"`
	Password string `json:"password"`
}

type AccountState string

type AuthConfig struct {
	Username string
	Password string
}

type CallFinalizer[T any] interface {
	Do(ctx context.Context) (FullResponse[T], error)
	DoOnNode(ctx context.Context, node int) (FullResponse[T], error)
	DoOnNodeByName(ctx context.Context, nodeName string) (FullResponse[T], error)
	DoOnNodes(ctx context.Context, nodes ...int) (FullResponse[T], error)
}

type Controller interface {
	RESTRequest(ctx context.Context, fullURL string, payload any, ops RESTOptions) (*Response, error)
	AccountCreate(ctx context.Context) (AccountCreateResponse, error)
	AccountActivate(ctx context.Context) (AccountActivateResponse, error)
	ServiceLookup(ctx context.Context, svc string) (ServiceLookupResponse, error)
	AccessSecret(ctx context.Context, peerNodeName string) (string, error)
}

type DNSConfig struct {
	Server         string
	FamilyStrategy INETFamilyStrategy
}

type EgressMatrix struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	Description string `json:"description"`
	MonitorAll  bool   `json:"monitorAll"`
}

type EgressPolicy struct {
	ID                         string   `json:"id"`
	Name                       string   `json:"name"`
	MatrixId                   string   `json:"matrixId"`
	Status                     string   `json:"status"`
	Description                string   `json:"description"`
	SourceSecurityGroupID      string   `json:"sourceSecurityGroupId"`
	DestinationSecurityGroupID string   `json:"destinationSecurityGroupId"`
	SGACLIDs                   []string `json:"sgaclIds"`
	Timestamp                  string   `json:"timestamp"`
}

type EgressPolicyTopicMessage struct {
	ID                 string   `json:"id"`
	Name               string   `json:"name"`
	Description        string   `json:"description"`
	SourceSGTID        string   `json:"sourceSgtId"`
	SourceSGTName      string   `json:"sourceSgtName"`
	DestinationSGTID   string   `json:"destinationSgtId"`
	DestinationSGTName string   `json:"destinationSgtName"`
	MatrixCellStatus   string   `json:"matrixCellStatus"`
	SGACLIDs           []string `json:"sgaclIds"`
	DefaultRule        string   `json:"defaultRule"`
	Sequence           int      `json:"sequence"`
	Deleted            bool     `json:"deleted"`
	Timestamp          string   `json:"timestamp"`
}

type EndpointAsset interface {
	PxGridService

	EndpointAssetSubscriber

	Properties() EndpointAssetPropsProvider
}

type EndpointAssetPropsProvider interface {
	WSPubsubService() (string, error)
	AssetTopic() (string, error)
}

type EndpointAssetSubscriber interface {
	OnAssetTopic() Subscriber[ANCAssetTopicMessage]
}

type EndpointAssetTopic string

type Failure struct {
	ID                       string   `json:"id"`
	Timestamp                string   `json:"timestamp"`
	FailureReason            string   `json:"failureReason"`
	UserName                 string   `json:"userName"`
	ServerName               string   `json:"serverName"`
	CallingStationID         string   `json:"callingStationId"`
	AuditSessionID           string   `json:"auditSessionId"`
	NASIPAddress             string   `json:"nasIpAddress"`
	NASPortID                string   `json:"nasPortId"`
	NASPortType              string   `json:"nasPortType"`
	IPAddresses              []string `json:"ipAddresses"`
	MACAddress               string   `json:"macAddress"`
	MessageCode              int      `json:"messageCode"`
	DestinationIPAddress     string   `json:"destinationIpAddress"`
	UserType                 string   `json:"userType"`
	AccessService            string   `json:"accessService"`
	IdentityStore            string   `json:"identityStore"`
	IdentityGroup            string   `json:"identityGroup"`
	AuthenticationMethod     string   `json:"authenticationMethod"`
	AuthenticationProtocol   string   `json:"authenticationProtocol"`
	ServiceType              string   `json:"serviceType"`
	NetworkDeviceName        string   `json:"networkDeviceName"`
	DeviceType               string   `json:"deviceType"`
	Location                 string   `json:"location"`
	SelectedAznProfiles      string   `json:"selectedAznProfiles"`
	PostureStatus            string   `json:"postureStatus"`
	CTSSecurityGroup         string   `json:"ctsSecurityGroup"`
	Response                 string   `json:"response"`
	ResponseTime             int      `json:"responseTime"`
	ExecutionSteps           string   `json:"executionSteps"`
	CredentialCheck          string   `json:"credentialCheck"`
	EndpointProfile          string   `json:"endpointProfile"`
	MDMServerName            string   `json:"mdmServerName"`
	PolicySetName            string   `json:"policySetName"`
	AuthorizationRule        string   `json:"authorizationRule"`
	MSEResponseTime          string   `json:"mseResponseTime"`
	MSEServerName            string   `json:"mseServerName"`
	OriginalCallingStationID string   `json:"originalCallingStationId"`
}

type FailureTopicMessage struct {
	Sequence int       `json:"sequence"`
	Failures []Failure `json:"failures"`
}

type FullResponse[R any] struct {
	StatusCode int
	Result     R
	Body       string
}

type GenericRESTCaller interface {
	AnyREST(call string, payload map[string]any) CallFinalizer[any]
}

type GetEgressPoliciesResponse struct {
	TotalCount            int            `json:"totalCount"`
	EgressPolicies        []EgressPolicy `json:"egressPolicies"`
	DeletedEgressPolicies []EgressPolicy `json:"deletedEgressPolicies"`
}

type GetSecurityGroupACLsResponse struct {
	TotalCount              int                `json:"totalCount"`
	SecurityGroupACLs       []SecurityGroupACL `json:"securityGroupAcls"`
	DeleteSecurityGroupACLs []SecurityGroupACL `json:"deletedSecurityGroupAcls"`
}

type GetSecurityGroupsResponse struct {
	TotalCount            int             `json:"totalCount"`
	SecurityGroups        []SecurityGroup `json:"securityGroups"`
	DeletedSecurityGroups []SecurityGroup `json:"deletedSecurityGroups"`
}

type GetVirtualNetworksResponse struct {
	TotalCount             int              `json:"totalCount"`
	VirtualNetworks        []VirtualNetwork `json:"virtualNetworks"`
	DeletedVirtualNetworks []VirtualNetwork `json:"deletedVirtualNetworks"`
}

type Group struct {
	Name string    `json:"name"`
	Type GroupType `json:"type"`
}

type GroupTopicMessage struct {
	UserGroups []Group `json:"userGroups"`
}

type GroupType string

type Host struct {
	Host        string
	ControlPort int
}

type INETFamilyStrategy int

type Logger interface {
	Debug(msg string, args ...any)
	DebugContext(ctx context.Context, msg string, args ...any)
	Error(msg string, args ...any)
	ErrorContext(ctx context.Context, msg string, args ...any)
	Info(msg string, args ...any)
	InfoContext(ctx context.Context, msg string, args ...any)
	Warn(msg string, args ...any)
	WarnContext(ctx context.Context, msg string, args ...any)
	With(args ...any) Logger
}

type MDM interface {
	PxGridService

	Rest() MDMRest

	MDMSubscriber

	Properties() MDMPropsProvider
}

type MDMEndpoint struct {
	MACAddress    string `json:"macAddress"`
	OSVersion     string `json:"osVersion"`
	Registered    bool   `json:"registered"`
	Compliant     bool   `json:"compliant"`
	DiskEncrypted bool   `json:"diskEncrypted"`
	JailBroken    bool   `json:"jailBroken"`
	PinLocked     bool   `json:"pinLocked"`
	Model         string `json:"model"`
	Manufacturer  string `json:"manufacturer"`
	IMEI          string `json:"imei"`
	MEID          string `json:"meid"`
	UDID          string `json:"udid"`
	SerialNumber  string `json:"serialNumber"`
	Location      string `json:"location"`
	DeviceManager string `json:"deviceManager"`
	LastSyncTime  string `json:"lastSyncTime"`
}

type MDMEndpointType string

type MDMOSType string

type MDMPropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	EndpointTopic() (string, error)
}

type MDMRest interface {
	GetEndpoints(filter *MDMEndpoint) CallFinalizer[*[]MDMEndpoint]
	GetEndpointByMacAddress(macAddress string) CallFinalizer[*MDMEndpoint]
	GetEndpointsByType(endpointType MDMEndpointType) CallFinalizer[*[]MDMEndpoint]
	GetEndpointsByOsType(osType MDMOSType) CallFinalizer[*[]MDMEndpoint]
}

type MDMSubscriber interface {
	OnEndpointTopic() Subscriber[MDMEndpoint]
}

type MDMTopic string

type Message[T any] struct {
	*stomp.Message

	Body           T
	UnmarshalError error
}

type NoResultCallFinalizer interface {
	Do(ctx context.Context) (NoResultResponse, error)
	DoOnNode(ctx context.Context, node int) (NoResultResponse, error)
	DoOnNodeByName(ctx context.Context, nodeName string) (NoResultResponse, error)
	DoOnNodes(ctx context.Context, nodes ...int) (NoResultResponse, error)
}

type NoResultResponse struct {
	StatusCode int
}

type OperationType string

type Policy struct {
	SourceSGT                  int    `json:"sourceSgt"`
	SourceSGTGenerationID      string `json:"sourceSgtGenerationId"`
	DestinationSGT             int    `json:"destinationSgt"`
	DestinationSGTGenerationID string `json:"destinationSgtGenerationId"`
	SGACLName                  string `json:"sgaclName"`
	SGACLGenerationID          string `json:"sgaclGenerationId"`
}

type PolicyDownload struct {
	Timestamp       string               `json:"timestamp"`
	ServerName      string               `json:"serverName"`
	Status          PolicyDownloadStatus `json:"status"`
	FailureReason   string               `json:"failureReason"`
	NASIPAddress    string               `json:"nasIpAddress"`
	MatrixName      string               `json:"matrixName"`
	RBACLSourceList string               `json:"rbaclSourceList"`
	Policies        []Policy             `json:"policies"`
}

type PolicyDownloadStatus string

type PolicyDownloadTopicMessage struct {
	PolicyDownloads []PolicyDownload `json:"policyDownloads"`
}

type Profile struct {
	ID       string `json:"id"`
	Name     string `json:"name"`
	FullName string `json:"fullName"`
}

type ProfilerConfiguration interface {
	PxGridService

	Rest() ProfilerConfigurationRest

	ProfilerConfigurationSubscriber

	Properties() ProfilerConfigurationPropsProvider
}

type ProfilerConfigurationPropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	Topic() (string, error)
}

type ProfilerConfigurationRest interface {
	GetProfiles() CallFinalizer[*[]Profile]
}

type ProfilerConfigurationSubscriber interface {
	OnTopic() Subscriber[ProfilerTopicMessage]
}

type ProfilerConfigurationTopic string

type ProfilerTopicMessage struct {
	OperationType OperationType `json:"operation"`
	Profile       Profile       `json:"profile"`
}

type PubSub interface {
	PxGridService

	PubSubSubscriber

	Properties() PubSubPropsProvider
}

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

type PubSubPropsProvider interface {
	WSURL() (string, error)
}

type PubSubSubscriber interface {
	Subscribe(ctx context.Context, picker ServiceNodePickerFactory, topic string) (*stomp.Subscription, error)
}

type PxGridConfig struct {
	Hosts       []Host
	Auth        AuthConfig
	NodeName    string
	Description string
	TLS         TLSConfig
	DNS         DNSConfig
	Logger      Logger
}

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

type PxGridService interface {
	Name() string
	Nodes() []ServiceNode
	Lookup(ctx context.Context) error
	UpdateSecrets(ctx context.Context) error
	CheckNodes(ctx context.Context) error
	FindProperty(ctx context.Context, property string, nodePick ...ServiceNodePickerFactory) (any, error)
	FindNodeIndexByName(name string) (int, error)
	On(topicProperty string) Subscriber[any]

	GenericRESTCaller
}

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

type RadiusFailure interface {
	PxGridService

	Rest() RadiusFailureRest

	RadiusFailureSubscriber

	Properties() RadiusFailurePropsProvider
}

type RadiusFailurePropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	FailureTopic() (string, error)
}

type RadiusFailureRest interface {
	GetFailures() CallFinalizer[*[]Failure]
	GetFailureByID(id string) CallFinalizer[*Failure]
}

type RadiusFailureSubscriber interface {
	OnFailureTopic() Subscriber[FailureTopicMessage]
}

type RadiusFailureTopic string

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

type Response struct {
	StatusCode int
	Body       string
	Result     interface{}
}

type SecurityGroup struct {
	ID          string `json:"id"`
	Name        string `json:"name"`
	Description string `json:"description"`
	Tag         int    `json:"tag"`
	Timestamp   string `json:"timestamp"`
}

type SecurityGroupACL struct {
	ID              string `json:"id"`
	IsDeleted       bool   `json:"isDeleted"`
	Name            string `json:"name"`
	Description     string `json:"description"`
	IPVersion       string `json:"ipVersion"`
	ACL             string `json:"acl"`
	ModelledContent any    `json:"modelledContent"`
	GenerationID    string `json:"generationId"`
	Timestamp       string `json:"timestamp"`
}

type SecurityGroupACLTopicMessage struct {
	ID              string `json:"id"`
	Name            string `json:"name"`
	Description     string `json:"description"`
	IPVersion       string `json:"ipVersion"`
	ACL             string `json:"acl"`
	ModelledContent any    `json:"modelledContent"`
	GenerationID    string `json:"generationId"`
	IsReadOnly      bool   `json:"isReadOnly"`
	Sequence        int    `json:"sequence"`
	Deleted         bool   `json:"deleted"`
	Timestamp       string `json:"timestamp"`
}

type SecurityGroupTopicMessage struct {
	Sequence      int           `json:"sequence"`
	OperationType OperationType `json:"operation"`
	SecurityGroup SecurityGroup `json:"securityGroup"`
}

type SecurityGroupVNVlanTopicMessage any

type ServiceLookupResponse struct {
	Services []ServiceNode `json:"services"`
}

type ServiceNode struct {
	Name       string                 `json:"name"`
	NodeName   string                 `json:"nodeName"`
	Properties map[string]interface{} `json:"properties"`
	Secret     string                 `json:"-"`
}

type ServiceNodePicker interface {
	PickNode() (*ServiceNode, bool, error)
}

type ServiceNodePickerFactory func(ServiceNodeSlice) ServiceNodePicker

type ServiceNodeSlice []ServiceNode

type Session struct {
	Timestamp                string       `json:"timestamp"`
	State                    SessionState `json:"state"`
	MacAddress               string       `json:"macAddress"`
	IPAddresses              []string     `json:"ipAddresses"`
	CallingStationID         string       `json:"callingStationId"`
	CalledStationID          string       `json:"calledStationId"`
	AuditSessionID           string       `json:"auditSessionId"`
	UserName                 string       `json:"userName"`
	NasIPAddress             string       `json:"nasIpAddress"`
	NasPortID                string       `json:"nasPortId"`
	NasPortType              string       `json:"nasPortType"`
	NasIdentifier            string       `json:"nasIdentifier"`
	SelectedAuthzProfiles    []string     `json:"selectedAuthzProfiles"`
	PostureStatus            string       `json:"postureStatus"`
	EndpointProfile          string       `json:"endpointProfile"`
	EndpointOperatingSystem  string       `json:"endpointOperatingSystem"`
	CTSSecurityGroup         string       `json:"ctsSecurityGroup"`
	ADNormalizedUser         string       `json:"adNormalizedUser"`
	ADUserDomainName         string       `json:"adUserDomainName"`
	ADHostDomainName         string       `json:"adHostDomainName"`
	ADUserNetBiosName        string       `json:"adUserNetBiosName"`
	ADHostNetBiosName        string       `json:"adHostNetBiosName"`
	ADUserResolvedIdentities string       `json:"adUserResolvedIdentities"`
	ADUserResolvedDNS        string       `json:"adUserResolvedDns"`
	ADHostResolvedIdentities string       `json:"adHostResolvedIdentities"`
	ADHostResolvedDNS        string       `json:"adHostResolvedDns"`
	ADUserSamAccountName     string       `json:"adUserSamAccountName"`
	ADHostSamAccountName     string       `json:"adHostSamAccountName"`
	ADUserQualifiedName      string       `json:"adUserQualifiedName"`
	ADHostQualifiedName      string       `json:"adHostQualifiedName"`
	Providers                []string     `json:"providers"`
	EndpointCheckResult      string       `json:"endpointCheckResult"`
	EndpointCheckTime        string       `json:"endpointCheckTime"`
	IdentitySourcePortStart  string       `json:"identitySourcePortStart"`
	IdentitySourcePortEnd    string       `json:"identitySourcePortEnd"`
	IdentitySourcePortFirst  string       `json:"identitySourcePortFirst"`
	TerminalServerAgentID    string       `json:"terminalServerAgentId"`
	IsMachineAuthentication  string       `json:"isMachineAuthentication"`
	ServiceType              string       `json:"serviceType"`
	TunnelPrivateGroupID     string       `json:"tunnelPrivateGroupId"`
	AirespaceWlanID          string       `json:"airespaceWlanId"`
	NetworkDeviceProfileName string       `json:"networkDeviceProfileName"`
	RadiusFlowType           string       `json:"radiusFlowType"`
	SSID                     string       `json:"ssid"`
	ANCPolicy                string       `json:"ancPolicy"`
	MDMMacAddress            string       `json:"mdmMacAddress"`
	MDMOSVersion             string       `json:"mdmOsVersion"`
	MDMRegistered            bool         `json:"mdmRegistered"`
	MDMCompliant             bool         `json:"mdmCompliant"`
	MDMDiskEncrypted         bool         `json:"mdmDiskEncrypted"`
	MDMJailBroken            bool         `json:"mdmJailBroken"`
	MDMPinLocked             bool         `json:"mdmPinLocked"`
	MDMModel                 string       `json:"mdmModel"`
	MDMManufacturer          string       `json:"mdmManufacturer"`
	MDMIMEI                  string       `json:"mdmImei"`
	MDMMEID                  string       `json:"mdmMeid"`
	MDMUDID                  string       `json:"mdmUdid"`
	MDMSerialNumber          string       `json:"mdmSerialNumber"`
	MDMLocation              string       `json:"mdmLocation"`
	MDMDeviceManager         string       `json:"mdmDeviceManager"`
	MDMLastSyncTime          string       `json:"mdmLastSyncTime"`
	VirtualNetwork           string       `json:"virtualNetwork"`
}

type SessionDirectory interface {
	PxGridService

	Rest() SessionDirectoryRest

	SessionDirectorySubscriber

	Properties() SessionDirectoryPropsProvider
}

type SessionDirectoryPropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	SessionTopic() (string, error)
	SessionTopicAll() (string, error)
	GroupTopic() (string, error)
}

type SessionDirectoryRest interface {
	GetSessions(startTimestamp string, filter any) CallFinalizer[*[]Session]
	GetSessionsForRecovery(startTimestamp, endTimestamp string) CallFinalizer[*[]Session]
	GetSessionByIPAddress(ipAddress string) CallFinalizer[*Session]
	GetSessionByMacAddress(macAddress string) CallFinalizer[*Session]
	GetUserGroups(filter any) CallFinalizer[*[]Group]
	GetUserGroupByUserName(userName string) CallFinalizer[*[]Group]
}

type SessionDirectorySubscriber interface {
	OnSessionTopic() Subscriber[SessionTopicMessage]
	OnSessionTopicAll() Subscriber[SessionTopicMessage]
	OnGroupTopic() Subscriber[GroupTopicMessage]
}

type SessionDirectoryTopic string

type SessionState string

type SessionTopicMessage struct {
	Sequence int       `json:"sequence"`
	Sessions []Session `json:"sessions"`
}

type Subscriber[T any] interface {
	WithServiceNodePicker(picker ServiceNodePickerFactory) Subscriber[T]
	WithPubSubNodePicker(picker ServiceNodePickerFactory) Subscriber[T]
	WithExplicitPubSub(pubsub PubSub) Subscriber[T]
	Subscribe(ctx context.Context) (*Subscription[T], error)
}

type Subscription[T any] struct {
	*stomp.Subscription

	C             chan *Message[T]
	PubSubService string
}

type SupportedRESTCallDetails struct {
	Name   string   `json:"name"`
	Params []string `json:"params"`
}

type SysHealth struct {
	Timestamp       string  `json:"timestamp"`
	ServerName      string  `json:"serverName"`
	IOWait          float64 `json:"ioWait"`
	CPUUsage        float64 `json:"cpuUsage"`
	MemoryUsage     float64 `json:"memoryUsage"`
	DiskUsageRoot   float64 `json:"diskUsageRoot"`
	DiskUsageOpt    float64 `json:"diskUsageOpt"`
	LoadAverage     float64 `json:"loadAverage"`
	NetworkSent     float64 `json:"networkSent"`
	NetworkReceived float64 `json:"networkReceived"`
}

type SysPerformance struct {
	Timestamp     string  `json:"timestamp"`
	ServerName    string  `json:"serverName"`
	RADIUSRate    float64 `json:"radiusRate"`
	RADIUSCount   float64 `json:"radiusCount"`
	RADIUSLatency float64 `json:"radiusLatency"`
}

type SystemHealth interface {
	PxGridService

	Rest() SystemHealthRest

	Properties() SystemHealthPropsProvider
}

type SystemHealthPropsProvider interface {
	RestBaseURL() (string, error)
}

type SystemHealthRest interface {
	GetHealths(nodeName string, startTimestamp string) CallFinalizer[*[]SysHealth]
	GetPerformances(nodeName string, startTimestamp string) CallFinalizer[*[]SysPerformance]
}

type TLSConfig struct {
	ClientCertificate *tls.Certificate
	InsecureTLS       bool
	CA                *x509.CertPool
}

type TrustSec interface {
	PxGridService

	TrustSecSubscriber

	Properties() TrustSecPropsProvider
}

type TrustSecConfiguration interface {
	PxGridService

	Rest() TrustSecConfigurationRest

	TrustSecConfigurationSubscriber

	Properties() TrustSecConfigurationPropsProvider
}

type TrustSecConfigurationPropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	SecurityGroupTopic() (string, error)
	SecurityGroupACLTopic() (string, error)
	SecurityGroupVNVlanTopic() (string, error)
	VirtualNetworkTopic() (string, error)
	EgressPolicyTopic() (string, error)
}

type TrustSecConfigurationRequestFilter func(*trustSecConfigurationRequestFilter)

type TrustSecConfigurationRest interface {
	GetSecurityGroups(filters ...TrustSecConfigurationRequestFilter) CallFinalizer[*GetSecurityGroupsResponse]
	GetSecurityGroupACLs(filters ...TrustSecConfigurationRequestFilter) CallFinalizer[*GetSecurityGroupACLsResponse]
	GetVirtualNetwork(filters ...TrustSecConfigurationRequestFilter) CallFinalizer[*GetVirtualNetworksResponse]
	GetEgressPolicies(filters ...TrustSecEgressPoliciesRequestFilter) CallFinalizer[*GetEgressPoliciesResponse]
	GetEgressMatrices() CallFinalizer[*[]EgressMatrix]
}

type TrustSecConfigurationSubscriber interface {
	OnSecurityGroupTopic() Subscriber[SecurityGroupTopicMessage]
	OnSecurityGroupACLTopic() Subscriber[SecurityGroupACLTopicMessage]
	OnSecurityGroupVNVlanTopic() Subscriber[SecurityGroupVNVlanTopicMessage]
	OnVirtualNetworkTopic() Subscriber[VirtualNetworkTopicMessage]
	OnEgressPolicyTopic() Subscriber[EgressPolicyTopicMessage]
}

type TrustSecConfigurationTopic string

type TrustSecEgressPoliciesRequestFilter func(*trustSecEgressPoliciesRequestFilter)

type TrustSecPropsProvider interface {
	WSPubsubService() (string, error)
	PolicyDownloadTopic() (string, error)
}

type TrustSecSXP interface {
	PxGridService

	Rest() TrustSecSXPRest

	TrustSecSXPSubscriber

	Properties() TrustSecSXPPropsProvider
}

type TrustSecSXPBinding struct {
	Tag          string `json:"tag"`
	IPPrefix     string `json:"ipPrefix"`
	Source       string `json:"source"`
	PeerSequence string `json:"peerSequence"`
	VPN          string `json:"vpn"`
}

type TrustSecSXPBindingTopicMessage struct {
	OperationType OperationType      `json:"operation"`
	Binding       TrustSecSXPBinding `json:"binding"`
}

type TrustSecSXPPropsProvider interface {
	RestBaseURL() (string, error)
	WSPubsubService() (string, error)
	BindingTopic() (string, error)
}

type TrustSecSXPRest interface {
	GetBindings(filter any) CallFinalizer[*[]TrustSecSXPBinding]
}

type TrustSecSXPSubscriber interface {
	OnBindingTopic() Subscriber[TrustSecSXPBindingTopicMessage]
}

type TrustSecSXPTopic string

type TrustSecSubscriber interface {
	OnPolicyDownloadTopic() Subscriber[PolicyDownloadTopicMessage]
}

type TrustSecTopic string

type VirtualNetwork struct {
	ID                   string `json:"id"`
	Name                 string `json:"name"`
	AdditionalAttributes string `json:"additionalAttributes"`
	Timestamp            string `json:"timestamp"`
}

type VirtualNetworkTopicMessage struct {
	ID                   string `json:"id"`
	Name                 string `json:"name"`
	AdditionalAttributes string `json:"additionalAttributes"`
	Sequence             int    `json:"sequence"`
	Deleted              bool   `json:"deleted"`
	Timestamp            string `json:"timestamp"`
}