discoveryrule

Documentation

Index

• func GetDiscovererGNMI(capRsp *gnmi.CapabilityResponse) (discoverers.Discoverer, error)
• type DiscoveryProfile
• type DiscoveryRule
  • func New(client client.Client, cfg *DiscoveryRuleConfig, ...) DiscoveryRule
• type DiscoveryRuleConfig
• type Iterator
• type Key
  • func GetKey(s string) Key
  • func (r Key) String() string
• type TargetConnectionProfile

Functions

func GetDiscovererGNMI

func GetDiscovererGNMI(capRsp *gnmi.CapabilityResponse) (discoverers.Discoverer, error)

Types

type DiscoveryProfile

type DiscoveryProfile struct {
	Secret                   string
	SecretResourceVersion    string // used to validate a profile change
	TLSSecret                string
	TLSSecretResourceVersion string // used to validate a profile change
	Connectionprofiles       []*invv1alpha1.TargetConnectionProfile
}

type DiscoveryRule

type DiscoveryRule interface {
	Run(ctx context.Context) error
	Stop(ctx context.Context)
	GetDiscoveryRulConfig() *DiscoveryRuleConfig
}

func New

func New(client client.Client, cfg *DiscoveryRuleConfig, targetStore storebackend.Storer[*target.Context]) DiscoveryRule

type DiscoveryRuleConfig

type DiscoveryRuleConfig struct {
	// Discovery defines if discovery is enabled or disabled
	Discovery bool
	// Default Schema is the default schema
	DefaultSchema *invv1alpha1.SchemaKey
	// CR that owns the discovery Rule
	CR invv1alpha1.DiscoveryObject
	// Selector for Pod/SVC
	//Selector labels.Selector
	// Prefixes used to discover/connect to the target
	//Prefixes []invv1alpha1.DiscoveryRulePrefix
	// DiscoveryProfile contains the profile data from the k8s api-server
	DiscoveryProfile *DiscoveryProfile
	// ConnectivityProfile contains the profile data from the k8s api-server
	TargetConnectionProfiles []TargetConnectionProfile
	// TargetTemplate defines the template to expand the target
	TargetTemplate *invv1alpha1.TargetTemplate
}

type Iterator

type Iterator interface {
	Next() (*hostInfo, bool)
}

type Key

type Key struct {
	APIVersion string
	Kind       string
	Namespace  string
	Name       string
}

func GetKey

func GetKey(s string) Key

func (Key) String

func (r Key) String() string

type TargetConnectionProfile

type TargetConnectionProfile struct {
	Secret                   string
	SecretResourceVersion    string // used to validate a profile change + provide the version to the target if provisioned
	TLSSecret                string
	TLSSecretResourceVersion string // used to validate a profile change + provide the version to the target if provisioned
	Connectionprofile        *invv1alpha1.TargetConnectionProfile
	Syncprofile              *invv1alpha1.TargetSyncProfile
}