Documentation
¶
Index ¶
- type MetadataServer
- func (m *MetadataServer) MetadataRegister(ctx context.Context, req *mesh_proto.MetaDataRegisterRequest) (*mesh_proto.MetaDataRegisterResponse, error)
- func (m *MetadataServer) MetadataSync(stream mesh_proto.MetadataService_MetadataSyncServer) error
- func (m *MetadataServer) NeedLeaderElection() bool
- func (m *MetadataServer) Start(stop <-chan struct{}) error
- type RegisterRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetadataServer ¶
type MetadataServer struct {
mesh_proto.MetadataServiceServer
SystemNamespace string
// contains filtered or unexported fields
}
func NewMetadataServe ¶
func NewMetadataServe( ctx context.Context, config dubbo.DubboConfig, pusher pusher.Pusher, manager kube_ctrl.Manager, converter k8s_common.Converter, resourceManager manager.ResourceManager, transactions core_store.Transactions, localZone string, systemNamespace string, ) *MetadataServer
func (*MetadataServer) MetadataRegister ¶
func (m *MetadataServer) MetadataRegister(ctx context.Context, req *mesh_proto.MetaDataRegisterRequest) (*mesh_proto.MetaDataRegisterResponse, error)
func (*MetadataServer) MetadataSync ¶
func (m *MetadataServer) MetadataSync(stream mesh_proto.MetadataService_MetadataSyncServer) error
func (*MetadataServer) NeedLeaderElection ¶
func (m *MetadataServer) NeedLeaderElection() bool
func (*MetadataServer) Start ¶
func (m *MetadataServer) Start(stop <-chan struct{}) error
type RegisterRequest ¶
type RegisterRequest struct {
ConfigsUpdated map[core_model.ResourceReq]*mesh_proto.MetaData
}
Source Files
Click to show internal directories.
Click to hide internal directories.