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) GetName() 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) GetLabels() map[string]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, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
- func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error
Constants ¶
This section is empty.
Variables ¶
var File_observability_v1alpha1_mads_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMonitoringAssignmentDiscoveryServiceServer ¶
func RegisterMonitoringAssignmentDiscoveryServiceServer(s *grpc.Server, srv MonitoringAssignmentDiscoveryServiceServer)
Types ¶
type MonitoringAssignment ¶
type MonitoringAssignment struct {
// MADS resource name.
//
// E.g., `/meshes/default/services/backend` or
// `/meshes/default/dataplanes/backend-01`.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// List of targets that need to be monitored.
Targets []*MonitoringAssignment_Target `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
// Labels associated with every target in that assignment.
//
// E.g., `["job" : "backend"]`.
Labels map[string]string `` /* 153-byte string literal not displayed */
// contains filtered or unexported fields
}
MADS resource type.
Describes a group of targets 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) GetTargets ¶
func (x *MonitoringAssignment) GetTargets() []*MonitoringAssignment_Target
func (*MonitoringAssignment) ProtoMessage ¶
func (*MonitoringAssignment) ProtoMessage()
func (*MonitoringAssignment) ProtoReflect ¶
func (x *MonitoringAssignment) ProtoReflect() protoreflect.Message
type MonitoringAssignmentDiscoveryServiceClient ¶
type MonitoringAssignmentDiscoveryServiceClient interface {
DeltaMonitoringAssignments(ctx context.Context, opts ...grpc.CallOption) (MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient, error)
StreamMonitoringAssignments(ctx context.Context, opts ...grpc.CallOption) (MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient, error)
FetchMonitoringAssignments(ctx context.Context, in *v2.DiscoveryRequest, opts ...grpc.CallOption) (*v2.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 {
DeltaMonitoringAssignments(MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer) error
StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error
FetchMonitoringAssignments(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
}
MonitoringAssignmentDiscoveryServiceServer is the server API for MonitoringAssignmentDiscoveryService service.
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient ¶
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsClient interface {
Send(*v2.DeltaDiscoveryRequest) error
Recv() (*v2.DeltaDiscoveryResponse, error)
grpc.ClientStream
}
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer ¶
type MonitoringAssignmentDiscoveryService_DeltaMonitoringAssignmentsServer interface {
Send(*v2.DeltaDiscoveryResponse) error
Recv() (*v2.DeltaDiscoveryRequest, error)
grpc.ServerStream
}
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient ¶
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsClient interface {
Send(*v2.DiscoveryRequest) error
Recv() (*v2.DiscoveryResponse, error)
grpc.ClientStream
}
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer ¶
type MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer interface {
Send(*v2.DiscoveryResponse) error
Recv() (*v2.DiscoveryRequest, error)
grpc.ServerStream
}
type MonitoringAssignment_Target ¶
type MonitoringAssignment_Target struct {
// Labels associated with that particular target.
//
// E.g.,
// `[
// "__address__" : "192.168.0.1:8080",
// "__metrics_path__" : "/metrics"]`,
// "instance" : "backend-01",
// ]`.
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) GetLabels ¶
func (x *MonitoringAssignment_Target) GetLabels() map[string]string
func (*MonitoringAssignment_Target) ProtoMessage ¶
func (*MonitoringAssignment_Target) ProtoMessage()
func (*MonitoringAssignment_Target) ProtoReflect ¶
func (x *MonitoringAssignment_Target) ProtoReflect() protoreflect.Message
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, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments ¶
func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error