Documentation ¶
Index ¶
- Variables
- func MetricsServiceServiceServer(server MetricsServiceServer) pluginsdk.ServiceServer
- func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)
- type AddSampleRequest
- func (*AddSampleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddSampleRequest) GetKey() []string
- func (x *AddSampleRequest) GetLabels() []*Label
- func (x *AddSampleRequest) GetVal() float32
- func (*AddSampleRequest) ProtoMessage()
- func (x *AddSampleRequest) ProtoReflect() protoreflect.Message
- func (x *AddSampleRequest) Reset()
- func (x *AddSampleRequest) String() string
- type AddSampleResponse
- type EmitKeyRequest
- func (*EmitKeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EmitKeyRequest) GetKey() []string
- func (x *EmitKeyRequest) GetVal() float32
- func (*EmitKeyRequest) ProtoMessage()
- func (x *EmitKeyRequest) ProtoReflect() protoreflect.Message
- func (x *EmitKeyRequest) Reset()
- func (x *EmitKeyRequest) String() string
- type EmitKeyResponse
- type IncrCounterRequest
- func (*IncrCounterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IncrCounterRequest) GetKey() []string
- func (x *IncrCounterRequest) GetLabels() []*Label
- func (x *IncrCounterRequest) GetVal() float32
- func (*IncrCounterRequest) ProtoMessage()
- func (x *IncrCounterRequest) ProtoReflect() protoreflect.Message
- func (x *IncrCounterRequest) Reset()
- func (x *IncrCounterRequest) String() string
- type IncrCounterResponse
- type Label
- type MeasureSinceRequest
- func (*MeasureSinceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MeasureSinceRequest) GetKey() []string
- func (x *MeasureSinceRequest) GetLabels() []*Label
- func (x *MeasureSinceRequest) GetTime() int64
- func (*MeasureSinceRequest) ProtoMessage()
- func (x *MeasureSinceRequest) ProtoReflect() protoreflect.Message
- func (x *MeasureSinceRequest) Reset()
- func (x *MeasureSinceRequest) String() string
- type MeasureSinceResponse
- type MetricsServiceClient
- type MetricsServiceServer
- type MetricsServiceServiceClient
- type SetGaugeRequest
- func (*SetGaugeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetGaugeRequest) GetKey() []string
- func (x *SetGaugeRequest) GetLabels() []*Label
- func (x *SetGaugeRequest) GetVal() float32
- func (*SetGaugeRequest) ProtoMessage()
- func (x *SetGaugeRequest) ProtoReflect() protoreflect.Message
- func (x *SetGaugeRequest) Reset()
- func (x *SetGaugeRequest) String() string
- type SetGaugeResponse
- type UnimplementedMetricsServiceServer
- func (UnimplementedMetricsServiceServer) AddSample(context.Context, *AddSampleRequest) (*AddSampleResponse, error)
- func (UnimplementedMetricsServiceServer) EmitKey(context.Context, *EmitKeyRequest) (*EmitKeyResponse, error)
- func (UnimplementedMetricsServiceServer) IncrCounter(context.Context, *IncrCounterRequest) (*IncrCounterResponse, error)
- func (UnimplementedMetricsServiceServer) MeasureSince(context.Context, *MeasureSinceRequest) (*MeasureSinceResponse, error)
- func (UnimplementedMetricsServiceServer) SetGauge(context.Context, *SetGaugeRequest) (*SetGaugeResponse, error)
- type UnsafeMetricsServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_spire_hostservice_common_metrics_v0_metrics_proto protoreflect.FileDescriptor
var MetricsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "spire.common.hostservices.MetricsService", HandlerType: (*MetricsServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetGauge", Handler: _MetricsService_SetGauge_Handler, }, { MethodName: "EmitKey", Handler: _MetricsService_EmitKey_Handler, }, { MethodName: "IncrCounter", Handler: _MetricsService_IncrCounter_Handler, }, { MethodName: "AddSample", Handler: _MetricsService_AddSample_Handler, }, { MethodName: "MeasureSince", Handler: _MetricsService_MeasureSince_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "spire/hostservice/common/metrics/v0/metrics.proto", }
MetricsService_ServiceDesc is the grpc.ServiceDesc for MetricsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func MetricsServiceServiceServer ¶
func MetricsServiceServiceServer(server MetricsServiceServer) pluginsdk.ServiceServer
func RegisterMetricsServiceServer ¶
func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer)
Types ¶
type AddSampleRequest ¶
type AddSampleRequest struct { Key []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"` Val float32 `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"` Labels []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*AddSampleRequest) Descriptor
deprecated
func (*AddSampleRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddSampleRequest.ProtoReflect.Descriptor instead.
func (*AddSampleRequest) GetKey ¶
func (x *AddSampleRequest) GetKey() []string
func (*AddSampleRequest) GetLabels ¶
func (x *AddSampleRequest) GetLabels() []*Label
func (*AddSampleRequest) GetVal ¶
func (x *AddSampleRequest) GetVal() float32
func (*AddSampleRequest) ProtoMessage ¶
func (*AddSampleRequest) ProtoMessage()
func (*AddSampleRequest) ProtoReflect ¶
func (x *AddSampleRequest) ProtoReflect() protoreflect.Message
func (*AddSampleRequest) Reset ¶
func (x *AddSampleRequest) Reset()
func (*AddSampleRequest) String ¶
func (x *AddSampleRequest) String() string
type AddSampleResponse ¶
type AddSampleResponse struct {
// contains filtered or unexported fields
}
func (*AddSampleResponse) Descriptor
deprecated
func (*AddSampleResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddSampleResponse.ProtoReflect.Descriptor instead.
func (*AddSampleResponse) ProtoMessage ¶
func (*AddSampleResponse) ProtoMessage()
func (*AddSampleResponse) ProtoReflect ¶
func (x *AddSampleResponse) ProtoReflect() protoreflect.Message
func (*AddSampleResponse) Reset ¶
func (x *AddSampleResponse) Reset()
func (*AddSampleResponse) String ¶
func (x *AddSampleResponse) String() string
type EmitKeyRequest ¶
type EmitKeyRequest struct { Key []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"` Val float32 `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"` // contains filtered or unexported fields }
func (*EmitKeyRequest) Descriptor
deprecated
func (*EmitKeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use EmitKeyRequest.ProtoReflect.Descriptor instead.
func (*EmitKeyRequest) GetKey ¶
func (x *EmitKeyRequest) GetKey() []string
func (*EmitKeyRequest) GetVal ¶
func (x *EmitKeyRequest) GetVal() float32
func (*EmitKeyRequest) ProtoMessage ¶
func (*EmitKeyRequest) ProtoMessage()
func (*EmitKeyRequest) ProtoReflect ¶
func (x *EmitKeyRequest) ProtoReflect() protoreflect.Message
func (*EmitKeyRequest) Reset ¶
func (x *EmitKeyRequest) Reset()
func (*EmitKeyRequest) String ¶
func (x *EmitKeyRequest) String() string
type EmitKeyResponse ¶
type EmitKeyResponse struct {
// contains filtered or unexported fields
}
func (*EmitKeyResponse) Descriptor
deprecated
func (*EmitKeyResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmitKeyResponse.ProtoReflect.Descriptor instead.
func (*EmitKeyResponse) ProtoMessage ¶
func (*EmitKeyResponse) ProtoMessage()
func (*EmitKeyResponse) ProtoReflect ¶
func (x *EmitKeyResponse) ProtoReflect() protoreflect.Message
func (*EmitKeyResponse) Reset ¶
func (x *EmitKeyResponse) Reset()
func (*EmitKeyResponse) String ¶
func (x *EmitKeyResponse) String() string
type IncrCounterRequest ¶
type IncrCounterRequest struct { Key []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"` Val float32 `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"` Labels []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*IncrCounterRequest) Descriptor
deprecated
func (*IncrCounterRequest) Descriptor() ([]byte, []int)
Deprecated: Use IncrCounterRequest.ProtoReflect.Descriptor instead.
func (*IncrCounterRequest) GetKey ¶
func (x *IncrCounterRequest) GetKey() []string
func (*IncrCounterRequest) GetLabels ¶
func (x *IncrCounterRequest) GetLabels() []*Label
func (*IncrCounterRequest) GetVal ¶
func (x *IncrCounterRequest) GetVal() float32
func (*IncrCounterRequest) ProtoMessage ¶
func (*IncrCounterRequest) ProtoMessage()
func (*IncrCounterRequest) ProtoReflect ¶
func (x *IncrCounterRequest) ProtoReflect() protoreflect.Message
func (*IncrCounterRequest) Reset ¶
func (x *IncrCounterRequest) Reset()
func (*IncrCounterRequest) String ¶
func (x *IncrCounterRequest) String() string
type IncrCounterResponse ¶
type IncrCounterResponse struct {
// contains filtered or unexported fields
}
func (*IncrCounterResponse) Descriptor
deprecated
func (*IncrCounterResponse) Descriptor() ([]byte, []int)
Deprecated: Use IncrCounterResponse.ProtoReflect.Descriptor instead.
func (*IncrCounterResponse) ProtoMessage ¶
func (*IncrCounterResponse) ProtoMessage()
func (*IncrCounterResponse) ProtoReflect ¶
func (x *IncrCounterResponse) ProtoReflect() protoreflect.Message
func (*IncrCounterResponse) Reset ¶
func (x *IncrCounterResponse) Reset()
func (*IncrCounterResponse) String ¶
func (x *IncrCounterResponse) String() string
type Label ¶
type Label struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Label) Descriptor
deprecated
func (*Label) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) ProtoReflect ¶
func (x *Label) ProtoReflect() protoreflect.Message
type MeasureSinceRequest ¶
type MeasureSinceRequest struct { Key []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"` // Unix time in nanoseconds Time int64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` Labels []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*MeasureSinceRequest) Descriptor
deprecated
func (*MeasureSinceRequest) Descriptor() ([]byte, []int)
Deprecated: Use MeasureSinceRequest.ProtoReflect.Descriptor instead.
func (*MeasureSinceRequest) GetKey ¶
func (x *MeasureSinceRequest) GetKey() []string
func (*MeasureSinceRequest) GetLabels ¶
func (x *MeasureSinceRequest) GetLabels() []*Label
func (*MeasureSinceRequest) GetTime ¶
func (x *MeasureSinceRequest) GetTime() int64
func (*MeasureSinceRequest) ProtoMessage ¶
func (*MeasureSinceRequest) ProtoMessage()
func (*MeasureSinceRequest) ProtoReflect ¶
func (x *MeasureSinceRequest) ProtoReflect() protoreflect.Message
func (*MeasureSinceRequest) Reset ¶
func (x *MeasureSinceRequest) Reset()
func (*MeasureSinceRequest) String ¶
func (x *MeasureSinceRequest) String() string
type MeasureSinceResponse ¶
type MeasureSinceResponse struct {
// contains filtered or unexported fields
}
func (*MeasureSinceResponse) Descriptor
deprecated
func (*MeasureSinceResponse) Descriptor() ([]byte, []int)
Deprecated: Use MeasureSinceResponse.ProtoReflect.Descriptor instead.
func (*MeasureSinceResponse) ProtoMessage ¶
func (*MeasureSinceResponse) ProtoMessage()
func (*MeasureSinceResponse) ProtoReflect ¶
func (x *MeasureSinceResponse) ProtoReflect() protoreflect.Message
func (*MeasureSinceResponse) Reset ¶
func (x *MeasureSinceResponse) Reset()
func (*MeasureSinceResponse) String ¶
func (x *MeasureSinceResponse) String() string
type MetricsServiceClient ¶
type MetricsServiceClient interface { SetGauge(ctx context.Context, in *SetGaugeRequest, opts ...grpc.CallOption) (*SetGaugeResponse, error) EmitKey(ctx context.Context, in *EmitKeyRequest, opts ...grpc.CallOption) (*EmitKeyResponse, error) IncrCounter(ctx context.Context, in *IncrCounterRequest, opts ...grpc.CallOption) (*IncrCounterResponse, error) AddSample(ctx context.Context, in *AddSampleRequest, opts ...grpc.CallOption) (*AddSampleResponse, error) MeasureSince(ctx context.Context, in *MeasureSinceRequest, opts ...grpc.CallOption) (*MeasureSinceResponse, error) }
MetricsServiceClient is the client API for MetricsService 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 NewMetricsServiceClient ¶
func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient
type MetricsServiceServer ¶
type MetricsServiceServer interface { SetGauge(context.Context, *SetGaugeRequest) (*SetGaugeResponse, error) EmitKey(context.Context, *EmitKeyRequest) (*EmitKeyResponse, error) IncrCounter(context.Context, *IncrCounterRequest) (*IncrCounterResponse, error) AddSample(context.Context, *AddSampleRequest) (*AddSampleResponse, error) MeasureSince(context.Context, *MeasureSinceRequest) (*MeasureSinceResponse, error) // contains filtered or unexported methods }
MetricsServiceServer is the server API for MetricsService service. All implementations must embed UnimplementedMetricsServiceServer for forward compatibility
type MetricsServiceServiceClient ¶
type MetricsServiceServiceClient struct {
MetricsServiceClient
}
func (*MetricsServiceServiceClient) GRPCServiceName ¶
func (c *MetricsServiceServiceClient) GRPCServiceName() string
func (*MetricsServiceServiceClient) InitClient ¶
func (c *MetricsServiceServiceClient) InitClient(conn grpc.ClientConnInterface) interface{}
func (*MetricsServiceServiceClient) IsInitialized ¶
func (c *MetricsServiceServiceClient) IsInitialized() bool
type SetGaugeRequest ¶
type SetGaugeRequest struct { Key []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"` Val float32 `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"` Labels []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*SetGaugeRequest) Descriptor
deprecated
func (*SetGaugeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetGaugeRequest.ProtoReflect.Descriptor instead.
func (*SetGaugeRequest) GetKey ¶
func (x *SetGaugeRequest) GetKey() []string
func (*SetGaugeRequest) GetLabels ¶
func (x *SetGaugeRequest) GetLabels() []*Label
func (*SetGaugeRequest) GetVal ¶
func (x *SetGaugeRequest) GetVal() float32
func (*SetGaugeRequest) ProtoMessage ¶
func (*SetGaugeRequest) ProtoMessage()
func (*SetGaugeRequest) ProtoReflect ¶
func (x *SetGaugeRequest) ProtoReflect() protoreflect.Message
func (*SetGaugeRequest) Reset ¶
func (x *SetGaugeRequest) Reset()
func (*SetGaugeRequest) String ¶
func (x *SetGaugeRequest) String() string
type SetGaugeResponse ¶
type SetGaugeResponse struct {
// contains filtered or unexported fields
}
func (*SetGaugeResponse) Descriptor
deprecated
func (*SetGaugeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetGaugeResponse.ProtoReflect.Descriptor instead.
func (*SetGaugeResponse) ProtoMessage ¶
func (*SetGaugeResponse) ProtoMessage()
func (*SetGaugeResponse) ProtoReflect ¶
func (x *SetGaugeResponse) ProtoReflect() protoreflect.Message
func (*SetGaugeResponse) Reset ¶
func (x *SetGaugeResponse) Reset()
func (*SetGaugeResponse) String ¶
func (x *SetGaugeResponse) String() string
type UnimplementedMetricsServiceServer ¶
type UnimplementedMetricsServiceServer struct { }
UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMetricsServiceServer) AddSample ¶
func (UnimplementedMetricsServiceServer) AddSample(context.Context, *AddSampleRequest) (*AddSampleResponse, error)
func (UnimplementedMetricsServiceServer) EmitKey ¶
func (UnimplementedMetricsServiceServer) EmitKey(context.Context, *EmitKeyRequest) (*EmitKeyResponse, error)
func (UnimplementedMetricsServiceServer) IncrCounter ¶
func (UnimplementedMetricsServiceServer) IncrCounter(context.Context, *IncrCounterRequest) (*IncrCounterResponse, error)
func (UnimplementedMetricsServiceServer) MeasureSince ¶
func (UnimplementedMetricsServiceServer) MeasureSince(context.Context, *MeasureSinceRequest) (*MeasureSinceResponse, error)
func (UnimplementedMetricsServiceServer) SetGauge ¶
func (UnimplementedMetricsServiceServer) SetGauge(context.Context, *SetGaugeRequest) (*SetGaugeResponse, error)
type UnsafeMetricsServiceServer ¶
type UnsafeMetricsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMetricsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricsServiceServer will result in compilation errors.