Versions in this module Expand all Collapse all v1 v1.0.0 Dec 9, 2024 Changes in this version + var File_app_observatory_burst_config_proto protoreflect.FileDescriptor + type Config struct + PingConfig *HealthPingConfig + SubjectSelector []string + func (*Config) Descriptor() ([]byte, []int) + func (*Config) ProtoMessage() + func (x *Config) GetPingConfig() *HealthPingConfig + func (x *Config) GetSubjectSelector() []string + func (x *Config) ProtoReflect() protoreflect.Message + func (x *Config) Reset() + func (x *Config) String() string + type HealthPing struct + Results map[string]*HealthPingRTTS + Settings *HealthPingSettings + func NewHealthPing(ctx context.Context, config *HealthPingConfig) *HealthPing + func (h *HealthPing) Check(tags []string) error + func (h *HealthPing) Cleanup(tags []string) + func (h *HealthPing) PutResult(tag string, rtt time.Duration) + func (h *HealthPing) StartScheduler(selector func() ([]string, error)) + func (h *HealthPing) StopScheduler() + type HealthPingConfig struct + Connectivity string + Destination string + Interval int64 + SamplingCount int32 + Timeout int64 + func (*HealthPingConfig) Descriptor() ([]byte, []int) + func (*HealthPingConfig) ProtoMessage() + func (x *HealthPingConfig) GetConnectivity() string + func (x *HealthPingConfig) GetDestination() string + func (x *HealthPingConfig) GetInterval() int64 + func (x *HealthPingConfig) GetSamplingCount() int32 + func (x *HealthPingConfig) GetTimeout() int64 + func (x *HealthPingConfig) ProtoReflect() protoreflect.Message + func (x *HealthPingConfig) Reset() + func (x *HealthPingConfig) String() string + type HealthPingRTTS struct + func NewHealthPingResult(cap int, validity time.Duration) *HealthPingRTTS + func (h *HealthPingRTTS) Get() *HealthPingStats + func (h *HealthPingRTTS) GetWithCache() *HealthPingStats + func (h *HealthPingRTTS) Put(d time.Duration) + type HealthPingSettings struct + Connectivity string + Destination string + Interval time.Duration + SamplingCount int + Timeout time.Duration + type HealthPingStats struct + All int + Average time.Duration + Deviation time.Duration + Fail int + Max time.Duration + Min time.Duration + type Observer struct + func New(ctx context.Context, config *Config) (*Observer, error) + func (o *Observer) Close() error + func (o *Observer) GetObservation(ctx context.Context) (proto.Message, error) + func (o *Observer) Start() error + func (o *Observer) Type() interface{}
Go to main page