Documentation
¶
Index ¶
- Variables
- type Config
- func (*Config) Descriptor() ([]byte, []int)deprecated
- func (x *Config) GetEnableConcurrency() bool
- func (x *Config) GetProbeInterval() int64
- func (x *Config) GetProbeUrl() string
- func (x *Config) GetSubjectSelector() []string
- func (*Config) ProtoMessage()
- func (x *Config) ProtoReflect() protoreflect.Message
- func (x *Config) Reset()
- func (x *Config) String() string
- type Intensity
- type ObservationResult
- func (*ObservationResult) Descriptor() ([]byte, []int)deprecated
- func (x *ObservationResult) GetStatus() []*OutboundStatus
- func (*ObservationResult) ProtoMessage()
- func (x *ObservationResult) ProtoReflect() protoreflect.Message
- func (x *ObservationResult) Reset()
- func (x *ObservationResult) String() string
- type Observer
- type OutboundStatus
- func (*OutboundStatus) Descriptor() ([]byte, []int)deprecated
- 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 (*OutboundStatus) ProtoMessage()
- func (x *OutboundStatus) ProtoReflect() protoreflect.Message
- func (x *OutboundStatus) Reset()
- func (x *OutboundStatus) String() string
- type ProbeResult
- func (*ProbeResult) Descriptor() ([]byte, []int)deprecated
- func (x *ProbeResult) GetAlive() bool
- func (x *ProbeResult) GetDelay() int64
- func (x *ProbeResult) GetLastErrorReason() string
- func (*ProbeResult) ProtoMessage()
- func (x *ProbeResult) ProtoReflect() protoreflect.Message
- func (x *ProbeResult) Reset()
- func (x *ProbeResult) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_app_observatory_config_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// @Document The selectors for outbound under observation
SubjectSelector []string `protobuf:"bytes,2,rep,name=subject_selector,json=subjectSelector,proto3" json:"subject_selector,omitempty"`
ProbeUrl string `protobuf:"bytes,3,opt,name=probe_url,json=probeUrl,proto3" json:"probe_url,omitempty"`
ProbeInterval int64 `protobuf:"varint,4,opt,name=probe_interval,json=probeInterval,proto3" json:"probe_interval,omitempty"`
EnableConcurrency bool `protobuf:"varint,5,opt,name=enable_concurrency,json=enableConcurrency,proto3" json:"enable_concurrency,omitempty"`
// contains filtered or unexported fields
}
func (*Config) Descriptor
deprecated
func (*Config) GetEnableConcurrency ¶
func (*Config) GetProbeInterval ¶
func (*Config) GetProbeUrl ¶
func (*Config) GetSubjectSelector ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶
func (x *Config) ProtoReflect() protoreflect.Message
type Intensity ¶
type Intensity struct {
// @Document The time interval for a probe request in ms.
// @Type time.ms
ProbeInterval uint32 `protobuf:"varint,1,opt,name=probe_interval,json=probeInterval,proto3" json:"probe_interval,omitempty"`
// contains filtered or unexported fields
}
func (*Intensity) Descriptor
deprecated
func (*Intensity) GetProbeInterval ¶
func (*Intensity) ProtoMessage ¶
func (*Intensity) ProtoMessage()
func (*Intensity) ProtoReflect ¶
func (x *Intensity) ProtoReflect() protoreflect.Message
type ObservationResult ¶
type ObservationResult struct {
Status []*OutboundStatus `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*ObservationResult) Descriptor
deprecated
func (*ObservationResult) Descriptor() ([]byte, []int)
Deprecated: Use ObservationResult.ProtoReflect.Descriptor instead.
func (*ObservationResult) GetStatus ¶
func (x *ObservationResult) GetStatus() []*OutboundStatus
func (*ObservationResult) ProtoMessage ¶
func (*ObservationResult) ProtoMessage()
func (*ObservationResult) ProtoReflect ¶
func (x *ObservationResult) ProtoReflect() protoreflect.Message
func (*ObservationResult) Reset ¶
func (x *ObservationResult) Reset()
func (*ObservationResult) String ¶
func (x *ObservationResult) String() string
type Observer ¶
type Observer struct {
// contains filtered or unexported fields
}
func (*Observer) GetObservation ¶
type OutboundStatus ¶
type OutboundStatus struct {
// @Document Whether this outbound is usable
// @Restriction ReadOnlyForUser
Alive bool `protobuf:"varint,1,opt,name=alive,proto3" json:"alive,omitempty"`
// @Document The time for probe request to finish.
// @Type time.ms
// @Restriction ReadOnlyForUser
Delay int64 `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
// @Document The last error caused this outbound failed to relay probe request
// @Restriction NotMachineReadable
LastErrorReason string `protobuf:"bytes,3,opt,name=last_error_reason,json=lastErrorReason,proto3" json:"last_error_reason,omitempty"`
// @Document The outbound tag for this Server
// @Type id.outboundTag
OutboundTag string `protobuf:"bytes,4,opt,name=outbound_tag,json=outboundTag,proto3" json:"outbound_tag,omitempty"`
// @Document The time this outbound is known to be alive
// @Type id.outboundTag
LastSeenTime int64 `protobuf:"varint,5,opt,name=last_seen_time,json=lastSeenTime,proto3" json:"last_seen_time,omitempty"`
// @Document The time this outbound is tried
// @Type id.outboundTag
LastTryTime int64 `protobuf:"varint,6,opt,name=last_try_time,json=lastTryTime,proto3" json:"last_try_time,omitempty"`
// contains filtered or unexported fields
}
func (*OutboundStatus) Descriptor
deprecated
func (*OutboundStatus) Descriptor() ([]byte, []int)
Deprecated: Use OutboundStatus.ProtoReflect.Descriptor instead.
func (*OutboundStatus) GetAlive ¶
func (x *OutboundStatus) GetAlive() bool
func (*OutboundStatus) GetDelay ¶
func (x *OutboundStatus) GetDelay() int64
func (*OutboundStatus) GetLastErrorReason ¶
func (x *OutboundStatus) GetLastErrorReason() string
func (*OutboundStatus) GetLastSeenTime ¶
func (x *OutboundStatus) GetLastSeenTime() int64
func (*OutboundStatus) GetLastTryTime ¶
func (x *OutboundStatus) GetLastTryTime() int64
func (*OutboundStatus) GetOutboundTag ¶
func (x *OutboundStatus) GetOutboundTag() string
func (*OutboundStatus) ProtoMessage ¶
func (*OutboundStatus) ProtoMessage()
func (*OutboundStatus) ProtoReflect ¶
func (x *OutboundStatus) ProtoReflect() protoreflect.Message
func (*OutboundStatus) Reset ¶
func (x *OutboundStatus) Reset()
func (*OutboundStatus) String ¶
func (x *OutboundStatus) String() string
type ProbeResult ¶
type ProbeResult struct {
// @Document Whether this outbound is usable
// @Restriction ReadOnlyForUser
Alive bool `protobuf:"varint,1,opt,name=alive,proto3" json:"alive,omitempty"`
// @Document The time for probe request to finish.
// @Type time.ms
// @Restriction ReadOnlyForUser
Delay int64 `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
// @Document The error caused this outbound failed to relay probe request
// @Restriction NotMachineReadable
LastErrorReason string `protobuf:"bytes,3,opt,name=last_error_reason,json=lastErrorReason,proto3" json:"last_error_reason,omitempty"`
// contains filtered or unexported fields
}
func (*ProbeResult) Descriptor
deprecated
func (*ProbeResult) Descriptor() ([]byte, []int)
Deprecated: Use ProbeResult.ProtoReflect.Descriptor instead.
func (*ProbeResult) GetAlive ¶
func (x *ProbeResult) GetAlive() bool
func (*ProbeResult) GetDelay ¶
func (x *ProbeResult) GetDelay() int64
func (*ProbeResult) GetLastErrorReason ¶
func (x *ProbeResult) GetLastErrorReason() string
func (*ProbeResult) ProtoMessage ¶
func (*ProbeResult) ProtoMessage()
func (*ProbeResult) ProtoReflect ¶
func (x *ProbeResult) ProtoReflect() protoreflect.Message
func (*ProbeResult) Reset ¶
func (x *ProbeResult) Reset()
func (*ProbeResult) String ¶
func (x *ProbeResult) String() string
Source Files
¶
Click to show internal directories.
Click to hide internal directories.