Documentation
¶
Index ¶
- type RegisterRequest
- type SnpServer
- func (s *SnpServer) MappingRegister(ctx context.Context, req *mesh_proto.MappingRegisterRequest) (*mesh_proto.MappingRegisterResponse, error)
- func (s *SnpServer) MappingSync(stream mesh_proto.ServiceNameMappingService_MappingSyncServer) error
- func (s *SnpServer) NeedLeaderElection() bool
- func (s *SnpServer) Start(stop <-chan struct{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RegisterRequest ¶
type RegisterRequest struct {
ConfigsUpdated map[core_model.ResourceReq]map[string]struct{}
}
type SnpServer ¶
type SnpServer struct {
mesh_proto.ServiceNameMappingServiceServer
// contains filtered or unexported fields
}
func NewSnpServer ¶
func NewSnpServer( 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, ) *SnpServer
func (*SnpServer) MappingRegister ¶
func (s *SnpServer) MappingRegister(ctx context.Context, req *mesh_proto.MappingRegisterRequest) (*mesh_proto.MappingRegisterResponse, error)
func (*SnpServer) MappingSync ¶
func (s *SnpServer) MappingSync(stream mesh_proto.ServiceNameMappingService_MappingSyncServer) error
func (*SnpServer) NeedLeaderElection ¶
Source Files
Click to show internal directories.
Click to hide internal directories.