healthcheck

Mar 4, 2024

Changes in this version

+ func SerialSetInsDbStatus(svr *Server, ins *apiservice.Instance, healthStatus bool, lastBeatTime int64) apimodel.Code

+ func WithBatchController(ba *batch.Controller) serverOption

+ func WithCache(cacheMgr cache.CacheManager) serverOption

+ func WithPlugins() serverOption

+ func WithStore(s store.Store) serverOption

+ func WithTimeAdjuster(adjuster *TimeAdjuster) serverOption

type Config

+ func (c *Config) IsOpen() bool

+ type ResourceHealthCheckHandler struct

+ func (handler *ResourceHealthCheckHandler) OnEvent(ctx context.Context, i interface{}) error

+ func (handler *ResourceHealthCheckHandler) PreProcess(ctx context.Context, value any) any

type Server

+ func NewHealthServer(ctx context.Context, hcOpt *Config, options ...serverOption) (*Server, error)

+ func (s *Server) SelfService() string

Aug 28, 2023

Changes in this version

type Server

+ func (s *Server) Destroy()

May 4, 2023

Changes in this version

+ func TestDestroy()

type CheckScheduler

+ func (c *CheckScheduler) UpsertInstance(instanceWithChecker *InstanceWithChecker)

type Server

+ func (s *Server) Reports(ctx context.Context, req []*apiservice.InstanceHeartbeat) *apiservice.Response

Mar 25, 2023

Changes in this version

type Server

+ func (s *Server) Checkers() map[int32]plugin.HealthChecker

Mar 12, 2023

Changes in this version

type Config

+ OmitReplicated bool

+ type InstanceEventHealthCheckHandler struct

+ func (handler *InstanceEventHealthCheckHandler) OnEvent(ctx context.Context, i interface{}) error

+ func (handler *InstanceEventHealthCheckHandler) PreProcess(ctx context.Context, value any) any

type LeaderChangeEventHandler

+ func (handler *LeaderChangeEventHandler) OnEvent(ctx context.Context, i interface{}) error

+ func (handler *LeaderChangeEventHandler) PreProcess(ctx context.Context, value any) any

Feb 27, 2023

Changes in this version

+ func SetServer(srv *Server)

type Config

+ ClientCheckInterval time.Duration

+ ClientCheckTtl time.Duration

+ type LeaderChangeEventHandler struct

Feb 14, 2023

Changes in this version

type CacheProvider

+ func (c *CacheProvider) GetSelfServiceInstance(instanceId string) *model.Instance

type Server

+ func (s *Server) ListCheckerServer() []*model.Instance

Nov 29, 2022

Changes in this version

+ var DefaultShardSize uint32

+ func Initialize(ctx context.Context, hcOpt *Config, cacheOpen bool, bc *batch.Controller) error

+ func NewShardMap(size uint32) *shardMap

+ type AdoptEvent struct

+ Add bool

+ Checker plugin.HealthChecker

+ InstanceId string

+ type Bucket struct

+ Host string

+ Weight uint32

+ type CacheEvent struct

+ type CacheProvider struct

+ func (c *CacheProvider) GetClient(clientId string) *model.Client

+ func (c *CacheProvider) GetInstance(instanceId string) *model.Instance

+ func (c *CacheProvider) OnBatchCreated(value interface{})

+ func (c *CacheProvider) OnBatchDeleted(value interface{})

+ func (c *CacheProvider) OnBatchUpdated(value interface{})

+ func (c *CacheProvider) OnCreated(value interface{})

+ func (c *CacheProvider) OnDeleted(value interface{})

+ func (c *CacheProvider) OnUpdated(value interface{})

+ func (c *CacheProvider) RangeHealthCheckClients(check func(itemChecker ItemWithChecker, client *model.Client))

+ func (c *CacheProvider) RangeHealthCheckInstances(check func(itemChecker ItemWithChecker, ins *model.Instance))

+ func (c *CacheProvider) RangeSelfServiceInstances(check func(instance *api.Instance))

+ type CheckScheduler struct

+ func (c *CheckScheduler) AddClient(clientWithChecker *ClientWithChecker)

+ func (c *CheckScheduler) AddInstance(instanceWithChecker *InstanceWithChecker)

+ func (c *CheckScheduler) DelClient(clientWithChecker *ClientWithChecker)

+ func (c *CheckScheduler) DelInstance(instanceWithChecker *InstanceWithChecker)

+ type ClientWithChecker struct

+ func (ic *ClientWithChecker) GetChecker() plugin.HealthChecker

+ func (ic *ClientWithChecker) GetClient() *model.Client

+ func (ic *ClientWithChecker) GetHashValue() uint

+ func (ic *ClientWithChecker) GetInstance() *model.Instance

+ type Config struct

+ Batch map[string]interface{}

+ Checkers []plugin.ConfigEntry

+ ClientReportInterval time.Duration

+ LocalHost string

+ MaxCheckInterval time.Duration

+ MinCheckInterval time.Duration

+ Open bool

+ Service string

+ SlotNum int

+ func (c *Config) SetDefault()

+ type Continuum struct

+ func New(buckets map[Bucket]bool) *Continuum

+ func (c *Continuum) Hash(h uint) string

+ type Dispatcher struct

+ func (d *Dispatcher) UpdateStatusByEvent(event CacheEvent)

+ type InstanceWithChecker struct

+ func (ic *InstanceWithChecker) GetChecker() plugin.HealthChecker

+ func (ic *InstanceWithChecker) GetClient() *model.Client

+ func (ic *InstanceWithChecker) GetHashValue() uint

+ func (ic *InstanceWithChecker) GetInstance() *model.Instance

+ type ItemType int

+ func (i ItemType) String() string

+ type ItemWithChecker interface

+ GetChecker func() plugin.HealthChecker

+ GetClient func() *model.Client

+ GetHashValue func() uint

+ GetInstance func() *model.Instance

+ type Server struct

+ func GetServer() (*Server, error)

+ func TestInitialize(ctx context.Context, hcOpt *Config, cacheOpen bool, bc *batch.Controller, ...) (*Server, error)

+ func (s *Server) CacheProvider() (*CacheProvider, error)

+ func (s *Server) GetLastHeartbeat(req *api.Instance) *api.Response

+ func (s *Server) RecordHistory(entry *model.RecordEntry)

+ func (s *Server) Report(ctx context.Context, req *api.Instance) *api.Response

+ func (s *Server) ReportByClient(ctx context.Context, req *api.Client) *api.Response

+ func (s *Server) SetInstanceCache(instanceCache cache.InstanceCache)

+ func (s *Server) SetServiceCache(serviceCache cache.ServiceCache)

+ type TimeAdjuster struct

+ func (t *TimeAdjuster) GetDiff() int64