golang

package module
v0.0.0-...-49b771d Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SentryFlow_GetAPILog_FullMethodName       = "/protobuf.SentryFlow/GetAPILog"
	SentryFlow_GetAPIEvent_FullMethodName     = "/protobuf.SentryFlow/GetAPIEvent"
	SentryFlow_SendAPIEvent_FullMethodName    = "/protobuf.SentryFlow/SendAPIEvent"
	SentryFlow_GetAPIMetrics_FullMethodName   = "/protobuf.SentryFlow/GetAPIMetrics"
	SentryFlow_GetEnvoyMetrics_FullMethodName = "/protobuf.SentryFlow/GetEnvoyMetrics"
)
View Source 
const (
	APIClassifier_ClassifyAPIs_FullMethodName = "/protobuf.APIClassifier/ClassifyAPIs"
)

Variables

View Source 
var APIClassifier_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protobuf.APIClassifier",
	HandlerType: (*APIClassifierServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ClassifyAPIs",
			Handler:       _APIClassifier_ClassifyAPIs_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "sentryflow_metrics.proto",
}

APIClassifier_ServiceDesc is the grpc.ServiceDesc for APIClassifier 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_sentryflow_metrics_proto protoreflect.FileDescriptor
View Source 
var File_sentryflow_proto protoreflect.FileDescriptor
View Source 
var SentryFlow_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protobuf.SentryFlow",
	HandlerType: (*SentryFlowServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendAPIEvent",
			Handler:    _SentryFlow_SendAPIEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetAPILog",
			Handler:       _SentryFlow_GetAPILog_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAPIEvent",
			Handler:       _SentryFlow_GetAPIEvent_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 RegisterAPIClassifierServer 

func RegisterAPIClassifierServer(s grpc.ServiceRegistrar, srv APIClassifierServer)

func RegisterSentryFlowServer 

func RegisterSentryFlowServer(s grpc.ServiceRegistrar, srv SentryFlowServer)

Types

type APIClassifierClient 

type APIClassifierClient interface {
	ClassifyAPIs(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[APIClassifierRequest, APIClassifierResponse], error)
}

APIClassifierClient is the client API for APIClassifier 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 NewAPIClassifierClient 

func NewAPIClassifierClient(cc grpc.ClientConnInterface) APIClassifierClient

type APIClassifierRequest 

type APIClassifierRequest struct {
	API []string `protobuf:"bytes,1,rep,name=API,proto3" json:"API,omitempty"`
	// contains filtered or unexported fields
}

func (*APIClassifierRequest) Descriptor deprecated 

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

Deprecated: Use APIClassifierRequest.ProtoReflect.Descriptor instead.

func (*APIClassifierRequest) GetAPI 

func (x *APIClassifierRequest) GetAPI() []string

func (*APIClassifierRequest) ProtoMessage 

func (*APIClassifierRequest) ProtoMessage()

func (*APIClassifierRequest) ProtoReflect 

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

func (*APIClassifierRequest) Reset 

func (x *APIClassifierRequest) Reset()

func (*APIClassifierRequest) String 

func (x *APIClassifierRequest) String() string

type APIClassifierResponse 

type APIClassifierResponse struct {
	APIs map[string]uint64 `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*APIClassifierResponse) Descriptor deprecated 

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

Deprecated: Use APIClassifierResponse.ProtoReflect.Descriptor instead.

func (*APIClassifierResponse) GetAPIs 

func (x *APIClassifierResponse) GetAPIs() map[string]uint64

func (*APIClassifierResponse) ProtoMessage 

func (*APIClassifierResponse) ProtoMessage()

func (*APIClassifierResponse) ProtoReflect 

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

func (*APIClassifierResponse) Reset 

func (x *APIClassifierResponse) Reset()

func (*APIClassifierResponse) String 

func (x *APIClassifierResponse) String() string

type APIClassifierServer 

type APIClassifierServer interface {
	ClassifyAPIs(grpc.BidiStreamingServer[APIClassifierRequest, APIClassifierResponse]) error
	// contains filtered or unexported methods
}

APIClassifierServer is the server API for APIClassifier service. All implementations must embed UnimplementedAPIClassifierServer for forward compatibility.

type APIClassifier_ClassifyAPIsClient 

type APIClassifier_ClassifyAPIsClient = grpc.BidiStreamingClient[APIClassifierRequest, APIClassifierResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type APIClassifier_ClassifyAPIsServer 

type APIClassifier_ClassifyAPIsServer = grpc.BidiStreamingServer[APIClassifierRequest, APIClassifierResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type APIEvent 

type APIEvent struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Source      *Workload `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Destination *Workload `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"`
	Request     *Request  `protobuf:"bytes,5,opt,name=request,proto3" json:"request,omitempty"`
	Response    *Response `protobuf:"bytes,6,opt,name=response,proto3" json:"response,omitempty"`
	Protocol    string    `protobuf:"bytes,7,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

APIEvent represents an event related to an API call, including metadata, source and destination workloads, and network information.

func (*APIEvent) Descriptor deprecated 

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

Deprecated: Use APIEvent.ProtoReflect.Descriptor instead.

func (*APIEvent) GetDestination 

func (x *APIEvent) GetDestination() *Workload

func (*APIEvent) GetMetadata 

func (x *APIEvent) GetMetadata() *Metadata

func (*APIEvent) GetProtocol 

func (x *APIEvent) GetProtocol() string

func (*APIEvent) GetRequest 

func (x *APIEvent) GetRequest() *Request

func (*APIEvent) GetResponse 

func (x *APIEvent) GetResponse() *Response

func (*APIEvent) GetSource 

func (x *APIEvent) GetSource() *Workload

func (*APIEvent) ProtoMessage 

func (*APIEvent) ProtoMessage()

func (*APIEvent) ProtoReflect 

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

func (*APIEvent) Reset 

func (x *APIEvent) Reset()

func (*APIEvent) String 

func (x *APIEvent) String() string

type APILog deprecated 

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 `` /* 144-byte string literal not displayed */
	SrcType      string            `protobuf:"bytes,21,opt,name=srcType,proto3" json:"srcType,omitempty"`
	SrcIP        string            `protobuf:"bytes,22,opt,name=srcIP,proto3" json:"srcIP,omitempty"`
	SrcPort      string            `protobuf:"bytes,23,opt,name=srcPort,proto3" json:"srcPort,omitempty"`
	DstNamespace string            `protobuf:"bytes,31,opt,name=dstNamespace,proto3" json:"dstNamespace,omitempty"`
	DstName      string            `protobuf:"bytes,32,opt,name=dstName,proto3" json:"dstName,omitempty"`
	DstLabel     map[string]string `` /* 144-byte string literal not displayed */
	DstType      string            `protobuf:"bytes,41,opt,name=dstType,proto3" json:"dstType,omitempty"`
	DstIP        string            `protobuf:"bytes,42,opt,name=dstIP,proto3" json:"dstIP,omitempty"`
	DstPort      string            `protobuf:"bytes,43,opt,name=dstPort,proto3" json:"dstPort,omitempty"`
	Protocol     string            `protobuf:"bytes,51,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Method       string            `protobuf:"bytes,52,opt,name=method,proto3" json:"method,omitempty"`
	Path         string            `protobuf:"bytes,53,opt,name=path,proto3" json:"path,omitempty"`
	ResponseCode int32             `protobuf:"varint,54,opt,name=responseCode,proto3" json:"responseCode,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in sentryflow.proto.

func (*APILog) Descriptor deprecated 

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

Deprecated: Use APILog.ProtoReflect.Descriptor instead.

func (*APILog) GetDstIP 

func (x *APILog) GetDstIP() string

func (*APILog) GetDstLabel 

func (x *APILog) GetDstLabel() map[string]string

func (*APILog) GetDstName 

func (x *APILog) GetDstName() string

func (*APILog) GetDstNamespace 

func (x *APILog) GetDstNamespace() string

func (*APILog) GetDstPort 

func (x *APILog) GetDstPort() string

func (*APILog) GetDstType 

func (x *APILog) GetDstType() string

func (*APILog) GetId 

func (x *APILog) GetId() uint64

func (*APILog) GetMethod 

func (x *APILog) GetMethod() string

func (*APILog) GetPath 

func (x *APILog) GetPath() string

func (*APILog) GetProtocol 

func (x *APILog) GetProtocol() string

func (*APILog) GetResponseCode 

func (x *APILog) GetResponseCode() int32

func (*APILog) GetSrcIP 

func (x *APILog) GetSrcIP() string

func (*APILog) GetSrcLabel 

func (x *APILog) GetSrcLabel() map[string]string

func (*APILog) GetSrcName 

func (x *APILog) GetSrcName() string

func (*APILog) GetSrcNamespace 

func (x *APILog) GetSrcNamespace() string

func (*APILog) GetSrcPort 

func (x *APILog) GetSrcPort() string

func (*APILog) GetSrcType 

func (x *APILog) GetSrcType() string

func (*APILog) GetTimeStamp 

func (x *APILog) GetTimeStamp() string

func (*APILog) ProtoMessage 

func (*APILog) ProtoMessage()

func (*APILog) ProtoReflect 

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

func (*APILog) Reset 

func (x *APILog) Reset()

func (*APILog) String 

func (x *APILog) String() string

type APIMetrics 

type APIMetrics struct {
	PerAPICounts map[string]uint64 `` // @todo: add some more metrics here
	/* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*APIMetrics) Descriptor deprecated 

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

Deprecated: Use APIMetrics.ProtoReflect.Descriptor instead.

func (*APIMetrics) GetPerAPICounts 

func (x *APIMetrics) GetPerAPICounts() map[string]uint64

func (*APIMetrics) ProtoMessage 

func (*APIMetrics) ProtoMessage()

func (*APIMetrics) ProtoReflect 

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

func (*APIMetrics) Reset 

func (x *APIMetrics) Reset()

func (*APIMetrics) String 

func (x *APIMetrics) String() string

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 EnvoyMetrics 

type EnvoyMetrics struct {
	TimeStamp string                  `protobuf:"bytes,1,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"`
	Namespace string                  `protobuf:"bytes,11,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string                  `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	IPAddress string                  `protobuf:"bytes,13,opt,name=IPAddress,proto3" json:"IPAddress,omitempty"`
	Labels    map[string]string       `` /* 140-byte string literal not displayed */
	Metrics   map[string]*MetricValue `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EnvoyMetrics) Descriptor deprecated 

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

Deprecated: Use EnvoyMetrics.ProtoReflect.Descriptor instead.

func (*EnvoyMetrics) GetIPAddress 

func (x *EnvoyMetrics) GetIPAddress() string

func (*EnvoyMetrics) GetLabels 

func (x *EnvoyMetrics) GetLabels() map[string]string

func (*EnvoyMetrics) GetMetrics 

func (x *EnvoyMetrics) GetMetrics() map[string]*MetricValue

func (*EnvoyMetrics) GetName 

func (x *EnvoyMetrics) GetName() string

func (*EnvoyMetrics) GetNamespace 

func (x *EnvoyMetrics) GetNamespace() string

func (*EnvoyMetrics) GetTimeStamp 

func (x *EnvoyMetrics) GetTimeStamp() string

func (*EnvoyMetrics) ProtoMessage 

func (*EnvoyMetrics) ProtoMessage()

func (*EnvoyMetrics) ProtoReflect 

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

func (*EnvoyMetrics) Reset 

func (x *EnvoyMetrics) Reset()

func (*EnvoyMetrics) String 

func (x *EnvoyMetrics) String() string

type Metadata 

type Metadata struct {
	ContextId uint32 `protobuf:"varint,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Deprecated: Marked as deprecated in sentryflow.proto.
	IstioVersion string `protobuf:"bytes,3,opt,name=istio_version,json=istioVersion,proto3" json:"istio_version,omitempty"`
	MeshId       string `protobuf:"bytes,4,opt,name=mesh_id,json=meshId,proto3" json:"mesh_id,omitempty"`
	// The name of the Kubernetes node where the workload is running. If the workload
	// is not running in a Kubernetes environment, this field will be empty.
	NodeName string `protobuf:"bytes,5,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Name of receiver (e.g., Istio, nginx).
	ReceiverName string `protobuf:"bytes,6,opt,name=receiver_name,json=receiverName,proto3" json:"receiver_name,omitempty"`
	// Version of receiver (e.g., 1.26.2).
	ReceiverVersion string `protobuf:"bytes,7,opt,name=receiver_version,json=receiverVersion,proto3" json:"receiver_version,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetContextId 

func (x *Metadata) GetContextId() uint32

func (*Metadata) GetIstioVersion deprecated 

func (x *Metadata) GetIstioVersion() string

Deprecated: Marked as deprecated in sentryflow.proto.

func (*Metadata) GetMeshId 

func (x *Metadata) GetMeshId() string

func (*Metadata) GetNodeName 

func (x *Metadata) GetNodeName() string

func (*Metadata) GetReceiverName 

func (x *Metadata) GetReceiverName() string

func (*Metadata) GetReceiverVersion 

func (x *Metadata) GetReceiverVersion() string

func (*Metadata) GetTimestamp 

func (x *Metadata) GetTimestamp() uint64

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type MetricValue 

type MetricValue struct {
	Value map[string]string `` /* 137-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 Request 

type Request struct {
	Headers map[string]string `` /* 141-byte string literal not displayed */
	Body    string            `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

Request represents an incoming HTTP request.

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetBody 

func (x *Request) GetBody() string

func (*Request) GetHeaders 

func (x *Request) GetHeaders() map[string]string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {
	Headers               map[string]string `` /* 141-byte string literal not displayed */
	Body                  string            `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	BackendLatencyInNanos uint64            `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

Response represents an outgoing HTTP response.

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetBackendLatencyInNanos 

func (x *Response) GetBackendLatencyInNanos() uint64

func (*Response) GetBody 

func (x *Response) GetBody() string

func (*Response) GetHeaders 

func (x *Response) GetHeaders() map[string]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 SentryFlowClient 

type SentryFlowClient interface {
	// Deprecated: Do not use.
	GetAPILog(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[APILog], error)
	GetAPIEvent(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[APIEvent], error)
	SendAPIEvent(ctx context.Context, in *APIEvent, opts ...grpc.CallOption) (*APIEvent, error)
	GetAPIMetrics(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[APIMetrics], error)
	GetEnvoyMetrics(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EnvoyMetrics], 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 SentryFlowServer 

type SentryFlowServer interface {
	// Deprecated: Do not use.
	GetAPILog(*ClientInfo, grpc.ServerStreamingServer[APILog]) error
	GetAPIEvent(*ClientInfo, grpc.ServerStreamingServer[APIEvent]) error
	SendAPIEvent(context.Context, *APIEvent) (*APIEvent, error)
	GetAPIMetrics(*ClientInfo, grpc.ServerStreamingServer[APIMetrics]) error
	GetEnvoyMetrics(*ClientInfo, grpc.ServerStreamingServer[EnvoyMetrics]) error
	// contains filtered or unexported methods
}

SentryFlowServer is the server API for SentryFlow service. All implementations must embed UnimplementedSentryFlowServer for forward compatibility.

type SentryFlow_GetAPIEventClient 

type SentryFlow_GetAPIEventClient = grpc.ServerStreamingClient[APIEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetAPIEventServer 

type SentryFlow_GetAPIEventServer = grpc.ServerStreamingServer[APIEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetAPILogClient 

type SentryFlow_GetAPILogClient = grpc.ServerStreamingClient[APILog]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetAPILogServer 

type SentryFlow_GetAPILogServer = grpc.ServerStreamingServer[APILog]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetAPIMetricsClient 

type SentryFlow_GetAPIMetricsClient = grpc.ServerStreamingClient[APIMetrics]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetAPIMetricsServer 

type SentryFlow_GetAPIMetricsServer = grpc.ServerStreamingServer[APIMetrics]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetEnvoyMetricsClient 

type SentryFlow_GetEnvoyMetricsClient = grpc.ServerStreamingClient[EnvoyMetrics]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SentryFlow_GetEnvoyMetricsServer 

type SentryFlow_GetEnvoyMetricsServer = grpc.ServerStreamingServer[EnvoyMetrics]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedAPIClassifierServer 

type UnimplementedAPIClassifierServer struct{}

UnimplementedAPIClassifierServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAPIClassifierServer) ClassifyAPIs 

func (UnimplementedAPIClassifierServer) ClassifyAPIs(grpc.BidiStreamingServer[APIClassifierRequest, APIClassifierResponse]) error

type UnimplementedSentryFlowServer 

type UnimplementedSentryFlowServer struct{}

UnimplementedSentryFlowServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSentryFlowServer) GetAPIEvent 

func (UnimplementedSentryFlowServer) GetAPIEvent(*ClientInfo, grpc.ServerStreamingServer[APIEvent]) error

func (UnimplementedSentryFlowServer) GetAPILog 

func (UnimplementedSentryFlowServer) GetAPILog(*ClientInfo, grpc.ServerStreamingServer[APILog]) error

func (UnimplementedSentryFlowServer) GetAPIMetrics 

func (UnimplementedSentryFlowServer) GetAPIMetrics(*ClientInfo, grpc.ServerStreamingServer[APIMetrics]) error

func (UnimplementedSentryFlowServer) GetEnvoyMetrics 

func (UnimplementedSentryFlowServer) GetEnvoyMetrics(*ClientInfo, grpc.ServerStreamingServer[EnvoyMetrics]) error

func (UnimplementedSentryFlowServer) SendAPIEvent 

func (UnimplementedSentryFlowServer) SendAPIEvent(context.Context, *APIEvent) (*APIEvent, error)

type UnsafeAPIClassifierServer 

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

UnsafeAPIClassifierServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIClassifierServer 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.

type Workload 

type Workload struct {

	// The name of the workload.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace in which the workload is deployed. This field is only applicable
	// for Kubernetes workloads.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The IP address of the workload.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// The port number used by the workload.
	Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

Workload represents a generic entity that can be either a Kubernetes or non-Kubernetes resource. It serves as a source or destination for access within a system.

func (*Workload) Descriptor deprecated 

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

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetIp 

func (x *Workload) GetIp() string

func (*Workload) GetName 

func (x *Workload) GetName() string

func (*Workload) GetNamespace 

func (x *Workload) GetNamespace() string

func (*Workload) GetPort 

func (x *Workload) GetPort() int32

func (*Workload) ProtoMessage 

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect 

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

func (*Workload) Reset 

func (x *Workload) Reset()

func (*Workload) String 

func (x *Workload) 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.