clientconfig

type Cache interface {
	// Run start watching for changes
	Run(sync bool) error
	// Stop stop watching for changes
	Stop()
	// Clear clears the entries we have till now
	Clear()
	Connections() <-chan ConnectionMap
	HandleReferrals(referrals ReferralMap) error
}

type ClientClusterPair struct {
	ClusterNqn string
	HostNqn    string
}

type ClusterConnections struct {
	ClusterConnectionsMap map[TKey]*Connection
	ActiveConnection      *Connection
}

type Connection struct {
	Hostnqn string
	Key     TKey
	Ctx     context.Context

	AENChan      chan hostapi.AENStruct
	ConnectionID hostapi.ConnectionID
	State        bool
	// contains filtered or unexported fields
}

type ConnectionMap map[ClientClusterPair]ClusterConnections

type Entry struct {
	Transport  string
	Trsvcid    int
	Traddr     string
	Hostnqn    string
	Subsysnqn  string
	Persistent bool
	Hostaddr   string
}

type Event struct {
	Name string
	Op   EventOp
}

type EventOp string

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

type ParserError struct {
	Msg     string
	Details string
	Err     error
}

type ReferralKey struct {
	Ip       string
	Port     uint16
	DPSubNqn string // Datapath subsystem nqn. The referral log page entry does not contain it but we need it to create a new connection based on the referral
	Hostnqn  string // The referral log page entry does not contain it but we need it to create a new connection based on the referral
}

type ReferralMap map[ReferralKey]*hostapi.NvmeDiscPageEntry

type TKey struct {
	Ip string

	// subsystem nqn
	Nqn string
	// contains filtered or unexported fields
}