kpimon

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2022 License: Apache-2.0 Imports: 11 Imported by: 14

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthKpimon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKpimon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupKpimon = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterKpimonServer 

func RegisterKpimonServer(s *grpc.Server, srv KpimonServer)

Types

type GetRequest 

type GetRequest struct {
}

func (*GetRequest) Descriptor 

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

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 {
	Measurements map[string]*MeasurementItems `` /* 165-byte string literal not displayed */
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetMeasurements added in v0.7.54 

func (m *GetResponse) GetMeasurements() map[string]*MeasurementItems

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 IntegerValue added in v0.7.54 

type IntegerValue struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*IntegerValue) Descriptor added in v0.7.54 

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

func (*IntegerValue) GetValue added in v0.7.54 

func (m *IntegerValue) GetValue() int64

func (*IntegerValue) Marshal added in v0.7.54 

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

func (*IntegerValue) MarshalTo added in v0.7.54 

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

func (*IntegerValue) MarshalToSizedBuffer added in v0.7.54 

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

func (*IntegerValue) ProtoMessage added in v0.7.54 

func (*IntegerValue) ProtoMessage()

func (*IntegerValue) Reset added in v0.7.54 

func (m *IntegerValue) Reset()

func (*IntegerValue) Size added in v0.7.54 

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

func (*IntegerValue) String added in v0.7.54 

func (m *IntegerValue) String() string

func (*IntegerValue) Unmarshal added in v0.7.54 

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

func (*IntegerValue) XXX_DiscardUnknown added in v0.7.54 

func (m *IntegerValue) XXX_DiscardUnknown()

func (*IntegerValue) XXX_Marshal added in v0.7.54 

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

func (*IntegerValue) XXX_Merge added in v0.7.54 

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

func (*IntegerValue) XXX_Size added in v0.7.54 

func (m *IntegerValue) XXX_Size() int

func (*IntegerValue) XXX_Unmarshal added in v0.7.54 

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

type KpimonClient 

type KpimonClient interface {
	ListMeasurements(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	WatchMeasurements(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Kpimon_WatchMeasurementsClient, error)
}

KpimonClient is the client API for Kpimon service.

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

func NewKpimonClient 

func NewKpimonClient(cc *grpc.ClientConn) KpimonClient

type KpimonServer 

type KpimonServer interface {
	ListMeasurements(context.Context, *GetRequest) (*GetResponse, error)
	WatchMeasurements(*GetRequest, Kpimon_WatchMeasurementsServer) error
}

KpimonServer is the server API for Kpimon service.

type Kpimon_WatchMeasurementsClient added in v0.7.56 

type Kpimon_WatchMeasurementsClient interface {
	Recv() (*GetResponse, error)
	grpc.ClientStream
}

type Kpimon_WatchMeasurementsServer added in v0.7.56 

type Kpimon_WatchMeasurementsServer interface {
	Send(*GetResponse) error
	grpc.ServerStream
}

type MeasurementItem added in v0.7.54 

type MeasurementItem struct {
	MeasurementRecords []*MeasurementRecord `protobuf:"bytes,1,rep,name=measurement_records,json=measurementRecords,proto3" json:"measurement_records,omitempty"`
}

func (*MeasurementItem) Descriptor added in v0.7.54 

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

func (*MeasurementItem) GetMeasurementRecords added in v0.7.54 

func (m *MeasurementItem) GetMeasurementRecords() []*MeasurementRecord

func (*MeasurementItem) Marshal added in v0.7.54 

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

func (*MeasurementItem) MarshalTo added in v0.7.54 

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

func (*MeasurementItem) MarshalToSizedBuffer added in v0.7.54 

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

func (*MeasurementItem) ProtoMessage added in v0.7.54 

func (*MeasurementItem) ProtoMessage()

func (*MeasurementItem) Reset added in v0.7.54 

func (m *MeasurementItem) Reset()

func (*MeasurementItem) Size added in v0.7.54 

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

func (*MeasurementItem) String added in v0.7.54 

func (m *MeasurementItem) String() string

func (*MeasurementItem) Unmarshal added in v0.7.54 

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

func (*MeasurementItem) XXX_DiscardUnknown added in v0.7.54 

func (m *MeasurementItem) XXX_DiscardUnknown()

func (*MeasurementItem) XXX_Marshal added in v0.7.54 

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

func (*MeasurementItem) XXX_Merge added in v0.7.54 

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

func (*MeasurementItem) XXX_Size added in v0.7.54 

func (m *MeasurementItem) XXX_Size() int

func (*MeasurementItem) XXX_Unmarshal added in v0.7.54 

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

type MeasurementItems added in v0.7.54 

type MeasurementItems struct {
	MeasurementItems []*MeasurementItem `protobuf:"bytes,1,rep,name=measurement_items,json=measurementItems,proto3" json:"measurement_items,omitempty"`
}

func (*MeasurementItems) Descriptor added in v0.7.54 

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

func (*MeasurementItems) GetMeasurementItems added in v0.7.54 

func (m *MeasurementItems) GetMeasurementItems() []*MeasurementItem

func (*MeasurementItems) Marshal added in v0.7.54 

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

func (*MeasurementItems) MarshalTo added in v0.7.54 

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

func (*MeasurementItems) MarshalToSizedBuffer added in v0.7.54 

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

func (*MeasurementItems) ProtoMessage added in v0.7.54 

func (*MeasurementItems) ProtoMessage()

func (*MeasurementItems) Reset added in v0.7.54 

func (m *MeasurementItems) Reset()

func (*MeasurementItems) Size added in v0.7.54 

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

func (*MeasurementItems) String added in v0.7.54 

func (m *MeasurementItems) String() string

func (*MeasurementItems) Unmarshal added in v0.7.54 

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

func (*MeasurementItems) XXX_DiscardUnknown added in v0.7.54 

func (m *MeasurementItems) XXX_DiscardUnknown()

func (*MeasurementItems) XXX_Marshal added in v0.7.54 

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

func (*MeasurementItems) XXX_Merge added in v0.7.54 

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

func (*MeasurementItems) XXX_Size added in v0.7.54 

func (m *MeasurementItems) XXX_Size() int

func (*MeasurementItems) XXX_Unmarshal added in v0.7.54 

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

type MeasurementRecord added in v0.7.54 

type MeasurementRecord struct {
	Timestamp        uint64     `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	MeasurementName  string     `protobuf:"bytes,3,opt,name=measurement_name,json=measurementName,proto3" json:"measurement_name,omitempty"`
	MeasurementValue *types.Any `protobuf:"bytes,4,opt,name=measurement_value,json=measurementValue,proto3" json:"measurement_value,omitempty"`
}

func (*MeasurementRecord) Descriptor added in v0.7.54 

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

func (*MeasurementRecord) GetMeasurementName added in v0.7.54 

func (m *MeasurementRecord) GetMeasurementName() string

func (*MeasurementRecord) GetMeasurementValue added in v0.7.54 

func (m *MeasurementRecord) GetMeasurementValue() *types.Any

func (*MeasurementRecord) GetTimestamp added in v0.7.54 

func (m *MeasurementRecord) GetTimestamp() uint64

func (*MeasurementRecord) Marshal added in v0.7.54 

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

func (*MeasurementRecord) MarshalTo added in v0.7.54 

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

func (*MeasurementRecord) MarshalToSizedBuffer added in v0.7.54 

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

func (*MeasurementRecord) ProtoMessage added in v0.7.54 

func (*MeasurementRecord) ProtoMessage()

func (*MeasurementRecord) Reset added in v0.7.54 

func (m *MeasurementRecord) Reset()

func (*MeasurementRecord) Size added in v0.7.54 

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

func (*MeasurementRecord) String added in v0.7.54 

func (m *MeasurementRecord) String() string

func (*MeasurementRecord) Unmarshal added in v0.7.54 

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

func (*MeasurementRecord) XXX_DiscardUnknown added in v0.7.54 

func (m *MeasurementRecord) XXX_DiscardUnknown()

func (*MeasurementRecord) XXX_Marshal added in v0.7.54 

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

func (*MeasurementRecord) XXX_Merge added in v0.7.54 

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

func (*MeasurementRecord) XXX_Size added in v0.7.54 

func (m *MeasurementRecord) XXX_Size() int

func (*MeasurementRecord) XXX_Unmarshal added in v0.7.54 

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

type NoValue added in v0.7.54 

type NoValue struct {
	Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*NoValue) Descriptor added in v0.7.54 

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

func (*NoValue) GetValue added in v0.7.54 

func (m *NoValue) GetValue() int32

func (*NoValue) Marshal added in v0.7.54 

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

func (*NoValue) MarshalTo added in v0.7.54 

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

func (*NoValue) MarshalToSizedBuffer added in v0.7.54 

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

func (*NoValue) ProtoMessage added in v0.7.54 

func (*NoValue) ProtoMessage()

func (*NoValue) Reset added in v0.7.54 

func (m *NoValue) Reset()

func (*NoValue) Size added in v0.7.54 

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

func (*NoValue) String added in v0.7.54 

func (m *NoValue) String() string

func (*NoValue) Unmarshal added in v0.7.54 

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

func (*NoValue) XXX_DiscardUnknown added in v0.7.54 

func (m *NoValue) XXX_DiscardUnknown()

func (*NoValue) XXX_Marshal added in v0.7.54 

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

func (*NoValue) XXX_Merge added in v0.7.54 

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

func (*NoValue) XXX_Size added in v0.7.54 

func (m *NoValue) XXX_Size() int

func (*NoValue) XXX_Unmarshal added in v0.7.54 

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

type RealValue added in v0.7.54 

type RealValue struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RealValue) Descriptor added in v0.7.54 

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

func (*RealValue) GetValue added in v0.7.54 

func (m *RealValue) GetValue() float64

func (*RealValue) Marshal added in v0.7.54 

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

func (*RealValue) MarshalTo added in v0.7.54 

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

func (*RealValue) MarshalToSizedBuffer added in v0.7.54 

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

func (*RealValue) ProtoMessage added in v0.7.54 

func (*RealValue) ProtoMessage()

func (*RealValue) Reset added in v0.7.54 

func (m *RealValue) Reset()

func (*RealValue) Size added in v0.7.54 

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

func (*RealValue) String added in v0.7.54 

func (m *RealValue) String() string

func (*RealValue) Unmarshal added in v0.7.54 

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

func (*RealValue) XXX_DiscardUnknown added in v0.7.54 

func (m *RealValue) XXX_DiscardUnknown()

func (*RealValue) XXX_Marshal added in v0.7.54 

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

func (*RealValue) XXX_Merge added in v0.7.54 

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

func (*RealValue) XXX_Size added in v0.7.54 

func (m *RealValue) XXX_Size() int

func (*RealValue) XXX_Unmarshal added in v0.7.54 

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

type UnimplementedKpimonServer 

type UnimplementedKpimonServer struct {
}

UnimplementedKpimonServer can be embedded to have forward compatible implementations.

func (*UnimplementedKpimonServer) ListMeasurements added in v0.7.56 

func (*UnimplementedKpimonServer) ListMeasurements(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedKpimonServer) WatchMeasurements added in v0.7.56 

func (*UnimplementedKpimonServer) WatchMeasurements(req *GetRequest, srv Kpimon_WatchMeasurementsServer) 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.