Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterSentryFlowMetricsServer(s grpc.ServiceRegistrar, srv SentryFlowMetricsServer)
- func RegisterSentryFlowServer(s grpc.ServiceRegistrar, srv SentryFlowServer)
- type APIClassificationRequest
- func (*APIClassificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *APIClassificationRequest) GetPath() []string
- func (*APIClassificationRequest) ProtoMessage()
- func (x *APIClassificationRequest) ProtoReflect() protoreflect.Message
- func (x *APIClassificationRequest) Reset()
- func (x *APIClassificationRequest) String() string
- type APIClassificationResponse
- func (*APIClassificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *APIClassificationResponse) GetFields() map[string]uint64
- func (*APIClassificationResponse) ProtoMessage()
- func (x *APIClassificationResponse) ProtoReflect() protoreflect.Message
- func (x *APIClassificationResponse) Reset()
- func (x *APIClassificationResponse) String() string
- type APILog
- func (*APILog) Descriptor() ([]byte, []int)deprecated
- func (x *APILog) GetDstIP() string
- func (x *APILog) GetDstLabel() map[string]string
- func (x *APILog) GetDstName() string
- func (x *APILog) GetDstNamespace() string
- func (x *APILog) GetDstPort() string
- func (x *APILog) GetDstType() string
- func (x *APILog) GetId() uint64
- func (x *APILog) GetMethod() string
- func (x *APILog) GetPath() string
- func (x *APILog) GetProtocol() string
- func (x *APILog) GetResponseCode() int32
- func (x *APILog) GetSrcIP() string
- func (x *APILog) GetSrcLabel() map[string]string
- func (x *APILog) GetSrcName() string
- func (x *APILog) GetSrcNamespace() string
- func (x *APILog) GetSrcPort() string
- func (x *APILog) GetSrcType() string
- func (x *APILog) GetTimeStamp() string
- func (*APILog) ProtoMessage()
- func (x *APILog) ProtoReflect() protoreflect.Message
- func (x *APILog) Reset()
- func (x *APILog) String() string
- type APIMetric
- type ClientInfo
- type EnvoyMetric
- func (*EnvoyMetric) Descriptor() ([]byte, []int)deprecated
- func (x *EnvoyMetric) GetLabels() map[string]string
- func (x *EnvoyMetric) GetMetric() map[string]*MetricValue
- func (x *EnvoyMetric) GetName() string
- func (x *EnvoyMetric) GetNamespace() string
- func (x *EnvoyMetric) GetPodIP() string
- func (x *EnvoyMetric) GetTimeStamp() string
- func (*EnvoyMetric) ProtoMessage()
- func (x *EnvoyMetric) ProtoReflect() protoreflect.Message
- func (x *EnvoyMetric) Reset()
- func (x *EnvoyMetric) String() string
- type MetricValue
- type SentryFlowClient
- type SentryFlowMetricsClient
- type SentryFlowMetricsServer
- type SentryFlowMetrics_GetAPIClassificationClient
- type SentryFlowMetrics_GetAPIClassificationServer
- type SentryFlowServer
- type SentryFlow_GetAPIMetricsClient
- type SentryFlow_GetAPIMetricsServer
- type SentryFlow_GetEnvoyMetricsClient
- type SentryFlow_GetEnvoyMetricsServer
- type SentryFlow_GetLogClient
- type SentryFlow_GetLogServer
- type UnimplementedSentryFlowMetricsServer
- type UnimplementedSentryFlowServer
- type UnsafeSentryFlowMetricsServer
- type UnsafeSentryFlowServer
Constants ¶
const ( SentryFlow_GetLog_FullMethodName = "/protobuf.SentryFlow/GetLog" SentryFlow_GetAPIMetrics_FullMethodName = "/protobuf.SentryFlow/GetAPIMetrics" SentryFlow_GetEnvoyMetrics_FullMethodName = "/protobuf.SentryFlow/GetEnvoyMetrics" )
const (
SentryFlowMetrics_GetAPIClassification_FullMethodName = "/protobuf.SentryFlowMetrics/GetAPIClassification"
)
Variables ¶
var File_sentryflow_metrics_proto protoreflect.FileDescriptor
var File_sentryflow_proto protoreflect.FileDescriptor
var SentryFlowMetrics_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protobuf.SentryFlowMetrics", HandlerType: (*SentryFlowMetricsServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "GetAPIClassification", Handler: _SentryFlowMetrics_GetAPIClassification_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "sentryflow_metrics.proto", }
SentryFlowMetrics_ServiceDesc is the grpc.ServiceDesc for SentryFlowMetrics service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SentryFlow_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protobuf.SentryFlow", HandlerType: (*SentryFlowServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "GetLog", Handler: _SentryFlow_GetLog_Handler, ServerStreams: true, }, { StreamName: "GetAPIMetrics", Handler: _SentryFlow_GetAPIMetrics_Handler, ServerStreams: true, }, { StreamName: "GetEnvoyMetrics", Handler: _SentryFlow_GetEnvoyMetrics_Handler, ServerStreams: true, }, }, Metadata: "sentryflow.proto", }
SentryFlow_ServiceDesc is the grpc.ServiceDesc for SentryFlow service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSentryFlowMetricsServer ¶
func RegisterSentryFlowMetricsServer(s grpc.ServiceRegistrar, srv SentryFlowMetricsServer)
func RegisterSentryFlowServer ¶
func RegisterSentryFlowServer(s grpc.ServiceRegistrar, srv SentryFlowServer)
Types ¶
type APIClassificationRequest ¶
type APIClassificationRequest struct { Path []string `protobuf:"bytes,1,rep,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*APIClassificationRequest) Descriptor
deprecated
func (*APIClassificationRequest) Descriptor() ([]byte, []int)
Deprecated: Use APIClassificationRequest.ProtoReflect.Descriptor instead.
func (*APIClassificationRequest) GetPath ¶
func (x *APIClassificationRequest) GetPath() []string
func (*APIClassificationRequest) ProtoMessage ¶
func (*APIClassificationRequest) ProtoMessage()
func (*APIClassificationRequest) ProtoReflect ¶
func (x *APIClassificationRequest) ProtoReflect() protoreflect.Message
func (*APIClassificationRequest) Reset ¶
func (x *APIClassificationRequest) Reset()
func (*APIClassificationRequest) String ¶
func (x *APIClassificationRequest) String() string
type APIClassificationResponse ¶
type APIClassificationResponse struct { Fields map[string]uint64 `` /* 154-byte string literal not displayed */ // contains filtered or unexported fields }
func (*APIClassificationResponse) Descriptor
deprecated
func (*APIClassificationResponse) Descriptor() ([]byte, []int)
Deprecated: Use APIClassificationResponse.ProtoReflect.Descriptor instead.
func (*APIClassificationResponse) GetFields ¶
func (x *APIClassificationResponse) GetFields() map[string]uint64
func (*APIClassificationResponse) ProtoMessage ¶
func (*APIClassificationResponse) ProtoMessage()
func (*APIClassificationResponse) ProtoReflect ¶
func (x *APIClassificationResponse) ProtoReflect() protoreflect.Message
func (*APIClassificationResponse) Reset ¶
func (x *APIClassificationResponse) Reset()
func (*APIClassificationResponse) String ¶
func (x *APIClassificationResponse) String() string
type APILog ¶
type APILog struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` TimeStamp string `protobuf:"bytes,2,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"` SrcNamespace string `protobuf:"bytes,11,opt,name=srcNamespace,proto3" json:"srcNamespace,omitempty"` SrcName string `protobuf:"bytes,12,opt,name=srcName,proto3" json:"srcName,omitempty"` SrcLabel map[string]string `` /* 158-byte string literal not displayed */ SrcType string `protobuf:"bytes,16,opt,name=srcType,proto3" json:"srcType,omitempty"` SrcIP string `protobuf:"bytes,17,opt,name=srcIP,proto3" json:"srcIP,omitempty"` SrcPort string `protobuf:"bytes,18,opt,name=srcPort,proto3" json:"srcPort,omitempty"` DstNamespace string `protobuf:"bytes,21,opt,name=dstNamespace,proto3" json:"dstNamespace,omitempty"` DstName string `protobuf:"bytes,22,opt,name=dstName,proto3" json:"dstName,omitempty"` DstLabel map[string]string `` /* 158-byte string literal not displayed */ DstType string `protobuf:"bytes,26,opt,name=dstType,proto3" json:"dstType,omitempty"` DstIP string `protobuf:"bytes,27,opt,name=dstIP,proto3" json:"dstIP,omitempty"` DstPort string `protobuf:"bytes,28,opt,name=dstPort,proto3" json:"dstPort,omitempty"` Protocol string `protobuf:"bytes,31,opt,name=protocol,proto3" json:"protocol,omitempty"` Method string `protobuf:"bytes,32,opt,name=method,proto3" json:"method,omitempty"` Path string `protobuf:"bytes,33,opt,name=path,proto3" json:"path,omitempty"` ResponseCode int32 `protobuf:"varint,34,opt,name=responseCode,proto3" json:"responseCode,omitempty"` // contains filtered or unexported fields }
func (*APILog) Descriptor
deprecated
func (*APILog) GetDstLabel ¶
func (*APILog) GetDstName ¶
func (*APILog) GetDstNamespace ¶
func (*APILog) GetDstPort ¶
func (*APILog) GetDstType ¶
func (*APILog) GetProtocol ¶
func (*APILog) GetResponseCode ¶
func (*APILog) GetSrcLabel ¶
func (*APILog) GetSrcName ¶
func (*APILog) GetSrcNamespace ¶
func (*APILog) GetSrcPort ¶
func (*APILog) GetSrcType ¶
func (*APILog) GetTimeStamp ¶
func (*APILog) ProtoMessage ¶
func (*APILog) ProtoMessage()
func (*APILog) ProtoReflect ¶
func (x *APILog) ProtoReflect() protoreflect.Message
type APIMetric ¶
type APIMetric struct { PerAPICounts map[string]uint64 `` // @todo: add some more metrics here /* 166-byte string literal not displayed */ // contains filtered or unexported fields }
func (*APIMetric) Descriptor
deprecated
func (*APIMetric) GetPerAPICounts ¶
func (*APIMetric) ProtoMessage ¶
func (*APIMetric) ProtoMessage()
func (*APIMetric) ProtoReflect ¶
func (x *APIMetric) ProtoReflect() protoreflect.Message
type ClientInfo ¶
type ClientInfo struct { HostName string `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"` IPAddress string `protobuf:"bytes,2,opt,name=IPAddress,proto3" json:"IPAddress,omitempty"` // contains filtered or unexported fields }
func (*ClientInfo) Descriptor
deprecated
func (*ClientInfo) Descriptor() ([]byte, []int)
Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.
func (*ClientInfo) GetHostName ¶
func (x *ClientInfo) GetHostName() string
func (*ClientInfo) GetIPAddress ¶
func (x *ClientInfo) GetIPAddress() string
func (*ClientInfo) ProtoMessage ¶
func (*ClientInfo) ProtoMessage()
func (*ClientInfo) ProtoReflect ¶
func (x *ClientInfo) ProtoReflect() protoreflect.Message
func (*ClientInfo) Reset ¶
func (x *ClientInfo) Reset()
func (*ClientInfo) String ¶
func (x *ClientInfo) String() string
type EnvoyMetric ¶
type EnvoyMetric struct { Namespace string `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ PodIP string `protobuf:"bytes,3,opt,name=podIP,proto3" json:"podIP,omitempty"` TimeStamp string `protobuf:"bytes,5,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"` Metric map[string]*MetricValue `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EnvoyMetric) Descriptor
deprecated
func (*EnvoyMetric) Descriptor() ([]byte, []int)
Deprecated: Use EnvoyMetric.ProtoReflect.Descriptor instead.
func (*EnvoyMetric) GetLabels ¶
func (x *EnvoyMetric) GetLabels() map[string]string
func (*EnvoyMetric) GetMetric ¶
func (x *EnvoyMetric) GetMetric() map[string]*MetricValue
func (*EnvoyMetric) GetName ¶
func (x *EnvoyMetric) GetName() string
func (*EnvoyMetric) GetNamespace ¶
func (x *EnvoyMetric) GetNamespace() string
func (*EnvoyMetric) GetPodIP ¶
func (x *EnvoyMetric) GetPodIP() string
func (*EnvoyMetric) GetTimeStamp ¶
func (x *EnvoyMetric) GetTimeStamp() string
func (*EnvoyMetric) ProtoMessage ¶
func (*EnvoyMetric) ProtoMessage()
func (*EnvoyMetric) ProtoReflect ¶
func (x *EnvoyMetric) ProtoReflect() protoreflect.Message
func (*EnvoyMetric) Reset ¶
func (x *EnvoyMetric) Reset()
func (*EnvoyMetric) String ¶
func (x *EnvoyMetric) String() string
type MetricValue ¶
type MetricValue struct { Value map[string]string `` /* 151-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MetricValue) Descriptor
deprecated
func (*MetricValue) Descriptor() ([]byte, []int)
Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.
func (*MetricValue) GetValue ¶
func (x *MetricValue) GetValue() map[string]string
func (*MetricValue) ProtoMessage ¶
func (*MetricValue) ProtoMessage()
func (*MetricValue) ProtoReflect ¶
func (x *MetricValue) ProtoReflect() protoreflect.Message
func (*MetricValue) Reset ¶
func (x *MetricValue) Reset()
func (*MetricValue) String ¶
func (x *MetricValue) String() string
type SentryFlowClient ¶
type SentryFlowClient interface { GetLog(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (SentryFlow_GetLogClient, error) GetAPIMetrics(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (SentryFlow_GetAPIMetricsClient, error) GetEnvoyMetrics(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (SentryFlow_GetEnvoyMetricsClient, error) }
SentryFlowClient is the client API for SentryFlow 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 NewSentryFlowClient ¶
func NewSentryFlowClient(cc grpc.ClientConnInterface) SentryFlowClient
type SentryFlowMetricsClient ¶
type SentryFlowMetricsClient interface {
GetAPIClassification(ctx context.Context, opts ...grpc.CallOption) (SentryFlowMetrics_GetAPIClassificationClient, error)
}
SentryFlowMetricsClient is the client API for SentryFlowMetrics 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 NewSentryFlowMetricsClient ¶
func NewSentryFlowMetricsClient(cc grpc.ClientConnInterface) SentryFlowMetricsClient
type SentryFlowMetricsServer ¶
type SentryFlowMetricsServer interface {
GetAPIClassification(SentryFlowMetrics_GetAPIClassificationServer) error
}
SentryFlowMetricsServer is the server API for SentryFlowMetrics service. All implementations should embed UnimplementedSentryFlowMetricsServer for forward compatibility
type SentryFlowMetrics_GetAPIClassificationClient ¶
type SentryFlowMetrics_GetAPIClassificationClient interface { Send(*APIClassificationRequest) error Recv() (*APIClassificationResponse, error) grpc.ClientStream }
type SentryFlowMetrics_GetAPIClassificationServer ¶
type SentryFlowMetrics_GetAPIClassificationServer interface { Send(*APIClassificationResponse) error Recv() (*APIClassificationRequest, error) grpc.ServerStream }
type SentryFlowServer ¶
type SentryFlowServer interface { GetLog(*ClientInfo, SentryFlow_GetLogServer) error GetAPIMetrics(*ClientInfo, SentryFlow_GetAPIMetricsServer) error GetEnvoyMetrics(*ClientInfo, SentryFlow_GetEnvoyMetricsServer) error }
SentryFlowServer is the server API for SentryFlow service. All implementations should embed UnimplementedSentryFlowServer for forward compatibility
type SentryFlow_GetAPIMetricsClient ¶
type SentryFlow_GetAPIMetricsClient interface { Recv() (*APIMetric, error) grpc.ClientStream }
type SentryFlow_GetAPIMetricsServer ¶
type SentryFlow_GetAPIMetricsServer interface { Send(*APIMetric) error grpc.ServerStream }
type SentryFlow_GetEnvoyMetricsClient ¶
type SentryFlow_GetEnvoyMetricsClient interface { Recv() (*EnvoyMetric, error) grpc.ClientStream }
type SentryFlow_GetEnvoyMetricsServer ¶
type SentryFlow_GetEnvoyMetricsServer interface { Send(*EnvoyMetric) error grpc.ServerStream }
type SentryFlow_GetLogClient ¶
type SentryFlow_GetLogClient interface { Recv() (*APILog, error) grpc.ClientStream }
type SentryFlow_GetLogServer ¶
type SentryFlow_GetLogServer interface { Send(*APILog) error grpc.ServerStream }
type UnimplementedSentryFlowMetricsServer ¶
type UnimplementedSentryFlowMetricsServer struct { }
UnimplementedSentryFlowMetricsServer should be embedded to have forward compatible implementations.
func (UnimplementedSentryFlowMetricsServer) GetAPIClassification ¶
func (UnimplementedSentryFlowMetricsServer) GetAPIClassification(SentryFlowMetrics_GetAPIClassificationServer) error
type UnimplementedSentryFlowServer ¶
type UnimplementedSentryFlowServer struct { }
UnimplementedSentryFlowServer should be embedded to have forward compatible implementations.
func (UnimplementedSentryFlowServer) GetAPIMetrics ¶
func (UnimplementedSentryFlowServer) GetAPIMetrics(*ClientInfo, SentryFlow_GetAPIMetricsServer) error
func (UnimplementedSentryFlowServer) GetEnvoyMetrics ¶
func (UnimplementedSentryFlowServer) GetEnvoyMetrics(*ClientInfo, SentryFlow_GetEnvoyMetricsServer) error
func (UnimplementedSentryFlowServer) GetLog ¶
func (UnimplementedSentryFlowServer) GetLog(*ClientInfo, SentryFlow_GetLogServer) error
type UnsafeSentryFlowMetricsServer ¶
type UnsafeSentryFlowMetricsServer interface {
// contains filtered or unexported methods
}
UnsafeSentryFlowMetricsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SentryFlowMetricsServer will result in compilation errors.
type UnsafeSentryFlowServer ¶
type UnsafeSentryFlowServer interface {
// contains filtered or unexported methods
}
UnsafeSentryFlowServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SentryFlowServer will result in compilation errors.