grpc

Documentation

Index

• type SynchronizerServer
  • func NewGenesisSynchronizerServer(cfg config.GenesisConfig, genesisSyncQueue, k8sQueue queue.QueueWriter, ...) *SynchronizerServer
  • 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) 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
	SyncTridentType                 tridentcommon.TridentType
	GenesisSyncDataOperation        *trident.GenesisPlatformData
	GenesisSyncProcessDataOperation *trident.GenesisProcessData
}