service

Documentation

Index

• Constants
• type HealthGServer
  • func NewHealthGServer(config *dt.HealthServerConfig) *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

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
)

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) GetId

func (self *HealthGServer) GetId(ctx context.Context, in *pb.Empty) (*pb.Peer, error)

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)