| // |
| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you under the Apache License, Version 2.0 (the |
| // "License"); you may not use this file except in compliance |
| // with the License. You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, |
| // software distributed under the License is distributed on an |
| // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| // KIND, either express or implied. See the License for the |
| // specific language governing permissions and limitations |
| // under the License. |
| // |
| |
| // Code generated by protoc-gen-go. DO NOT EDIT. |
| // versions: |
| // protoc-gen-go v1.36.11 |
| // protoc v6.31.1 |
| // source: InstanceCommunication.proto |
| |
| package api |
| |
| import ( |
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" |
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" |
| emptypb "google.golang.org/protobuf/types/known/emptypb" |
| reflect "reflect" |
| sync "sync" |
| unsafe "unsafe" |
| ) |
| |
| const ( |
| // Verify that this generated code is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) |
| // Verify that runtime/protoimpl is sufficiently up-to-date. |
| _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) |
| ) |
| |
| type FunctionStatus struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| Running bool `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"` |
| FailureException string `protobuf:"bytes,2,opt,name=failureException,proto3" json:"failureException,omitempty"` |
| NumRestarts int64 `protobuf:"varint,3,opt,name=numRestarts,proto3" json:"numRestarts,omitempty"` |
| // int64 numProcessed = 4; |
| NumReceived int64 `protobuf:"varint,17,opt,name=numReceived,proto3" json:"numReceived,omitempty"` |
| NumSuccessfullyProcessed int64 `protobuf:"varint,5,opt,name=numSuccessfullyProcessed,proto3" json:"numSuccessfullyProcessed,omitempty"` |
| NumUserExceptions int64 `protobuf:"varint,6,opt,name=numUserExceptions,proto3" json:"numUserExceptions,omitempty"` |
| LatestUserExceptions []*FunctionStatus_ExceptionInformation `protobuf:"bytes,7,rep,name=latestUserExceptions,proto3" json:"latestUserExceptions,omitempty"` |
| NumSystemExceptions int64 `protobuf:"varint,8,opt,name=numSystemExceptions,proto3" json:"numSystemExceptions,omitempty"` |
| LatestSystemExceptions []*FunctionStatus_ExceptionInformation `protobuf:"bytes,9,rep,name=latestSystemExceptions,proto3" json:"latestSystemExceptions,omitempty"` |
| NumSourceExceptions int64 `protobuf:"varint,18,opt,name=numSourceExceptions,proto3" json:"numSourceExceptions,omitempty"` |
| LatestSourceExceptions []*FunctionStatus_ExceptionInformation `protobuf:"bytes,19,rep,name=latestSourceExceptions,proto3" json:"latestSourceExceptions,omitempty"` |
| NumSinkExceptions int64 `protobuf:"varint,20,opt,name=numSinkExceptions,proto3" json:"numSinkExceptions,omitempty"` |
| LatestSinkExceptions []*FunctionStatus_ExceptionInformation `protobuf:"bytes,21,rep,name=latestSinkExceptions,proto3" json:"latestSinkExceptions,omitempty"` |
| // map from topic name to number of deserialization exceptions |
| // |
| // map<string, int64> deserializationExceptions = 10; |
| // |
| // number of serialization exceptions on the output |
| // |
| // int64 serializationExceptions = 11; |
| // |
| // average latency |
| AverageLatency float64 `protobuf:"fixed64,12,opt,name=averageLatency,proto3" json:"averageLatency,omitempty"` |
| // When was the last time the function was invoked. |
| // expressed in ms since epoch |
| LastInvocationTime int64 `protobuf:"varint,13,opt,name=lastInvocationTime,proto3" json:"lastInvocationTime,omitempty"` |
| InstanceId string `protobuf:"bytes,14,opt,name=instanceId,proto3" json:"instanceId,omitempty"` |
| // MetricsData metrics = 15 [deprecated=true]; |
| // |
| // owner of function-instance |
| WorkerId string `protobuf:"bytes,16,opt,name=workerId,proto3" json:"workerId,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *FunctionStatus) Reset() { |
| *x = FunctionStatus{} |
| mi := &file_InstanceCommunication_proto_msgTypes[0] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *FunctionStatus) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FunctionStatus) ProtoMessage() {} |
| |
| func (x *FunctionStatus) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[0] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FunctionStatus.ProtoReflect.Descriptor instead. |
| func (*FunctionStatus) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{0} |
| } |
| |
| func (x *FunctionStatus) GetRunning() bool { |
| if x != nil { |
| return x.Running |
| } |
| return false |
| } |
| |
| func (x *FunctionStatus) GetFailureException() string { |
| if x != nil { |
| return x.FailureException |
| } |
| return "" |
| } |
| |
| func (x *FunctionStatus) GetNumRestarts() int64 { |
| if x != nil { |
| return x.NumRestarts |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetNumReceived() int64 { |
| if x != nil { |
| return x.NumReceived |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetNumSuccessfullyProcessed() int64 { |
| if x != nil { |
| return x.NumSuccessfullyProcessed |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetNumUserExceptions() int64 { |
| if x != nil { |
| return x.NumUserExceptions |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetLatestUserExceptions() []*FunctionStatus_ExceptionInformation { |
| if x != nil { |
| return x.LatestUserExceptions |
| } |
| return nil |
| } |
| |
| func (x *FunctionStatus) GetNumSystemExceptions() int64 { |
| if x != nil { |
| return x.NumSystemExceptions |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetLatestSystemExceptions() []*FunctionStatus_ExceptionInformation { |
| if x != nil { |
| return x.LatestSystemExceptions |
| } |
| return nil |
| } |
| |
| func (x *FunctionStatus) GetNumSourceExceptions() int64 { |
| if x != nil { |
| return x.NumSourceExceptions |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetLatestSourceExceptions() []*FunctionStatus_ExceptionInformation { |
| if x != nil { |
| return x.LatestSourceExceptions |
| } |
| return nil |
| } |
| |
| func (x *FunctionStatus) GetNumSinkExceptions() int64 { |
| if x != nil { |
| return x.NumSinkExceptions |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetLatestSinkExceptions() []*FunctionStatus_ExceptionInformation { |
| if x != nil { |
| return x.LatestSinkExceptions |
| } |
| return nil |
| } |
| |
| func (x *FunctionStatus) GetAverageLatency() float64 { |
| if x != nil { |
| return x.AverageLatency |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetLastInvocationTime() int64 { |
| if x != nil { |
| return x.LastInvocationTime |
| } |
| return 0 |
| } |
| |
| func (x *FunctionStatus) GetInstanceId() string { |
| if x != nil { |
| return x.InstanceId |
| } |
| return "" |
| } |
| |
| func (x *FunctionStatus) GetWorkerId() string { |
| if x != nil { |
| return x.WorkerId |
| } |
| return "" |
| } |
| |
| // Deprecated |
| type FunctionStatusList struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` |
| FunctionStatusList []*FunctionStatus `protobuf:"bytes,1,rep,name=functionStatusList,proto3" json:"functionStatusList,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *FunctionStatusList) Reset() { |
| *x = FunctionStatusList{} |
| mi := &file_InstanceCommunication_proto_msgTypes[1] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *FunctionStatusList) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FunctionStatusList) ProtoMessage() {} |
| |
| func (x *FunctionStatusList) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[1] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FunctionStatusList.ProtoReflect.Descriptor instead. |
| func (*FunctionStatusList) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{1} |
| } |
| |
| func (x *FunctionStatusList) GetError() string { |
| if x != nil { |
| return x.Error |
| } |
| return "" |
| } |
| |
| func (x *FunctionStatusList) GetFunctionStatusList() []*FunctionStatus { |
| if x != nil { |
| return x.FunctionStatusList |
| } |
| return nil |
| } |
| |
| type MetricsData struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| // Total number of records function received from source |
| ReceivedTotal int64 `protobuf:"varint,2,opt,name=receivedTotal,proto3" json:"receivedTotal,omitempty"` |
| ReceivedTotal_1Min int64 `protobuf:"varint,10,opt,name=receivedTotal_1min,json=receivedTotal1min,proto3" json:"receivedTotal_1min,omitempty"` |
| // Total number of records successfully processed by user function |
| ProcessedSuccessfullyTotal int64 `protobuf:"varint,4,opt,name=processedSuccessfullyTotal,proto3" json:"processedSuccessfullyTotal,omitempty"` |
| ProcessedSuccessfullyTotal_1Min int64 `protobuf:"varint,12,opt,name=processedSuccessfullyTotal_1min,json=processedSuccessfullyTotal1min,proto3" json:"processedSuccessfullyTotal_1min,omitempty"` |
| // Total number of system exceptions thrown |
| SystemExceptionsTotal int64 `protobuf:"varint,5,opt,name=systemExceptionsTotal,proto3" json:"systemExceptionsTotal,omitempty"` |
| SystemExceptionsTotal_1Min int64 `protobuf:"varint,13,opt,name=systemExceptionsTotal_1min,json=systemExceptionsTotal1min,proto3" json:"systemExceptionsTotal_1min,omitempty"` |
| // Total number of user exceptions thrown |
| UserExceptionsTotal int64 `protobuf:"varint,6,opt,name=userExceptionsTotal,proto3" json:"userExceptionsTotal,omitempty"` |
| UserExceptionsTotal_1Min int64 `protobuf:"varint,14,opt,name=userExceptionsTotal_1min,json=userExceptionsTotal1min,proto3" json:"userExceptionsTotal_1min,omitempty"` |
| // Average process latency for function |
| AvgProcessLatency float64 `protobuf:"fixed64,7,opt,name=avgProcessLatency,proto3" json:"avgProcessLatency,omitempty"` |
| AvgProcessLatency_1Min float64 `protobuf:"fixed64,15,opt,name=avgProcessLatency_1min,json=avgProcessLatency1min,proto3" json:"avgProcessLatency_1min,omitempty"` |
| // Timestamp of when the function was last invoked |
| LastInvocation int64 `protobuf:"varint,8,opt,name=lastInvocation,proto3" json:"lastInvocation,omitempty"` |
| // User defined metrics |
| UserMetrics map[string]float64 `protobuf:"bytes,9,rep,name=userMetrics,proto3" json:"userMetrics,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"fixed64,2,opt,name=value"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *MetricsData) Reset() { |
| *x = MetricsData{} |
| mi := &file_InstanceCommunication_proto_msgTypes[2] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *MetricsData) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*MetricsData) ProtoMessage() {} |
| |
| func (x *MetricsData) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[2] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use MetricsData.ProtoReflect.Descriptor instead. |
| func (*MetricsData) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{2} |
| } |
| |
| func (x *MetricsData) GetReceivedTotal() int64 { |
| if x != nil { |
| return x.ReceivedTotal |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetReceivedTotal_1Min() int64 { |
| if x != nil { |
| return x.ReceivedTotal_1Min |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetProcessedSuccessfullyTotal() int64 { |
| if x != nil { |
| return x.ProcessedSuccessfullyTotal |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetProcessedSuccessfullyTotal_1Min() int64 { |
| if x != nil { |
| return x.ProcessedSuccessfullyTotal_1Min |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetSystemExceptionsTotal() int64 { |
| if x != nil { |
| return x.SystemExceptionsTotal |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetSystemExceptionsTotal_1Min() int64 { |
| if x != nil { |
| return x.SystemExceptionsTotal_1Min |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetUserExceptionsTotal() int64 { |
| if x != nil { |
| return x.UserExceptionsTotal |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetUserExceptionsTotal_1Min() int64 { |
| if x != nil { |
| return x.UserExceptionsTotal_1Min |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetAvgProcessLatency() float64 { |
| if x != nil { |
| return x.AvgProcessLatency |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetAvgProcessLatency_1Min() float64 { |
| if x != nil { |
| return x.AvgProcessLatency_1Min |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetLastInvocation() int64 { |
| if x != nil { |
| return x.LastInvocation |
| } |
| return 0 |
| } |
| |
| func (x *MetricsData) GetUserMetrics() map[string]float64 { |
| if x != nil { |
| return x.UserMetrics |
| } |
| return nil |
| } |
| |
| type HealthCheckResult struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *HealthCheckResult) Reset() { |
| *x = HealthCheckResult{} |
| mi := &file_InstanceCommunication_proto_msgTypes[3] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *HealthCheckResult) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*HealthCheckResult) ProtoMessage() {} |
| |
| func (x *HealthCheckResult) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[3] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use HealthCheckResult.ProtoReflect.Descriptor instead. |
| func (*HealthCheckResult) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{3} |
| } |
| |
| func (x *HealthCheckResult) GetSuccess() bool { |
| if x != nil { |
| return x.Success |
| } |
| return false |
| } |
| |
| type Metrics struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| Metrics []*Metrics_InstanceMetrics `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *Metrics) Reset() { |
| *x = Metrics{} |
| mi := &file_InstanceCommunication_proto_msgTypes[4] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *Metrics) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Metrics) ProtoMessage() {} |
| |
| func (x *Metrics) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[4] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Metrics.ProtoReflect.Descriptor instead. |
| func (*Metrics) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{4} |
| } |
| |
| func (x *Metrics) GetMetrics() []*Metrics_InstanceMetrics { |
| if x != nil { |
| return x.Metrics |
| } |
| return nil |
| } |
| |
| type FunctionStatus_ExceptionInformation struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| ExceptionString string `protobuf:"bytes,1,opt,name=exceptionString,proto3" json:"exceptionString,omitempty"` |
| MsSinceEpoch int64 `protobuf:"varint,2,opt,name=msSinceEpoch,proto3" json:"msSinceEpoch,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *FunctionStatus_ExceptionInformation) Reset() { |
| *x = FunctionStatus_ExceptionInformation{} |
| mi := &file_InstanceCommunication_proto_msgTypes[5] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *FunctionStatus_ExceptionInformation) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*FunctionStatus_ExceptionInformation) ProtoMessage() {} |
| |
| func (x *FunctionStatus_ExceptionInformation) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[5] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use FunctionStatus_ExceptionInformation.ProtoReflect.Descriptor instead. |
| func (*FunctionStatus_ExceptionInformation) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{0, 0} |
| } |
| |
| func (x *FunctionStatus_ExceptionInformation) GetExceptionString() string { |
| if x != nil { |
| return x.ExceptionString |
| } |
| return "" |
| } |
| |
| func (x *FunctionStatus_ExceptionInformation) GetMsSinceEpoch() int64 { |
| if x != nil { |
| return x.MsSinceEpoch |
| } |
| return 0 |
| } |
| |
| type Metrics_InstanceMetrics struct { |
| state protoimpl.MessageState `protogen:"open.v1"` |
| Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| InstanceId int32 `protobuf:"varint,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"` |
| MetricsData *MetricsData `protobuf:"bytes,3,opt,name=metricsData,proto3" json:"metricsData,omitempty"` |
| unknownFields protoimpl.UnknownFields |
| sizeCache protoimpl.SizeCache |
| } |
| |
| func (x *Metrics_InstanceMetrics) Reset() { |
| *x = Metrics_InstanceMetrics{} |
| mi := &file_InstanceCommunication_proto_msgTypes[7] |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| ms.StoreMessageInfo(mi) |
| } |
| |
| func (x *Metrics_InstanceMetrics) String() string { |
| return protoimpl.X.MessageStringOf(x) |
| } |
| |
| func (*Metrics_InstanceMetrics) ProtoMessage() {} |
| |
| func (x *Metrics_InstanceMetrics) ProtoReflect() protoreflect.Message { |
| mi := &file_InstanceCommunication_proto_msgTypes[7] |
| if x != nil { |
| ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) |
| if ms.LoadMessageInfo() == nil { |
| ms.StoreMessageInfo(mi) |
| } |
| return ms |
| } |
| return mi.MessageOf(x) |
| } |
| |
| // Deprecated: Use Metrics_InstanceMetrics.ProtoReflect.Descriptor instead. |
| func (*Metrics_InstanceMetrics) Descriptor() ([]byte, []int) { |
| return file_InstanceCommunication_proto_rawDescGZIP(), []int{4, 0} |
| } |
| |
| func (x *Metrics_InstanceMetrics) GetName() string { |
| if x != nil { |
| return x.Name |
| } |
| return "" |
| } |
| |
| func (x *Metrics_InstanceMetrics) GetInstanceId() int32 { |
| if x != nil { |
| return x.InstanceId |
| } |
| return 0 |
| } |
| |
| func (x *Metrics_InstanceMetrics) GetMetricsData() *MetricsData { |
| if x != nil { |
| return x.MetricsData |
| } |
| return nil |
| } |
| |
| var File_InstanceCommunication_proto protoreflect.FileDescriptor |
| |
| const file_InstanceCommunication_proto_rawDesc = "" + |
| "\n" + |
| "\x1bInstanceCommunication.proto\x12\x05proto\x1a\x1bgoogle/protobuf/empty.proto\"\x98\b\n" + |
| "\x0eFunctionStatus\x12\x18\n" + |
| "\arunning\x18\x01 \x01(\bR\arunning\x12*\n" + |
| "\x10failureException\x18\x02 \x01(\tR\x10failureException\x12 \n" + |
| "\vnumRestarts\x18\x03 \x01(\x03R\vnumRestarts\x12 \n" + |
| "\vnumReceived\x18\x11 \x01(\x03R\vnumReceived\x12:\n" + |
| "\x18numSuccessfullyProcessed\x18\x05 \x01(\x03R\x18numSuccessfullyProcessed\x12,\n" + |
| "\x11numUserExceptions\x18\x06 \x01(\x03R\x11numUserExceptions\x12^\n" + |
| "\x14latestUserExceptions\x18\a \x03(\v2*.proto.FunctionStatus.ExceptionInformationR\x14latestUserExceptions\x120\n" + |
| "\x13numSystemExceptions\x18\b \x01(\x03R\x13numSystemExceptions\x12b\n" + |
| "\x16latestSystemExceptions\x18\t \x03(\v2*.proto.FunctionStatus.ExceptionInformationR\x16latestSystemExceptions\x120\n" + |
| "\x13numSourceExceptions\x18\x12 \x01(\x03R\x13numSourceExceptions\x12b\n" + |
| "\x16latestSourceExceptions\x18\x13 \x03(\v2*.proto.FunctionStatus.ExceptionInformationR\x16latestSourceExceptions\x12,\n" + |
| "\x11numSinkExceptions\x18\x14 \x01(\x03R\x11numSinkExceptions\x12^\n" + |
| "\x14latestSinkExceptions\x18\x15 \x03(\v2*.proto.FunctionStatus.ExceptionInformationR\x14latestSinkExceptions\x12&\n" + |
| "\x0eaverageLatency\x18\f \x01(\x01R\x0eaverageLatency\x12.\n" + |
| "\x12lastInvocationTime\x18\r \x01(\x03R\x12lastInvocationTime\x12\x1e\n" + |
| "\n" + |
| "instanceId\x18\x0e \x01(\tR\n" + |
| "instanceId\x12\x1a\n" + |
| "\bworkerId\x18\x10 \x01(\tR\bworkerId\x1ad\n" + |
| "\x14ExceptionInformation\x12(\n" + |
| "\x0fexceptionString\x18\x01 \x01(\tR\x0fexceptionString\x12\"\n" + |
| "\fmsSinceEpoch\x18\x02 \x01(\x03R\fmsSinceEpoch\"q\n" + |
| "\x12FunctionStatusList\x12\x14\n" + |
| "\x05error\x18\x02 \x01(\tR\x05error\x12E\n" + |
| "\x12functionStatusList\x18\x01 \x03(\v2\x15.proto.FunctionStatusR\x12functionStatusList\"\xe1\x05\n" + |
| "\vMetricsData\x12$\n" + |
| "\rreceivedTotal\x18\x02 \x01(\x03R\rreceivedTotal\x12-\n" + |
| "\x12receivedTotal_1min\x18\n" + |
| " \x01(\x03R\x11receivedTotal1min\x12>\n" + |
| "\x1aprocessedSuccessfullyTotal\x18\x04 \x01(\x03R\x1aprocessedSuccessfullyTotal\x12G\n" + |
| "\x1fprocessedSuccessfullyTotal_1min\x18\f \x01(\x03R\x1eprocessedSuccessfullyTotal1min\x124\n" + |
| "\x15systemExceptionsTotal\x18\x05 \x01(\x03R\x15systemExceptionsTotal\x12=\n" + |
| "\x1asystemExceptionsTotal_1min\x18\r \x01(\x03R\x19systemExceptionsTotal1min\x120\n" + |
| "\x13userExceptionsTotal\x18\x06 \x01(\x03R\x13userExceptionsTotal\x129\n" + |
| "\x18userExceptionsTotal_1min\x18\x0e \x01(\x03R\x17userExceptionsTotal1min\x12,\n" + |
| "\x11avgProcessLatency\x18\a \x01(\x01R\x11avgProcessLatency\x125\n" + |
| "\x16avgProcessLatency_1min\x18\x0f \x01(\x01R\x15avgProcessLatency1min\x12&\n" + |
| "\x0elastInvocation\x18\b \x01(\x03R\x0elastInvocation\x12E\n" + |
| "\vuserMetrics\x18\t \x03(\v2#.proto.MetricsData.UserMetricsEntryR\vuserMetrics\x1a>\n" + |
| "\x10UserMetricsEntry\x12\x10\n" + |
| "\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" + |
| "\x05value\x18\x02 \x01(\x01R\x05value:\x028\x01\"-\n" + |
| "\x11HealthCheckResult\x12\x18\n" + |
| "\asuccess\x18\x01 \x01(\bR\asuccess\"\xc0\x01\n" + |
| "\aMetrics\x128\n" + |
| "\ametrics\x18\x01 \x03(\v2\x1e.proto.Metrics.InstanceMetricsR\ametrics\x1a{\n" + |
| "\x0fInstanceMetrics\x12\x12\n" + |
| "\x04name\x18\x01 \x01(\tR\x04name\x12\x1e\n" + |
| "\n" + |
| "instanceId\x18\x02 \x01(\x05R\n" + |
| "instanceId\x124\n" + |
| "\vmetricsData\x18\x03 \x01(\v2\x12.proto.MetricsDataR\vmetricsData2\xdc\x02\n" + |
| "\x0fInstanceControl\x12D\n" + |
| "\x11GetFunctionStatus\x12\x16.google.protobuf.Empty\x1a\x15.proto.FunctionStatus\"\x00\x12B\n" + |
| "\x12GetAndResetMetrics\x12\x16.google.protobuf.Empty\x1a\x12.proto.MetricsData\"\x00\x12@\n" + |
| "\fResetMetrics\x12\x16.google.protobuf.Empty\x1a\x16.google.protobuf.Empty\"\x00\x12:\n" + |
| "\n" + |
| "GetMetrics\x12\x16.google.protobuf.Empty\x1a\x12.proto.MetricsData\"\x00\x12A\n" + |
| "\vHealthCheck\x12\x16.google.protobuf.Empty\x1a\x18.proto.HealthCheckResult\"\x00B:\n" + |
| "!org.apache.pulsar.functions.protoB\x15InstanceCommunicationb\x06proto3" |
| |
| var ( |
| file_InstanceCommunication_proto_rawDescOnce sync.Once |
| file_InstanceCommunication_proto_rawDescData []byte |
| ) |
| |
| func file_InstanceCommunication_proto_rawDescGZIP() []byte { |
| file_InstanceCommunication_proto_rawDescOnce.Do(func() { |
| file_InstanceCommunication_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_InstanceCommunication_proto_rawDesc), len(file_InstanceCommunication_proto_rawDesc))) |
| }) |
| return file_InstanceCommunication_proto_rawDescData |
| } |
| |
| var file_InstanceCommunication_proto_msgTypes = make([]protoimpl.MessageInfo, 8) |
| var file_InstanceCommunication_proto_goTypes = []any{ |
| (*FunctionStatus)(nil), // 0: proto.FunctionStatus |
| (*FunctionStatusList)(nil), // 1: proto.FunctionStatusList |
| (*MetricsData)(nil), // 2: proto.MetricsData |
| (*HealthCheckResult)(nil), // 3: proto.HealthCheckResult |
| (*Metrics)(nil), // 4: proto.Metrics |
| (*FunctionStatus_ExceptionInformation)(nil), // 5: proto.FunctionStatus.ExceptionInformation |
| nil, // 6: proto.MetricsData.UserMetricsEntry |
| (*Metrics_InstanceMetrics)(nil), // 7: proto.Metrics.InstanceMetrics |
| (*emptypb.Empty)(nil), // 8: google.protobuf.Empty |
| } |
| var file_InstanceCommunication_proto_depIdxs = []int32{ |
| 5, // 0: proto.FunctionStatus.latestUserExceptions:type_name -> proto.FunctionStatus.ExceptionInformation |
| 5, // 1: proto.FunctionStatus.latestSystemExceptions:type_name -> proto.FunctionStatus.ExceptionInformation |
| 5, // 2: proto.FunctionStatus.latestSourceExceptions:type_name -> proto.FunctionStatus.ExceptionInformation |
| 5, // 3: proto.FunctionStatus.latestSinkExceptions:type_name -> proto.FunctionStatus.ExceptionInformation |
| 0, // 4: proto.FunctionStatusList.functionStatusList:type_name -> proto.FunctionStatus |
| 6, // 5: proto.MetricsData.userMetrics:type_name -> proto.MetricsData.UserMetricsEntry |
| 7, // 6: proto.Metrics.metrics:type_name -> proto.Metrics.InstanceMetrics |
| 2, // 7: proto.Metrics.InstanceMetrics.metricsData:type_name -> proto.MetricsData |
| 8, // 8: proto.InstanceControl.GetFunctionStatus:input_type -> google.protobuf.Empty |
| 8, // 9: proto.InstanceControl.GetAndResetMetrics:input_type -> google.protobuf.Empty |
| 8, // 10: proto.InstanceControl.ResetMetrics:input_type -> google.protobuf.Empty |
| 8, // 11: proto.InstanceControl.GetMetrics:input_type -> google.protobuf.Empty |
| 8, // 12: proto.InstanceControl.HealthCheck:input_type -> google.protobuf.Empty |
| 0, // 13: proto.InstanceControl.GetFunctionStatus:output_type -> proto.FunctionStatus |
| 2, // 14: proto.InstanceControl.GetAndResetMetrics:output_type -> proto.MetricsData |
| 8, // 15: proto.InstanceControl.ResetMetrics:output_type -> google.protobuf.Empty |
| 2, // 16: proto.InstanceControl.GetMetrics:output_type -> proto.MetricsData |
| 3, // 17: proto.InstanceControl.HealthCheck:output_type -> proto.HealthCheckResult |
| 13, // [13:18] is the sub-list for method output_type |
| 8, // [8:13] is the sub-list for method input_type |
| 8, // [8:8] is the sub-list for extension type_name |
| 8, // [8:8] is the sub-list for extension extendee |
| 0, // [0:8] is the sub-list for field type_name |
| } |
| |
| func init() { file_InstanceCommunication_proto_init() } |
| func file_InstanceCommunication_proto_init() { |
| if File_InstanceCommunication_proto != nil { |
| return |
| } |
| type x struct{} |
| out := protoimpl.TypeBuilder{ |
| File: protoimpl.DescBuilder{ |
| GoPackagePath: reflect.TypeOf(x{}).PkgPath(), |
| RawDescriptor: unsafe.Slice(unsafe.StringData(file_InstanceCommunication_proto_rawDesc), len(file_InstanceCommunication_proto_rawDesc)), |
| NumEnums: 0, |
| NumMessages: 8, |
| NumExtensions: 0, |
| NumServices: 1, |
| }, |
| GoTypes: file_InstanceCommunication_proto_goTypes, |
| DependencyIndexes: file_InstanceCommunication_proto_depIdxs, |
| MessageInfos: file_InstanceCommunication_proto_msgTypes, |
| }.Build() |
| File_InstanceCommunication_proto = out.File |
| file_InstanceCommunication_proto_goTypes = nil |
| file_InstanceCommunication_proto_depIdxs = nil |
| } |
