sync

Documentation

Index

• type GenesisSync
  • func NewGenesisSync(ctx context.Context, queue queue.QueueReader, config *config.ControllerConfig) *GenesisSync
  • func (g *GenesisSync) GetGenesisSyncData(orgID int) common.GenesisSyncDataResponse
  • func (g *GenesisSync) GetGenesisSyncResponse(orgID int) (common.GenesisSyncDataResponse, error)
  • func (g *GenesisSync) Start()
  • func (s *GenesisSync) Stop()
• type GenesisSyncDataOperation
• type GenesisSyncTypeOperation
  • func NewHostPlatformDataOperation(orgID int, dataList []model.GenesisHost) *GenesisSyncTypeOperation[model.GenesisHost]
  • func NewIPLastSeenPlatformDataOperation(orgID int, dataList []model.GenesisIP) *GenesisSyncTypeOperation[model.GenesisIP]
  • func NewLldpInfoPlatformDataOperation(orgID int, dataList []model.GenesisLldp) *GenesisSyncTypeOperation[model.GenesisLldp]
  • func NewNetworkPlatformDataOperation(orgID int, dataList []model.GenesisNetwork) *GenesisSyncTypeOperation[model.GenesisNetwork]
  • func NewPortPlatformDataOperation(orgID int, dataList []model.GenesisPort) *GenesisSyncTypeOperation[model.GenesisPort]
  • func NewProcessPlatformDataOperation(orgID int, dataList []model.GenesisProcess) *GenesisSyncTypeOperation[model.GenesisProcess]
  • func NewVIPPlatformDataOperation(orgID int, dataList []model.GenesisVIP) *GenesisSyncTypeOperation[model.GenesisVIP]
  • func NewVMPlatformDataOperation(orgID int, dataList []model.GenesisVM) *GenesisSyncTypeOperation[model.GenesisVM]
  • func NewVinterfacePlatformDataOperation(orgID int, dataList []model.GenesisVinterface) *GenesisSyncTypeOperation[model.GenesisVinterface]
  • func NewVpcPlatformDataOperation(orgID int, dataList []model.GenesisVpc) *GenesisSyncTypeOperation[model.GenesisVpc]
  • func (g *GenesisSyncTypeOperation[T]) Age(timestamp time.Time, timeout time.Duration) bool
  • func (g *GenesisSyncTypeOperation[T]) Fetch() map[int][]T
  • func (g *GenesisSyncTypeOperation[T]) Load(timestamp time.Time, timeout time.Duration)
  • func (g *GenesisSyncTypeOperation[T]) Renew(orgID int, timestamp time.Time, items []T)
  • func (g *GenesisSyncTypeOperation[T]) Save()
  • func (g *GenesisSyncTypeOperation[T]) Update(orgID int, timestamp time.Time, items []T)
• type SyncStorage
  • func NewSyncStorage(ctx context.Context, cfg config.GenesisConfig, ...) *SyncStorage
  • func (s *SyncStorage) Renew(orgID int, data common.GenesisSyncDataResponse)
  • func (s *SyncStorage) Start()
  • func (s *SyncStorage) Stop()
  • func (s *SyncStorage) Update(orgID int, vtapID uint32, data common.GenesisSyncDataResponse)

Types

type GenesisSync

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

func NewGenesisSync

func NewGenesisSync(ctx context.Context, queue queue.QueueReader, config *config.ControllerConfig) *GenesisSync

func (*GenesisSync) GetGenesisSyncData

func (g *GenesisSync) GetGenesisSyncData(orgID int) common.GenesisSyncDataResponse

func (*GenesisSync) GetGenesisSyncResponse

func (g *GenesisSync) GetGenesisSyncResponse(orgID int) (common.GenesisSyncDataResponse, error)

func (*GenesisSync) Start

func (g *GenesisSync) Start()

func (*GenesisSync) Stop

func (s *GenesisSync) Stop()

type GenesisSyncDataOperation

type GenesisSyncDataOperation struct {
	IPlastseens *GenesisSyncTypeOperation[model.GenesisIP]
	VIPs        *GenesisSyncTypeOperation[model.GenesisVIP]
	VMs         *GenesisSyncTypeOperation[model.GenesisVM]
	VPCs        *GenesisSyncTypeOperation[model.GenesisVpc]
	Hosts       *GenesisSyncTypeOperation[model.GenesisHost]
	Lldps       *GenesisSyncTypeOperation[model.GenesisLldp]
	Ports       *GenesisSyncTypeOperation[model.GenesisPort]
	Networks    *GenesisSyncTypeOperation[model.GenesisNetwork]
	Vinterfaces *GenesisSyncTypeOperation[model.GenesisVinterface]
	Processes   *GenesisSyncTypeOperation[model.GenesisProcess]
}

type GenesisSyncTypeOperation

type GenesisSyncTypeOperation[T common.GenesisSyncType] struct {
	// contains filtered or unexported fields
}

func NewHostPlatformDataOperation

func NewHostPlatformDataOperation(orgID int, dataList []model.GenesisHost) *GenesisSyncTypeOperation[model.GenesisHost]

func NewIPLastSeenPlatformDataOperation

func NewIPLastSeenPlatformDataOperation(orgID int, dataList []model.GenesisIP) *GenesisSyncTypeOperation[model.GenesisIP]

func NewLldpInfoPlatformDataOperation

func NewLldpInfoPlatformDataOperation(orgID int, dataList []model.GenesisLldp) *GenesisSyncTypeOperation[model.GenesisLldp]

func NewNetworkPlatformDataOperation

func NewNetworkPlatformDataOperation(orgID int, dataList []model.GenesisNetwork) *GenesisSyncTypeOperation[model.GenesisNetwork]

func NewPortPlatformDataOperation

func NewPortPlatformDataOperation(orgID int, dataList []model.GenesisPort) *GenesisSyncTypeOperation[model.GenesisPort]

func NewProcessPlatformDataOperation

func NewProcessPlatformDataOperation(orgID int, dataList []model.GenesisProcess) *GenesisSyncTypeOperation[model.GenesisProcess]

func NewVIPPlatformDataOperation

func NewVIPPlatformDataOperation(orgID int, dataList []model.GenesisVIP) *GenesisSyncTypeOperation[model.GenesisVIP]

func NewVMPlatformDataOperation

func NewVMPlatformDataOperation(orgID int, dataList []model.GenesisVM) *GenesisSyncTypeOperation[model.GenesisVM]

func NewVinterfacePlatformDataOperation

func NewVinterfacePlatformDataOperation(orgID int, dataList []model.GenesisVinterface) *GenesisSyncTypeOperation[model.GenesisVinterface]

func NewVpcPlatformDataOperation

func NewVpcPlatformDataOperation(orgID int, dataList []model.GenesisVpc) *GenesisSyncTypeOperation[model.GenesisVpc]

func (*GenesisSyncTypeOperation[T]) Age

func (g *GenesisSyncTypeOperation[T]) Age(timestamp time.Time, timeout time.Duration) bool

func (*GenesisSyncTypeOperation[T]) Fetch

func (g *GenesisSyncTypeOperation[T]) Fetch() map[int][]T

func (*GenesisSyncTypeOperation[T]) Load

func (g *GenesisSyncTypeOperation[T]) Load(timestamp time.Time, timeout time.Duration)

func (*GenesisSyncTypeOperation[T]) Renew

func (g *GenesisSyncTypeOperation[T]) Renew(orgID int, timestamp time.Time, items []T)

func (*GenesisSyncTypeOperation[T]) Save

func (g *GenesisSyncTypeOperation[T]) Save()

func (*GenesisSyncTypeOperation[T]) Update

func (g *GenesisSyncTypeOperation[T]) Update(orgID int, timestamp time.Time, items []T)

type SyncStorage

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

func NewSyncStorage

func NewSyncStorage(ctx context.Context, cfg config.GenesisConfig, sChan chan common.GenesisSyncData) *SyncStorage

func (*SyncStorage) Renew

func (s *SyncStorage) Renew(orgID int, data common.GenesisSyncDataResponse)

func (*SyncStorage) Start

func (s *SyncStorage) Start()

func (*SyncStorage) Stop

func (s *SyncStorage) Stop()

func (*SyncStorage) Update

func (s *SyncStorage) Update(orgID int, vtapID uint32, data common.GenesisSyncDataResponse)