server

Documentation

Index

• type ObserverServer
  • func NewObserverServer(key, addr string) ObserverServer

Types

type ObserverServer

type ObserverServer interface {
	Start() error
	Close()

	Monitors() dependents.MonitorDependentsManager
	GetAddr() string
	GetKey() string

	SetPushFirst(f func(ctx context.Context, req *msa_observer.RequestPushFirst) (*msa_observer.ResponsePushFirst, error))
	SetPushStats(f func(ctx context.Context, req *msa_observer.RequestPushStats) (*msa_observer.Response, error))
	SetPushStatus(f func(ctx context.Context, req *msa_observer.RequestPushStatus) (*msa_observer.Response, error))
	SetWho(f func(ctx context.Context, req *msa_observer.RequestWho) (*msa_observer.ResponseWho, error))
	SetRestartService(f func(ctx context.Context, req *msa_observer.RequestRestartService) (*msa_observer.Response, error))
}

func NewObserverServer

func NewObserverServer(key, addr string) ObserverServer