Documentation ¶
Index ¶
- Variables
- func RegisterMonitoringAssignmentDiscoveryServiceServer(s *grpc.Server, srv MonitoringAssignmentDiscoveryServiceServer)
- type MonitoringAssignment
- func (*MonitoringAssignment) Descriptor() ([]byte, []int)deprecated
- func (x *MonitoringAssignment) GetLabels() map[string]string
- func (x *MonitoringAssignment) GetMesh() string
- func (x *MonitoringAssignment) GetService() string
- func (x *MonitoringAssignment) GetTargets() []*MonitoringAssignment_Target
- func (*MonitoringAssignment) ProtoMessage()
- func (x *MonitoringAssignment) ProtoReflect() protoreflect.Message
- func (x *MonitoringAssignment) Reset()
- func (x *MonitoringAssignment) String() string
- type MonitoringAssignmentDiscoveryServiceClient
- type MonitoringAssignmentDiscoveryServiceServer
- type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient
- type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer
- type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient
- type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer
- type MonitoringAssignment_Target
- func (*MonitoringAssignment_Target) Descriptor() ([]byte, []int)deprecated
- func (x *MonitoringAssignment_Target) GetAddress() string
- func (x *MonitoringAssignment_Target) GetLabels() map[string]string
- func (x *MonitoringAssignment_Target) GetMetricsPath() string
- func (x *MonitoringAssignment_Target) GetName() string
- func (x *MonitoringAssignment_Target) GetScheme() string
- func (*MonitoringAssignment_Target) ProtoMessage()
- func (x *MonitoringAssignment_Target) ProtoReflect() protoreflect.Message
- func (x *MonitoringAssignment_Target) Reset()
- func (x *MonitoringAssignment_Target) String() string
- type UnimplementedMonitoringAssignmentDiscoveryServiceServer
- func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) DeltaMonitoringAssignments(MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer) error
- func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) FetchMonitoringAssignments(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
- func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error
Constants ¶
This section is empty.
Variables ¶
var File_observability_v1_mads_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMonitoringAssignmentDiscoveryServiceServer ¶
func RegisterMonitoringAssignmentDiscoveryServiceServer(s *grpc.Server, srv MonitoringAssignmentDiscoveryServiceServer)
Types ¶
type MonitoringAssignment ¶
type MonitoringAssignment struct { // Mesh of the dataplane. // // E.g., `default` Mesh string `protobuf:"bytes,2,opt,name=mesh,proto3" json:"mesh,omitempty"` // Identifying service being monitored. // // E.g., `backend` Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"` // List of targets that need to be monitored. Targets []*MonitoringAssignment_Target `protobuf:"bytes,4,rep,name=targets,proto3" json:"targets,omitempty"` // Arbitrary Labels associated with every target in the assignment. // // E.g., `{"team": "infra"}`. Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
MADS resource type.
Describes a group of targets on a single service that need to be monitored.
func (*MonitoringAssignment) Descriptor
deprecated
func (*MonitoringAssignment) Descriptor() ([]byte, []int)
Deprecated: Use MonitoringAssignment.ProtoReflect.Descriptor instead.
func (*MonitoringAssignment) GetLabels ¶
func (x *MonitoringAssignment) GetLabels() map[string]string
func (*MonitoringAssignment) GetMesh ¶
func (x *MonitoringAssignment) GetMesh() string
func (*MonitoringAssignment) GetService ¶
func (x *MonitoringAssignment) GetService() string
func (*MonitoringAssignment) GetTargets ¶
func (x *MonitoringAssignment) GetTargets() []*MonitoringAssignment_Target
func (*MonitoringAssignment) ProtoMessage ¶
func (*MonitoringAssignment) ProtoMessage()
func (*MonitoringAssignment) ProtoReflect ¶
func (x *MonitoringAssignment) ProtoReflect() protoreflect.Message
func (*MonitoringAssignment) Reset ¶
func (x *MonitoringAssignment) Reset()
func (*MonitoringAssignment) String ¶
func (x *MonitoringAssignment) String() string
type MonitoringAssignmentDiscoveryServiceClient ¶
type MonitoringAssignmentDiscoveryServiceClient interface { // GRPC DeltaMonitoringAssignments(ctx context.Context, opts ...grpc.CallOption) (MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient, error) StreamMonitoringAssignments(ctx context.Context, opts ...grpc.CallOption) (MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient, error) // HTTP FetchMonitoringAssignments(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error) }
MonitoringAssignmentDiscoveryServiceClient is the client API for MonitoringAssignmentDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMonitoringAssignmentDiscoveryServiceClient ¶
func NewMonitoringAssignmentDiscoveryServiceClient(cc grpc.ClientConnInterface) MonitoringAssignmentDiscoveryServiceClient
type MonitoringAssignmentDiscoveryServiceServer ¶
type MonitoringAssignmentDiscoveryServiceServer interface { // GRPC DeltaMonitoringAssignments(MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer) error StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error // HTTP FetchMonitoringAssignments(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) }
MonitoringAssignmentDiscoveryServiceServer is the server API for MonitoringAssignmentDiscoveryService service.
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient ¶
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient interface { Send(*v3.DeltaDiscoveryRequest) error Recv() (*v3.DeltaDiscoveryResponse, error) grpc.ClientStream }
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer ¶
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer interface { Send(*v3.DeltaDiscoveryResponse) error Recv() (*v3.DeltaDiscoveryRequest, error) grpc.ServerStream }
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient ¶
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient interface { Send(*v3.DiscoveryRequest) error Recv() (*v3.DiscoveryResponse, error) grpc.ClientStream }
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer ¶
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer interface { Send(*v3.DiscoveryResponse) error Recv() (*v3.DiscoveryRequest, error) grpc.ServerStream }
type MonitoringAssignment_Target ¶
type MonitoringAssignment_Target struct { // Dataplane name. // // E.g., `backend-01` Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Scheme on which to scrape the target. // E.g., `http` Scheme string `protobuf:"bytes,2,opt,name=scheme,proto3" json:"scheme,omitempty"` // Address (preferably IP) for the service // E.g., `backend.svc` or `10.1.4.32:9090` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // Optional path to append to the address for scraping // E.g., `/metrics` MetricsPath string `protobuf:"bytes,4,opt,name=metrics_path,json=metricsPath,proto3" json:"metrics_path,omitempty"` // Arbitrary labels associated with that particular target. // // E.g., // `{ // "commit_hash" : "620506a88", // }`. Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Describes a single target that needs to be monitored.
func (*MonitoringAssignment_Target) Descriptor
deprecated
func (*MonitoringAssignment_Target) Descriptor() ([]byte, []int)
Deprecated: Use MonitoringAssignment_Target.ProtoReflect.Descriptor instead.
func (*MonitoringAssignment_Target) GetAddress ¶
func (x *MonitoringAssignment_Target) GetAddress() string
func (*MonitoringAssignment_Target) GetLabels ¶
func (x *MonitoringAssignment_Target) GetLabels() map[string]string
func (*MonitoringAssignment_Target) GetMetricsPath ¶
func (x *MonitoringAssignment_Target) GetMetricsPath() string
func (*MonitoringAssignment_Target) GetName ¶
func (x *MonitoringAssignment_Target) GetName() string
func (*MonitoringAssignment_Target) GetScheme ¶
func (x *MonitoringAssignment_Target) GetScheme() string
func (*MonitoringAssignment_Target) ProtoMessage ¶
func (*MonitoringAssignment_Target) ProtoMessage()
func (*MonitoringAssignment_Target) ProtoReflect ¶
func (x *MonitoringAssignment_Target) ProtoReflect() protoreflect.Message
func (*MonitoringAssignment_Target) Reset ¶
func (x *MonitoringAssignment_Target) Reset()
func (*MonitoringAssignment_Target) String ¶
func (x *MonitoringAssignment_Target) String() string
type UnimplementedMonitoringAssignmentDiscoveryServiceServer ¶
type UnimplementedMonitoringAssignmentDiscoveryServiceServer struct { }
UnimplementedMonitoringAssignmentDiscoveryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) DeltaMonitoringAssignments ¶
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) DeltaMonitoringAssignments(MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer) error
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) FetchMonitoringAssignments ¶
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) FetchMonitoringAssignments(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments ¶
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error