Versions in this module Expand all Collapse all v1 v1.8.26 Dec 6, 2024 Changes in this version + var File_app_observatory_config_proto protoreflect.FileDescriptor + type Config struct + EnableConcurrency bool + ProbeInterval int64 + ProbeUrl string + SubjectSelector []string + func (*Config) Descriptor() ([]byte, []int) + func (*Config) ProtoMessage() + func (x *Config) GetEnableConcurrency() bool + func (x *Config) GetProbeInterval() int64 + func (x *Config) GetProbeUrl() string + func (x *Config) GetSubjectSelector() []string + func (x *Config) ProtoReflect() protoreflect.Message + func (x *Config) Reset() + func (x *Config) String() string + type HealthPingMeasurementResult struct + All int64 + Average int64 + Deviation int64 + Fail int64 + Max int64 + Min int64 + func (*HealthPingMeasurementResult) Descriptor() ([]byte, []int) + func (*HealthPingMeasurementResult) ProtoMessage() + func (x *HealthPingMeasurementResult) GetAll() int64 + func (x *HealthPingMeasurementResult) GetAverage() int64 + func (x *HealthPingMeasurementResult) GetDeviation() int64 + func (x *HealthPingMeasurementResult) GetFail() int64 + func (x *HealthPingMeasurementResult) GetMax() int64 + func (x *HealthPingMeasurementResult) GetMin() int64 + func (x *HealthPingMeasurementResult) ProtoReflect() protoreflect.Message + func (x *HealthPingMeasurementResult) Reset() + func (x *HealthPingMeasurementResult) String() string + type Intensity struct + ProbeInterval uint32 + func (*Intensity) Descriptor() ([]byte, []int) + func (*Intensity) ProtoMessage() + func (x *Intensity) GetProbeInterval() uint32 + func (x *Intensity) ProtoReflect() protoreflect.Message + func (x *Intensity) Reset() + func (x *Intensity) String() string + type ObservationResult struct + Status []*OutboundStatus + func (*ObservationResult) Descriptor() ([]byte, []int) + func (*ObservationResult) ProtoMessage() + func (x *ObservationResult) GetStatus() []*OutboundStatus + func (x *ObservationResult) ProtoReflect() protoreflect.Message + func (x *ObservationResult) Reset() + func (x *ObservationResult) String() string + 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{} + type OutboundStatus struct + Alive bool + Delay int64 + HealthPing *HealthPingMeasurementResult + LastErrorReason string + LastSeenTime int64 + LastTryTime int64 + OutboundTag string + func (*OutboundStatus) Descriptor() ([]byte, []int) + func (*OutboundStatus) ProtoMessage() + func (x *OutboundStatus) GetAlive() bool + func (x *OutboundStatus) GetDelay() int64 + func (x *OutboundStatus) GetHealthPing() *HealthPingMeasurementResult + func (x *OutboundStatus) GetLastErrorReason() string + func (x *OutboundStatus) GetLastSeenTime() int64 + func (x *OutboundStatus) GetLastTryTime() int64 + func (x *OutboundStatus) GetOutboundTag() string + func (x *OutboundStatus) ProtoReflect() protoreflect.Message + func (x *OutboundStatus) Reset() + func (x *OutboundStatus) String() string + type ProbeResult struct + Alive bool + Delay int64 + LastErrorReason string + func (*ProbeResult) Descriptor() ([]byte, []int) + func (*ProbeResult) ProtoMessage() + func (x *ProbeResult) GetAlive() bool + func (x *ProbeResult) GetDelay() int64 + func (x *ProbeResult) GetLastErrorReason() string + func (x *ProbeResult) ProtoReflect() protoreflect.Message + func (x *ProbeResult) Reset() + func (x *ProbeResult) String() string Other modules containing this package github.com/morooi/xray-core/v24