com_alibaba_tsdb_service_api

package
v0.0.0-...-730c616 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2021 License: MIT Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthAlitsdb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAlitsdb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAlitsdb = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterMultiFieldsPutServiceServer

func RegisterMultiFieldsPutServiceServer(s *grpc.Server, srv MultiFieldsPutServiceServer)

Types

type MputPoint

type MputPoint struct {
	Timestamp            int64     `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Serieskey            string    `protobuf:"bytes,2,opt,name=serieskey,proto3" json:"serieskey,omitempty"`
	Fvalues              []float64 `protobuf:"fixed64,3,rep,packed,name=fvalues,proto3" json:"fvalues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

for mput request

func (*MputPoint) Descriptor

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

func (*MputPoint) GetFvalues

func (m *MputPoint) GetFvalues() []float64

func (*MputPoint) GetSerieskey

func (m *MputPoint) GetSerieskey() string

func (*MputPoint) GetTimestamp

func (m *MputPoint) GetTimestamp() int64

func (*MputPoint) Marshal

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

func (*MputPoint) MarshalTo

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

func (*MputPoint) MarshalToSizedBuffer

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

func (*MputPoint) ProtoMessage

func (*MputPoint) ProtoMessage()

func (*MputPoint) Reset

func (m *MputPoint) Reset()

func (*MputPoint) Size

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

func (*MputPoint) String

func (m *MputPoint) String() string

func (*MputPoint) Unmarshal

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

func (*MputPoint) XXX_DiscardUnknown

func (m *MputPoint) XXX_DiscardUnknown()

func (*MputPoint) XXX_Marshal

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

func (*MputPoint) XXX_Merge

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

func (*MputPoint) XXX_Size

func (m *MputPoint) XXX_Size() int

func (*MputPoint) XXX_Unmarshal

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

type MputRequest

type MputRequest struct {
	Fnames               []string     `protobuf:"bytes,1,rep,name=fnames,proto3" json:"fnames,omitempty"`
	Points               []*MputPoint `protobuf:"bytes,2,rep,name=points,proto3" json:"points,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MputRequest) Descriptor

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

func (*MputRequest) GetFnames

func (m *MputRequest) GetFnames() []string

func (*MputRequest) GetPoints

func (m *MputRequest) GetPoints() []*MputPoint

func (*MputRequest) Marshal

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

func (*MputRequest) MarshalTo

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

func (*MputRequest) MarshalToSizedBuffer

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

func (*MputRequest) ProtoMessage

func (*MputRequest) ProtoMessage()

func (*MputRequest) Reset

func (m *MputRequest) Reset()

func (*MputRequest) Size

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

func (*MputRequest) String

func (m *MputRequest) String() string

func (*MputRequest) Unmarshal

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

func (*MputRequest) XXX_DiscardUnknown

func (m *MputRequest) XXX_DiscardUnknown()

func (*MputRequest) XXX_Marshal

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

func (*MputRequest) XXX_Merge

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

func (*MputRequest) XXX_Size

func (m *MputRequest) XXX_Size() int

func (*MputRequest) XXX_Unmarshal

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

type MputResponse

type MputResponse struct {
	Ret                  bool     `protobuf:"varint,1,opt,name=ret,proto3" json:"ret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MputResponse) Descriptor

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

func (*MputResponse) GetRet

func (m *MputResponse) GetRet() bool

func (*MputResponse) Marshal

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

func (*MputResponse) MarshalTo

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

func (*MputResponse) MarshalToSizedBuffer

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

func (*MputResponse) ProtoMessage

func (*MputResponse) ProtoMessage()

func (*MputResponse) Reset

func (m *MputResponse) Reset()

func (*MputResponse) Size

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

func (*MputResponse) String

func (m *MputResponse) String() string

func (*MputResponse) Unmarshal

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

func (*MputResponse) XXX_DiscardUnknown

func (m *MputResponse) XXX_DiscardUnknown()

func (*MputResponse) XXX_Marshal

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

func (*MputResponse) XXX_Merge

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

func (*MputResponse) XXX_Size

func (m *MputResponse) XXX_Size() int

func (*MputResponse) XXX_Unmarshal

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

type MultiFieldsPutServiceClient

type MultiFieldsPutServiceClient interface {
	Mput(ctx context.Context, in *MputRequest, opts ...grpc.CallOption) (*MputResponse, error)
}

MultiFieldsPutServiceClient is the client API for MultiFieldsPutService service.

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

func NewMultiFieldsPutServiceClient

func NewMultiFieldsPutServiceClient(cc *grpc.ClientConn) MultiFieldsPutServiceClient

type MultiFieldsPutServiceServer

type MultiFieldsPutServiceServer interface {
	Mput(context.Context, *MputRequest) (*MputResponse, error)
}

MultiFieldsPutServiceServer is the server API for MultiFieldsPutService service.

type MultifieldPoint

type MultifieldPoint struct {
	Timestamp            int64              `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Serieskey            string             `protobuf:"bytes,2,opt,name=serieskey,proto3" json:"serieskey,omitempty"`
	Fields               map[string]float64 `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

for data generation

func (*MultifieldPoint) Descriptor

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

func (*MultifieldPoint) GetFields

func (m *MultifieldPoint) GetFields() map[string]float64

func (*MultifieldPoint) GetSerieskey

func (m *MultifieldPoint) GetSerieskey() string

func (*MultifieldPoint) GetTimestamp

func (m *MultifieldPoint) GetTimestamp() int64

func (*MultifieldPoint) Marshal

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

func (*MultifieldPoint) MarshalTo

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

func (*MultifieldPoint) MarshalToSizedBuffer

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

func (*MultifieldPoint) ProtoMessage

func (*MultifieldPoint) ProtoMessage()

func (*MultifieldPoint) Reset

func (m *MultifieldPoint) Reset()

func (*MultifieldPoint) Size

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

func (*MultifieldPoint) String

func (m *MultifieldPoint) String() string

func (*MultifieldPoint) Unmarshal

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

func (*MultifieldPoint) XXX_DiscardUnknown

func (m *MultifieldPoint) XXX_DiscardUnknown()

func (*MultifieldPoint) XXX_Marshal

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

func (*MultifieldPoint) XXX_Merge

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

func (*MultifieldPoint) XXX_Size

func (m *MultifieldPoint) XXX_Size() int

func (*MultifieldPoint) XXX_Unmarshal

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

type UnimplementedMultiFieldsPutServiceServer

type UnimplementedMultiFieldsPutServiceServer struct {
}

UnimplementedMultiFieldsPutServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMultiFieldsPutServiceServer) Mput

Jump to

Keyboard shortcuts

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