msd

Documentation

Index

• type DiscoverdRepo
  • func NewDiscoverdRepo(cluster cluster.Cluster, ttl time.Duration, l *log.Logger) *DiscoverdRepo
  • func (s *DiscoverdRepo) AddRouter(node string, addr string, mss []string)
  • func (s *DiscoverdRepo) GetRouterTable(addr string) *api.RouterTable
  • func (s *DiscoverdRepo) ListMicroApps() []api.MicroApp
  • func (s *DiscoverdRepo) ListRouters() []api.Router
  • func (s *DiscoverdRepo) OnAppExpired(dm map[string]interface{})
  • func (s *DiscoverdRepo) Refresh(addr string) *api.AppStatus
  • func (s *DiscoverdRepo) Register(ma *api.MicroApp)
  • func (s *DiscoverdRepo) RemoveRouter(addr string)
  • func (s *DiscoverdRepo) RemoveRouterByHost(node string)
  • func (s *DiscoverdRepo) UpdateRouters(rs []api.Router)
• type ServiceResource
  • func NewServiceResource(dr *DiscoverdRepo, l *log.Logger) *ServiceResource
  • func (sr *ServiceResource) GetRouterTable(c *gin.Context)
  • func (sr *ServiceResource) Refresh(c *gin.Context)
  • func (sr *ServiceResource) RegMicroApp(c *gin.Context)

Types

type DiscoverdRepo

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

func NewDiscoverdRepo

func NewDiscoverdRepo(cluster cluster.Cluster, ttl time.Duration, l *log.Logger) *DiscoverdRepo

func (*DiscoverdRepo) AddRouter

func (s *DiscoverdRepo) AddRouter(node string, addr string, mss []string)

func (*DiscoverdRepo) GetRouterTable

func (s *DiscoverdRepo) GetRouterTable(addr string) *api.RouterTable

func (*DiscoverdRepo) ListMicroApps

func (s *DiscoverdRepo) ListMicroApps() []api.MicroApp

func (*DiscoverdRepo) ListRouters

func (s *DiscoverdRepo) ListRouters() []api.Router

func (*DiscoverdRepo) OnAppExpired

func (s *DiscoverdRepo) OnAppExpired(dm map[string]interface{})

func (*DiscoverdRepo) Refresh

func (s *DiscoverdRepo) Refresh(addr string) *api.AppStatus

func (*DiscoverdRepo) Register

func (s *DiscoverdRepo) Register(ma *api.MicroApp)

func (*DiscoverdRepo) RemoveRouter

func (s *DiscoverdRepo) RemoveRouter(addr string)

func (*DiscoverdRepo) RemoveRouterByHost

func (s *DiscoverdRepo) RemoveRouterByHost(node string)

func (*DiscoverdRepo) UpdateRouters

func (s *DiscoverdRepo) UpdateRouters(rs []api.Router)

type ServiceResource

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

func NewServiceResource

func NewServiceResource(dr *DiscoverdRepo, l *log.Logger) *ServiceResource

func (*ServiceResource) GetRouterTable

func (sr *ServiceResource) GetRouterTable(c *gin.Context)

func (*ServiceResource) Refresh

func (sr *ServiceResource) Refresh(c *gin.Context)

func (*ServiceResource) RegMicroApp

func (sr *ServiceResource) RegMicroApp(c *gin.Context)