v1alpha1

package
v0.0.0-...-7118e27 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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) GetName 

func (x *MonitoringAssignment) GetName() 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 {
	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

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, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments 

func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments(MonitoringAssignmentDiscoveryService_StreamMonitoringAssignmentsServer) error

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.