Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func KeyPrefix(p string) []byte
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetMeasureCount() uint64
- func (m *GenesisState) GetMeasureList() []Measure
- func (m *GenesisState) GetTimeseriesCount() uint64
- func (m *GenesisState) GetTimeseriesList() []Timeseries
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type Measure
- func (*Measure) Descriptor() ([]byte, []int)
- func (m *Measure) GetCreator() string
- func (m *Measure) GetId() uint64
- func (m *Measure) GetTimeseriesID() string
- func (m *Measure) GetTs() string
- func (m *Measure) GetValue() string
- func (m *Measure) Marshal() (dAtA []byte, err error)
- func (m *Measure) MarshalTo(dAtA []byte) (int, error)
- func (m *Measure) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Measure) ProtoMessage()
- func (m *Measure) Reset()
- func (m *Measure) Size() (n int)
- func (m *Measure) String() string
- func (m *Measure) Unmarshal(dAtA []byte) error
- func (m *Measure) XXX_DiscardUnknown()
- func (m *Measure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Measure) XXX_Merge(src proto.Message)
- func (m *Measure) XXX_Size() int
- func (m *Measure) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgCreateMeasure
- func (*MsgCreateMeasure) Descriptor() ([]byte, []int)
- func (m *MsgCreateMeasure) GetCreator() string
- func (msg *MsgCreateMeasure) GetSignBytes() []byte
- func (msg *MsgCreateMeasure) GetSigners() []sdk.AccAddress
- func (m *MsgCreateMeasure) GetTimeseriesID() string
- func (m *MsgCreateMeasure) GetTs() string
- func (m *MsgCreateMeasure) GetValue() string
- func (m *MsgCreateMeasure) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateMeasure) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateMeasure) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateMeasure) ProtoMessage()
- func (m *MsgCreateMeasure) Reset()
- func (msg *MsgCreateMeasure) Route() string
- func (m *MsgCreateMeasure) Size() (n int)
- func (m *MsgCreateMeasure) String() string
- func (msg *MsgCreateMeasure) Type() string
- func (m *MsgCreateMeasure) Unmarshal(dAtA []byte) error
- func (msg *MsgCreateMeasure) ValidateBasic() error
- func (m *MsgCreateMeasure) XXX_DiscardUnknown()
- func (m *MsgCreateMeasure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateMeasure) XXX_Merge(src proto.Message)
- func (m *MsgCreateMeasure) XXX_Size() int
- func (m *MsgCreateMeasure) XXX_Unmarshal(b []byte) error
- type MsgCreateMeasureResponse
- func (*MsgCreateMeasureResponse) Descriptor() ([]byte, []int)
- func (m *MsgCreateMeasureResponse) GetId() uint64
- func (m *MsgCreateMeasureResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateMeasureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateMeasureResponse) ProtoMessage()
- func (m *MsgCreateMeasureResponse) Reset()
- func (m *MsgCreateMeasureResponse) Size() (n int)
- func (m *MsgCreateMeasureResponse) String() string
- func (m *MsgCreateMeasureResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCreateMeasureResponse) XXX_DiscardUnknown()
- func (m *MsgCreateMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateMeasureResponse) XXX_Merge(src proto.Message)
- func (m *MsgCreateMeasureResponse) XXX_Size() int
- func (m *MsgCreateMeasureResponse) XXX_Unmarshal(b []byte) error
- type MsgCreateTimeseries
- func (*MsgCreateTimeseries) Descriptor() ([]byte, []int)
- func (m *MsgCreateTimeseries) GetCreator() string
- func (m *MsgCreateTimeseries) GetLocation() string
- func (msg *MsgCreateTimeseries) GetSignBytes() []byte
- func (m *MsgCreateTimeseries) GetSignal() string
- func (msg *MsgCreateTimeseries) GetSigners() []sdk.AccAddress
- func (m *MsgCreateTimeseries) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateTimeseries) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateTimeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateTimeseries) ProtoMessage()
- func (m *MsgCreateTimeseries) Reset()
- func (msg *MsgCreateTimeseries) Route() string
- func (m *MsgCreateTimeseries) Size() (n int)
- func (m *MsgCreateTimeseries) String() string
- func (msg *MsgCreateTimeseries) Type() string
- func (m *MsgCreateTimeseries) Unmarshal(dAtA []byte) error
- func (msg *MsgCreateTimeseries) ValidateBasic() error
- func (m *MsgCreateTimeseries) XXX_DiscardUnknown()
- func (m *MsgCreateTimeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateTimeseries) XXX_Merge(src proto.Message)
- func (m *MsgCreateTimeseries) XXX_Size() int
- func (m *MsgCreateTimeseries) XXX_Unmarshal(b []byte) error
- type MsgCreateTimeseriesResponse
- func (*MsgCreateTimeseriesResponse) Descriptor() ([]byte, []int)
- func (m *MsgCreateTimeseriesResponse) GetId() uint64
- func (m *MsgCreateTimeseriesResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateTimeseriesResponse) ProtoMessage()
- func (m *MsgCreateTimeseriesResponse) Reset()
- func (m *MsgCreateTimeseriesResponse) Size() (n int)
- func (m *MsgCreateTimeseriesResponse) String() string
- func (m *MsgCreateTimeseriesResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCreateTimeseriesResponse) XXX_DiscardUnknown()
- func (m *MsgCreateTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateTimeseriesResponse) XXX_Merge(src proto.Message)
- func (m *MsgCreateTimeseriesResponse) XXX_Size() int
- func (m *MsgCreateTimeseriesResponse) XXX_Unmarshal(b []byte) error
- type MsgDeleteMeasure
- func (*MsgDeleteMeasure) Descriptor() ([]byte, []int)
- func (m *MsgDeleteMeasure) GetCreator() string
- func (m *MsgDeleteMeasure) GetId() uint64
- func (msg *MsgDeleteMeasure) GetSignBytes() []byte
- func (msg *MsgDeleteMeasure) GetSigners() []sdk.AccAddress
- func (m *MsgDeleteMeasure) Marshal() (dAtA []byte, err error)
- func (m *MsgDeleteMeasure) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeleteMeasure) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeleteMeasure) ProtoMessage()
- func (m *MsgDeleteMeasure) Reset()
- func (msg *MsgDeleteMeasure) Route() string
- func (m *MsgDeleteMeasure) Size() (n int)
- func (m *MsgDeleteMeasure) String() string
- func (msg *MsgDeleteMeasure) Type() string
- func (m *MsgDeleteMeasure) Unmarshal(dAtA []byte) error
- func (msg *MsgDeleteMeasure) ValidateBasic() error
- func (m *MsgDeleteMeasure) XXX_DiscardUnknown()
- func (m *MsgDeleteMeasure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeleteMeasure) XXX_Merge(src proto.Message)
- func (m *MsgDeleteMeasure) XXX_Size() int
- func (m *MsgDeleteMeasure) XXX_Unmarshal(b []byte) error
- type MsgDeleteMeasureResponse
- func (*MsgDeleteMeasureResponse) Descriptor() ([]byte, []int)
- func (m *MsgDeleteMeasureResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgDeleteMeasureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeleteMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeleteMeasureResponse) ProtoMessage()
- func (m *MsgDeleteMeasureResponse) Reset()
- func (m *MsgDeleteMeasureResponse) Size() (n int)
- func (m *MsgDeleteMeasureResponse) String() string
- func (m *MsgDeleteMeasureResponse) Unmarshal(dAtA []byte) error
- func (m *MsgDeleteMeasureResponse) XXX_DiscardUnknown()
- func (m *MsgDeleteMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeleteMeasureResponse) XXX_Merge(src proto.Message)
- func (m *MsgDeleteMeasureResponse) XXX_Size() int
- func (m *MsgDeleteMeasureResponse) XXX_Unmarshal(b []byte) error
- type MsgDeleteTimeseries
- func (*MsgDeleteTimeseries) Descriptor() ([]byte, []int)
- func (m *MsgDeleteTimeseries) GetCreator() string
- func (m *MsgDeleteTimeseries) GetId() uint64
- func (msg *MsgDeleteTimeseries) GetSignBytes() []byte
- func (msg *MsgDeleteTimeseries) GetSigners() []sdk.AccAddress
- func (m *MsgDeleteTimeseries) Marshal() (dAtA []byte, err error)
- func (m *MsgDeleteTimeseries) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeleteTimeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeleteTimeseries) ProtoMessage()
- func (m *MsgDeleteTimeseries) Reset()
- func (msg *MsgDeleteTimeseries) Route() string
- func (m *MsgDeleteTimeseries) Size() (n int)
- func (m *MsgDeleteTimeseries) String() string
- func (msg *MsgDeleteTimeseries) Type() string
- func (m *MsgDeleteTimeseries) Unmarshal(dAtA []byte) error
- func (msg *MsgDeleteTimeseries) ValidateBasic() error
- func (m *MsgDeleteTimeseries) XXX_DiscardUnknown()
- func (m *MsgDeleteTimeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeleteTimeseries) XXX_Merge(src proto.Message)
- func (m *MsgDeleteTimeseries) XXX_Size() int
- func (m *MsgDeleteTimeseries) XXX_Unmarshal(b []byte) error
- type MsgDeleteTimeseriesResponse
- func (*MsgDeleteTimeseriesResponse) Descriptor() ([]byte, []int)
- func (m *MsgDeleteTimeseriesResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgDeleteTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgDeleteTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgDeleteTimeseriesResponse) ProtoMessage()
- func (m *MsgDeleteTimeseriesResponse) Reset()
- func (m *MsgDeleteTimeseriesResponse) Size() (n int)
- func (m *MsgDeleteTimeseriesResponse) String() string
- func (m *MsgDeleteTimeseriesResponse) Unmarshal(dAtA []byte) error
- func (m *MsgDeleteTimeseriesResponse) XXX_DiscardUnknown()
- func (m *MsgDeleteTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgDeleteTimeseriesResponse) XXX_Merge(src proto.Message)
- func (m *MsgDeleteTimeseriesResponse) XXX_Size() int
- func (m *MsgDeleteTimeseriesResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MsgUpdateMeasure
- func (*MsgUpdateMeasure) Descriptor() ([]byte, []int)
- func (m *MsgUpdateMeasure) GetCreator() string
- func (m *MsgUpdateMeasure) GetId() uint64
- func (msg *MsgUpdateMeasure) GetSignBytes() []byte
- func (msg *MsgUpdateMeasure) GetSigners() []sdk.AccAddress
- func (m *MsgUpdateMeasure) GetTimeseriesID() string
- func (m *MsgUpdateMeasure) GetTs() string
- func (m *MsgUpdateMeasure) GetValue() string
- func (m *MsgUpdateMeasure) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateMeasure) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateMeasure) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateMeasure) ProtoMessage()
- func (m *MsgUpdateMeasure) Reset()
- func (msg *MsgUpdateMeasure) Route() string
- func (m *MsgUpdateMeasure) Size() (n int)
- func (m *MsgUpdateMeasure) String() string
- func (msg *MsgUpdateMeasure) Type() string
- func (m *MsgUpdateMeasure) Unmarshal(dAtA []byte) error
- func (msg *MsgUpdateMeasure) ValidateBasic() error
- func (m *MsgUpdateMeasure) XXX_DiscardUnknown()
- func (m *MsgUpdateMeasure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateMeasure) XXX_Merge(src proto.Message)
- func (m *MsgUpdateMeasure) XXX_Size() int
- func (m *MsgUpdateMeasure) XXX_Unmarshal(b []byte) error
- type MsgUpdateMeasureResponse
- func (*MsgUpdateMeasureResponse) Descriptor() ([]byte, []int)
- func (m *MsgUpdateMeasureResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateMeasureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateMeasureResponse) ProtoMessage()
- func (m *MsgUpdateMeasureResponse) Reset()
- func (m *MsgUpdateMeasureResponse) Size() (n int)
- func (m *MsgUpdateMeasureResponse) String() string
- func (m *MsgUpdateMeasureResponse) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateMeasureResponse) XXX_DiscardUnknown()
- func (m *MsgUpdateMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateMeasureResponse) XXX_Merge(src proto.Message)
- func (m *MsgUpdateMeasureResponse) XXX_Size() int
- func (m *MsgUpdateMeasureResponse) XXX_Unmarshal(b []byte) error
- type MsgUpdateTimeseries
- func (*MsgUpdateTimeseries) Descriptor() ([]byte, []int)
- func (m *MsgUpdateTimeseries) GetCreator() string
- func (m *MsgUpdateTimeseries) GetId() uint64
- func (m *MsgUpdateTimeseries) GetLocation() string
- func (msg *MsgUpdateTimeseries) GetSignBytes() []byte
- func (m *MsgUpdateTimeseries) GetSignal() string
- func (msg *MsgUpdateTimeseries) GetSigners() []sdk.AccAddress
- func (m *MsgUpdateTimeseries) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateTimeseries) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateTimeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateTimeseries) ProtoMessage()
- func (m *MsgUpdateTimeseries) Reset()
- func (msg *MsgUpdateTimeseries) Route() string
- func (m *MsgUpdateTimeseries) Size() (n int)
- func (m *MsgUpdateTimeseries) String() string
- func (msg *MsgUpdateTimeseries) Type() string
- func (m *MsgUpdateTimeseries) Unmarshal(dAtA []byte) error
- func (msg *MsgUpdateTimeseries) ValidateBasic() error
- func (m *MsgUpdateTimeseries) XXX_DiscardUnknown()
- func (m *MsgUpdateTimeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateTimeseries) XXX_Merge(src proto.Message)
- func (m *MsgUpdateTimeseries) XXX_Size() int
- func (m *MsgUpdateTimeseries) XXX_Unmarshal(b []byte) error
- type MsgUpdateTimeseriesResponse
- func (*MsgUpdateTimeseriesResponse) Descriptor() ([]byte, []int)
- func (m *MsgUpdateTimeseriesResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateTimeseriesResponse) ProtoMessage()
- func (m *MsgUpdateTimeseriesResponse) Reset()
- func (m *MsgUpdateTimeseriesResponse) Size() (n int)
- func (m *MsgUpdateTimeseriesResponse) String() string
- func (m *MsgUpdateTimeseriesResponse) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateTimeseriesResponse) XXX_DiscardUnknown()
- func (m *MsgUpdateTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateTimeseriesResponse) XXX_Merge(src proto.Message)
- func (m *MsgUpdateTimeseriesResponse) XXX_Size() int
- func (m *MsgUpdateTimeseriesResponse) XXX_Unmarshal(b []byte) error
- type QueryAllMeasureRequest
- func (*QueryAllMeasureRequest) Descriptor() ([]byte, []int)
- func (m *QueryAllMeasureRequest) GetPagination() *query.PageRequest
- func (m *QueryAllMeasureRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAllMeasureRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllMeasureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllMeasureRequest) ProtoMessage()
- func (m *QueryAllMeasureRequest) Reset()
- func (m *QueryAllMeasureRequest) Size() (n int)
- func (m *QueryAllMeasureRequest) String() string
- func (m *QueryAllMeasureRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAllMeasureRequest) XXX_DiscardUnknown()
- func (m *QueryAllMeasureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllMeasureRequest) XXX_Merge(src proto.Message)
- func (m *QueryAllMeasureRequest) XXX_Size() int
- func (m *QueryAllMeasureRequest) XXX_Unmarshal(b []byte) error
- type QueryAllMeasureResponse
- func (*QueryAllMeasureResponse) Descriptor() ([]byte, []int)
- func (m *QueryAllMeasureResponse) GetMeasure() []Measure
- func (m *QueryAllMeasureResponse) GetPagination() *query.PageResponse
- func (m *QueryAllMeasureResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAllMeasureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllMeasureResponse) ProtoMessage()
- func (m *QueryAllMeasureResponse) Reset()
- func (m *QueryAllMeasureResponse) Size() (n int)
- func (m *QueryAllMeasureResponse) String() string
- func (m *QueryAllMeasureResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAllMeasureResponse) XXX_DiscardUnknown()
- func (m *QueryAllMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllMeasureResponse) XXX_Merge(src proto.Message)
- func (m *QueryAllMeasureResponse) XXX_Size() int
- func (m *QueryAllMeasureResponse) XXX_Unmarshal(b []byte) error
- type QueryAllTimeseriesRequest
- func (*QueryAllTimeseriesRequest) Descriptor() ([]byte, []int)
- func (m *QueryAllTimeseriesRequest) GetPagination() *query.PageRequest
- func (m *QueryAllTimeseriesRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAllTimeseriesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllTimeseriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllTimeseriesRequest) ProtoMessage()
- func (m *QueryAllTimeseriesRequest) Reset()
- func (m *QueryAllTimeseriesRequest) Size() (n int)
- func (m *QueryAllTimeseriesRequest) String() string
- func (m *QueryAllTimeseriesRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAllTimeseriesRequest) XXX_DiscardUnknown()
- func (m *QueryAllTimeseriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllTimeseriesRequest) XXX_Merge(src proto.Message)
- func (m *QueryAllTimeseriesRequest) XXX_Size() int
- func (m *QueryAllTimeseriesRequest) XXX_Unmarshal(b []byte) error
- type QueryAllTimeseriesResponse
- func (*QueryAllTimeseriesResponse) Descriptor() ([]byte, []int)
- func (m *QueryAllTimeseriesResponse) GetPagination() *query.PageResponse
- func (m *QueryAllTimeseriesResponse) GetTimeseries() []Timeseries
- func (m *QueryAllTimeseriesResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAllTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllTimeseriesResponse) ProtoMessage()
- func (m *QueryAllTimeseriesResponse) Reset()
- func (m *QueryAllTimeseriesResponse) Size() (n int)
- func (m *QueryAllTimeseriesResponse) String() string
- func (m *QueryAllTimeseriesResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAllTimeseriesResponse) XXX_DiscardUnknown()
- func (m *QueryAllTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllTimeseriesResponse) XXX_Merge(src proto.Message)
- func (m *QueryAllTimeseriesResponse) XXX_Size() int
- func (m *QueryAllTimeseriesResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryGetMeasureRequest
- func (*QueryGetMeasureRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetMeasureRequest) GetId() uint64
- func (m *QueryGetMeasureRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetMeasureRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetMeasureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetMeasureRequest) ProtoMessage()
- func (m *QueryGetMeasureRequest) Reset()
- func (m *QueryGetMeasureRequest) Size() (n int)
- func (m *QueryGetMeasureRequest) String() string
- func (m *QueryGetMeasureRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetMeasureRequest) XXX_DiscardUnknown()
- func (m *QueryGetMeasureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetMeasureRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetMeasureRequest) XXX_Size() int
- func (m *QueryGetMeasureRequest) XXX_Unmarshal(b []byte) error
- type QueryGetMeasureResponse
- func (*QueryGetMeasureResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetMeasureResponse) GetMeasure() Measure
- func (m *QueryGetMeasureResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetMeasureResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetMeasureResponse) ProtoMessage()
- func (m *QueryGetMeasureResponse) Reset()
- func (m *QueryGetMeasureResponse) Size() (n int)
- func (m *QueryGetMeasureResponse) String() string
- func (m *QueryGetMeasureResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetMeasureResponse) XXX_DiscardUnknown()
- func (m *QueryGetMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetMeasureResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetMeasureResponse) XXX_Size() int
- func (m *QueryGetMeasureResponse) XXX_Unmarshal(b []byte) error
- type QueryGetTimeseriesRequest
- func (*QueryGetTimeseriesRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetTimeseriesRequest) GetId() uint64
- func (m *QueryGetTimeseriesRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetTimeseriesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetTimeseriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetTimeseriesRequest) ProtoMessage()
- func (m *QueryGetTimeseriesRequest) Reset()
- func (m *QueryGetTimeseriesRequest) Size() (n int)
- func (m *QueryGetTimeseriesRequest) String() string
- func (m *QueryGetTimeseriesRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetTimeseriesRequest) XXX_DiscardUnknown()
- func (m *QueryGetTimeseriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetTimeseriesRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetTimeseriesRequest) XXX_Size() int
- func (m *QueryGetTimeseriesRequest) XXX_Unmarshal(b []byte) error
- type QueryGetTimeseriesResponse
- func (*QueryGetTimeseriesResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetTimeseriesResponse) GetTimeseries() Timeseries
- func (m *QueryGetTimeseriesResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetTimeseriesResponse) ProtoMessage()
- func (m *QueryGetTimeseriesResponse) Reset()
- func (m *QueryGetTimeseriesResponse) Size() (n int)
- func (m *QueryGetTimeseriesResponse) String() string
- func (m *QueryGetTimeseriesResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetTimeseriesResponse) XXX_DiscardUnknown()
- func (m *QueryGetTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetTimeseriesResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetTimeseriesResponse) XXX_Size() int
- func (m *QueryGetTimeseriesResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type Timeseries
- func (*Timeseries) Descriptor() ([]byte, []int)
- func (m *Timeseries) GetCreator() string
- func (m *Timeseries) GetId() uint64
- func (m *Timeseries) GetLocation() string
- func (m *Timeseries) GetSignal() string
- func (m *Timeseries) Marshal() (dAtA []byte, err error)
- func (m *Timeseries) MarshalTo(dAtA []byte) (int, error)
- func (m *Timeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Timeseries) ProtoMessage()
- func (m *Timeseries) Reset()
- func (m *Timeseries) Size() (n int)
- func (m *Timeseries) String() string
- func (m *Timeseries) Unmarshal(dAtA []byte) error
- func (m *Timeseries) XXX_DiscardUnknown()
- func (m *Timeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Timeseries) XXX_Merge(src proto.Message)
- func (m *Timeseries) XXX_Size() int
- func (m *Timeseries) XXX_Unmarshal(b []byte) error
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) CreateMeasure(ctx context.Context, req *MsgCreateMeasure) (*MsgCreateMeasureResponse, error)
- func (*UnimplementedMsgServer) CreateTimeseries(ctx context.Context, req *MsgCreateTimeseries) (*MsgCreateTimeseriesResponse, error)
- func (*UnimplementedMsgServer) DeleteMeasure(ctx context.Context, req *MsgDeleteMeasure) (*MsgDeleteMeasureResponse, error)
- func (*UnimplementedMsgServer) DeleteTimeseries(ctx context.Context, req *MsgDeleteTimeseries) (*MsgDeleteTimeseriesResponse, error)
- func (*UnimplementedMsgServer) UpdateMeasure(ctx context.Context, req *MsgUpdateMeasure) (*MsgUpdateMeasureResponse, error)
- func (*UnimplementedMsgServer) UpdateTimeseries(ctx context.Context, req *MsgUpdateTimeseries) (*MsgUpdateTimeseriesResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) Measure(ctx context.Context, req *QueryGetMeasureRequest) (*QueryGetMeasureResponse, error)
- func (*UnimplementedQueryServer) MeasureAll(ctx context.Context, req *QueryAllMeasureRequest) (*QueryAllMeasureResponse, error)
- func (*UnimplementedQueryServer) Timeseries(ctx context.Context, req *QueryGetTimeseriesRequest) (*QueryGetTimeseriesResponse, error)
- func (*UnimplementedQueryServer) TimeseriesAll(ctx context.Context, req *QueryAllTimeseriesRequest) (*QueryAllTimeseriesResponse, error)
Constants ¶
const ( // ModuleName defines the module name ModuleName = "tsdb" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey is the message route for slashing RouterKey = ModuleName // QuerierRoute defines the module's query routing key QuerierRoute = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_tsdb" )
const ( TimeseriesKey = "Timeseries-value-" TimeseriesCountKey = "Timeseries-count-" )
const ( MeasureKey = "Measure-value-" MeasureCountKey = "Measure-count-" )
const DefaultIndex uint64 = 1
DefaultIndex is the default capability global index
Variables ¶
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthMeasure = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMeasure = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMeasure = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTimeseries = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTimeseries = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTimeseries = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var (
ErrSample = sdkerrors.Register(ModuleName, 1100, "sample error")
)
x/tsdb module sentinel errors
var (
ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
Functions ¶
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type GenesisState ¶
type GenesisState struct { TimeseriesList []Timeseries `protobuf:"bytes,1,rep,name=timeseriesList,proto3" json:"timeseriesList"` TimeseriesCount uint64 `protobuf:"varint,2,opt,name=timeseriesCount,proto3" json:"timeseriesCount,omitempty"` MeasureList []Measure `protobuf:"bytes,3,rep,name=measureList,proto3" json:"measureList"` MeasureCount uint64 `protobuf:"varint,4,opt,name=measureCount,proto3" json:"measureCount,omitempty"` }
GenesisState defines the tsdb module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default Capability genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetMeasureCount ¶
func (m *GenesisState) GetMeasureCount() uint64
func (*GenesisState) GetMeasureList ¶
func (m *GenesisState) GetMeasureList() []Measure
func (*GenesisState) GetTimeseriesCount ¶
func (m *GenesisState) GetTimeseriesCount() uint64
func (*GenesisState) GetTimeseriesList ¶
func (m *GenesisState) GetTimeseriesList() []Timeseries
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type Measure ¶
type Measure struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` TimeseriesID string `protobuf:"bytes,2,opt,name=timeseriesID,proto3" json:"timeseriesID,omitempty"` Ts string `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"` Value string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` Creator string `protobuf:"bytes,5,opt,name=creator,proto3" json:"creator,omitempty"` }
func (*Measure) Descriptor ¶
func (*Measure) GetCreator ¶
func (*Measure) GetTimeseriesID ¶
func (*Measure) MarshalToSizedBuffer ¶
func (*Measure) ProtoMessage ¶
func (*Measure) ProtoMessage()
func (*Measure) XXX_DiscardUnknown ¶
func (m *Measure) XXX_DiscardUnknown()
func (*Measure) XXX_Marshal ¶
func (*Measure) XXX_Unmarshal ¶
type MsgClient ¶
type MsgClient interface { CreateTimeseries(ctx context.Context, in *MsgCreateTimeseries, opts ...grpc.CallOption) (*MsgCreateTimeseriesResponse, error) UpdateTimeseries(ctx context.Context, in *MsgUpdateTimeseries, opts ...grpc.CallOption) (*MsgUpdateTimeseriesResponse, error) DeleteTimeseries(ctx context.Context, in *MsgDeleteTimeseries, opts ...grpc.CallOption) (*MsgDeleteTimeseriesResponse, error) CreateMeasure(ctx context.Context, in *MsgCreateMeasure, opts ...grpc.CallOption) (*MsgCreateMeasureResponse, error) UpdateMeasure(ctx context.Context, in *MsgUpdateMeasure, opts ...grpc.CallOption) (*MsgUpdateMeasureResponse, error) DeleteMeasure(ctx context.Context, in *MsgDeleteMeasure, opts ...grpc.CallOption) (*MsgDeleteMeasureResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc1.ClientConn) MsgClient
type MsgCreateMeasure ¶
type MsgCreateMeasure struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` TimeseriesID string `protobuf:"bytes,2,opt,name=timeseriesID,proto3" json:"timeseriesID,omitempty"` Ts string `protobuf:"bytes,3,opt,name=ts,proto3" json:"ts,omitempty"` Value string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func NewMsgCreateMeasure ¶
func NewMsgCreateMeasure(creator string, timeseriesID string, ts string, value string) *MsgCreateMeasure
func (*MsgCreateMeasure) Descriptor ¶
func (*MsgCreateMeasure) Descriptor() ([]byte, []int)
func (*MsgCreateMeasure) GetCreator ¶
func (m *MsgCreateMeasure) GetCreator() string
func (*MsgCreateMeasure) GetSignBytes ¶
func (msg *MsgCreateMeasure) GetSignBytes() []byte
func (*MsgCreateMeasure) GetSigners ¶
func (msg *MsgCreateMeasure) GetSigners() []sdk.AccAddress
func (*MsgCreateMeasure) GetTimeseriesID ¶
func (m *MsgCreateMeasure) GetTimeseriesID() string
func (*MsgCreateMeasure) GetTs ¶
func (m *MsgCreateMeasure) GetTs() string
func (*MsgCreateMeasure) GetValue ¶
func (m *MsgCreateMeasure) GetValue() string
func (*MsgCreateMeasure) Marshal ¶
func (m *MsgCreateMeasure) Marshal() (dAtA []byte, err error)
func (*MsgCreateMeasure) MarshalToSizedBuffer ¶
func (m *MsgCreateMeasure) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateMeasure) ProtoMessage ¶
func (*MsgCreateMeasure) ProtoMessage()
func (*MsgCreateMeasure) Reset ¶
func (m *MsgCreateMeasure) Reset()
func (*MsgCreateMeasure) Route ¶
func (msg *MsgCreateMeasure) Route() string
func (*MsgCreateMeasure) Size ¶
func (m *MsgCreateMeasure) Size() (n int)
func (*MsgCreateMeasure) String ¶
func (m *MsgCreateMeasure) String() string
func (*MsgCreateMeasure) Type ¶
func (msg *MsgCreateMeasure) Type() string
func (*MsgCreateMeasure) Unmarshal ¶
func (m *MsgCreateMeasure) Unmarshal(dAtA []byte) error
func (*MsgCreateMeasure) ValidateBasic ¶
func (msg *MsgCreateMeasure) ValidateBasic() error
func (*MsgCreateMeasure) XXX_DiscardUnknown ¶
func (m *MsgCreateMeasure) XXX_DiscardUnknown()
func (*MsgCreateMeasure) XXX_Marshal ¶
func (m *MsgCreateMeasure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateMeasure) XXX_Merge ¶
func (m *MsgCreateMeasure) XXX_Merge(src proto.Message)
func (*MsgCreateMeasure) XXX_Size ¶
func (m *MsgCreateMeasure) XXX_Size() int
func (*MsgCreateMeasure) XXX_Unmarshal ¶
func (m *MsgCreateMeasure) XXX_Unmarshal(b []byte) error
type MsgCreateMeasureResponse ¶
type MsgCreateMeasureResponse struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*MsgCreateMeasureResponse) Descriptor ¶
func (*MsgCreateMeasureResponse) Descriptor() ([]byte, []int)
func (*MsgCreateMeasureResponse) GetId ¶
func (m *MsgCreateMeasureResponse) GetId() uint64
func (*MsgCreateMeasureResponse) Marshal ¶
func (m *MsgCreateMeasureResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreateMeasureResponse) MarshalTo ¶
func (m *MsgCreateMeasureResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateMeasureResponse) MarshalToSizedBuffer ¶
func (m *MsgCreateMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateMeasureResponse) ProtoMessage ¶
func (*MsgCreateMeasureResponse) ProtoMessage()
func (*MsgCreateMeasureResponse) Reset ¶
func (m *MsgCreateMeasureResponse) Reset()
func (*MsgCreateMeasureResponse) Size ¶
func (m *MsgCreateMeasureResponse) Size() (n int)
func (*MsgCreateMeasureResponse) String ¶
func (m *MsgCreateMeasureResponse) String() string
func (*MsgCreateMeasureResponse) Unmarshal ¶
func (m *MsgCreateMeasureResponse) Unmarshal(dAtA []byte) error
func (*MsgCreateMeasureResponse) XXX_DiscardUnknown ¶
func (m *MsgCreateMeasureResponse) XXX_DiscardUnknown()
func (*MsgCreateMeasureResponse) XXX_Marshal ¶
func (m *MsgCreateMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateMeasureResponse) XXX_Merge ¶
func (m *MsgCreateMeasureResponse) XXX_Merge(src proto.Message)
func (*MsgCreateMeasureResponse) XXX_Size ¶
func (m *MsgCreateMeasureResponse) XXX_Size() int
func (*MsgCreateMeasureResponse) XXX_Unmarshal ¶
func (m *MsgCreateMeasureResponse) XXX_Unmarshal(b []byte) error
type MsgCreateTimeseries ¶
type MsgCreateTimeseries struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` Signal string `protobuf:"bytes,3,opt,name=signal,proto3" json:"signal,omitempty"` }
func NewMsgCreateTimeseries ¶
func NewMsgCreateTimeseries(creator string, location string, signal string) *MsgCreateTimeseries
func (*MsgCreateTimeseries) Descriptor ¶
func (*MsgCreateTimeseries) Descriptor() ([]byte, []int)
func (*MsgCreateTimeseries) GetCreator ¶
func (m *MsgCreateTimeseries) GetCreator() string
func (*MsgCreateTimeseries) GetLocation ¶
func (m *MsgCreateTimeseries) GetLocation() string
func (*MsgCreateTimeseries) GetSignBytes ¶
func (msg *MsgCreateTimeseries) GetSignBytes() []byte
func (*MsgCreateTimeseries) GetSignal ¶
func (m *MsgCreateTimeseries) GetSignal() string
func (*MsgCreateTimeseries) GetSigners ¶
func (msg *MsgCreateTimeseries) GetSigners() []sdk.AccAddress
func (*MsgCreateTimeseries) Marshal ¶
func (m *MsgCreateTimeseries) Marshal() (dAtA []byte, err error)
func (*MsgCreateTimeseries) MarshalTo ¶
func (m *MsgCreateTimeseries) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateTimeseries) MarshalToSizedBuffer ¶
func (m *MsgCreateTimeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateTimeseries) ProtoMessage ¶
func (*MsgCreateTimeseries) ProtoMessage()
func (*MsgCreateTimeseries) Reset ¶
func (m *MsgCreateTimeseries) Reset()
func (*MsgCreateTimeseries) Route ¶
func (msg *MsgCreateTimeseries) Route() string
func (*MsgCreateTimeseries) Size ¶
func (m *MsgCreateTimeseries) Size() (n int)
func (*MsgCreateTimeseries) String ¶
func (m *MsgCreateTimeseries) String() string
func (*MsgCreateTimeseries) Type ¶
func (msg *MsgCreateTimeseries) Type() string
func (*MsgCreateTimeseries) Unmarshal ¶
func (m *MsgCreateTimeseries) Unmarshal(dAtA []byte) error
func (*MsgCreateTimeseries) ValidateBasic ¶
func (msg *MsgCreateTimeseries) ValidateBasic() error
func (*MsgCreateTimeseries) XXX_DiscardUnknown ¶
func (m *MsgCreateTimeseries) XXX_DiscardUnknown()
func (*MsgCreateTimeseries) XXX_Marshal ¶
func (m *MsgCreateTimeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateTimeseries) XXX_Merge ¶
func (m *MsgCreateTimeseries) XXX_Merge(src proto.Message)
func (*MsgCreateTimeseries) XXX_Size ¶
func (m *MsgCreateTimeseries) XXX_Size() int
func (*MsgCreateTimeseries) XXX_Unmarshal ¶
func (m *MsgCreateTimeseries) XXX_Unmarshal(b []byte) error
type MsgCreateTimeseriesResponse ¶
type MsgCreateTimeseriesResponse struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*MsgCreateTimeseriesResponse) Descriptor ¶
func (*MsgCreateTimeseriesResponse) Descriptor() ([]byte, []int)
func (*MsgCreateTimeseriesResponse) GetId ¶
func (m *MsgCreateTimeseriesResponse) GetId() uint64
func (*MsgCreateTimeseriesResponse) Marshal ¶
func (m *MsgCreateTimeseriesResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreateTimeseriesResponse) MarshalTo ¶
func (m *MsgCreateTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateTimeseriesResponse) MarshalToSizedBuffer ¶
func (m *MsgCreateTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateTimeseriesResponse) ProtoMessage ¶
func (*MsgCreateTimeseriesResponse) ProtoMessage()
func (*MsgCreateTimeseriesResponse) Reset ¶
func (m *MsgCreateTimeseriesResponse) Reset()
func (*MsgCreateTimeseriesResponse) Size ¶
func (m *MsgCreateTimeseriesResponse) Size() (n int)
func (*MsgCreateTimeseriesResponse) String ¶
func (m *MsgCreateTimeseriesResponse) String() string
func (*MsgCreateTimeseriesResponse) Unmarshal ¶
func (m *MsgCreateTimeseriesResponse) Unmarshal(dAtA []byte) error
func (*MsgCreateTimeseriesResponse) XXX_DiscardUnknown ¶
func (m *MsgCreateTimeseriesResponse) XXX_DiscardUnknown()
func (*MsgCreateTimeseriesResponse) XXX_Marshal ¶
func (m *MsgCreateTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateTimeseriesResponse) XXX_Merge ¶
func (m *MsgCreateTimeseriesResponse) XXX_Merge(src proto.Message)
func (*MsgCreateTimeseriesResponse) XXX_Size ¶
func (m *MsgCreateTimeseriesResponse) XXX_Size() int
func (*MsgCreateTimeseriesResponse) XXX_Unmarshal ¶
func (m *MsgCreateTimeseriesResponse) XXX_Unmarshal(b []byte) error
type MsgDeleteMeasure ¶
type MsgDeleteMeasure struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` }
func NewMsgDeleteMeasure ¶
func NewMsgDeleteMeasure(creator string, id uint64) *MsgDeleteMeasure
func (*MsgDeleteMeasure) Descriptor ¶
func (*MsgDeleteMeasure) Descriptor() ([]byte, []int)
func (*MsgDeleteMeasure) GetCreator ¶
func (m *MsgDeleteMeasure) GetCreator() string
func (*MsgDeleteMeasure) GetId ¶
func (m *MsgDeleteMeasure) GetId() uint64
func (*MsgDeleteMeasure) GetSignBytes ¶
func (msg *MsgDeleteMeasure) GetSignBytes() []byte
func (*MsgDeleteMeasure) GetSigners ¶
func (msg *MsgDeleteMeasure) GetSigners() []sdk.AccAddress
func (*MsgDeleteMeasure) Marshal ¶
func (m *MsgDeleteMeasure) Marshal() (dAtA []byte, err error)
func (*MsgDeleteMeasure) MarshalToSizedBuffer ¶
func (m *MsgDeleteMeasure) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeleteMeasure) ProtoMessage ¶
func (*MsgDeleteMeasure) ProtoMessage()
func (*MsgDeleteMeasure) Reset ¶
func (m *MsgDeleteMeasure) Reset()
func (*MsgDeleteMeasure) Route ¶
func (msg *MsgDeleteMeasure) Route() string
func (*MsgDeleteMeasure) Size ¶
func (m *MsgDeleteMeasure) Size() (n int)
func (*MsgDeleteMeasure) String ¶
func (m *MsgDeleteMeasure) String() string
func (*MsgDeleteMeasure) Type ¶
func (msg *MsgDeleteMeasure) Type() string
func (*MsgDeleteMeasure) Unmarshal ¶
func (m *MsgDeleteMeasure) Unmarshal(dAtA []byte) error
func (*MsgDeleteMeasure) ValidateBasic ¶
func (msg *MsgDeleteMeasure) ValidateBasic() error
func (*MsgDeleteMeasure) XXX_DiscardUnknown ¶
func (m *MsgDeleteMeasure) XXX_DiscardUnknown()
func (*MsgDeleteMeasure) XXX_Marshal ¶
func (m *MsgDeleteMeasure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeleteMeasure) XXX_Merge ¶
func (m *MsgDeleteMeasure) XXX_Merge(src proto.Message)
func (*MsgDeleteMeasure) XXX_Size ¶
func (m *MsgDeleteMeasure) XXX_Size() int
func (*MsgDeleteMeasure) XXX_Unmarshal ¶
func (m *MsgDeleteMeasure) XXX_Unmarshal(b []byte) error
type MsgDeleteMeasureResponse ¶
type MsgDeleteMeasureResponse struct { }
func (*MsgDeleteMeasureResponse) Descriptor ¶
func (*MsgDeleteMeasureResponse) Descriptor() ([]byte, []int)
func (*MsgDeleteMeasureResponse) Marshal ¶
func (m *MsgDeleteMeasureResponse) Marshal() (dAtA []byte, err error)
func (*MsgDeleteMeasureResponse) MarshalTo ¶
func (m *MsgDeleteMeasureResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgDeleteMeasureResponse) MarshalToSizedBuffer ¶
func (m *MsgDeleteMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeleteMeasureResponse) ProtoMessage ¶
func (*MsgDeleteMeasureResponse) ProtoMessage()
func (*MsgDeleteMeasureResponse) Reset ¶
func (m *MsgDeleteMeasureResponse) Reset()
func (*MsgDeleteMeasureResponse) Size ¶
func (m *MsgDeleteMeasureResponse) Size() (n int)
func (*MsgDeleteMeasureResponse) String ¶
func (m *MsgDeleteMeasureResponse) String() string
func (*MsgDeleteMeasureResponse) Unmarshal ¶
func (m *MsgDeleteMeasureResponse) Unmarshal(dAtA []byte) error
func (*MsgDeleteMeasureResponse) XXX_DiscardUnknown ¶
func (m *MsgDeleteMeasureResponse) XXX_DiscardUnknown()
func (*MsgDeleteMeasureResponse) XXX_Marshal ¶
func (m *MsgDeleteMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeleteMeasureResponse) XXX_Merge ¶
func (m *MsgDeleteMeasureResponse) XXX_Merge(src proto.Message)
func (*MsgDeleteMeasureResponse) XXX_Size ¶
func (m *MsgDeleteMeasureResponse) XXX_Size() int
func (*MsgDeleteMeasureResponse) XXX_Unmarshal ¶
func (m *MsgDeleteMeasureResponse) XXX_Unmarshal(b []byte) error
type MsgDeleteTimeseries ¶
type MsgDeleteTimeseries struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` }
func NewMsgDeleteTimeseries ¶
func NewMsgDeleteTimeseries(creator string, id uint64) *MsgDeleteTimeseries
func (*MsgDeleteTimeseries) Descriptor ¶
func (*MsgDeleteTimeseries) Descriptor() ([]byte, []int)
func (*MsgDeleteTimeseries) GetCreator ¶
func (m *MsgDeleteTimeseries) GetCreator() string
func (*MsgDeleteTimeseries) GetId ¶
func (m *MsgDeleteTimeseries) GetId() uint64
func (*MsgDeleteTimeseries) GetSignBytes ¶
func (msg *MsgDeleteTimeseries) GetSignBytes() []byte
func (*MsgDeleteTimeseries) GetSigners ¶
func (msg *MsgDeleteTimeseries) GetSigners() []sdk.AccAddress
func (*MsgDeleteTimeseries) Marshal ¶
func (m *MsgDeleteTimeseries) Marshal() (dAtA []byte, err error)
func (*MsgDeleteTimeseries) MarshalTo ¶
func (m *MsgDeleteTimeseries) MarshalTo(dAtA []byte) (int, error)
func (*MsgDeleteTimeseries) MarshalToSizedBuffer ¶
func (m *MsgDeleteTimeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeleteTimeseries) ProtoMessage ¶
func (*MsgDeleteTimeseries) ProtoMessage()
func (*MsgDeleteTimeseries) Reset ¶
func (m *MsgDeleteTimeseries) Reset()
func (*MsgDeleteTimeseries) Route ¶
func (msg *MsgDeleteTimeseries) Route() string
func (*MsgDeleteTimeseries) Size ¶
func (m *MsgDeleteTimeseries) Size() (n int)
func (*MsgDeleteTimeseries) String ¶
func (m *MsgDeleteTimeseries) String() string
func (*MsgDeleteTimeseries) Type ¶
func (msg *MsgDeleteTimeseries) Type() string
func (*MsgDeleteTimeseries) Unmarshal ¶
func (m *MsgDeleteTimeseries) Unmarshal(dAtA []byte) error
func (*MsgDeleteTimeseries) ValidateBasic ¶
func (msg *MsgDeleteTimeseries) ValidateBasic() error
func (*MsgDeleteTimeseries) XXX_DiscardUnknown ¶
func (m *MsgDeleteTimeseries) XXX_DiscardUnknown()
func (*MsgDeleteTimeseries) XXX_Marshal ¶
func (m *MsgDeleteTimeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeleteTimeseries) XXX_Merge ¶
func (m *MsgDeleteTimeseries) XXX_Merge(src proto.Message)
func (*MsgDeleteTimeseries) XXX_Size ¶
func (m *MsgDeleteTimeseries) XXX_Size() int
func (*MsgDeleteTimeseries) XXX_Unmarshal ¶
func (m *MsgDeleteTimeseries) XXX_Unmarshal(b []byte) error
type MsgDeleteTimeseriesResponse ¶
type MsgDeleteTimeseriesResponse struct { }
func (*MsgDeleteTimeseriesResponse) Descriptor ¶
func (*MsgDeleteTimeseriesResponse) Descriptor() ([]byte, []int)
func (*MsgDeleteTimeseriesResponse) Marshal ¶
func (m *MsgDeleteTimeseriesResponse) Marshal() (dAtA []byte, err error)
func (*MsgDeleteTimeseriesResponse) MarshalTo ¶
func (m *MsgDeleteTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgDeleteTimeseriesResponse) MarshalToSizedBuffer ¶
func (m *MsgDeleteTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgDeleteTimeseriesResponse) ProtoMessage ¶
func (*MsgDeleteTimeseriesResponse) ProtoMessage()
func (*MsgDeleteTimeseriesResponse) Reset ¶
func (m *MsgDeleteTimeseriesResponse) Reset()
func (*MsgDeleteTimeseriesResponse) Size ¶
func (m *MsgDeleteTimeseriesResponse) Size() (n int)
func (*MsgDeleteTimeseriesResponse) String ¶
func (m *MsgDeleteTimeseriesResponse) String() string
func (*MsgDeleteTimeseriesResponse) Unmarshal ¶
func (m *MsgDeleteTimeseriesResponse) Unmarshal(dAtA []byte) error
func (*MsgDeleteTimeseriesResponse) XXX_DiscardUnknown ¶
func (m *MsgDeleteTimeseriesResponse) XXX_DiscardUnknown()
func (*MsgDeleteTimeseriesResponse) XXX_Marshal ¶
func (m *MsgDeleteTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgDeleteTimeseriesResponse) XXX_Merge ¶
func (m *MsgDeleteTimeseriesResponse) XXX_Merge(src proto.Message)
func (*MsgDeleteTimeseriesResponse) XXX_Size ¶
func (m *MsgDeleteTimeseriesResponse) XXX_Size() int
func (*MsgDeleteTimeseriesResponse) XXX_Unmarshal ¶
func (m *MsgDeleteTimeseriesResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { CreateTimeseries(context.Context, *MsgCreateTimeseries) (*MsgCreateTimeseriesResponse, error) UpdateTimeseries(context.Context, *MsgUpdateTimeseries) (*MsgUpdateTimeseriesResponse, error) DeleteTimeseries(context.Context, *MsgDeleteTimeseries) (*MsgDeleteTimeseriesResponse, error) CreateMeasure(context.Context, *MsgCreateMeasure) (*MsgCreateMeasureResponse, error) UpdateMeasure(context.Context, *MsgUpdateMeasure) (*MsgUpdateMeasureResponse, error) DeleteMeasure(context.Context, *MsgDeleteMeasure) (*MsgDeleteMeasureResponse, error) }
MsgServer is the server API for Msg service.
type MsgUpdateMeasure ¶
type MsgUpdateMeasure struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` TimeseriesID string `protobuf:"bytes,3,opt,name=timeseriesID,proto3" json:"timeseriesID,omitempty"` Ts string `protobuf:"bytes,4,opt,name=ts,proto3" json:"ts,omitempty"` Value string `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` }
func NewMsgUpdateMeasure ¶
func (*MsgUpdateMeasure) Descriptor ¶
func (*MsgUpdateMeasure) Descriptor() ([]byte, []int)
func (*MsgUpdateMeasure) GetCreator ¶
func (m *MsgUpdateMeasure) GetCreator() string
func (*MsgUpdateMeasure) GetId ¶
func (m *MsgUpdateMeasure) GetId() uint64
func (*MsgUpdateMeasure) GetSignBytes ¶
func (msg *MsgUpdateMeasure) GetSignBytes() []byte
func (*MsgUpdateMeasure) GetSigners ¶
func (msg *MsgUpdateMeasure) GetSigners() []sdk.AccAddress
func (*MsgUpdateMeasure) GetTimeseriesID ¶
func (m *MsgUpdateMeasure) GetTimeseriesID() string
func (*MsgUpdateMeasure) GetTs ¶
func (m *MsgUpdateMeasure) GetTs() string
func (*MsgUpdateMeasure) GetValue ¶
func (m *MsgUpdateMeasure) GetValue() string
func (*MsgUpdateMeasure) Marshal ¶
func (m *MsgUpdateMeasure) Marshal() (dAtA []byte, err error)
func (*MsgUpdateMeasure) MarshalToSizedBuffer ¶
func (m *MsgUpdateMeasure) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateMeasure) ProtoMessage ¶
func (*MsgUpdateMeasure) ProtoMessage()
func (*MsgUpdateMeasure) Reset ¶
func (m *MsgUpdateMeasure) Reset()
func (*MsgUpdateMeasure) Route ¶
func (msg *MsgUpdateMeasure) Route() string
func (*MsgUpdateMeasure) Size ¶
func (m *MsgUpdateMeasure) Size() (n int)
func (*MsgUpdateMeasure) String ¶
func (m *MsgUpdateMeasure) String() string
func (*MsgUpdateMeasure) Type ¶
func (msg *MsgUpdateMeasure) Type() string
func (*MsgUpdateMeasure) Unmarshal ¶
func (m *MsgUpdateMeasure) Unmarshal(dAtA []byte) error
func (*MsgUpdateMeasure) ValidateBasic ¶
func (msg *MsgUpdateMeasure) ValidateBasic() error
func (*MsgUpdateMeasure) XXX_DiscardUnknown ¶
func (m *MsgUpdateMeasure) XXX_DiscardUnknown()
func (*MsgUpdateMeasure) XXX_Marshal ¶
func (m *MsgUpdateMeasure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateMeasure) XXX_Merge ¶
func (m *MsgUpdateMeasure) XXX_Merge(src proto.Message)
func (*MsgUpdateMeasure) XXX_Size ¶
func (m *MsgUpdateMeasure) XXX_Size() int
func (*MsgUpdateMeasure) XXX_Unmarshal ¶
func (m *MsgUpdateMeasure) XXX_Unmarshal(b []byte) error
type MsgUpdateMeasureResponse ¶
type MsgUpdateMeasureResponse struct { }
func (*MsgUpdateMeasureResponse) Descriptor ¶
func (*MsgUpdateMeasureResponse) Descriptor() ([]byte, []int)
func (*MsgUpdateMeasureResponse) Marshal ¶
func (m *MsgUpdateMeasureResponse) Marshal() (dAtA []byte, err error)
func (*MsgUpdateMeasureResponse) MarshalTo ¶
func (m *MsgUpdateMeasureResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateMeasureResponse) MarshalToSizedBuffer ¶
func (m *MsgUpdateMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateMeasureResponse) ProtoMessage ¶
func (*MsgUpdateMeasureResponse) ProtoMessage()
func (*MsgUpdateMeasureResponse) Reset ¶
func (m *MsgUpdateMeasureResponse) Reset()
func (*MsgUpdateMeasureResponse) Size ¶
func (m *MsgUpdateMeasureResponse) Size() (n int)
func (*MsgUpdateMeasureResponse) String ¶
func (m *MsgUpdateMeasureResponse) String() string
func (*MsgUpdateMeasureResponse) Unmarshal ¶
func (m *MsgUpdateMeasureResponse) Unmarshal(dAtA []byte) error
func (*MsgUpdateMeasureResponse) XXX_DiscardUnknown ¶
func (m *MsgUpdateMeasureResponse) XXX_DiscardUnknown()
func (*MsgUpdateMeasureResponse) XXX_Marshal ¶
func (m *MsgUpdateMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateMeasureResponse) XXX_Merge ¶
func (m *MsgUpdateMeasureResponse) XXX_Merge(src proto.Message)
func (*MsgUpdateMeasureResponse) XXX_Size ¶
func (m *MsgUpdateMeasureResponse) XXX_Size() int
func (*MsgUpdateMeasureResponse) XXX_Unmarshal ¶
func (m *MsgUpdateMeasureResponse) XXX_Unmarshal(b []byte) error
type MsgUpdateTimeseries ¶
type MsgUpdateTimeseries struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Location string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"` Signal string `protobuf:"bytes,4,opt,name=signal,proto3" json:"signal,omitempty"` }
func NewMsgUpdateTimeseries ¶
func NewMsgUpdateTimeseries(creator string, id uint64, location string, signal string) *MsgUpdateTimeseries
func (*MsgUpdateTimeseries) Descriptor ¶
func (*MsgUpdateTimeseries) Descriptor() ([]byte, []int)
func (*MsgUpdateTimeseries) GetCreator ¶
func (m *MsgUpdateTimeseries) GetCreator() string
func (*MsgUpdateTimeseries) GetId ¶
func (m *MsgUpdateTimeseries) GetId() uint64
func (*MsgUpdateTimeseries) GetLocation ¶
func (m *MsgUpdateTimeseries) GetLocation() string
func (*MsgUpdateTimeseries) GetSignBytes ¶
func (msg *MsgUpdateTimeseries) GetSignBytes() []byte
func (*MsgUpdateTimeseries) GetSignal ¶
func (m *MsgUpdateTimeseries) GetSignal() string
func (*MsgUpdateTimeseries) GetSigners ¶
func (msg *MsgUpdateTimeseries) GetSigners() []sdk.AccAddress
func (*MsgUpdateTimeseries) Marshal ¶
func (m *MsgUpdateTimeseries) Marshal() (dAtA []byte, err error)
func (*MsgUpdateTimeseries) MarshalTo ¶
func (m *MsgUpdateTimeseries) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateTimeseries) MarshalToSizedBuffer ¶
func (m *MsgUpdateTimeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateTimeseries) ProtoMessage ¶
func (*MsgUpdateTimeseries) ProtoMessage()
func (*MsgUpdateTimeseries) Reset ¶
func (m *MsgUpdateTimeseries) Reset()
func (*MsgUpdateTimeseries) Route ¶
func (msg *MsgUpdateTimeseries) Route() string
func (*MsgUpdateTimeseries) Size ¶
func (m *MsgUpdateTimeseries) Size() (n int)
func (*MsgUpdateTimeseries) String ¶
func (m *MsgUpdateTimeseries) String() string
func (*MsgUpdateTimeseries) Type ¶
func (msg *MsgUpdateTimeseries) Type() string
func (*MsgUpdateTimeseries) Unmarshal ¶
func (m *MsgUpdateTimeseries) Unmarshal(dAtA []byte) error
func (*MsgUpdateTimeseries) ValidateBasic ¶
func (msg *MsgUpdateTimeseries) ValidateBasic() error
func (*MsgUpdateTimeseries) XXX_DiscardUnknown ¶
func (m *MsgUpdateTimeseries) XXX_DiscardUnknown()
func (*MsgUpdateTimeseries) XXX_Marshal ¶
func (m *MsgUpdateTimeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateTimeseries) XXX_Merge ¶
func (m *MsgUpdateTimeseries) XXX_Merge(src proto.Message)
func (*MsgUpdateTimeseries) XXX_Size ¶
func (m *MsgUpdateTimeseries) XXX_Size() int
func (*MsgUpdateTimeseries) XXX_Unmarshal ¶
func (m *MsgUpdateTimeseries) XXX_Unmarshal(b []byte) error
type MsgUpdateTimeseriesResponse ¶
type MsgUpdateTimeseriesResponse struct { }
func (*MsgUpdateTimeseriesResponse) Descriptor ¶
func (*MsgUpdateTimeseriesResponse) Descriptor() ([]byte, []int)
func (*MsgUpdateTimeseriesResponse) Marshal ¶
func (m *MsgUpdateTimeseriesResponse) Marshal() (dAtA []byte, err error)
func (*MsgUpdateTimeseriesResponse) MarshalTo ¶
func (m *MsgUpdateTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateTimeseriesResponse) MarshalToSizedBuffer ¶
func (m *MsgUpdateTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateTimeseriesResponse) ProtoMessage ¶
func (*MsgUpdateTimeseriesResponse) ProtoMessage()
func (*MsgUpdateTimeseriesResponse) Reset ¶
func (m *MsgUpdateTimeseriesResponse) Reset()
func (*MsgUpdateTimeseriesResponse) Size ¶
func (m *MsgUpdateTimeseriesResponse) Size() (n int)
func (*MsgUpdateTimeseriesResponse) String ¶
func (m *MsgUpdateTimeseriesResponse) String() string
func (*MsgUpdateTimeseriesResponse) Unmarshal ¶
func (m *MsgUpdateTimeseriesResponse) Unmarshal(dAtA []byte) error
func (*MsgUpdateTimeseriesResponse) XXX_DiscardUnknown ¶
func (m *MsgUpdateTimeseriesResponse) XXX_DiscardUnknown()
func (*MsgUpdateTimeseriesResponse) XXX_Marshal ¶
func (m *MsgUpdateTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateTimeseriesResponse) XXX_Merge ¶
func (m *MsgUpdateTimeseriesResponse) XXX_Merge(src proto.Message)
func (*MsgUpdateTimeseriesResponse) XXX_Size ¶
func (m *MsgUpdateTimeseriesResponse) XXX_Size() int
func (*MsgUpdateTimeseriesResponse) XXX_Unmarshal ¶
func (m *MsgUpdateTimeseriesResponse) XXX_Unmarshal(b []byte) error
type QueryAllMeasureRequest ¶
type QueryAllMeasureRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryAllMeasureRequest) Descriptor ¶
func (*QueryAllMeasureRequest) Descriptor() ([]byte, []int)
func (*QueryAllMeasureRequest) GetPagination ¶
func (m *QueryAllMeasureRequest) GetPagination() *query.PageRequest
func (*QueryAllMeasureRequest) Marshal ¶
func (m *QueryAllMeasureRequest) Marshal() (dAtA []byte, err error)
func (*QueryAllMeasureRequest) MarshalTo ¶
func (m *QueryAllMeasureRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllMeasureRequest) MarshalToSizedBuffer ¶
func (m *QueryAllMeasureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllMeasureRequest) ProtoMessage ¶
func (*QueryAllMeasureRequest) ProtoMessage()
func (*QueryAllMeasureRequest) Reset ¶
func (m *QueryAllMeasureRequest) Reset()
func (*QueryAllMeasureRequest) Size ¶
func (m *QueryAllMeasureRequest) Size() (n int)
func (*QueryAllMeasureRequest) String ¶
func (m *QueryAllMeasureRequest) String() string
func (*QueryAllMeasureRequest) Unmarshal ¶
func (m *QueryAllMeasureRequest) Unmarshal(dAtA []byte) error
func (*QueryAllMeasureRequest) XXX_DiscardUnknown ¶
func (m *QueryAllMeasureRequest) XXX_DiscardUnknown()
func (*QueryAllMeasureRequest) XXX_Marshal ¶
func (m *QueryAllMeasureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllMeasureRequest) XXX_Merge ¶
func (m *QueryAllMeasureRequest) XXX_Merge(src proto.Message)
func (*QueryAllMeasureRequest) XXX_Size ¶
func (m *QueryAllMeasureRequest) XXX_Size() int
func (*QueryAllMeasureRequest) XXX_Unmarshal ¶
func (m *QueryAllMeasureRequest) XXX_Unmarshal(b []byte) error
type QueryAllMeasureResponse ¶
type QueryAllMeasureResponse struct { Measure []Measure `protobuf:"bytes,1,rep,name=Measure,proto3" json:"Measure"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryAllMeasureResponse) Descriptor ¶
func (*QueryAllMeasureResponse) Descriptor() ([]byte, []int)
func (*QueryAllMeasureResponse) GetMeasure ¶
func (m *QueryAllMeasureResponse) GetMeasure() []Measure
func (*QueryAllMeasureResponse) GetPagination ¶
func (m *QueryAllMeasureResponse) GetPagination() *query.PageResponse
func (*QueryAllMeasureResponse) Marshal ¶
func (m *QueryAllMeasureResponse) Marshal() (dAtA []byte, err error)
func (*QueryAllMeasureResponse) MarshalTo ¶
func (m *QueryAllMeasureResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllMeasureResponse) MarshalToSizedBuffer ¶
func (m *QueryAllMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllMeasureResponse) ProtoMessage ¶
func (*QueryAllMeasureResponse) ProtoMessage()
func (*QueryAllMeasureResponse) Reset ¶
func (m *QueryAllMeasureResponse) Reset()
func (*QueryAllMeasureResponse) Size ¶
func (m *QueryAllMeasureResponse) Size() (n int)
func (*QueryAllMeasureResponse) String ¶
func (m *QueryAllMeasureResponse) String() string
func (*QueryAllMeasureResponse) Unmarshal ¶
func (m *QueryAllMeasureResponse) Unmarshal(dAtA []byte) error
func (*QueryAllMeasureResponse) XXX_DiscardUnknown ¶
func (m *QueryAllMeasureResponse) XXX_DiscardUnknown()
func (*QueryAllMeasureResponse) XXX_Marshal ¶
func (m *QueryAllMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllMeasureResponse) XXX_Merge ¶
func (m *QueryAllMeasureResponse) XXX_Merge(src proto.Message)
func (*QueryAllMeasureResponse) XXX_Size ¶
func (m *QueryAllMeasureResponse) XXX_Size() int
func (*QueryAllMeasureResponse) XXX_Unmarshal ¶
func (m *QueryAllMeasureResponse) XXX_Unmarshal(b []byte) error
type QueryAllTimeseriesRequest ¶
type QueryAllTimeseriesRequest struct {
Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}
func (*QueryAllTimeseriesRequest) Descriptor ¶
func (*QueryAllTimeseriesRequest) Descriptor() ([]byte, []int)
func (*QueryAllTimeseriesRequest) GetPagination ¶
func (m *QueryAllTimeseriesRequest) GetPagination() *query.PageRequest
func (*QueryAllTimeseriesRequest) Marshal ¶
func (m *QueryAllTimeseriesRequest) Marshal() (dAtA []byte, err error)
func (*QueryAllTimeseriesRequest) MarshalTo ¶
func (m *QueryAllTimeseriesRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllTimeseriesRequest) MarshalToSizedBuffer ¶
func (m *QueryAllTimeseriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllTimeseriesRequest) ProtoMessage ¶
func (*QueryAllTimeseriesRequest) ProtoMessage()
func (*QueryAllTimeseriesRequest) Reset ¶
func (m *QueryAllTimeseriesRequest) Reset()
func (*QueryAllTimeseriesRequest) Size ¶
func (m *QueryAllTimeseriesRequest) Size() (n int)
func (*QueryAllTimeseriesRequest) String ¶
func (m *QueryAllTimeseriesRequest) String() string
func (*QueryAllTimeseriesRequest) Unmarshal ¶
func (m *QueryAllTimeseriesRequest) Unmarshal(dAtA []byte) error
func (*QueryAllTimeseriesRequest) XXX_DiscardUnknown ¶
func (m *QueryAllTimeseriesRequest) XXX_DiscardUnknown()
func (*QueryAllTimeseriesRequest) XXX_Marshal ¶
func (m *QueryAllTimeseriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllTimeseriesRequest) XXX_Merge ¶
func (m *QueryAllTimeseriesRequest) XXX_Merge(src proto.Message)
func (*QueryAllTimeseriesRequest) XXX_Size ¶
func (m *QueryAllTimeseriesRequest) XXX_Size() int
func (*QueryAllTimeseriesRequest) XXX_Unmarshal ¶
func (m *QueryAllTimeseriesRequest) XXX_Unmarshal(b []byte) error
type QueryAllTimeseriesResponse ¶
type QueryAllTimeseriesResponse struct { Timeseries []Timeseries `protobuf:"bytes,1,rep,name=Timeseries,proto3" json:"Timeseries"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryAllTimeseriesResponse) Descriptor ¶
func (*QueryAllTimeseriesResponse) Descriptor() ([]byte, []int)
func (*QueryAllTimeseriesResponse) GetPagination ¶
func (m *QueryAllTimeseriesResponse) GetPagination() *query.PageResponse
func (*QueryAllTimeseriesResponse) GetTimeseries ¶
func (m *QueryAllTimeseriesResponse) GetTimeseries() []Timeseries
func (*QueryAllTimeseriesResponse) Marshal ¶
func (m *QueryAllTimeseriesResponse) Marshal() (dAtA []byte, err error)
func (*QueryAllTimeseriesResponse) MarshalTo ¶
func (m *QueryAllTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllTimeseriesResponse) MarshalToSizedBuffer ¶
func (m *QueryAllTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllTimeseriesResponse) ProtoMessage ¶
func (*QueryAllTimeseriesResponse) ProtoMessage()
func (*QueryAllTimeseriesResponse) Reset ¶
func (m *QueryAllTimeseriesResponse) Reset()
func (*QueryAllTimeseriesResponse) Size ¶
func (m *QueryAllTimeseriesResponse) Size() (n int)
func (*QueryAllTimeseriesResponse) String ¶
func (m *QueryAllTimeseriesResponse) String() string
func (*QueryAllTimeseriesResponse) Unmarshal ¶
func (m *QueryAllTimeseriesResponse) Unmarshal(dAtA []byte) error
func (*QueryAllTimeseriesResponse) XXX_DiscardUnknown ¶
func (m *QueryAllTimeseriesResponse) XXX_DiscardUnknown()
func (*QueryAllTimeseriesResponse) XXX_Marshal ¶
func (m *QueryAllTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllTimeseriesResponse) XXX_Merge ¶
func (m *QueryAllTimeseriesResponse) XXX_Merge(src proto.Message)
func (*QueryAllTimeseriesResponse) XXX_Size ¶
func (m *QueryAllTimeseriesResponse) XXX_Size() int
func (*QueryAllTimeseriesResponse) XXX_Unmarshal ¶
func (m *QueryAllTimeseriesResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Queries a timeseries by id. Timeseries(ctx context.Context, in *QueryGetTimeseriesRequest, opts ...grpc.CallOption) (*QueryGetTimeseriesResponse, error) // Queries a list of timeseries items. TimeseriesAll(ctx context.Context, in *QueryAllTimeseriesRequest, opts ...grpc.CallOption) (*QueryAllTimeseriesResponse, error) // Queries a measure by id. Measure(ctx context.Context, in *QueryGetMeasureRequest, opts ...grpc.CallOption) (*QueryGetMeasureResponse, error) // Queries a list of measure items. MeasureAll(ctx context.Context, in *QueryAllMeasureRequest, opts ...grpc.CallOption) (*QueryAllMeasureResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryGetMeasureRequest ¶
type QueryGetMeasureRequest struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*QueryGetMeasureRequest) Descriptor ¶
func (*QueryGetMeasureRequest) Descriptor() ([]byte, []int)
func (*QueryGetMeasureRequest) GetId ¶
func (m *QueryGetMeasureRequest) GetId() uint64
func (*QueryGetMeasureRequest) Marshal ¶
func (m *QueryGetMeasureRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetMeasureRequest) MarshalTo ¶
func (m *QueryGetMeasureRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetMeasureRequest) MarshalToSizedBuffer ¶
func (m *QueryGetMeasureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetMeasureRequest) ProtoMessage ¶
func (*QueryGetMeasureRequest) ProtoMessage()
func (*QueryGetMeasureRequest) Reset ¶
func (m *QueryGetMeasureRequest) Reset()
func (*QueryGetMeasureRequest) Size ¶
func (m *QueryGetMeasureRequest) Size() (n int)
func (*QueryGetMeasureRequest) String ¶
func (m *QueryGetMeasureRequest) String() string
func (*QueryGetMeasureRequest) Unmarshal ¶
func (m *QueryGetMeasureRequest) Unmarshal(dAtA []byte) error
func (*QueryGetMeasureRequest) XXX_DiscardUnknown ¶
func (m *QueryGetMeasureRequest) XXX_DiscardUnknown()
func (*QueryGetMeasureRequest) XXX_Marshal ¶
func (m *QueryGetMeasureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetMeasureRequest) XXX_Merge ¶
func (m *QueryGetMeasureRequest) XXX_Merge(src proto.Message)
func (*QueryGetMeasureRequest) XXX_Size ¶
func (m *QueryGetMeasureRequest) XXX_Size() int
func (*QueryGetMeasureRequest) XXX_Unmarshal ¶
func (m *QueryGetMeasureRequest) XXX_Unmarshal(b []byte) error
type QueryGetMeasureResponse ¶
type QueryGetMeasureResponse struct {
Measure Measure `protobuf:"bytes,1,opt,name=Measure,proto3" json:"Measure"`
}
func (*QueryGetMeasureResponse) Descriptor ¶
func (*QueryGetMeasureResponse) Descriptor() ([]byte, []int)
func (*QueryGetMeasureResponse) GetMeasure ¶
func (m *QueryGetMeasureResponse) GetMeasure() Measure
func (*QueryGetMeasureResponse) Marshal ¶
func (m *QueryGetMeasureResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetMeasureResponse) MarshalTo ¶
func (m *QueryGetMeasureResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetMeasureResponse) MarshalToSizedBuffer ¶
func (m *QueryGetMeasureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetMeasureResponse) ProtoMessage ¶
func (*QueryGetMeasureResponse) ProtoMessage()
func (*QueryGetMeasureResponse) Reset ¶
func (m *QueryGetMeasureResponse) Reset()
func (*QueryGetMeasureResponse) Size ¶
func (m *QueryGetMeasureResponse) Size() (n int)
func (*QueryGetMeasureResponse) String ¶
func (m *QueryGetMeasureResponse) String() string
func (*QueryGetMeasureResponse) Unmarshal ¶
func (m *QueryGetMeasureResponse) Unmarshal(dAtA []byte) error
func (*QueryGetMeasureResponse) XXX_DiscardUnknown ¶
func (m *QueryGetMeasureResponse) XXX_DiscardUnknown()
func (*QueryGetMeasureResponse) XXX_Marshal ¶
func (m *QueryGetMeasureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetMeasureResponse) XXX_Merge ¶
func (m *QueryGetMeasureResponse) XXX_Merge(src proto.Message)
func (*QueryGetMeasureResponse) XXX_Size ¶
func (m *QueryGetMeasureResponse) XXX_Size() int
func (*QueryGetMeasureResponse) XXX_Unmarshal ¶
func (m *QueryGetMeasureResponse) XXX_Unmarshal(b []byte) error
type QueryGetTimeseriesRequest ¶
type QueryGetTimeseriesRequest struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*QueryGetTimeseriesRequest) Descriptor ¶
func (*QueryGetTimeseriesRequest) Descriptor() ([]byte, []int)
func (*QueryGetTimeseriesRequest) GetId ¶
func (m *QueryGetTimeseriesRequest) GetId() uint64
func (*QueryGetTimeseriesRequest) Marshal ¶
func (m *QueryGetTimeseriesRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetTimeseriesRequest) MarshalTo ¶
func (m *QueryGetTimeseriesRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetTimeseriesRequest) MarshalToSizedBuffer ¶
func (m *QueryGetTimeseriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetTimeseriesRequest) ProtoMessage ¶
func (*QueryGetTimeseriesRequest) ProtoMessage()
func (*QueryGetTimeseriesRequest) Reset ¶
func (m *QueryGetTimeseriesRequest) Reset()
func (*QueryGetTimeseriesRequest) Size ¶
func (m *QueryGetTimeseriesRequest) Size() (n int)
func (*QueryGetTimeseriesRequest) String ¶
func (m *QueryGetTimeseriesRequest) String() string
func (*QueryGetTimeseriesRequest) Unmarshal ¶
func (m *QueryGetTimeseriesRequest) Unmarshal(dAtA []byte) error
func (*QueryGetTimeseriesRequest) XXX_DiscardUnknown ¶
func (m *QueryGetTimeseriesRequest) XXX_DiscardUnknown()
func (*QueryGetTimeseriesRequest) XXX_Marshal ¶
func (m *QueryGetTimeseriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetTimeseriesRequest) XXX_Merge ¶
func (m *QueryGetTimeseriesRequest) XXX_Merge(src proto.Message)
func (*QueryGetTimeseriesRequest) XXX_Size ¶
func (m *QueryGetTimeseriesRequest) XXX_Size() int
func (*QueryGetTimeseriesRequest) XXX_Unmarshal ¶
func (m *QueryGetTimeseriesRequest) XXX_Unmarshal(b []byte) error
type QueryGetTimeseriesResponse ¶
type QueryGetTimeseriesResponse struct {
Timeseries Timeseries `protobuf:"bytes,1,opt,name=Timeseries,proto3" json:"Timeseries"`
}
func (*QueryGetTimeseriesResponse) Descriptor ¶
func (*QueryGetTimeseriesResponse) Descriptor() ([]byte, []int)
func (*QueryGetTimeseriesResponse) GetTimeseries ¶
func (m *QueryGetTimeseriesResponse) GetTimeseries() Timeseries
func (*QueryGetTimeseriesResponse) Marshal ¶
func (m *QueryGetTimeseriesResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetTimeseriesResponse) MarshalTo ¶
func (m *QueryGetTimeseriesResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetTimeseriesResponse) MarshalToSizedBuffer ¶
func (m *QueryGetTimeseriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetTimeseriesResponse) ProtoMessage ¶
func (*QueryGetTimeseriesResponse) ProtoMessage()
func (*QueryGetTimeseriesResponse) Reset ¶
func (m *QueryGetTimeseriesResponse) Reset()
func (*QueryGetTimeseriesResponse) Size ¶
func (m *QueryGetTimeseriesResponse) Size() (n int)
func (*QueryGetTimeseriesResponse) String ¶
func (m *QueryGetTimeseriesResponse) String() string
func (*QueryGetTimeseriesResponse) Unmarshal ¶
func (m *QueryGetTimeseriesResponse) Unmarshal(dAtA []byte) error
func (*QueryGetTimeseriesResponse) XXX_DiscardUnknown ¶
func (m *QueryGetTimeseriesResponse) XXX_DiscardUnknown()
func (*QueryGetTimeseriesResponse) XXX_Marshal ¶
func (m *QueryGetTimeseriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetTimeseriesResponse) XXX_Merge ¶
func (m *QueryGetTimeseriesResponse) XXX_Merge(src proto.Message)
func (*QueryGetTimeseriesResponse) XXX_Size ¶
func (m *QueryGetTimeseriesResponse) XXX_Size() int
func (*QueryGetTimeseriesResponse) XXX_Unmarshal ¶
func (m *QueryGetTimeseriesResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Queries a timeseries by id. Timeseries(context.Context, *QueryGetTimeseriesRequest) (*QueryGetTimeseriesResponse, error) // Queries a list of timeseries items. TimeseriesAll(context.Context, *QueryAllTimeseriesRequest) (*QueryAllTimeseriesResponse, error) // Queries a measure by id. Measure(context.Context, *QueryGetMeasureRequest) (*QueryGetMeasureResponse, error) // Queries a list of measure items. MeasureAll(context.Context, *QueryAllMeasureRequest) (*QueryAllMeasureResponse, error) }
QueryServer is the server API for Query service.
type Timeseries ¶
type Timeseries struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Location string `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` Signal string `protobuf:"bytes,3,opt,name=signal,proto3" json:"signal,omitempty"` Creator string `protobuf:"bytes,4,opt,name=creator,proto3" json:"creator,omitempty"` }
func (*Timeseries) Descriptor ¶
func (*Timeseries) Descriptor() ([]byte, []int)
func (*Timeseries) GetCreator ¶
func (m *Timeseries) GetCreator() string
func (*Timeseries) GetId ¶
func (m *Timeseries) GetId() uint64
func (*Timeseries) GetLocation ¶
func (m *Timeseries) GetLocation() string
func (*Timeseries) GetSignal ¶
func (m *Timeseries) GetSignal() string
func (*Timeseries) Marshal ¶
func (m *Timeseries) Marshal() (dAtA []byte, err error)
func (*Timeseries) MarshalToSizedBuffer ¶
func (m *Timeseries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Timeseries) ProtoMessage ¶
func (*Timeseries) ProtoMessage()
func (*Timeseries) Reset ¶
func (m *Timeseries) Reset()
func (*Timeseries) Size ¶
func (m *Timeseries) Size() (n int)
func (*Timeseries) String ¶
func (m *Timeseries) String() string
func (*Timeseries) Unmarshal ¶
func (m *Timeseries) Unmarshal(dAtA []byte) error
func (*Timeseries) XXX_DiscardUnknown ¶
func (m *Timeseries) XXX_DiscardUnknown()
func (*Timeseries) XXX_Marshal ¶
func (m *Timeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Timeseries) XXX_Merge ¶
func (m *Timeseries) XXX_Merge(src proto.Message)
func (*Timeseries) XXX_Size ¶
func (m *Timeseries) XXX_Size() int
func (*Timeseries) XXX_Unmarshal ¶
func (m *Timeseries) XXX_Unmarshal(b []byte) error
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) CreateMeasure ¶
func (*UnimplementedMsgServer) CreateMeasure(ctx context.Context, req *MsgCreateMeasure) (*MsgCreateMeasureResponse, error)
func (*UnimplementedMsgServer) CreateTimeseries ¶
func (*UnimplementedMsgServer) CreateTimeseries(ctx context.Context, req *MsgCreateTimeseries) (*MsgCreateTimeseriesResponse, error)
func (*UnimplementedMsgServer) DeleteMeasure ¶
func (*UnimplementedMsgServer) DeleteMeasure(ctx context.Context, req *MsgDeleteMeasure) (*MsgDeleteMeasureResponse, error)
func (*UnimplementedMsgServer) DeleteTimeseries ¶
func (*UnimplementedMsgServer) DeleteTimeseries(ctx context.Context, req *MsgDeleteTimeseries) (*MsgDeleteTimeseriesResponse, error)
func (*UnimplementedMsgServer) UpdateMeasure ¶
func (*UnimplementedMsgServer) UpdateMeasure(ctx context.Context, req *MsgUpdateMeasure) (*MsgUpdateMeasureResponse, error)
func (*UnimplementedMsgServer) UpdateTimeseries ¶
func (*UnimplementedMsgServer) UpdateTimeseries(ctx context.Context, req *MsgUpdateTimeseries) (*MsgUpdateTimeseriesResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Measure ¶
func (*UnimplementedQueryServer) Measure(ctx context.Context, req *QueryGetMeasureRequest) (*QueryGetMeasureResponse, error)
func (*UnimplementedQueryServer) MeasureAll ¶
func (*UnimplementedQueryServer) MeasureAll(ctx context.Context, req *QueryAllMeasureRequest) (*QueryAllMeasureResponse, error)
func (*UnimplementedQueryServer) Timeseries ¶
func (*UnimplementedQueryServer) Timeseries(ctx context.Context, req *QueryGetTimeseriesRequest) (*QueryGetTimeseriesResponse, error)
func (*UnimplementedQueryServer) TimeseriesAll ¶
func (*UnimplementedQueryServer) TimeseriesAll(ctx context.Context, req *QueryAllTimeseriesRequest) (*QueryAllTimeseriesResponse, error)