Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.