metrics

package
v0.8.32 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2022 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMetrics        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetrics          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetrics = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EventType_name = map[int32]string{
	0: "NONE",
	1: "UPDATED",
	2: "DELETED",
}
View Source 
var EventType_value = map[string]int32{
	"NONE":    0,
	"UPDATED": 1,
	"DELETED": 2,
}

Functions

func RegisterMetricsServiceServer 

func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)

Types

type DeleteAllRequest 

type DeleteAllRequest struct {
	EntityID uint64 `protobuf:"varint,1,opt,name=entityid,proto3" json:"entityid,omitempty"`
}

func (*DeleteAllRequest) Descriptor 

func (*DeleteAllRequest) Descriptor() ([]byte, []int)

func (*DeleteAllRequest) GetEntityID 

func (m *DeleteAllRequest) GetEntityID() uint64

func (*DeleteAllRequest) Marshal 

func (m *DeleteAllRequest) Marshal() (dAtA []byte, err error)

func (*DeleteAllRequest) MarshalTo 

func (m *DeleteAllRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteAllRequest) MarshalToSizedBuffer 

func (m *DeleteAllRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteAllRequest) ProtoMessage 

func (*DeleteAllRequest) ProtoMessage()

func (*DeleteAllRequest) Reset 

func (m *DeleteAllRequest) Reset()

func (*DeleteAllRequest) Size 

func (m *DeleteAllRequest) Size() (n int)

func (*DeleteAllRequest) String 

func (m *DeleteAllRequest) String() string

func (*DeleteAllRequest) Unmarshal 

func (m *DeleteAllRequest) Unmarshal(dAtA []byte) error

func (*DeleteAllRequest) XXX_DiscardUnknown 

func (m *DeleteAllRequest) XXX_DiscardUnknown()

func (*DeleteAllRequest) XXX_Marshal 

func (m *DeleteAllRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteAllRequest) XXX_Merge 

func (m *DeleteAllRequest) XXX_Merge(src proto.Message)

func (*DeleteAllRequest) XXX_Size 

func (m *DeleteAllRequest) XXX_Size() int

func (*DeleteAllRequest) XXX_Unmarshal 

func (m *DeleteAllRequest) XXX_Unmarshal(b []byte) error

type DeleteAllResponse 

type DeleteAllResponse struct {
}

func (*DeleteAllResponse) Descriptor 

func (*DeleteAllResponse) Descriptor() ([]byte, []int)

func (*DeleteAllResponse) Marshal 

func (m *DeleteAllResponse) Marshal() (dAtA []byte, err error)

func (*DeleteAllResponse) MarshalTo 

func (m *DeleteAllResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteAllResponse) MarshalToSizedBuffer 

func (m *DeleteAllResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteAllResponse) ProtoMessage 

func (*DeleteAllResponse) ProtoMessage()

func (*DeleteAllResponse) Reset 

func (m *DeleteAllResponse) Reset()

func (*DeleteAllResponse) Size 

func (m *DeleteAllResponse) Size() (n int)

func (*DeleteAllResponse) String 

func (m *DeleteAllResponse) String() string

func (*DeleteAllResponse) Unmarshal 

func (m *DeleteAllResponse) Unmarshal(dAtA []byte) error

func (*DeleteAllResponse) XXX_DiscardUnknown 

func (m *DeleteAllResponse) XXX_DiscardUnknown()

func (*DeleteAllResponse) XXX_Marshal 

func (m *DeleteAllResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteAllResponse) XXX_Merge 

func (m *DeleteAllResponse) XXX_Merge(src proto.Message)

func (*DeleteAllResponse) XXX_Size 

func (m *DeleteAllResponse) XXX_Size() int

func (*DeleteAllResponse) XXX_Unmarshal 

func (m *DeleteAllResponse) XXX_Unmarshal(b []byte) error

type DeleteRequest 

type DeleteRequest struct {
	EntityID uint64 `protobuf:"varint,1,opt,name=entityid,proto3" json:"entityid,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*DeleteRequest) Descriptor 

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) GetEntityID 

func (m *DeleteRequest) GetEntityID() uint64

func (*DeleteRequest) GetName 

func (m *DeleteRequest) GetName() string

func (*DeleteRequest) Marshal 

func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRequest) MarshalTo 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToSizedBuffer 

func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

func (m *DeleteRequest) Unmarshal(dAtA []byte) error

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge 

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DeleteResponse 

type DeleteResponse struct {
}

func (*DeleteResponse) Descriptor 

func (*DeleteResponse) Descriptor() ([]byte, []int)

func (*DeleteResponse) Marshal 

func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

func (*DeleteResponse) MarshalTo 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToSizedBuffer 

func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

func (m *DeleteResponse) Unmarshal(dAtA []byte) error

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteResponse) XXX_Merge 

func (m *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

func (m *DeleteResponse) XXX_Unmarshal(b []byte) error

type EventType 

type EventType int32

Change event type 

const (
	// NONE indicates unknown event type
	EventType_NONE EventType = 0
	// UPDATED indicates a metric value was set (updated)
	EventType_UPDATED EventType = 1
	// DELETED indicates a metric was deleted
	EventType_DELETED EventType = 2
)

func (EventType) EnumDescriptor 

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String 

func (x EventType) String() string

type GetRequest 

type GetRequest struct {
	EntityID uint64 `protobuf:"varint,1,opt,name=entityid,proto3" json:"entityid,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*GetRequest) Descriptor 

func (*GetRequest) Descriptor() ([]byte, []int)

func (*GetRequest) GetEntityID 

func (m *GetRequest) GetEntityID() uint64

func (*GetRequest) GetName 

func (m *GetRequest) GetName() string

func (*GetRequest) Marshal 

func (m *GetRequest) Marshal() (dAtA []byte, err error)

func (*GetRequest) MarshalTo 

func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRequest) MarshalToSizedBuffer 

func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

func (m *GetRequest) Size() (n int)

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

func (m *GetRequest) Unmarshal(dAtA []byte) error

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge 

func (m *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

type GetResponse 

type GetResponse struct {
	Metric *Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
}

func (*GetResponse) Descriptor 

func (*GetResponse) Descriptor() ([]byte, []int)

func (*GetResponse) GetMetric 

func (m *GetResponse) GetMetric() *Metric

func (*GetResponse) Marshal 

func (m *GetResponse) Marshal() (dAtA []byte, err error)

func (*GetResponse) MarshalTo 

func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetResponse) MarshalToSizedBuffer 

func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

func (m *GetResponse) Size() (n int)

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

func (m *GetResponse) Unmarshal(dAtA []byte) error

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResponse) XXX_Merge 

func (m *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

func (m *GetResponse) XXX_Unmarshal(b []byte) error

type ListRequest 

type ListRequest struct {
	EntityID uint64 `protobuf:"varint,1,opt,name=entityid,proto3" json:"entityid,omitempty"`
}

func (*ListRequest) Descriptor 

func (*ListRequest) Descriptor() ([]byte, []int)

func (*ListRequest) GetEntityID 

func (m *ListRequest) GetEntityID() uint64

func (*ListRequest) Marshal 

func (m *ListRequest) Marshal() (dAtA []byte, err error)

func (*ListRequest) MarshalTo 

func (m *ListRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListRequest) MarshalToSizedBuffer 

func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) Size 

func (m *ListRequest) Size() (n int)

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) Unmarshal 

func (m *ListRequest) Unmarshal(dAtA []byte) error

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListResponse 

type ListResponse struct {
	EntityID uint64    `protobuf:"varint,1,opt,name=entityid,proto3" json:"entityid,omitempty"`
	Metrics  []*Metric `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
}

func (*ListResponse) Descriptor 

func (*ListResponse) Descriptor() ([]byte, []int)

func (*ListResponse) GetEntityID 

func (m *ListResponse) GetEntityID() uint64

func (*ListResponse) GetMetrics 

func (m *ListResponse) GetMetrics() []*Metric

func (*ListResponse) Marshal 

func (m *ListResponse) Marshal() (dAtA []byte, err error)

func (*ListResponse) MarshalTo 

func (m *ListResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListResponse) MarshalToSizedBuffer 

func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) Size 

func (m *ListResponse) Size() (n int)

func (*ListResponse) String 

func (m *ListResponse) String() string

func (*ListResponse) Unmarshal 

func (m *ListResponse) Unmarshal(dAtA []byte) error

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListResponse) XXX_Merge 

func (m *ListResponse) XXX_Merge(src proto.Message)

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

func (m *ListResponse) XXX_Unmarshal(b []byte) error

type Metric 

type Metric struct {
	EntityID uint64 `protobuf:"varint,1,opt,name=entityid,proto3" json:"entityid,omitempty"`
	Key      string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value    string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Type     string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
}

func (*Metric) Descriptor 

func (*Metric) Descriptor() ([]byte, []int)

func (*Metric) GetEntityID 

func (m *Metric) GetEntityID() uint64

func (*Metric) GetKey 

func (m *Metric) GetKey() string

func (*Metric) GetType 

func (m *Metric) GetType() string

func (*Metric) GetValue 

func (m *Metric) GetValue() string

func (*Metric) Marshal 

func (m *Metric) Marshal() (dAtA []byte, err error)

func (*Metric) MarshalTo 

func (m *Metric) MarshalTo(dAtA []byte) (int, error)

func (*Metric) MarshalToSizedBuffer 

func (m *Metric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) Reset 

func (m *Metric) Reset()

func (*Metric) Size 

func (m *Metric) Size() (n int)

func (*Metric) String 

func (m *Metric) String() string

func (*Metric) Unmarshal 

func (m *Metric) Unmarshal(dAtA []byte) error

func (*Metric) XXX_DiscardUnknown 

func (m *Metric) XXX_DiscardUnknown()

func (*Metric) XXX_Marshal 

func (m *Metric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metric) XXX_Merge 

func (m *Metric) XXX_Merge(src proto.Message)

func (*Metric) XXX_Size 

func (m *Metric) XXX_Size() int

func (*Metric) XXX_Unmarshal 

func (m *Metric) XXX_Unmarshal(b []byte) error

type MetricsServiceClient 

type MetricsServiceClient interface {
	// List returns an array of all metrics for the specified entity (Node, Cell or UE)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// Set sets value of the named metric for the specified entity
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Get retrieves the named metric for the specified entity
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Delete deletes the the named metric for the specified entity
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// DeleteAll deletes all metrics for the specified entity
	DeleteAll(ctx context.Context, in *DeleteAllRequest, opts ...grpc.CallOption) (*DeleteAllResponse, error)
	// Watch returns a stream of ongoing changes to the metrics
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (MetricsService_WatchClient, error)
}

MetricsServiceClient is the client API for MetricsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetricsServiceClient 

func NewMetricsServiceClient(cc *grpc.ClientConn) MetricsServiceClient

type MetricsServiceServer 

type MetricsServiceServer interface {
	// List returns an array of all metrics for the specified entity (Node, Cell or UE)
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Set sets value of the named metric for the specified entity
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Get retrieves the named metric for the specified entity
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Delete deletes the the named metric for the specified entity
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// DeleteAll deletes all metrics for the specified entity
	DeleteAll(context.Context, *DeleteAllRequest) (*DeleteAllResponse, error)
	// Watch returns a stream of ongoing changes to the metrics
	Watch(*WatchRequest, MetricsService_WatchServer) error
}

MetricsServiceServer is the server API for MetricsService service.

type MetricsService_WatchClient 

type MetricsService_WatchClient interface {
	Recv() (*WatchResponse, error)
	grpc.ClientStream
}

type MetricsService_WatchServer 

type MetricsService_WatchServer interface {
	Send(*WatchResponse) error
	grpc.ServerStream
}

type SetRequest 

type SetRequest struct {
	Metric *Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
}

func (*SetRequest) Descriptor 

func (*SetRequest) Descriptor() ([]byte, []int)

func (*SetRequest) GetMetric 

func (m *SetRequest) GetMetric() *Metric

func (*SetRequest) Marshal 

func (m *SetRequest) Marshal() (dAtA []byte, err error)

func (*SetRequest) MarshalTo 

func (m *SetRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetRequest) MarshalToSizedBuffer 

func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset 

func (m *SetRequest) Reset()

func (*SetRequest) Size 

func (m *SetRequest) Size() (n int)

func (*SetRequest) String 

func (m *SetRequest) String() string

func (*SetRequest) Unmarshal 

func (m *SetRequest) Unmarshal(dAtA []byte) error

func (*SetRequest) XXX_DiscardUnknown 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal 

func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetRequest) XXX_Merge 

func (m *SetRequest) XXX_Merge(src proto.Message)

func (*SetRequest) XXX_Size 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal 

func (m *SetRequest) XXX_Unmarshal(b []byte) error

type SetResponse 

type SetResponse struct {
}

func (*SetResponse) Descriptor 

func (*SetResponse) Descriptor() ([]byte, []int)

func (*SetResponse) Marshal 

func (m *SetResponse) Marshal() (dAtA []byte, err error)

func (*SetResponse) MarshalTo 

func (m *SetResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetResponse) MarshalToSizedBuffer 

func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) Reset 

func (m *SetResponse) Reset()

func (*SetResponse) Size 

func (m *SetResponse) Size() (n int)

func (*SetResponse) String 

func (m *SetResponse) String() string

func (*SetResponse) Unmarshal 

func (m *SetResponse) Unmarshal(dAtA []byte) error

func (*SetResponse) XXX_DiscardUnknown 

func (m *SetResponse) XXX_DiscardUnknown()

func (*SetResponse) XXX_Marshal 

func (m *SetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetResponse) XXX_Merge 

func (m *SetResponse) XXX_Merge(src proto.Message)

func (*SetResponse) XXX_Size 

func (m *SetResponse) XXX_Size() int

func (*SetResponse) XXX_Unmarshal 

func (m *SetResponse) XXX_Unmarshal(b []byte) error

type UnimplementedMetricsServiceServer 

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsServiceServer) Delete 

func (*UnimplementedMetricsServiceServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedMetricsServiceServer) DeleteAll 

func (*UnimplementedMetricsServiceServer) DeleteAll(ctx context.Context, req *DeleteAllRequest) (*DeleteAllResponse, error)

func (*UnimplementedMetricsServiceServer) Get 

func (*UnimplementedMetricsServiceServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedMetricsServiceServer) List 

func (*UnimplementedMetricsServiceServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

func (*UnimplementedMetricsServiceServer) Set 

func (*UnimplementedMetricsServiceServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)

func (*UnimplementedMetricsServiceServer) Watch 

func (*UnimplementedMetricsServiceServer) Watch(req *WatchRequest, srv MetricsService_WatchServer) error

type WatchRequest 

type WatchRequest struct {
}

func (*WatchRequest) Descriptor 

func (*WatchRequest) Descriptor() ([]byte, []int)

func (*WatchRequest) Marshal 

func (m *WatchRequest) Marshal() (dAtA []byte, err error)

func (*WatchRequest) MarshalTo 

func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchRequest) MarshalToSizedBuffer 

func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) Size 

func (m *WatchRequest) Size() (n int)

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) Unmarshal 

func (m *WatchRequest) Unmarshal(dAtA []byte) error

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchRequest) XXX_Merge 

func (m *WatchRequest) XXX_Merge(src proto.Message)

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

func (m *WatchRequest) XXX_Unmarshal(b []byte) error

type WatchResponse 

type WatchResponse struct {
	Metric *Metric   `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Type   EventType `protobuf:"varint,2,opt,name=type,proto3,enum=onos.ransim.metrics.EventType" json:"type,omitempty"`
}

func (*WatchResponse) Descriptor 

func (*WatchResponse) Descriptor() ([]byte, []int)

func (*WatchResponse) GetMetric 

func (m *WatchResponse) GetMetric() *Metric

func (*WatchResponse) GetType 

func (m *WatchResponse) GetType() EventType

func (*WatchResponse) Marshal 

func (m *WatchResponse) Marshal() (dAtA []byte, err error)

func (*WatchResponse) MarshalTo 

func (m *WatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*WatchResponse) MarshalToSizedBuffer 

func (m *WatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) Size 

func (m *WatchResponse) Size() (n int)

func (*WatchResponse) String 

func (m *WatchResponse) String() string

func (*WatchResponse) Unmarshal 

func (m *WatchResponse) Unmarshal(dAtA []byte) error

func (*WatchResponse) XXX_DiscardUnknown 

func (m *WatchResponse) XXX_DiscardUnknown()

func (*WatchResponse) XXX_Marshal 

func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchResponse) XXX_Merge 

func (m *WatchResponse) XXX_Merge(src proto.Message)

func (*WatchResponse) XXX_Size 

func (m *WatchResponse) XXX_Size() int

func (*WatchResponse) XXX_Unmarshal 

func (m *WatchResponse) XXX_Unmarshal(b []byte) 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.