grpc

Documentation

Index

• type SynchronizerServer
  • func NewGenesisSynchronizerServer(cfg config.GenesisConfig, genesisSyncQueue, k8sQueue queue.QueueWriter, ...) *SynchronizerServer
  • func (g *SynchronizerServer) AgentGenesisSync(ctx context.Context, request *agent.GenesisSyncRequest) (*agent.GenesisSyncResponse, error)
  • func (g *SynchronizerServer) AgentKubernetesAPISync(ctx context.Context, request *agent.KubernetesAPISyncRequest) (*agent.KubernetesAPISyncResponse, error)
  • func (g *SynchronizerServer) GenesisSharingK8S(ctx context.Context, request *controller.GenesisSharingK8SRequest) (*controller.GenesisSharingK8SResponse, error)
  • func (g *SynchronizerServer) GenesisSharingSync(ctx context.Context, request *controller.GenesisSharingSyncRequest) (*controller.GenesisSharingSyncResponse, error)
  • func (g *SynchronizerServer) GenesisSync(ctx context.Context, request *trident.GenesisSyncRequest) (*trident.GenesisSyncResponse, error)
  • func (g *SynchronizerServer) GetAgentStats(orgID, vtapID string) (TridentStats, error)
  • func (g *SynchronizerServer) KubernetesAPISync(ctx context.Context, request *trident.KubernetesAPISyncRequest) (*trident.KubernetesAPISyncResponse, error)
• type TridentStats

Types

type SynchronizerServer

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

func NewGenesisSynchronizerServer

func NewGenesisSynchronizerServer(cfg config.GenesisConfig, genesisSyncQueue, k8sQueue queue.QueueWriter,
	gsync *sstore.GenesisSync, gkubernetes *kstore.GenesisKubernetes) *SynchronizerServer

func (*SynchronizerServer) AgentGenesisSync

func (g *SynchronizerServer) AgentGenesisSync(ctx context.Context, request *agent.GenesisSyncRequest) (*agent.GenesisSyncResponse, error)

func (*SynchronizerServer) AgentKubernetesAPISync

func (g *SynchronizerServer) AgentKubernetesAPISync(ctx context.Context, request *agent.KubernetesAPISyncRequest) (*agent.KubernetesAPISyncResponse, error)

func (*SynchronizerServer) GenesisSharingK8S

func (g *SynchronizerServer) GenesisSharingK8S(ctx context.Context, request *controller.GenesisSharingK8SRequest) (*controller.GenesisSharingK8SResponse, error)

func (*SynchronizerServer) GenesisSharingSync

func (g *SynchronizerServer) GenesisSharingSync(ctx context.Context, request *controller.GenesisSharingSyncRequest) (*controller.GenesisSharingSyncResponse, error)

func (*SynchronizerServer) GenesisSync

func (g *SynchronizerServer) GenesisSync(ctx context.Context, request *trident.GenesisSyncRequest) (*trident.GenesisSyncResponse, error)

func (*SynchronizerServer) GetAgentStats

func (g *SynchronizerServer) GetAgentStats(orgID, vtapID string) (TridentStats, error)

func (*SynchronizerServer) KubernetesAPISync

func (g *SynchronizerServer) KubernetesAPISync(ctx context.Context, request *trident.KubernetesAPISyncRequest) (*trident.KubernetesAPISyncResponse, error)

type TridentStats

type TridentStats struct {
	OrgID                                int
	TeamID                               int
	VtapID                               uint32
	TeamShortLcuuid                      string
	IP                                   string
	Proxy                                string
	K8sVersion                           uint64
	SyncVersion                          uint64
	K8sLastSeen                          time.Time
	SyncLastSeen                         time.Time
	K8sClusterID                         string
	SyncAgentType                        agent.AgentType
	SyncTridentType                      tridentcommon.TridentType
	GenesisSyncDataOperation             *trident.GenesisPlatformData
	GenesisSyncProcessDataOperation      *trident.GenesisProcessData
	AgentGenesisSyncDataOperation        *agent.GenesisPlatformData
	AgentGenesisSyncProcessDataOperation *agent.GenesisProcessData
}