burst

Apr 12, 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{}