Documentation
¶
Index ¶
- Constants
- type HealthGServer
- func (self *HealthGServer) AnalyzeReport(report *pb.Report, check_hold bool)
- func (self *HealthGServer) DumpInference(ctx context.Context, in *pb.Empty) (*pb.DumpInferenceReply, error)
- func (self *HealthGServer) DumpPanorama(ctx context.Context, in *pb.Empty) (*pb.DumpPanoramaReply, error)
- func (self *HealthGServer) GC()
- func (self *HealthGServer) GetId(ctx context.Context, in *pb.Empty) (*pb.Peer, error)
- func (self *HealthGServer) GetInference(ctx context.Context, in *pb.GetInferenceRequest) (*pb.Inference, error)
- func (self *HealthGServer) GetLatestReport(ctx context.Context, in *pb.GetReportRequest) (*pb.Report, error)
- func (self *HealthGServer) GetObservedSubjects(ctx context.Context, in *pb.Empty) (*pb.GetObservedSubjectsReply, error)
- func (self *HealthGServer) GetPanorama(ctx context.Context, in *pb.GetPanoramaRequest) (*pb.Panorama, error)
- func (self *HealthGServer) GetPeers(ctx context.Context, in *pb.Empty) (*pb.GetPeerReply, error)
- func (self *HealthGServer) GetView(ctx context.Context, in *pb.GetViewRequest) (*pb.View, error)
- func (self *HealthGServer) LearnReport(ctx context.Context, in *pb.LearnReportRequest) (*pb.LearnReportReply, error)
- func (self *HealthGServer) Observe(ctx context.Context, in *pb.ObserveRequest) (*pb.ObserveReply, error)
- func (self *HealthGServer) Ping(ctx context.Context, in *pb.PingRequest) (*pb.PingReply, error)
- func (self *HealthGServer) Register(ctx context.Context, in *pb.RegisterRequest) (*pb.RegisterReply, error)
- func (self *HealthGServer) Start(errch chan error) error
- func (self *HealthGServer) Stop(graceful bool) error
- func (self *HealthGServer) StopObserving(ctx context.Context, in *pb.ObserveRequest) (*pb.ObserveReply, error)
- func (self *HealthGServer) SubmitReport(ctx context.Context, in *pb.SubmitReportRequest) (*pb.SubmitReportReply, error)
Constants ¶
View Source
const ( HANDLE_START = 10000 GC_FREQUENCY = 3 * time.Minute // frequency to invoke garbage collection GC_THRESHOLD = 5 * time.Minute // TTL threshold GC_RELATIVE = true // garbage collect based on relative timestamp HOLD_TIME = 3 * time.Minute // time to hold ignored reports HOLD_LIST_LEN = 60 // number of items to hold at most for each subject DEFAULT_DBFILE = "deephealth.db" // default database file for storing local observations )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HealthGServer ¶
type HealthGServer struct {
dt.HealthServerConfig
// contains filtered or unexported fields
}
func NewHealthGServer ¶
func NewHealthGServer(config *dt.HealthServerConfig) *HealthGServer
func (*HealthGServer) AnalyzeReport ¶
func (self *HealthGServer) AnalyzeReport(report *pb.Report, check_hold bool)
func (*HealthGServer) DumpInference ¶
func (self *HealthGServer) DumpInference(ctx context.Context, in *pb.Empty) (*pb.DumpInferenceReply, error)
func (*HealthGServer) DumpPanorama ¶
func (self *HealthGServer) DumpPanorama(ctx context.Context, in *pb.Empty) (*pb.DumpPanoramaReply, error)
func (*HealthGServer) GC ¶
func (self *HealthGServer) GC()
func (*HealthGServer) GetInference ¶
func (self *HealthGServer) GetInference(ctx context.Context, in *pb.GetInferenceRequest) (*pb.Inference, error)
func (*HealthGServer) GetLatestReport ¶
func (self *HealthGServer) GetLatestReport(ctx context.Context, in *pb.GetReportRequest) (*pb.Report, error)
func (*HealthGServer) GetObservedSubjects ¶
func (self *HealthGServer) GetObservedSubjects(ctx context.Context, in *pb.Empty) (*pb.GetObservedSubjectsReply, error)
func (*HealthGServer) GetPanorama ¶
func (self *HealthGServer) GetPanorama(ctx context.Context, in *pb.GetPanoramaRequest) (*pb.Panorama, error)
func (*HealthGServer) GetPeers ¶
func (self *HealthGServer) GetPeers(ctx context.Context, in *pb.Empty) (*pb.GetPeerReply, error)
func (*HealthGServer) GetView ¶
func (self *HealthGServer) GetView(ctx context.Context, in *pb.GetViewRequest) (*pb.View, error)
func (*HealthGServer) LearnReport ¶
func (self *HealthGServer) LearnReport(ctx context.Context, in *pb.LearnReportRequest) (*pb.LearnReportReply, error)
func (*HealthGServer) Observe ¶
func (self *HealthGServer) Observe(ctx context.Context, in *pb.ObserveRequest) (*pb.ObserveReply, error)
func (*HealthGServer) Ping ¶
func (self *HealthGServer) Ping(ctx context.Context, in *pb.PingRequest) (*pb.PingReply, error)
func (*HealthGServer) Register ¶
func (self *HealthGServer) Register(ctx context.Context, in *pb.RegisterRequest) (*pb.RegisterReply, error)
func (*HealthGServer) Start ¶
func (self *HealthGServer) Start(errch chan error) error
func (*HealthGServer) Stop ¶
func (self *HealthGServer) Stop(graceful bool) error
func (*HealthGServer) StopObserving ¶
func (self *HealthGServer) StopObserving(ctx context.Context, in *pb.ObserveRequest) (*pb.ObserveReply, error)
func (*HealthGServer) SubmitReport ¶
func (self *HealthGServer) SubmitReport(ctx context.Context, in *pb.SubmitReportRequest) (*pb.SubmitReportReply, error)
Source Files
Click to show internal directories.
Click to hide internal directories.