protoc_event_server

package module
v0.0.0-...-887131c Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2024 License: MIT Imports: 16 Imported by: 4

Documentation

Overview

Package protoc_event_server is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventServer_LogExposureGroup_FullMethodName     = "/opensource.tab.cache_server.EventServer/LogExposureGroup"
	EventServer_LogEventGroup_FullMethodName        = "/opensource.tab.cache_server.EventServer/LogEventGroup"
	EventServer_LogMonitorEventGroup_FullMethodName = "/opensource.tab.cache_server.EventServer/LogMonitorEventGroup"
)

Variables

View Source 
var (
	ExposureType_name = map[int32]string{
		0: "EXPOSURE_TYPE_UNKNOWN",
		1: "EXPOSURE_TYPE_AUTOMATIC",
		2: "EXPOSURE_TYPE_MANUAL",
	}
	ExposureType_value = map[string]int32{
		"EXPOSURE_TYPE_UNKNOWN":   0,
		"EXPOSURE_TYPE_AUTOMATIC": 1,
		"EXPOSURE_TYPE_MANUAL":    2,
	}
)

Enum value maps for ExposureType.

View Source 
var (
	EventServerCode_name = map[int32]string{
		0:    "EVENT_SERVER_CODE_SUCCESS",
		1001: "EVENT_SERVER_CODE_NO_PERMISSION",
		1002: "EVENT_SERVER_CODE_TRAFFIC_LIMIT",
		1003: "EVENT_SERVER_CODE_INVALID_PROJECT_ID",
		1004: "EVENT_SERVER_CODE_SERVER_ERR",
		1005: "EVENT_SERVER_CODE_INVALID_PARAM",
		2001: "EVENT_SERVER_CODE_SAME_VERSION",
	}
	EventServerCode_value = map[string]int32{
		"EVENT_SERVER_CODE_SUCCESS":            0,
		"EVENT_SERVER_CODE_NO_PERMISSION":      1001,
		"EVENT_SERVER_CODE_TRAFFIC_LIMIT":      1002,
		"EVENT_SERVER_CODE_INVALID_PROJECT_ID": 1003,
		"EVENT_SERVER_CODE_SERVER_ERR":         1004,
		"EVENT_SERVER_CODE_INVALID_PARAM":      1005,
		"EVENT_SERVER_CODE_SAME_VERSION":       2001,
	}
)

Enum value maps for EventServerCode.

View Source 
var (
	MonitorEventStatus_name = map[int32]string{
		0:  "STATUS_SUCCESS",
		-1: "STATUS_UNEXPECTED",
	}
	MonitorEventStatus_value = map[string]int32{
		"STATUS_SUCCESS":    0,
		"STATUS_UNEXPECTED": -1,
	}
)

Enum value maps for MonitorEventStatus.

View Source 
var EventServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "opensource.tab.cache_server.EventServer",
	HandlerType: (*EventServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LogExposureGroup",
			Handler:    _EventServer_LogExposureGroup_Handler,
		},
		{
			MethodName: "LogEventGroup",
			Handler:    _EventServer_LogEventGroup_Handler,
		},
		{
			MethodName: "LogMonitorEventGroup",
			Handler:    _EventServer_LogMonitorEventGroup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "event_server.proto",
}

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

View Source 
var EventServer_ServiceDescV2 = grpc.ServiceDesc{
	ServiceName: "opensource.tab.cache_server.EventServer",
	HandlerType: (*EventServerServerV2)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LogExposureGroup",
			Handler:    _EventServer_LogExposureGroup_HandlerV2,
		},
		{
			MethodName: "LogEventGroup",
			Handler:    _EventServer_LogEventGroup_HandlerV2,
		},
		{
			MethodName: "LogMonitorEventGroup",
			Handler:    _EventServer_LogMonitorEventGroup_HandlerV2,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "event_server.proto",
}

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

View Source 
var File_event_server_proto protoreflect.FileDescriptor

Functions

func RegisterEventServerHandler 

func RegisterEventServerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventServerHandler registers the http handlers for service EventServer to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventServerHandlerClient 

func RegisterEventServerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventServerClient) error

RegisterEventServerHandlerClient registers the http handlers for service EventServer to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventServerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventServerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventServerClient" to call the correct interceptors.

func RegisterEventServerHandlerFromEndpoint 

func RegisterEventServerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventServerHandlerFromEndpoint is same as RegisterEventServerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventServerHandlerServer 

func RegisterEventServerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventServerServer) error

RegisterEventServerHandlerServer registers the http handlers for service EventServer to "mux". UnaryRPC :call EventServerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterEventServerHandlerFromEndpoint instead.

func RegisterEventServerServer 

func RegisterEventServerServer(s grpc.ServiceRegistrar, srv EventServerServer)

func RegisterEventServerServerV2 

func RegisterEventServerServerV2(s grpc.ServiceRegistrar, srv EventServerServerV2)

Types

type CommonResp 

type CommonResp struct {
	Code    EventServerCode `protobuf:"varint,1,opt,name=code,proto3,enum=opensource.tab.cache_server.EventServerCode" json:"code,omitempty"` // error code
	Message string          `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                                             // Detailed description
	// contains filtered or unexported fields
}

func (*CommonResp) Descriptor deprecated 

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

Deprecated: Use CommonResp.ProtoReflect.Descriptor instead.

func (*CommonResp) GetCode 

func (x *CommonResp) GetCode() EventServerCode

func (*CommonResp) GetMessage 

func (x *CommonResp) GetMessage() string

func (*CommonResp) ProtoMessage 

func (*CommonResp) ProtoMessage()

func (*CommonResp) ProtoReflect 

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

func (*CommonResp) Reset 

func (x *CommonResp) Reset()

func (*CommonResp) String 

func (x *CommonResp) String() string

type Device 

type Device struct {
	ProjectVersion string `protobuf:"bytes,1,opt,name=project_version,json=projectVersion,proto3" json:"project_version,omitempty"` // project version
	Platform       string `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`                                   // Platform Type Windows/MacOS/iPhone/Android/iPod/iPad/Linux/UNIX/Unknown
	OsModel        string `protobuf:"bytes,3,opt,name=os_model,json=osModel,proto3" json:"os_model,omitempty"`                      // Declare the browser operating system or device type，QQBrowser/UCBrowser
	OsVersion      string `protobuf:"bytes,4,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`                // System platform version
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetOsModel 

func (x *Device) GetOsModel() string

func (*Device) GetOsVersion 

func (x *Device) GetOsVersion() string

func (*Device) GetPlatform 

func (x *Device) GetPlatform() string

func (*Device) GetProjectVersion 

func (x *Device) GetProjectVersion() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

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

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type Event 

type Event struct {

	// Required
	EventName string            `protobuf:"bytes,1,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"` // event name
	ProjectId string            `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // project id
	Time      int64             `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`                           // Timestamp, accurate to seconds
	Metadata  map[string]string ``                                                                                         // Multiple kv combinations in one log
	/* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

General event reporting

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEventName 

func (x *Event) GetEventName() string

func (*Event) GetMetadata 

func (x *Event) GetMetadata() map[string]string

func (*Event) GetProjectId 

func (x *Event) GetProjectId() string

func (*Event) GetTime 

func (x *Event) GetTime() int64

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventGroup 

type EventGroup struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // Multiple event records
	// contains filtered or unexported fields
}

Batch reporting events

func (*EventGroup) Descriptor deprecated 

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

Deprecated: Use EventGroup.ProtoReflect.Descriptor instead.

func (*EventGroup) GetEvents 

func (x *EventGroup) GetEvents() []*Event

func (*EventGroup) ProtoMessage 

func (*EventGroup) ProtoMessage()

func (*EventGroup) ProtoReflect 

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

func (*EventGroup) Reset 

func (x *EventGroup) Reset()

func (*EventGroup) String 

func (x *EventGroup) String() string

type EventServerClient 

type EventServerClient interface {
	LogExposureGroup(ctx context.Context, in *ExposureGroup, opts ...grpc.CallOption) (*CommonResp, error)
	LogEventGroup(ctx context.Context, in *EventGroup, opts ...grpc.CallOption) (*CommonResp, error)
	LogMonitorEventGroup(ctx context.Context, in *MonitorEventGroup, opts ...grpc.CallOption) (*CommonResp, error)
}

EventServerClient is the client API for EventServer 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 NewEventServerClient 

func NewEventServerClient(cc grpc.ClientConnInterface) EventServerClient

type EventServerClientV2 

type EventServerClientV2 interface {
	LogExposureGroup(ctx context.Context, in *ExposureGroup, opts ...grpc.CallOption) (*CommonResp, error)
	LogEventGroup(ctx context.Context, in *EventGroup, opts ...grpc.CallOption) (*CommonResp, error)
	LogMonitorEventGroup(ctx context.Context, in *MonitorEventGroup, opts ...grpc.CallOption) (*CommonResp, error)
}

EventServerClientV2 is the client API for EventServer 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 NewEventServerClientV2 

func NewEventServerClientV2(cc grpc.ClientConnInterface) EventServerClientV2

type EventServerCode 

type EventServerCode int32
const (
	EventServerCode_EVENT_SERVER_CODE_SUCCESS            EventServerCode = 0    // success
	EventServerCode_EVENT_SERVER_CODE_NO_PERMISSION      EventServerCode = 1001 // no permission
	EventServerCode_EVENT_SERVER_CODE_TRAFFIC_LIMIT      EventServerCode = 1002 // traffic limit
	EventServerCode_EVENT_SERVER_CODE_INVALID_PROJECT_ID EventServerCode = 1003 //  projectID error
	EventServerCode_EVENT_SERVER_CODE_SERVER_ERR         EventServerCode = 1004 // server error
	EventServerCode_EVENT_SERVER_CODE_INVALID_PARAM      EventServerCode = 1005 // invalid param
	EventServerCode_EVENT_SERVER_CODE_SAME_VERSION       EventServerCode = 2001 // Version not updated
)

func (EventServerCode) Descriptor 

func (EventServerCode) Descriptor() protoreflect.EnumDescriptor

func (EventServerCode) Enum 

func (x EventServerCode) Enum() *EventServerCode

func (EventServerCode) EnumDescriptor deprecated 

func (EventServerCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventServerCode.Descriptor instead.

func (EventServerCode) Number 

func (x EventServerCode) Number() protoreflect.EnumNumber

func (EventServerCode) String 

func (x EventServerCode) String() string

func (EventServerCode) Type 

func (EventServerCode) Type() protoreflect.EnumType

type EventServerServer 

type EventServerServer interface {
	LogExposureGroup(context.Context, *ExposureGroup) (*CommonResp, error)
	LogEventGroup(context.Context, *EventGroup) (*CommonResp, error)
	LogMonitorEventGroup(context.Context, *MonitorEventGroup) (*CommonResp, error)
}

EventServerServer is the server API for EventServer service. All implementations should embed UnimplementedEventServerServer for forward compatibility

type EventServerServerV2 

type EventServerServerV2 interface {
	LogExposureGroup(context.Context, *ExposureGroup, *CommonResp) error
	LogEventGroup(context.Context, *EventGroup, *CommonResp) error
	LogMonitorEventGroup(context.Context, *MonitorEventGroup, *CommonResp) error
}

EventServerServerV2 is the server API for EventServer service. All implementations should embed UnimplementedEventServerServerV2 for forward compatibility

type Exposure 

type Exposure struct {

	// Required
	UnitId    string `protobuf:"bytes,1,opt,name=unit_id,json=unitId,proto3" json:"unit_id,omitempty"`          // unitID，The same UnitID stably hits the same experimental version
	GroupId   int64  `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`      // Experimental version of hit ID
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // project ID
	Time      int64  `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`                           // Timestamp, accurate to seconds
	// optional
	LayerKey     string       `protobuf:"bytes,5,opt,name=layer_key,json=layerKey,proto3" json:"layer_key,omitempty"`        // layer key
	ExpKey       string       `protobuf:"bytes,6,opt,name=exp_key,json=expKey,proto3" json:"exp_key,omitempty"`              // experiment key
	UnitType     string       `protobuf:"bytes,7,opt,name=unit_type,json=unitType,proto3" json:"unit_type,omitempty"`        // unitID type, reserved
	ClusterId    string       `protobuf:"bytes,8,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`     // clusterID Network experiment group ID, reserved for advanced experiments
	SdkType      string       `protobuf:"bytes,9,opt,name=sdk_type,json=sdkType,proto3" json:"sdk_type,omitempty"`           // sdk type golang、cpp、java
	SdkVersion   string       `protobuf:"bytes,10,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"` // sdk version
	ExposureType ExposureType ``                                                                                             // ExposureType
	/* 145-byte string literal not displayed */
	Device    *Device           `protobuf:"bytes,12,opt,name=device,proto3" json:"device,omitempty"` // End device metadata, optional, can also be passed in via http header
	ExtraData map[string]string ``                                                                   // Extended fields
	/* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

Exposure Report

func (*Exposure) Descriptor deprecated 

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

Deprecated: Use Exposure.ProtoReflect.Descriptor instead.

func (*Exposure) GetClusterId 

func (x *Exposure) GetClusterId() string

func (*Exposure) GetDevice 

func (x *Exposure) GetDevice() *Device

func (*Exposure) GetExpKey 

func (x *Exposure) GetExpKey() string

func (*Exposure) GetExposureType 

func (x *Exposure) GetExposureType() ExposureType

func (*Exposure) GetExtraData 

func (x *Exposure) GetExtraData() map[string]string

func (*Exposure) GetGroupId 

func (x *Exposure) GetGroupId() int64

func (*Exposure) GetLayerKey 

func (x *Exposure) GetLayerKey() string

func (*Exposure) GetProjectId 

func (x *Exposure) GetProjectId() string

func (*Exposure) GetSdkType 

func (x *Exposure) GetSdkType() string

func (*Exposure) GetSdkVersion 

func (x *Exposure) GetSdkVersion() string

func (*Exposure) GetTime 

func (x *Exposure) GetTime() int64

func (*Exposure) GetUnitId 

func (x *Exposure) GetUnitId() string

func (*Exposure) GetUnitType 

func (x *Exposure) GetUnitType() string

func (*Exposure) ProtoMessage 

func (*Exposure) ProtoMessage()

func (*Exposure) ProtoReflect 

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

func (*Exposure) Reset 

func (x *Exposure) Reset()

func (*Exposure) String 

func (x *Exposure) String() string

type ExposureGroup 

type ExposureGroup struct {
	Exposures []*Exposure `protobuf:"bytes,1,rep,name=exposures,proto3" json:"exposures,omitempty"` // Multiple exposure records
	// contains filtered or unexported fields
}

Batch reporting exposure

func (*ExposureGroup) Descriptor deprecated 

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

Deprecated: Use ExposureGroup.ProtoReflect.Descriptor instead.

func (*ExposureGroup) GetExposures 

func (x *ExposureGroup) GetExposures() []*Exposure

func (*ExposureGroup) ProtoMessage 

func (*ExposureGroup) ProtoMessage()

func (*ExposureGroup) ProtoReflect 

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

func (*ExposureGroup) Reset 

func (x *ExposureGroup) Reset()

func (*ExposureGroup) String 

func (x *ExposureGroup) String() string

type ExposureType 

type ExposureType int32
const (
	ExposureType_EXPOSURE_TYPE_UNKNOWN   ExposureType = 0
	ExposureType_EXPOSURE_TYPE_AUTOMATIC ExposureType = 1 // sdk Automatically record exposure
	ExposureType_EXPOSURE_TYPE_MANUAL    ExposureType = 2 // Manually record exposure, the developer calls the API to record exposure
)

func (ExposureType) Descriptor 

func (ExposureType) Descriptor() protoreflect.EnumDescriptor

func (ExposureType) Enum 

func (x ExposureType) Enum() *ExposureType

func (ExposureType) EnumDescriptor deprecated 

func (ExposureType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExposureType.Descriptor instead.

func (ExposureType) Number 

func (x ExposureType) Number() protoreflect.EnumNumber

func (ExposureType) String 

func (x ExposureType) String() string

func (ExposureType) Type 

func (ExposureType) Type() protoreflect.EnumType

type MonitorEvent 

type MonitorEvent struct {
	Time       int64              `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`                           // Timestamp, accurate to seconds
	Ip         string             `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`                                // 10.0.0.8
	ProjectId  string             `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // project id
	EventName  string             `protobuf:"bytes,4,opt,name=event_name,json=eventName,proto3" json:"event_name,omitempty"` // event name
	Latency    float32            `protobuf:"fixed32,5,opt,name=latency,proto3" json:"latency,omitempty"`                    // latency，unit us
	StatusCode MonitorEventStatus ``                                                                                         // status
	/* 144-byte string literal not displayed */
	Message    string            `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`                          // Unexpected event error cause, normal event description
	SdkType    string            `protobuf:"bytes,8,opt,name=sdk_type,json=sdkType,proto3" json:"sdk_type,omitempty"`           // sdk type，EG GOLANG\CPP\JAVA\NODEJS\CSHARP
	SdkVersion string            `protobuf:"bytes,9,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version,omitempty"`  // v1.5.18
	InvokePath string            `protobuf:"bytes,10,opt,name=invoke_path,json=invokePath,proto3" json:"invoke_path,omitempty"` // Event-triggered call path, stack information
	InputData  string            `protobuf:"bytes,11,opt,name=input_data,json=inputData,proto3" json:"input_data,omitempty"`    // Event input parameters
	OutputData string            `protobuf:"bytes,12,opt,name=output_data,json=outputData,proto3" json:"output_data,omitempty"` // Event output information
	ExtInfo    map[string]string ``                                                                                             // Further information
	/* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

Event data of buried point monitoring

func (*MonitorEvent) Descriptor deprecated 

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

Deprecated: Use MonitorEvent.ProtoReflect.Descriptor instead.

func (*MonitorEvent) GetEventName 

func (x *MonitorEvent) GetEventName() string

func (*MonitorEvent) GetExtInfo 

func (x *MonitorEvent) GetExtInfo() map[string]string

func (*MonitorEvent) GetInputData 

func (x *MonitorEvent) GetInputData() string

func (*MonitorEvent) GetInvokePath 

func (x *MonitorEvent) GetInvokePath() string

func (*MonitorEvent) GetIp 

func (x *MonitorEvent) GetIp() string

func (*MonitorEvent) GetLatency 

func (x *MonitorEvent) GetLatency() float32

func (*MonitorEvent) GetMessage 

func (x *MonitorEvent) GetMessage() string

func (*MonitorEvent) GetOutputData 

func (x *MonitorEvent) GetOutputData() string

func (*MonitorEvent) GetProjectId 

func (x *MonitorEvent) GetProjectId() string

func (*MonitorEvent) GetSdkType 

func (x *MonitorEvent) GetSdkType() string

func (*MonitorEvent) GetSdkVersion 

func (x *MonitorEvent) GetSdkVersion() string

func (*MonitorEvent) GetStatusCode 

func (x *MonitorEvent) GetStatusCode() MonitorEventStatus

func (*MonitorEvent) GetTime 

func (x *MonitorEvent) GetTime() int64

func (*MonitorEvent) ProtoMessage 

func (*MonitorEvent) ProtoMessage()

func (*MonitorEvent) ProtoReflect 

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

func (*MonitorEvent) Reset 

func (x *MonitorEvent) Reset()

func (*MonitorEvent) String 

func (x *MonitorEvent) String() string

type MonitorEventGroup 

type MonitorEventGroup struct {
	Events []*MonitorEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // Multiple monitoring report logs
	// contains filtered or unexported fields
}

func (*MonitorEventGroup) Descriptor deprecated 

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

Deprecated: Use MonitorEventGroup.ProtoReflect.Descriptor instead.

func (*MonitorEventGroup) GetEvents 

func (x *MonitorEventGroup) GetEvents() []*MonitorEvent

func (*MonitorEventGroup) ProtoMessage 

func (*MonitorEventGroup) ProtoMessage()

func (*MonitorEventGroup) ProtoReflect 

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

func (*MonitorEventGroup) Reset 

func (x *MonitorEventGroup) Reset()

func (*MonitorEventGroup) String 

func (x *MonitorEventGroup) String() string

type MonitorEventStatus 

type MonitorEventStatus int32
const (
	MonitorEvent_STATUS_SUCCESS    MonitorEventStatus = 0  // success
	MonitorEvent_STATUS_UNEXPECTED MonitorEventStatus = -1 // unexpected
)

func (MonitorEventStatus) Descriptor 

func (MonitorEventStatus) Descriptor() protoreflect.EnumDescriptor

func (MonitorEventStatus) Enum 

func (x MonitorEventStatus) Enum() *MonitorEventStatus

func (MonitorEventStatus) EnumDescriptor deprecated 

func (MonitorEventStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use MonitorEventStatus.Descriptor instead.

func (MonitorEventStatus) Number 

func (x MonitorEventStatus) Number() protoreflect.EnumNumber

func (MonitorEventStatus) String 

func (x MonitorEventStatus) String() string

func (MonitorEventStatus) Type 

func (MonitorEventStatus) Type() protoreflect.EnumType

type UnimplementedEventServerServer 

type UnimplementedEventServerServer struct {
}

UnimplementedEventServerServer should be embedded to have forward compatible implementations.

func (UnimplementedEventServerServer) LogEventGroup 

func (UnimplementedEventServerServer) LogEventGroup(context.Context, *EventGroup) (*CommonResp, error)

func (UnimplementedEventServerServer) LogExposureGroup 

func (UnimplementedEventServerServer) LogExposureGroup(context.Context, *ExposureGroup) (*CommonResp, error)

func (UnimplementedEventServerServer) LogMonitorEventGroup 

func (UnimplementedEventServerServer) LogMonitorEventGroup(context.Context, *MonitorEventGroup) (*CommonResp, error)

type UnimplementedEventServerServerV2 

type UnimplementedEventServerServerV2 struct {
}

UnimplementedEventServerServerV2 should be embedded to have forward compatible implementations.

func (UnimplementedEventServerServerV2) LogEventGroup 

func (UnimplementedEventServerServerV2) LogEventGroup(context.Context, *EventGroup, *CommonResp) error

func (UnimplementedEventServerServerV2) LogExposureGroup 

func (UnimplementedEventServerServerV2) LogExposureGroup(context.Context, *ExposureGroup, *CommonResp) error

func (UnimplementedEventServerServerV2) LogMonitorEventGroup 

func (UnimplementedEventServerServerV2) LogMonitorEventGroup(context.Context, *MonitorEventGroup, *CommonResp) error

type UnsafeEventServerServer 

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

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

type UnsafeEventServerServerV2 

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

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

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.