pivot

package
v0.1.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 8, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_protobuf_pivot_proto protoreflect.FileDescriptor
View Source 
var PivotService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.PivotService",
	HandlerType: (*PivotServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "collectStatisticsInfo",
			Handler:    _PivotService_CollectStatisticsInfo_Handler,
		},
		{
			MethodName: "collectException",
			Handler:    _PivotService_CollectException_Handler,
		},
		{
			MethodName: "collectWarn",
			Handler:    _PivotService_CollectWarn_Handler,
		},
		{
			MethodName: "collectEvent",
			Handler:    _PivotService_CollectEvent_Handler,
		},
		{
			MethodName: "collectTracer",
			Handler:    _PivotService_CollectTracer_Handler,
		},
		{
			MethodName: "collectLog",
			Handler:    _PivotService_CollectLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protobuf/pivot.proto",
}

PivotService_ServiceDesc is the grpc.ServiceDesc for PivotService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPivotServiceServer 

func RegisterPivotServiceServer(s grpc.ServiceRegistrar, srv PivotServiceServer)

Types

type AuditLogInfoRequest 

type AuditLogInfoRequest struct {
	AppName    string   `protobuf:"bytes,1,opt,name=appName,proto3" json:"appName,omitempty"`
	LogName    string   `protobuf:"bytes,2,opt,name=logName,proto3" json:"logName,omitempty"`
	LogMsgList []string `protobuf:"bytes,3,rep,name=logMsgList,proto3" json:"logMsgList,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditLogInfoRequest) Descriptor deprecated 

func (*AuditLogInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuditLogInfoRequest.ProtoReflect.Descriptor instead.

func (*AuditLogInfoRequest) GetAppName 

func (x *AuditLogInfoRequest) GetAppName() string

func (*AuditLogInfoRequest) GetLogMsgList 

func (x *AuditLogInfoRequest) GetLogMsgList() []string

func (*AuditLogInfoRequest) GetLogName 

func (x *AuditLogInfoRequest) GetLogName() string

func (*AuditLogInfoRequest) ProtoMessage 

func (*AuditLogInfoRequest) ProtoMessage()

func (*AuditLogInfoRequest) ProtoReflect 

func (x *AuditLogInfoRequest) ProtoReflect() protoreflect.Message

func (*AuditLogInfoRequest) Reset 

func (x *AuditLogInfoRequest) Reset()

func (*AuditLogInfoRequest) String 

func (x *AuditLogInfoRequest) String() string

type DefaultEventRequest 

type DefaultEventRequest struct {

	//AbstractBaseInfo
	Passport       string `protobuf:"bytes,1,opt,name=passport,proto3" json:"passport,omitempty"`
	ProfilesActive string `protobuf:"bytes,2,opt,name=profilesActive,proto3" json:"profilesActive,omitempty"`
	Namespace      string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AppName        string `protobuf:"bytes,4,opt,name=appName,proto3" json:"appName,omitempty"`
	Ip             string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	ResourceName   string `protobuf:"bytes,6,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	RemoteAppName  string `protobuf:"bytes,7,opt,name=remoteAppName,proto3" json:"remoteAppName,omitempty"`
	RemoteIp       string `protobuf:"bytes,8,opt,name=remoteIp,proto3" json:"remoteIp,omitempty"`
	ResourceType   string `protobuf:"bytes,9,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	DataType       string `protobuf:"bytes,10,opt,name=dataType,proto3" json:"dataType,omitempty"`
	IsServer       bool   `protobuf:"varint,11,opt,name=isServer,proto3" json:"isServer,omitempty"`
	Perf           bool   `protobuf:"varint,12,opt,name=perf,proto3" json:"perf,omitempty"`
	Timestamp      int64  `protobuf:"varint,13,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CurrentMin     int64  `protobuf:"varint,14,opt,name=currentMin,proto3" json:"currentMin,omitempty"`
	// AbstractEvent
	Code       string            `protobuf:"bytes,15,opt,name=code,proto3" json:"code,omitempty"`
	TraceId    string            `protobuf:"bytes,16,opt,name=traceId,proto3" json:"traceId,omitempty"`
	EventType  string            `protobuf:"bytes,17,opt,name=eventType,proto3" json:"eventType,omitempty"`
	EventLevel string            `protobuf:"bytes,18,opt,name=eventLevel,proto3" json:"eventLevel,omitempty"`
	AttrMap    map[string]string `` /* 156-byte string literal not displayed */
	Merge      int32             `protobuf:"varint,20,opt,name=merge,proto3" json:"merge,omitempty"`
	//DefaultEvent
	Message string `protobuf:"bytes,21,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultEventRequest) Descriptor deprecated 

func (*DefaultEventRequest) Descriptor() ([]byte, []int)

Deprecated: Use DefaultEventRequest.ProtoReflect.Descriptor instead.

func (*DefaultEventRequest) GetAppName 

func (x *DefaultEventRequest) GetAppName() string

func (*DefaultEventRequest) GetAttrMap 

func (x *DefaultEventRequest) GetAttrMap() map[string]string

func (*DefaultEventRequest) GetCode 

func (x *DefaultEventRequest) GetCode() string

func (*DefaultEventRequest) GetCurrentMin 

func (x *DefaultEventRequest) GetCurrentMin() int64

func (*DefaultEventRequest) GetDataType 

func (x *DefaultEventRequest) GetDataType() string

func (*DefaultEventRequest) GetEventLevel 

func (x *DefaultEventRequest) GetEventLevel() string

func (*DefaultEventRequest) GetEventType 

func (x *DefaultEventRequest) GetEventType() string

func (*DefaultEventRequest) GetIp 

func (x *DefaultEventRequest) GetIp() string

func (*DefaultEventRequest) GetIsServer 

func (x *DefaultEventRequest) GetIsServer() bool

func (*DefaultEventRequest) GetMerge 

func (x *DefaultEventRequest) GetMerge() int32

func (*DefaultEventRequest) GetMessage 

func (x *DefaultEventRequest) GetMessage() string

func (*DefaultEventRequest) GetNamespace 

func (x *DefaultEventRequest) GetNamespace() string

func (*DefaultEventRequest) GetPassport 

func (x *DefaultEventRequest) GetPassport() string

func (*DefaultEventRequest) GetPerf 

func (x *DefaultEventRequest) GetPerf() bool

func (*DefaultEventRequest) GetProfilesActive 

func (x *DefaultEventRequest) GetProfilesActive() string

func (*DefaultEventRequest) GetRemoteAppName 

func (x *DefaultEventRequest) GetRemoteAppName() string

func (*DefaultEventRequest) GetRemoteIp 

func (x *DefaultEventRequest) GetRemoteIp() string

func (*DefaultEventRequest) GetResourceName 

func (x *DefaultEventRequest) GetResourceName() string

func (*DefaultEventRequest) GetResourceType 

func (x *DefaultEventRequest) GetResourceType() string

func (*DefaultEventRequest) GetTimestamp 

func (x *DefaultEventRequest) GetTimestamp() int64

func (*DefaultEventRequest) GetTraceId 

func (x *DefaultEventRequest) GetTraceId() string

func (*DefaultEventRequest) ProtoMessage 

func (*DefaultEventRequest) ProtoMessage()

func (*DefaultEventRequest) ProtoReflect 

func (x *DefaultEventRequest) ProtoReflect() protoreflect.Message

func (*DefaultEventRequest) Reset 

func (x *DefaultEventRequest) Reset()

func (*DefaultEventRequest) String 

func (x *DefaultEventRequest) String() string

type ExceptionEventRequest 

type ExceptionEventRequest struct {

	//AbstractBaseInfo
	Passport       string `protobuf:"bytes,1,opt,name=passport,proto3" json:"passport,omitempty"`
	ProfilesActive string `protobuf:"bytes,2,opt,name=profilesActive,proto3" json:"profilesActive,omitempty"`
	Namespace      string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AppName        string `protobuf:"bytes,4,opt,name=appName,proto3" json:"appName,omitempty"`
	Ip             string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	ResourceName   string `protobuf:"bytes,6,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	RemoteAppName  string `protobuf:"bytes,7,opt,name=remoteAppName,proto3" json:"remoteAppName,omitempty"`
	RemoteIp       string `protobuf:"bytes,8,opt,name=remoteIp,proto3" json:"remoteIp,omitempty"`
	ResourceType   string `protobuf:"bytes,9,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	DataType       string `protobuf:"bytes,10,opt,name=dataType,proto3" json:"dataType,omitempty"`
	IsServer       bool   `protobuf:"varint,11,opt,name=isServer,proto3" json:"isServer,omitempty"`
	Perf           bool   `protobuf:"varint,12,opt,name=perf,proto3" json:"perf,omitempty"`
	Timestamp      int64  `protobuf:"varint,13,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CurrentMin     int64  `protobuf:"varint,14,opt,name=currentMin,proto3" json:"currentMin,omitempty"`
	// AbstractEvent
	Code       string            `protobuf:"bytes,15,opt,name=code,proto3" json:"code,omitempty"`
	TraceId    string            `protobuf:"bytes,16,opt,name=traceId,proto3" json:"traceId,omitempty"`
	EventType  string            `protobuf:"bytes,17,opt,name=eventType,proto3" json:"eventType,omitempty"`
	EventLevel string            `protobuf:"bytes,18,opt,name=eventLevel,proto3" json:"eventLevel,omitempty"`
	AttrMap    map[string]string `` /* 156-byte string literal not displayed */
	Merge      int32             `protobuf:"varint,20,opt,name=merge,proto3" json:"merge,omitempty"`
	//ExceptionEvent
	ExceptionMsg string `protobuf:"bytes,21,opt,name=exceptionMsg,proto3" json:"exceptionMsg,omitempty"`
	Rt           int64  `protobuf:"varint,22,opt,name=rt,proto3" json:"rt,omitempty"`
	Context      string `protobuf:"bytes,23,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*ExceptionEventRequest) Descriptor deprecated 

func (*ExceptionEventRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExceptionEventRequest.ProtoReflect.Descriptor instead.

func (*ExceptionEventRequest) GetAppName 

func (x *ExceptionEventRequest) GetAppName() string

func (*ExceptionEventRequest) GetAttrMap 

func (x *ExceptionEventRequest) GetAttrMap() map[string]string

func (*ExceptionEventRequest) GetCode 

func (x *ExceptionEventRequest) GetCode() string

func (*ExceptionEventRequest) GetContext 

func (x *ExceptionEventRequest) GetContext() string

func (*ExceptionEventRequest) GetCurrentMin 

func (x *ExceptionEventRequest) GetCurrentMin() int64

func (*ExceptionEventRequest) GetDataType 

func (x *ExceptionEventRequest) GetDataType() string

func (*ExceptionEventRequest) GetEventLevel 

func (x *ExceptionEventRequest) GetEventLevel() string

func (*ExceptionEventRequest) GetEventType 

func (x *ExceptionEventRequest) GetEventType() string

func (*ExceptionEventRequest) GetExceptionMsg 

func (x *ExceptionEventRequest) GetExceptionMsg() string

func (*ExceptionEventRequest) GetIp 

func (x *ExceptionEventRequest) GetIp() string

func (*ExceptionEventRequest) GetIsServer 

func (x *ExceptionEventRequest) GetIsServer() bool

func (*ExceptionEventRequest) GetMerge 

func (x *ExceptionEventRequest) GetMerge() int32

func (*ExceptionEventRequest) GetNamespace 

func (x *ExceptionEventRequest) GetNamespace() string

func (*ExceptionEventRequest) GetPassport 

func (x *ExceptionEventRequest) GetPassport() string

func (*ExceptionEventRequest) GetPerf 

func (x *ExceptionEventRequest) GetPerf() bool

func (*ExceptionEventRequest) GetProfilesActive 

func (x *ExceptionEventRequest) GetProfilesActive() string

func (*ExceptionEventRequest) GetRemoteAppName 

func (x *ExceptionEventRequest) GetRemoteAppName() string

func (*ExceptionEventRequest) GetRemoteIp 

func (x *ExceptionEventRequest) GetRemoteIp() string

func (*ExceptionEventRequest) GetResourceName 

func (x *ExceptionEventRequest) GetResourceName() string

func (*ExceptionEventRequest) GetResourceType 

func (x *ExceptionEventRequest) GetResourceType() string

func (*ExceptionEventRequest) GetRt 

func (x *ExceptionEventRequest) GetRt() int64

func (*ExceptionEventRequest) GetTimestamp 

func (x *ExceptionEventRequest) GetTimestamp() int64

func (*ExceptionEventRequest) GetTraceId 

func (x *ExceptionEventRequest) GetTraceId() string

func (*ExceptionEventRequest) ProtoMessage 

func (*ExceptionEventRequest) ProtoMessage()

func (*ExceptionEventRequest) ProtoReflect 

func (x *ExceptionEventRequest) ProtoReflect() protoreflect.Message

func (*ExceptionEventRequest) Reset 

func (x *ExceptionEventRequest) Reset()

func (*ExceptionEventRequest) String 

func (x *ExceptionEventRequest) String() string

type MetricTxnRequest 

type MetricTxnRequest struct {

	//AbstractBaseInfo
	Passport       string `protobuf:"bytes,1,opt,name=passport,proto3" json:"passport,omitempty"`
	ProfilesActive string `protobuf:"bytes,2,opt,name=profilesActive,proto3" json:"profilesActive,omitempty"`
	Namespace      string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AppName        string `protobuf:"bytes,4,opt,name=appName,proto3" json:"appName,omitempty"`
	Ip             string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	ResourceName   string `protobuf:"bytes,6,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	RemoteAppName  string `protobuf:"bytes,7,opt,name=remoteAppName,proto3" json:"remoteAppName,omitempty"`
	RemoteIp       string `protobuf:"bytes,8,opt,name=remoteIp,proto3" json:"remoteIp,omitempty"`
	ResourceType   string `protobuf:"bytes,9,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	DataType       string `protobuf:"bytes,10,opt,name=dataType,proto3" json:"dataType,omitempty"`
	IsServer       bool   `protobuf:"varint,11,opt,name=isServer,proto3" json:"isServer,omitempty"`
	Perf           bool   `protobuf:"varint,12,opt,name=perf,proto3" json:"perf,omitempty"`
	Timestamp      int64  `protobuf:"varint,13,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CurrentMin     int64  `protobuf:"varint,14,opt,name=currentMin,proto3" json:"currentMin,omitempty"`
	//MetricTxn
	Success         int64                `protobuf:"varint,15,opt,name=success,proto3" json:"success,omitempty"`
	Exception       int64                `protobuf:"varint,16,opt,name=exception,proto3" json:"exception,omitempty"`
	Warn            int64                `protobuf:"varint,17,opt,name=warn,proto3" json:"warn,omitempty"`
	TotalRt         int64                `protobuf:"varint,18,opt,name=totalRt,proto3" json:"totalRt,omitempty"`
	GovernanceEvent int64                `protobuf:"varint,19,opt,name=governanceEvent,proto3" json:"governanceEvent,omitempty"`
	AvgRt           int64                `protobuf:"varint,20,opt,name=avgRt,proto3" json:"avgRt,omitempty"`
	MaxRt           int64                `protobuf:"varint,21,opt,name=maxRt,proto3" json:"maxRt,omitempty"`
	MinRt           int64                `protobuf:"varint,22,opt,name=minRt,proto3" json:"minRt,omitempty"`
	IntervalIndex   int32                `protobuf:"varint,23,opt,name=intervalIndex,proto3" json:"intervalIndex,omitempty"`
	RtIntervals     []*RtIntervalRequest `protobuf:"bytes,24,rep,name=rtIntervals,proto3" json:"rtIntervals,omitempty"`
	RtWave          *RtWaveRequest       `protobuf:"bytes,25,opt,name=rtWave,proto3" json:"rtWave,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricTxnRequest) Descriptor deprecated 

func (*MetricTxnRequest) Descriptor() ([]byte, []int)

Deprecated: Use MetricTxnRequest.ProtoReflect.Descriptor instead.

func (*MetricTxnRequest) GetAppName 

func (x *MetricTxnRequest) GetAppName() string

func (*MetricTxnRequest) GetAvgRt 

func (x *MetricTxnRequest) GetAvgRt() int64

func (*MetricTxnRequest) GetCurrentMin 

func (x *MetricTxnRequest) GetCurrentMin() int64

func (*MetricTxnRequest) GetDataType 

func (x *MetricTxnRequest) GetDataType() string

func (*MetricTxnRequest) GetException 

func (x *MetricTxnRequest) GetException() int64

func (*MetricTxnRequest) GetGovernanceEvent 

func (x *MetricTxnRequest) GetGovernanceEvent() int64

func (*MetricTxnRequest) GetIntervalIndex 

func (x *MetricTxnRequest) GetIntervalIndex() int32

func (*MetricTxnRequest) GetIp 

func (x *MetricTxnRequest) GetIp() string

func (*MetricTxnRequest) GetIsServer 

func (x *MetricTxnRequest) GetIsServer() bool

func (*MetricTxnRequest) GetMaxRt 

func (x *MetricTxnRequest) GetMaxRt() int64

func (*MetricTxnRequest) GetMinRt 

func (x *MetricTxnRequest) GetMinRt() int64

func (*MetricTxnRequest) GetNamespace 

func (x *MetricTxnRequest) GetNamespace() string

func (*MetricTxnRequest) GetPassport 

func (x *MetricTxnRequest) GetPassport() string

func (*MetricTxnRequest) GetPerf 

func (x *MetricTxnRequest) GetPerf() bool

func (*MetricTxnRequest) GetProfilesActive 

func (x *MetricTxnRequest) GetProfilesActive() string

func (*MetricTxnRequest) GetRemoteAppName 

func (x *MetricTxnRequest) GetRemoteAppName() string

func (*MetricTxnRequest) GetRemoteIp 

func (x *MetricTxnRequest) GetRemoteIp() string

func (*MetricTxnRequest) GetResourceName 

func (x *MetricTxnRequest) GetResourceName() string

func (*MetricTxnRequest) GetResourceType 

func (x *MetricTxnRequest) GetResourceType() string

func (*MetricTxnRequest) GetRtIntervals 

func (x *MetricTxnRequest) GetRtIntervals() []*RtIntervalRequest

func (*MetricTxnRequest) GetRtWave 

func (x *MetricTxnRequest) GetRtWave() *RtWaveRequest

func (*MetricTxnRequest) GetSuccess 

func (x *MetricTxnRequest) GetSuccess() int64

func (*MetricTxnRequest) GetTimestamp 

func (x *MetricTxnRequest) GetTimestamp() int64

func (*MetricTxnRequest) GetTotalRt 

func (x *MetricTxnRequest) GetTotalRt() int64

func (*MetricTxnRequest) GetWarn 

func (x *MetricTxnRequest) GetWarn() int64

func (*MetricTxnRequest) ProtoMessage 

func (*MetricTxnRequest) ProtoMessage()

func (*MetricTxnRequest) ProtoReflect 

func (x *MetricTxnRequest) ProtoReflect() protoreflect.Message

func (*MetricTxnRequest) Reset 

func (x *MetricTxnRequest) Reset()

func (*MetricTxnRequest) String 

func (x *MetricTxnRequest) String() string

type PivotServiceClient 

type PivotServiceClient interface {
	CollectStatisticsInfo(ctx context.Context, in *StatisticInfoRequest, opts ...grpc.CallOption) (*Response, error)
	CollectException(ctx context.Context, in *ExceptionEventRequest, opts ...grpc.CallOption) (*Response, error)
	CollectWarn(ctx context.Context, in *WarnEventRequest, opts ...grpc.CallOption) (*Response, error)
	CollectEvent(ctx context.Context, in *DefaultEventRequest, opts ...grpc.CallOption) (*Response, error)
	CollectTracer(ctx context.Context, in *TraceLogRequest, opts ...grpc.CallOption) (*Response, error)
	CollectLog(ctx context.Context, in *AuditLogInfoRequest, opts ...grpc.CallOption) (*Response, error)
}

PivotServiceClient is the client API for PivotService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPivotServiceClient 

func NewPivotServiceClient(cc grpc.ClientConnInterface) PivotServiceClient

type PivotServiceServer 

type PivotServiceServer interface {
	CollectStatisticsInfo(context.Context, *StatisticInfoRequest) (*Response, error)
	CollectException(context.Context, *ExceptionEventRequest) (*Response, error)
	CollectWarn(context.Context, *WarnEventRequest) (*Response, error)
	CollectEvent(context.Context, *DefaultEventRequest) (*Response, error)
	CollectTracer(context.Context, *TraceLogRequest) (*Response, error)
	CollectLog(context.Context, *AuditLogInfoRequest) (*Response, error)
	// contains filtered or unexported methods
}

PivotServiceServer is the server API for PivotService service. All implementations must embed UnimplementedPivotServiceServer for forward compatibility

type Response 

type Response struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCode 

func (x *Response) GetCode() int32

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type RtIntervalRequest 

type RtIntervalRequest struct {
	MinValue     int64  `protobuf:"varint,1,opt,name=minValue,proto3" json:"minValue,omitempty"`
	MaxValue     int64  `protobuf:"varint,2,opt,name=maxValue,proto3" json:"maxValue,omitempty"`
	IntervalName string `protobuf:"bytes,3,opt,name=intervalName,proto3" json:"intervalName,omitempty"`
	RtCounter    int64  `protobuf:"varint,4,opt,name=rtCounter,proto3" json:"rtCounter,omitempty"`
	// contains filtered or unexported fields
}

func (*RtIntervalRequest) Descriptor deprecated 

func (*RtIntervalRequest) Descriptor() ([]byte, []int)

Deprecated: Use RtIntervalRequest.ProtoReflect.Descriptor instead.

func (*RtIntervalRequest) GetIntervalName 

func (x *RtIntervalRequest) GetIntervalName() string

func (*RtIntervalRequest) GetMaxValue 

func (x *RtIntervalRequest) GetMaxValue() int64

func (*RtIntervalRequest) GetMinValue 

func (x *RtIntervalRequest) GetMinValue() int64

func (*RtIntervalRequest) GetRtCounter 

func (x *RtIntervalRequest) GetRtCounter() int64

func (*RtIntervalRequest) ProtoMessage 

func (*RtIntervalRequest) ProtoMessage()

func (*RtIntervalRequest) ProtoReflect 

func (x *RtIntervalRequest) ProtoReflect() protoreflect.Message

func (*RtIntervalRequest) Reset 

func (x *RtIntervalRequest) Reset()

func (*RtIntervalRequest) String 

func (x *RtIntervalRequest) String() string

type RtWaveRequest 

type RtWaveRequest struct {
	MaxRt     int64  `protobuf:"varint,1,opt,name=maxRt,proto3" json:"maxRt,omitempty"`
	MaxRtTime int64  `protobuf:"varint,2,opt,name=maxRtTime,proto3" json:"maxRtTime,omitempty"`
	TraceId   string `protobuf:"bytes,3,opt,name=traceId,proto3" json:"traceId,omitempty"`
	// contains filtered or unexported fields
}

func (*RtWaveRequest) Descriptor deprecated 

func (*RtWaveRequest) Descriptor() ([]byte, []int)

Deprecated: Use RtWaveRequest.ProtoReflect.Descriptor instead.

func (*RtWaveRequest) GetMaxRt 

func (x *RtWaveRequest) GetMaxRt() int64

func (*RtWaveRequest) GetMaxRtTime 

func (x *RtWaveRequest) GetMaxRtTime() int64

func (*RtWaveRequest) GetTraceId 

func (x *RtWaveRequest) GetTraceId() string

func (*RtWaveRequest) ProtoMessage 

func (*RtWaveRequest) ProtoMessage()

func (*RtWaveRequest) ProtoReflect 

func (x *RtWaveRequest) ProtoReflect() protoreflect.Message

func (*RtWaveRequest) Reset 

func (x *RtWaveRequest) Reset()

func (*RtWaveRequest) String 

func (x *RtWaveRequest) String() string

type StatisticInfoRequest 

type StatisticInfoRequest struct {
	Passport       string              `protobuf:"bytes,1,opt,name=passport,proto3" json:"passport,omitempty"`
	ProfilesActive string              `protobuf:"bytes,2,opt,name=profilesActive,proto3" json:"profilesActive,omitempty"`
	Namespace      string              `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AppName        string              `protobuf:"bytes,4,opt,name=appName,proto3" json:"appName,omitempty"`
	Ip             string              `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	MetricTxns     []*MetricTxnRequest `protobuf:"bytes,6,rep,name=metricTxns,proto3" json:"metricTxns,omitempty"`
	Timestamp      int64               `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticInfoRequest) Descriptor deprecated 

func (*StatisticInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatisticInfoRequest.ProtoReflect.Descriptor instead.

func (*StatisticInfoRequest) GetAppName 

func (x *StatisticInfoRequest) GetAppName() string

func (*StatisticInfoRequest) GetIp 

func (x *StatisticInfoRequest) GetIp() string

func (*StatisticInfoRequest) GetMetricTxns 

func (x *StatisticInfoRequest) GetMetricTxns() []*MetricTxnRequest

func (*StatisticInfoRequest) GetNamespace 

func (x *StatisticInfoRequest) GetNamespace() string

func (*StatisticInfoRequest) GetPassport 

func (x *StatisticInfoRequest) GetPassport() string

func (*StatisticInfoRequest) GetProfilesActive 

func (x *StatisticInfoRequest) GetProfilesActive() string

func (*StatisticInfoRequest) GetTimestamp 

func (x *StatisticInfoRequest) GetTimestamp() int64

func (*StatisticInfoRequest) ProtoMessage 

func (*StatisticInfoRequest) ProtoMessage()

func (*StatisticInfoRequest) ProtoReflect 

func (x *StatisticInfoRequest) ProtoReflect() protoreflect.Message

func (*StatisticInfoRequest) Reset 

func (x *StatisticInfoRequest) Reset()

func (*StatisticInfoRequest) String 

func (x *StatisticInfoRequest) String() string

type TraceLogRequest 

type TraceLogRequest struct {

	//AbstractBaseInfo
	TraceId string `protobuf:"bytes,1,opt,name=traceId,proto3" json:"traceId,omitempty"`
	RpcId   string `protobuf:"bytes,2,opt,name=rpcId,proto3" json:"rpcId,omitempty"`
	// 跟踪类型,参考枚举类含义
	TraceType int32 `protobuf:"varint,3,opt,name=traceType,proto3" json:"traceType,omitempty"`
	//名称
	TraceName string `protobuf:"bytes,4,opt,name=traceName,proto3" json:"traceName,omitempty"`
	// 端信息
	Endpoint int32 `protobuf:"varint,5,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// 跟踪结果
	Status int32 `protobuf:"varint,6,opt,name=status,proto3" json:"status,omitempty"`
	// remote返回结果
	RemoteStatus int32 `protobuf:"varint,7,opt,name=remoteStatus,proto3" json:"remoteStatus,omitempty"`
	// 下游(Client)或上游(Server)ip
	RemoteIp string `protobuf:"bytes,8,opt,name=remoteIp,proto3" json:"remoteIp,omitempty"`
	// 结果附属信息
	Message string `protobuf:"bytes,9,opt,name=message,proto3" json:"message,omitempty"`
	// 响应大小
	Size int32 `protobuf:"varint,10,opt,name=size,proto3" json:"size,omitempty"`
	// 开始时间
	StartTime int64 `protobuf:"varint,11,opt,name=startTime,proto3" json:"startTime,omitempty"`
	// 结束时间
	EndTime int64 `protobuf:"varint,12,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Sampled bool  `protobuf:"varint,13,opt,name=sampled,proto3" json:"sampled,omitempty"`
	// 业务通过 PivotTrace.record的自定义数据
	BizData map[string][]byte `` /* 156-byte string literal not displayed */
	// 是否已经结束
	Ended bool `protobuf:"varint,15,opt,name=ended,proto3" json:"ended,omitempty"`
	// 贯穿整个trace链路的信息集合, 内部使用
	AttrMap map[string]string `` /* 156-byte string literal not displayed */
	// 用于临时储存，不可存放大数据(带货)
	ContextMap map[string][]byte `` /* 162-byte string literal not displayed */
	// 线程的切换方式
	ThreadMode     int32  `protobuf:"varint,18,opt,name=threadMode,proto3" json:"threadMode,omitempty"`
	ProfilesActive string `protobuf:"bytes,19,opt,name=profilesActive,proto3" json:"profilesActive,omitempty"`
	AppName        string `protobuf:"bytes,20,opt,name=appName,proto3" json:"appName,omitempty"`
	Ip             string `protobuf:"bytes,21,opt,name=ip,proto3" json:"ip,omitempty"`
	UserId         string `protobuf:"bytes,22,opt,name=userId,proto3" json:"userId,omitempty"`
	//* tracer.endTime - tracer.startTime
	Rt int32 `protobuf:"varint,23,opt,name=rt,proto3" json:"rt,omitempty"`
	//*
	// type为mysql时, 为sql
	// type为redis时, 为执行的命令
	//
	Sql string `protobuf:"bytes,24,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceLogRequest) Descriptor deprecated 

func (*TraceLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use TraceLogRequest.ProtoReflect.Descriptor instead.

func (*TraceLogRequest) GetAppName 

func (x *TraceLogRequest) GetAppName() string

func (*TraceLogRequest) GetAttrMap 

func (x *TraceLogRequest) GetAttrMap() map[string]string

func (*TraceLogRequest) GetBizData 

func (x *TraceLogRequest) GetBizData() map[string][]byte

func (*TraceLogRequest) GetContextMap 

func (x *TraceLogRequest) GetContextMap() map[string][]byte

func (*TraceLogRequest) GetEndTime 

func (x *TraceLogRequest) GetEndTime() int64

func (*TraceLogRequest) GetEnded 

func (x *TraceLogRequest) GetEnded() bool

func (*TraceLogRequest) GetEndpoint 

func (x *TraceLogRequest) GetEndpoint() int32

func (*TraceLogRequest) GetIp 

func (x *TraceLogRequest) GetIp() string

func (*TraceLogRequest) GetMessage 

func (x *TraceLogRequest) GetMessage() string

func (*TraceLogRequest) GetProfilesActive 

func (x *TraceLogRequest) GetProfilesActive() string

func (*TraceLogRequest) GetRemoteIp 

func (x *TraceLogRequest) GetRemoteIp() string

func (*TraceLogRequest) GetRemoteStatus 

func (x *TraceLogRequest) GetRemoteStatus() int32

func (*TraceLogRequest) GetRpcId 

func (x *TraceLogRequest) GetRpcId() string

func (*TraceLogRequest) GetRt 

func (x *TraceLogRequest) GetRt() int32

func (*TraceLogRequest) GetSampled 

func (x *TraceLogRequest) GetSampled() bool

func (*TraceLogRequest) GetSize 

func (x *TraceLogRequest) GetSize() int32

func (*TraceLogRequest) GetSql 

func (x *TraceLogRequest) GetSql() string

func (*TraceLogRequest) GetStartTime 

func (x *TraceLogRequest) GetStartTime() int64

func (*TraceLogRequest) GetStatus 

func (x *TraceLogRequest) GetStatus() int32

func (*TraceLogRequest) GetThreadMode 

func (x *TraceLogRequest) GetThreadMode() int32

func (*TraceLogRequest) GetTraceId 

func (x *TraceLogRequest) GetTraceId() string

func (*TraceLogRequest) GetTraceName 

func (x *TraceLogRequest) GetTraceName() string

func (*TraceLogRequest) GetTraceType 

func (x *TraceLogRequest) GetTraceType() int32

func (*TraceLogRequest) GetUserId 

func (x *TraceLogRequest) GetUserId() string

func (*TraceLogRequest) ProtoMessage 

func (*TraceLogRequest) ProtoMessage()

func (*TraceLogRequest) ProtoReflect 

func (x *TraceLogRequest) ProtoReflect() protoreflect.Message

func (*TraceLogRequest) Reset 

func (x *TraceLogRequest) Reset()

func (*TraceLogRequest) String 

func (x *TraceLogRequest) String() string

type UnimplementedPivotServiceServer 

type UnimplementedPivotServiceServer struct {
}

UnimplementedPivotServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPivotServiceServer) CollectEvent 

func (UnimplementedPivotServiceServer) CollectEvent(context.Context, *DefaultEventRequest) (*Response, error)

func (UnimplementedPivotServiceServer) CollectException 

func (UnimplementedPivotServiceServer) CollectException(context.Context, *ExceptionEventRequest) (*Response, error)

func (UnimplementedPivotServiceServer) CollectLog 

func (UnimplementedPivotServiceServer) CollectLog(context.Context, *AuditLogInfoRequest) (*Response, error)

func (UnimplementedPivotServiceServer) CollectStatisticsInfo 

func (UnimplementedPivotServiceServer) CollectStatisticsInfo(context.Context, *StatisticInfoRequest) (*Response, error)

func (UnimplementedPivotServiceServer) CollectTracer 

func (UnimplementedPivotServiceServer) CollectTracer(context.Context, *TraceLogRequest) (*Response, error)

func (UnimplementedPivotServiceServer) CollectWarn 

func (UnimplementedPivotServiceServer) CollectWarn(context.Context, *WarnEventRequest) (*Response, error)

type UnsafePivotServiceServer 

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

UnsafePivotServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PivotServiceServer will result in compilation errors.

type WarnEventRequest 

type WarnEventRequest struct {

	//AbstractBaseInfo
	Passport       string `protobuf:"bytes,1,opt,name=passport,proto3" json:"passport,omitempty"`
	ProfilesActive string `protobuf:"bytes,2,opt,name=profilesActive,proto3" json:"profilesActive,omitempty"`
	Namespace      string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	AppName        string `protobuf:"bytes,4,opt,name=appName,proto3" json:"appName,omitempty"`
	Ip             string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	ResourceName   string `protobuf:"bytes,6,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	RemoteAppName  string `protobuf:"bytes,7,opt,name=remoteAppName,proto3" json:"remoteAppName,omitempty"`
	RemoteIp       string `protobuf:"bytes,8,opt,name=remoteIp,proto3" json:"remoteIp,omitempty"`
	ResourceType   string `protobuf:"bytes,9,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	DataType       string `protobuf:"bytes,10,opt,name=dataType,proto3" json:"dataType,omitempty"`
	IsServer       bool   `protobuf:"varint,11,opt,name=isServer,proto3" json:"isServer,omitempty"`
	Perf           bool   `protobuf:"varint,12,opt,name=perf,proto3" json:"perf,omitempty"`
	Timestamp      int64  `protobuf:"varint,13,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	CurrentMin     int64  `protobuf:"varint,14,opt,name=currentMin,proto3" json:"currentMin,omitempty"`
	// AbstractEvent
	Code       string            `protobuf:"bytes,15,opt,name=code,proto3" json:"code,omitempty"`
	TraceId    string            `protobuf:"bytes,16,opt,name=traceId,proto3" json:"traceId,omitempty"`
	EventType  string            `protobuf:"bytes,17,opt,name=eventType,proto3" json:"eventType,omitempty"`
	EventLevel string            `protobuf:"bytes,18,opt,name=eventLevel,proto3" json:"eventLevel,omitempty"`
	AttrMap    map[string]string `` /* 156-byte string literal not displayed */
	Merge      int32             `protobuf:"varint,20,opt,name=merge,proto3" json:"merge,omitempty"`
	//WarnEvent
	WarnMsg string `protobuf:"bytes,21,opt,name=warnMsg,proto3" json:"warnMsg,omitempty"`
	Rt      int64  `protobuf:"varint,22,opt,name=rt,proto3" json:"rt,omitempty"`
	Context string `protobuf:"bytes,23,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*WarnEventRequest) Descriptor deprecated 

func (*WarnEventRequest) Descriptor() ([]byte, []int)

Deprecated: Use WarnEventRequest.ProtoReflect.Descriptor instead.

func (*WarnEventRequest) GetAppName 

func (x *WarnEventRequest) GetAppName() string

func (*WarnEventRequest) GetAttrMap 

func (x *WarnEventRequest) GetAttrMap() map[string]string

func (*WarnEventRequest) GetCode 

func (x *WarnEventRequest) GetCode() string

func (*WarnEventRequest) GetContext 

func (x *WarnEventRequest) GetContext() string

func (*WarnEventRequest) GetCurrentMin 

func (x *WarnEventRequest) GetCurrentMin() int64

func (*WarnEventRequest) GetDataType 

func (x *WarnEventRequest) GetDataType() string

func (*WarnEventRequest) GetEventLevel 

func (x *WarnEventRequest) GetEventLevel() string

func (*WarnEventRequest) GetEventType 

func (x *WarnEventRequest) GetEventType() string

func (*WarnEventRequest) GetIp 

func (x *WarnEventRequest) GetIp() string

func (*WarnEventRequest) GetIsServer 

func (x *WarnEventRequest) GetIsServer() bool

func (*WarnEventRequest) GetMerge 

func (x *WarnEventRequest) GetMerge() int32

func (*WarnEventRequest) GetNamespace 

func (x *WarnEventRequest) GetNamespace() string

func (*WarnEventRequest) GetPassport 

func (x *WarnEventRequest) GetPassport() string

func (*WarnEventRequest) GetPerf 

func (x *WarnEventRequest) GetPerf() bool

func (*WarnEventRequest) GetProfilesActive 

func (x *WarnEventRequest) GetProfilesActive() string

func (*WarnEventRequest) GetRemoteAppName 

func (x *WarnEventRequest) GetRemoteAppName() string

func (*WarnEventRequest) GetRemoteIp 

func (x *WarnEventRequest) GetRemoteIp() string

func (*WarnEventRequest) GetResourceName 

func (x *WarnEventRequest) GetResourceName() string

func (*WarnEventRequest) GetResourceType 

func (x *WarnEventRequest) GetResourceType() string

func (*WarnEventRequest) GetRt 

func (x *WarnEventRequest) GetRt() int64

func (*WarnEventRequest) GetTimestamp 

func (x *WarnEventRequest) GetTimestamp() int64

func (*WarnEventRequest) GetTraceId 

func (x *WarnEventRequest) GetTraceId() string

func (*WarnEventRequest) GetWarnMsg 

func (x *WarnEventRequest) GetWarnMsg() string

func (*WarnEventRequest) ProtoMessage 

func (*WarnEventRequest) ProtoMessage()

func (*WarnEventRequest) ProtoReflect 

func (x *WarnEventRequest) ProtoReflect() protoreflect.Message

func (*WarnEventRequest) Reset 

func (x *WarnEventRequest) Reset()

func (*WarnEventRequest) String 

func (x *WarnEventRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.