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: 0

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 

func (*UnimplementedMultiFieldsPutServiceServer) Mput(ctx context.Context, req *MputRequest) (*MputResponse, 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.