Documentation ¶
Index ¶
- func RegisterService(s giraffe_micro.Server, srv Service)
- type Client
- type InfluxdbProxyRequest
- func (*InfluxdbProxyRequest) Descriptor() ([]byte, []int)
- func (m *InfluxdbProxyRequest) GetDb() string
- func (m *InfluxdbProxyRequest) GetEpoch() string
- func (m *InfluxdbProxyRequest) GetQ() string
- func (*InfluxdbProxyRequest) ProtoMessage()
- func (m *InfluxdbProxyRequest) Reset()
- func (m *InfluxdbProxyRequest) String() string
- func (this *InfluxdbProxyRequest) Validate() error
- func (m *InfluxdbProxyRequest) XXX_DiscardUnknown()
- func (m *InfluxdbProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfluxdbProxyRequest) XXX_Merge(src proto.Message)
- func (m *InfluxdbProxyRequest) XXX_Size() int
- func (m *InfluxdbProxyRequest) XXX_Unmarshal(b []byte) error
- type InfluxdbProxyResponse
- func (*InfluxdbProxyResponse) Descriptor() ([]byte, []int)
- func (m *InfluxdbProxyResponse) GetResults() []*InfluxdbProxyResponse_Results
- func (*InfluxdbProxyResponse) ProtoMessage()
- func (m *InfluxdbProxyResponse) Reset()
- func (m *InfluxdbProxyResponse) String() string
- func (this *InfluxdbProxyResponse) Validate() error
- func (m *InfluxdbProxyResponse) XXX_DiscardUnknown()
- func (m *InfluxdbProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfluxdbProxyResponse) XXX_Merge(src proto.Message)
- func (m *InfluxdbProxyResponse) XXX_Size() int
- func (m *InfluxdbProxyResponse) XXX_Unmarshal(b []byte) error
- type InfluxdbProxyResponseWrapper
- func (*InfluxdbProxyResponseWrapper) Descriptor() ([]byte, []int)
- func (m *InfluxdbProxyResponseWrapper) GetCode() int32
- func (m *InfluxdbProxyResponseWrapper) GetCodeExplain() string
- func (m *InfluxdbProxyResponseWrapper) GetData() *InfluxdbProxyResponse
- func (m *InfluxdbProxyResponseWrapper) GetError() string
- func (*InfluxdbProxyResponseWrapper) ProtoMessage()
- func (m *InfluxdbProxyResponseWrapper) Reset()
- func (m *InfluxdbProxyResponseWrapper) String() string
- func (this *InfluxdbProxyResponseWrapper) Validate() error
- func (m *InfluxdbProxyResponseWrapper) XXX_DiscardUnknown()
- func (m *InfluxdbProxyResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfluxdbProxyResponseWrapper) XXX_Merge(src proto.Message)
- func (m *InfluxdbProxyResponseWrapper) XXX_Size() int
- func (m *InfluxdbProxyResponseWrapper) XXX_Unmarshal(b []byte) error
- type InfluxdbProxyResponse_Results
- func (*InfluxdbProxyResponse_Results) Descriptor() ([]byte, []int)
- func (m *InfluxdbProxyResponse_Results) GetError() string
- func (m *InfluxdbProxyResponse_Results) GetSeries() []*InfluxdbProxyResponse_Results_Series
- func (m *InfluxdbProxyResponse_Results) GetStatementId() int32
- func (*InfluxdbProxyResponse_Results) ProtoMessage()
- func (m *InfluxdbProxyResponse_Results) Reset()
- func (m *InfluxdbProxyResponse_Results) String() string
- func (this *InfluxdbProxyResponse_Results) Validate() error
- func (m *InfluxdbProxyResponse_Results) XXX_DiscardUnknown()
- func (m *InfluxdbProxyResponse_Results) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfluxdbProxyResponse_Results) XXX_Merge(src proto.Message)
- func (m *InfluxdbProxyResponse_Results) XXX_Size() int
- func (m *InfluxdbProxyResponse_Results) XXX_Unmarshal(b []byte) error
- type InfluxdbProxyResponse_Results_Series
- func (*InfluxdbProxyResponse_Results_Series) Descriptor() ([]byte, []int)
- func (m *InfluxdbProxyResponse_Results_Series) GetColumns() []string
- func (m *InfluxdbProxyResponse_Results_Series) GetName() string
- func (m *InfluxdbProxyResponse_Results_Series) GetTags() *types.Struct
- func (m *InfluxdbProxyResponse_Results_Series) GetValues() *types.Value
- func (*InfluxdbProxyResponse_Results_Series) ProtoMessage()
- func (m *InfluxdbProxyResponse_Results_Series) Reset()
- func (m *InfluxdbProxyResponse_Results_Series) String() string
- func (this *InfluxdbProxyResponse_Results_Series) Validate() error
- func (m *InfluxdbProxyResponse_Results_Series) XXX_DiscardUnknown()
- func (m *InfluxdbProxyResponse_Results_Series) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InfluxdbProxyResponse_Results_Series) XXX_Merge(src proto.Message)
- func (m *InfluxdbProxyResponse_Results_Series) XXX_Size() int
- func (m *InfluxdbProxyResponse_Results_Series) XXX_Unmarshal(b []byte) error
- type Service
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterService ¶
func RegisterService(s giraffe_micro.Server, srv Service)
Types ¶
type Client ¶
type Client interface {
InfluxdbProxy(ctx context.Context, in *InfluxdbProxyRequest) (*InfluxdbProxyResponse, error)
}
Client is the client API for influxdb service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClient ¶
func NewClient(c giraffe_micro.Client) Client
type InfluxdbProxyRequest ¶
type InfluxdbProxyRequest struct { // //数据库 Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db" form:"db"` // //SQL语句 Q string `protobuf:"bytes,2,opt,name=q,proto3" json:"q" form:"q"` // //返回时间戳的精度 Epoch string `protobuf:"bytes,3,opt,name=epoch,proto3" json:"epoch" form:"epoch"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
InfluxdbProxy请求
func (*InfluxdbProxyRequest) Descriptor ¶
func (*InfluxdbProxyRequest) Descriptor() ([]byte, []int)
func (*InfluxdbProxyRequest) GetDb ¶
func (m *InfluxdbProxyRequest) GetDb() string
func (*InfluxdbProxyRequest) GetEpoch ¶
func (m *InfluxdbProxyRequest) GetEpoch() string
func (*InfluxdbProxyRequest) GetQ ¶
func (m *InfluxdbProxyRequest) GetQ() string
func (*InfluxdbProxyRequest) ProtoMessage ¶
func (*InfluxdbProxyRequest) ProtoMessage()
func (*InfluxdbProxyRequest) Reset ¶
func (m *InfluxdbProxyRequest) Reset()
func (*InfluxdbProxyRequest) String ¶
func (m *InfluxdbProxyRequest) String() string
func (*InfluxdbProxyRequest) Validate ¶
func (this *InfluxdbProxyRequest) Validate() error
func (*InfluxdbProxyRequest) XXX_DiscardUnknown ¶
func (m *InfluxdbProxyRequest) XXX_DiscardUnknown()
func (*InfluxdbProxyRequest) XXX_Marshal ¶
func (m *InfluxdbProxyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfluxdbProxyRequest) XXX_Merge ¶
func (m *InfluxdbProxyRequest) XXX_Merge(src proto.Message)
func (*InfluxdbProxyRequest) XXX_Size ¶
func (m *InfluxdbProxyRequest) XXX_Size() int
func (*InfluxdbProxyRequest) XXX_Unmarshal ¶
func (m *InfluxdbProxyRequest) XXX_Unmarshal(b []byte) error
type InfluxdbProxyResponse ¶
type InfluxdbProxyResponse struct { // //返回的数据 Results []*InfluxdbProxyResponse_Results `protobuf:"bytes,1,rep,name=results,proto3" json:"results" form:"results"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
InfluxdbProxy返回
func (*InfluxdbProxyResponse) Descriptor ¶
func (*InfluxdbProxyResponse) Descriptor() ([]byte, []int)
func (*InfluxdbProxyResponse) GetResults ¶
func (m *InfluxdbProxyResponse) GetResults() []*InfluxdbProxyResponse_Results
func (*InfluxdbProxyResponse) ProtoMessage ¶
func (*InfluxdbProxyResponse) ProtoMessage()
func (*InfluxdbProxyResponse) Reset ¶
func (m *InfluxdbProxyResponse) Reset()
func (*InfluxdbProxyResponse) String ¶
func (m *InfluxdbProxyResponse) String() string
func (*InfluxdbProxyResponse) Validate ¶
func (this *InfluxdbProxyResponse) Validate() error
func (*InfluxdbProxyResponse) XXX_DiscardUnknown ¶
func (m *InfluxdbProxyResponse) XXX_DiscardUnknown()
func (*InfluxdbProxyResponse) XXX_Marshal ¶
func (m *InfluxdbProxyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfluxdbProxyResponse) XXX_Merge ¶
func (m *InfluxdbProxyResponse) XXX_Merge(src proto.Message)
func (*InfluxdbProxyResponse) XXX_Size ¶
func (m *InfluxdbProxyResponse) XXX_Size() int
func (*InfluxdbProxyResponse) XXX_Unmarshal ¶
func (m *InfluxdbProxyResponse) XXX_Unmarshal(b []byte) error
type InfluxdbProxyResponseWrapper ¶
type InfluxdbProxyResponseWrapper struct { // //返回码 Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"` // //返回码解释 CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"` // //错误详情 Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"` // //返回数据 Data *InfluxdbProxyResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
InfluxdbProxyApi返回
func (*InfluxdbProxyResponseWrapper) Descriptor ¶
func (*InfluxdbProxyResponseWrapper) Descriptor() ([]byte, []int)
func (*InfluxdbProxyResponseWrapper) GetCode ¶
func (m *InfluxdbProxyResponseWrapper) GetCode() int32
func (*InfluxdbProxyResponseWrapper) GetCodeExplain ¶
func (m *InfluxdbProxyResponseWrapper) GetCodeExplain() string
func (*InfluxdbProxyResponseWrapper) GetData ¶
func (m *InfluxdbProxyResponseWrapper) GetData() *InfluxdbProxyResponse
func (*InfluxdbProxyResponseWrapper) GetError ¶
func (m *InfluxdbProxyResponseWrapper) GetError() string
func (*InfluxdbProxyResponseWrapper) ProtoMessage ¶
func (*InfluxdbProxyResponseWrapper) ProtoMessage()
func (*InfluxdbProxyResponseWrapper) Reset ¶
func (m *InfluxdbProxyResponseWrapper) Reset()
func (*InfluxdbProxyResponseWrapper) String ¶
func (m *InfluxdbProxyResponseWrapper) String() string
func (*InfluxdbProxyResponseWrapper) Validate ¶
func (this *InfluxdbProxyResponseWrapper) Validate() error
func (*InfluxdbProxyResponseWrapper) XXX_DiscardUnknown ¶
func (m *InfluxdbProxyResponseWrapper) XXX_DiscardUnknown()
func (*InfluxdbProxyResponseWrapper) XXX_Marshal ¶
func (m *InfluxdbProxyResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfluxdbProxyResponseWrapper) XXX_Merge ¶
func (m *InfluxdbProxyResponseWrapper) XXX_Merge(src proto.Message)
func (*InfluxdbProxyResponseWrapper) XXX_Size ¶
func (m *InfluxdbProxyResponseWrapper) XXX_Size() int
func (*InfluxdbProxyResponseWrapper) XXX_Unmarshal ¶
func (m *InfluxdbProxyResponseWrapper) XXX_Unmarshal(b []byte) error
type InfluxdbProxyResponse_Results ¶
type InfluxdbProxyResponse_Results struct { // //series Series []*InfluxdbProxyResponse_Results_Series `protobuf:"bytes,1,rep,name=series,proto3" json:"series" form:"series"` // //error Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error" form:"error"` // //statement_id StatementId int32 `protobuf:"varint,3,opt,name=statement_id,json=statementId,proto3" json:"statement_id" form:"statement_id"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InfluxdbProxyResponse_Results) Descriptor ¶
func (*InfluxdbProxyResponse_Results) Descriptor() ([]byte, []int)
func (*InfluxdbProxyResponse_Results) GetError ¶
func (m *InfluxdbProxyResponse_Results) GetError() string
func (*InfluxdbProxyResponse_Results) GetSeries ¶
func (m *InfluxdbProxyResponse_Results) GetSeries() []*InfluxdbProxyResponse_Results_Series
func (*InfluxdbProxyResponse_Results) GetStatementId ¶
func (m *InfluxdbProxyResponse_Results) GetStatementId() int32
func (*InfluxdbProxyResponse_Results) ProtoMessage ¶
func (*InfluxdbProxyResponse_Results) ProtoMessage()
func (*InfluxdbProxyResponse_Results) Reset ¶
func (m *InfluxdbProxyResponse_Results) Reset()
func (*InfluxdbProxyResponse_Results) String ¶
func (m *InfluxdbProxyResponse_Results) String() string
func (*InfluxdbProxyResponse_Results) Validate ¶
func (this *InfluxdbProxyResponse_Results) Validate() error
func (*InfluxdbProxyResponse_Results) XXX_DiscardUnknown ¶
func (m *InfluxdbProxyResponse_Results) XXX_DiscardUnknown()
func (*InfluxdbProxyResponse_Results) XXX_Marshal ¶
func (m *InfluxdbProxyResponse_Results) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfluxdbProxyResponse_Results) XXX_Merge ¶
func (m *InfluxdbProxyResponse_Results) XXX_Merge(src proto.Message)
func (*InfluxdbProxyResponse_Results) XXX_Size ¶
func (m *InfluxdbProxyResponse_Results) XXX_Size() int
func (*InfluxdbProxyResponse_Results) XXX_Unmarshal ¶
func (m *InfluxdbProxyResponse_Results) XXX_Unmarshal(b []byte) error
type InfluxdbProxyResponse_Results_Series ¶
type InfluxdbProxyResponse_Results_Series struct { // //指标值(是一个二维表),根据sql不同而不同,他的列在columns标明 Values *types.Value `protobuf:"bytes,1,opt,name=values,proto3" json:"values" form:"values"` // //表名 Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"` // //列名 Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns" form:"columns"` // //tags Tags *types.Struct `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags" form:"tags"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InfluxdbProxyResponse_Results_Series) Descriptor ¶
func (*InfluxdbProxyResponse_Results_Series) Descriptor() ([]byte, []int)
func (*InfluxdbProxyResponse_Results_Series) GetColumns ¶
func (m *InfluxdbProxyResponse_Results_Series) GetColumns() []string
func (*InfluxdbProxyResponse_Results_Series) GetName ¶
func (m *InfluxdbProxyResponse_Results_Series) GetName() string
func (*InfluxdbProxyResponse_Results_Series) GetTags ¶
func (m *InfluxdbProxyResponse_Results_Series) GetTags() *types.Struct
func (*InfluxdbProxyResponse_Results_Series) GetValues ¶
func (m *InfluxdbProxyResponse_Results_Series) GetValues() *types.Value
func (*InfluxdbProxyResponse_Results_Series) ProtoMessage ¶
func (*InfluxdbProxyResponse_Results_Series) ProtoMessage()
func (*InfluxdbProxyResponse_Results_Series) Reset ¶
func (m *InfluxdbProxyResponse_Results_Series) Reset()
func (*InfluxdbProxyResponse_Results_Series) String ¶
func (m *InfluxdbProxyResponse_Results_Series) String() string
func (*InfluxdbProxyResponse_Results_Series) Validate ¶
func (this *InfluxdbProxyResponse_Results_Series) Validate() error
func (*InfluxdbProxyResponse_Results_Series) XXX_DiscardUnknown ¶
func (m *InfluxdbProxyResponse_Results_Series) XXX_DiscardUnknown()
func (*InfluxdbProxyResponse_Results_Series) XXX_Marshal ¶
func (m *InfluxdbProxyResponse_Results_Series) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfluxdbProxyResponse_Results_Series) XXX_Merge ¶
func (m *InfluxdbProxyResponse_Results_Series) XXX_Merge(src proto.Message)
func (*InfluxdbProxyResponse_Results_Series) XXX_Size ¶
func (m *InfluxdbProxyResponse_Results_Series) XXX_Size() int
func (*InfluxdbProxyResponse_Results_Series) XXX_Unmarshal ¶
func (m *InfluxdbProxyResponse_Results_Series) XXX_Unmarshal(b []byte) error
type Service ¶
type Service interface {
InfluxdbProxy(context.Context, *InfluxdbProxyRequest) (*InfluxdbProxyResponse, error)
}
Service is the server API for influxdb service.
Click to show internal directories.
Click to hide internal directories.