Versions in this module Expand all Collapse all v1 v1.8.7 Dec 27, 2023 v1.0.0 Dec 27, 2023 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 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 + 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) 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