metricsdbrpc

package
v0.1.21 Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2021 License: CC0-1.0, CC0-1.0, CC0-1.0, + 1 more Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Value_Type_name = map[int32]string{
	0:  "UNDEFINED",
	1:  "INT",
	2:  "INT8",
	3:  "INT16",
	4:  "INT32",
	5:  "INT64",
	6:  "UINT",
	7:  "UINT8",
	8:  "UINT16",
	9:  "UINT32",
	10: "UINT64",
	11: "BOOL",
	12: "FLOAT64",
	13: "STRING",
	14: "TIMESTAMP",
	15: "DURATION",
}
View Source 
var Value_Type_value = map[string]int32{
	"UNDEFINED": 0,
	"INT":       1,
	"INT8":      2,
	"INT16":     3,
	"INT32":     4,
	"INT64":     5,
	"UINT":      6,
	"UINT8":     7,
	"UINT16":    8,
	"UINT32":    9,
	"UINT64":    10,
	"BOOL":      11,
	"FLOAT64":   12,
	"STRING":    13,
	"TIMESTAMP": 14,
	"DURATION":  15,
}

Functions

func FromPoint 

func FromPoint(p *Point) (*metrics.Point, error)

FromPoint converts a *Point to a *metrics.Point.

func RegisterMetricsdbServer 

func RegisterMetricsdbServer(s *grpc.Server, srv MetricsdbServer)

Types

type MetricsdbClient 

type MetricsdbClient interface {
	Submit(ctx context.Context, opts ...grpc.CallOption) (Metricsdb_SubmitClient, error)
}

MetricsdbClient is the client API for Metricsdb service.

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

func NewMetricsdbClient 

func NewMetricsdbClient(cc *grpc.ClientConn) MetricsdbClient

type MetricsdbServer 

type MetricsdbServer interface {
	Submit(Metricsdb_SubmitServer) error
}

MetricsdbServer is the server API for Metricsdb service.

type Metricsdb_SubmitClient 

type Metricsdb_SubmitClient interface {
	Send(*Point) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type Metricsdb_SubmitServer 

type Metricsdb_SubmitServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*Point, error)
	grpc.ServerStream
}

type Point 

type Point struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Fields               map[string]*Value    `` /* 153-byte string literal not displayed */
	Tags                 map[string]string    `` /* 149-byte string literal not displayed */
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Point is the type defining a metric point.

func ToPoint 

func ToPoint(p *metrics.Point) (*Point, error)

ToPoint converts a *metrics.Point to a *Point.

func (*Point) Descriptor 

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

func (*Point) GetFields 

func (m *Point) GetFields() map[string]*Value

func (*Point) GetName 

func (m *Point) GetName() string

func (*Point) GetTags 

func (m *Point) GetTags() map[string]string

func (*Point) GetTimestamp 

func (m *Point) GetTimestamp() *timestamp.Timestamp

func (*Point) ProtoMessage 

func (*Point) ProtoMessage()

func (*Point) Reset 

func (m *Point) Reset()

func (*Point) String 

func (m *Point) String() string

func (*Point) XXX_DiscardUnknown 

func (m *Point) XXX_DiscardUnknown()

func (*Point) XXX_Marshal 

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

func (*Point) XXX_Merge 

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

func (*Point) XXX_Size 

func (m *Point) XXX_Size() int

func (*Point) XXX_Unmarshal 

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

type UnimplementedMetricsdbServer 

type UnimplementedMetricsdbServer struct {
}

UnimplementedMetricsdbServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsdbServer) Submit 

func (*UnimplementedMetricsdbServer) Submit(srv Metricsdb_SubmitServer) error

type Value 

type Value struct {
	Type Value_Type `protobuf:"varint,1,opt,name=type,proto3,enum=metricsdb.Value_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Value_Int32Value
	//	*Value_Int64Value
	//	*Value_Uint32Value
	//	*Value_Uint64Value
	//	*Value_BoolValue
	//	*Value_DoubleValue
	//	*Value_StringValue
	//	*Value_TimestampValue
	//	*Value_DurationValue
	Value                isValue_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Value describes a value in a point.

func (*Value) Descriptor 

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

func (*Value) GetBoolValue 

func (m *Value) GetBoolValue() bool

func (*Value) GetDoubleValue 

func (m *Value) GetDoubleValue() float64

func (*Value) GetDurationValue 

func (m *Value) GetDurationValue() *duration.Duration

func (*Value) GetInt32Value 

func (m *Value) GetInt32Value() int32

func (*Value) GetInt64Value 

func (m *Value) GetInt64Value() int64

func (*Value) GetStringValue 

func (m *Value) GetStringValue() string

func (*Value) GetTimestampValue 

func (m *Value) GetTimestampValue() *timestamp.Timestamp

func (*Value) GetType 

func (m *Value) GetType() Value_Type

func (*Value) GetUint32Value 

func (m *Value) GetUint32Value() uint32

func (*Value) GetUint64Value 

func (m *Value) GetUint64Value() uint64

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

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

func (*Value) XXX_Merge 

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

func (*Value) XXX_OneofWrappers 

func (*Value) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

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

type Value_BoolValue 

type Value_BoolValue struct {
	BoolValue bool `protobuf:"varint,6,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type Value_DoubleValue 

type Value_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,7,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type Value_DurationValue 

type Value_DurationValue struct {
	DurationValue *duration.Duration `protobuf:"bytes,10,opt,name=duration_value,json=durationValue,proto3,oneof"`
}

type Value_Int32Value 

type Value_Int32Value struct {
	Int32Value int32 `protobuf:"varint,2,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type Value_Int64Value 

type Value_Int64Value struct {
	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type Value_StringValue 

type Value_StringValue struct {
	StringValue string `protobuf:"bytes,8,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Value_TimestampValue 

type Value_TimestampValue struct {
	TimestampValue *timestamp.Timestamp `protobuf:"bytes,9,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type Value_Type 

type Value_Type int32

Type enumerates the possible value types 

const (
	Value_UNDEFINED Value_Type = 0
	Value_INT       Value_Type = 1
	Value_INT8      Value_Type = 2
	Value_INT16     Value_Type = 3
	Value_INT32     Value_Type = 4
	Value_INT64     Value_Type = 5
	Value_UINT      Value_Type = 6
	Value_UINT8     Value_Type = 7
	Value_UINT16    Value_Type = 8
	Value_UINT32    Value_Type = 9
	Value_UINT64    Value_Type = 10
	Value_BOOL      Value_Type = 11
	Value_FLOAT64   Value_Type = 12
	Value_STRING    Value_Type = 13
	Value_TIMESTAMP Value_Type = 14
	Value_DURATION  Value_Type = 15
)

func (Value_Type) EnumDescriptor 

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

func (Value_Type) String 

func (x Value_Type) String() string

type Value_Uint32Value 

type Value_Uint32Value struct {
	Uint32Value uint32 `protobuf:"varint,4,opt,name=uint32_value,json=uint32Value,proto3,oneof"`
}

type Value_Uint64Value 

type Value_Uint64Value struct {
	Uint64Value uint64 `protobuf:"varint,5,opt,name=uint64_value,json=uint64Value,proto3,oneof"`
}

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.