api_v1

type AdaptiveSampling struct {
	SamplingRate float64 `protobuf:"fixed64,1,opt,name=samplingRate,proto3" json:"samplingRate,omitempty"`
	// contains filtered or unexported fields
}

type ConstSampling struct {
	AlwaysSample bool `protobuf:"varint,1,opt,name=alwaysSample,proto3" json:"alwaysSample,omitempty"`
	// contains filtered or unexported fields
}

type DynamicSampling struct {
	SamplingRate float64 `protobuf:"fixed64,1,opt,name=samplingRate,proto3" json:"samplingRate,omitempty"`
	// contains filtered or unexported fields
}

type EvaluatingTag struct {
	TagName       string                      `protobuf:"bytes,1,opt,name=tagName,proto3" json:"tagName,omitempty"`
	OperationType EvaluatingTag_OperationType `protobuf:"varint,2,opt,name=operationType,proto3,enum=houyi.EvaluatingTag_OperationType" json:"operationType,omitempty"`
	ValueType     EvaluatingTag_ValueType     `protobuf:"varint,3,opt,name=valueType,proto3,enum=houyi.EvaluatingTag_ValueType" json:"valueType,omitempty"`
	// Types that are assignable to Value:
	//	*EvaluatingTag_IntegerVal
	//	*EvaluatingTag_FloatVal
	//	*EvaluatingTag_BooleanVal
	//	*EvaluatingTag_StringVal
	Value isEvaluatingTag_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type EvaluatingTag_BooleanVal struct {
	BooleanVal bool `protobuf:"varint,6,opt,name=booleanVal,proto3,oneof"`
}

type EvaluatingTag_FloatVal struct {
	FloatVal float64 `protobuf:"fixed64,5,opt,name=floatVal,proto3,oneof"`
}

type EvaluatingTag_IntegerVal struct {
	IntegerVal int64 `protobuf:"varint,4,opt,name=integerVal,proto3,oneof"`
}

type EvaluatingTag_OperationType int32

type EvaluatingTag_StringVal struct {
	StringVal string `protobuf:"bytes,7,opt,name=stringVal,proto3,oneof"`
}

type EvaluatingTag_ValueType int32

type EvaluatingTags struct {
	Tags []*EvaluatingTag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type EvaluatorManagerClient interface {
	UpdateTags(ctx context.Context, in *UpdateTagsRequest, opts ...grpc.CallOption) (*NullRely, error)
}

type EvaluatorManagerServer interface {
	UpdateTags(context.Context, *UpdateTagsRequest) (*NullRely, error)
	// contains filtered or unexported methods
}

type HeartbeatReply struct {
	NodeId int64   `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Peers  []*Peer `protobuf:"bytes,3,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatRequest struct {
	NodeId int64  `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Port   int64  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Ip     string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {
	MsgId   int64               `protobuf:"varint,1,opt,name=msgId,proto3" json:"msgId,omitempty"`
	MsgType Message_MessageType `protobuf:"varint,2,opt,name=msgType,proto3,enum=gossip.Message_MessageType" json:"msgType,omitempty"`
	// Types that are assignable to Msg:
	//	*Message_Operation
	//	*Message_Relation
	//	*Message_EvaluateTags
	Msg isMessage_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

type Message_EvaluateTags struct {
	EvaluateTags *EvaluatingTags `protobuf:"bytes,5,opt,name=evaluateTags,proto3,oneof"`
}

type Message_MessageType int32

type Message_Operation struct {
	Operation *Operation `protobuf:"bytes,3,opt,name=operation,proto3,oneof"`
}

type Message_Relation struct {
	Relation *Relation `protobuf:"bytes,4,opt,name=relation,proto3,oneof"`
}

type NullRely struct {
	// contains filtered or unexported fields
}

type NullReply struct {
	// contains filtered or unexported fields
}

type Operation struct {
	Service   string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type Peer struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port int64  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type PerOperationStrategy struct {
	Service   string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Operation string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	Type      Type   `protobuf:"varint,3,opt,name=type,proto3,enum=sampling.Type" json:"type,omitempty"`
	// Types that are assignable to Strategy:
	//	*PerOperationStrategy_Const
	//	*PerOperationStrategy_Probability
	//	*PerOperationStrategy_RateLimiting
	//	*PerOperationStrategy_Adaptive
	//	*PerOperationStrategy_Dynamic
	Strategy isPerOperationStrategy_Strategy `protobuf_oneof:"strategy"`
	// contains filtered or unexported fields
}

type PerOperationStrategy_Adaptive struct {
	Adaptive *AdaptiveSampling `protobuf:"bytes,7,opt,name=adaptive,proto3,oneof"`
}

type PerOperationStrategy_Const struct {
	Const *ConstSampling `protobuf:"bytes,4,opt,name=const,proto3,oneof"`
}

type PerOperationStrategy_Dynamic struct {
	Dynamic *DynamicSampling `protobuf:"bytes,8,opt,name=dynamic,proto3,oneof"`
}

type PerOperationStrategy_Probability struct {
	Probability *ProbabilitySampling `protobuf:"bytes,5,opt,name=probability,proto3,oneof"`
}

type PerOperationStrategy_RateLimiting struct {
	RateLimiting *RateLimitingSampling `protobuf:"bytes,6,opt,name=rateLimiting,proto3,oneof"`
}

type ProbabilitySampling struct {
	SamplingRate float64 `protobuf:"fixed64,1,opt,name=samplingRate,proto3" json:"samplingRate,omitempty"`
	// contains filtered or unexported fields
}

type RateLimitingSampling struct {
	MaxTracesPerSecond int64 `protobuf:"varint,1,opt,name=maxTracesPerSecond,proto3" json:"maxTracesPerSecond,omitempty"`
	// contains filtered or unexported fields
}

type RegisterRely struct {
	NodeId     int64   `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Interval   int64   `protobuf:"varint,2,opt,name=interval,proto3" json:"interval,omitempty"`
	RandomPick int64   `protobuf:"varint,3,opt,name=randomPick,proto3" json:"randomPick,omitempty"`
	ProbToR    float64 `protobuf:"fixed64,4,opt,name=probToR,proto3" json:"probToR,omitempty"`
	// contains filtered or unexported fields
}

type RegisterRequest struct {
	Port int64  `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Ip   string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

type RegistryClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterRely, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatReply, error)
}

type RegistryServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterRely, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatReply, error)
	// contains filtered or unexported methods
}

type Relation struct {
	From *Operation `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To   *Operation `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

type SeedClient interface {
	Sync(ctx context.Context, in *Message, opts ...grpc.CallOption) (*NullReply, error)
}

type SeedServer interface {
	Sync(context.Context, *Message) (*NullReply, error)
	// contains filtered or unexported methods
}

type StrategiesResponse struct {
	Strategies []*PerOperationStrategy `protobuf:"bytes,1,rep,name=strategies,proto3" json:"strategies,omitempty"`
	// contains filtered or unexported fields
}

type StrategyManagerClient interface {
	GetStrategies(ctx context.Context, in *StrategyRequest, opts ...grpc.CallOption) (*StrategiesResponse, error)
	Promote(ctx context.Context, in *Operation, opts ...grpc.CallOption) (*NullRely, error)
}

type StrategyManagerServer interface {
	GetStrategies(context.Context, *StrategyRequest) (*StrategiesResponse, error)
	Promote(context.Context, *Operation) (*NullRely, error)
	// contains filtered or unexported methods
}

type StrategyRequest struct {
	Service    string                       `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Operations []*StrategyRequest_Operation `protobuf:"bytes,3,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

type StrategyRequest_Operation struct {
	Name string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Qps  float64 `protobuf:"fixed64,2,opt,name=qps,proto3" json:"qps,omitempty"`
	// contains filtered or unexported fields
}

type Type int32

type UnimplementedEvaluatorManagerServer struct {
}

type UnimplementedRegistryServer struct {
}

type UnimplementedSeedServer struct {
}

type UnimplementedStrategyManagerServer struct {
}

type UnsafeEvaluatorManagerServer interface {
	// contains filtered or unexported methods
}

type UnsafeRegistryServer interface {
	// contains filtered or unexported methods
}

type UnsafeSeedServer interface {
	// contains filtered or unexported methods
}

type UnsafeStrategyManagerServer interface {
	// contains filtered or unexported methods
}

type UpdateTagsRequest struct {
	Tags []*EvaluatingTag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}