v1

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_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 (*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.

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 (*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) FetchMonitoringAssignments

func (*UnimplementedMonitoringAssignmentDiscoveryServiceServer) StreamMonitoringAssignments

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL