1
0
mirror of https://github.com/v2fly/v2ray-core.git synced 2024-12-22 18:17:52 -05:00
v2fly/app/observatory/multiobservatory/multi.go
2022-01-02 15:16:23 +00:00

48 lines
1.3 KiB
Go

package multiobservatory
import (
"context"
"github.com/golang/protobuf/jsonpb"
"github.com/golang/protobuf/proto"
"github.com/v2fly/v2ray-core/v5/common"
"github.com/v2fly/v2ray-core/v5/common/taggedfeatures"
"github.com/v2fly/v2ray-core/v5/features"
"github.com/v2fly/v2ray-core/v5/features/extension"
)
type Observer struct {
features.TaggedFeatures
config *Config
ctx context.Context
}
func (o Observer) GetObservation(ctx context.Context) (proto.Message, error) {
return common.Must2(o.GetFeaturesByTag("")).(extension.Observatory).GetObservation(ctx)
}
func (o Observer) Type() interface{} {
return extension.ObservatoryType()
}
func New(ctx context.Context, config *Config) (*Observer, error) {
holder, err := taggedfeatures.NewHolderFromConfig(ctx, config.Holders, extension.ObservatoryType())
if err != nil {
return nil, err
}
return &Observer{config: config, ctx: ctx, TaggedFeatures: holder}, nil
}
func (x *Config) UnmarshalJSONPB(unmarshaler *jsonpb.Unmarshaler, bytes []byte) error {
var err error
x.Holders, err = taggedfeatures.LoadJSONConfig(context.TODO(), "service", "background", bytes)
return err
}
func init() {
common.Must(common.RegisterConfig((*Config)(nil), func(ctx context.Context, config interface{}) (interface{}, error) {
return New(ctx, config.(*Config))
}))
}