Skip to content
GitLab
Projects
Groups
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Register
Sign in
Toggle navigation
Menu
Open sidebar
Tiger Ton
osmosis
Commits
4bbd3fb4
Unverified
Commit
4bbd3fb4
authored
2 years ago
by
Dev Ojha
Committed by
GitHub
2 years ago
Browse files
Options
Download
Email Patches
Plain Diff
Add TWAP params queries (#2678)
parent
85beb4f5
Changes
6
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
proto/osmosis/twap/v1beta1/query.proto
+7
-0
proto/osmosis/twap/v1beta1/query.proto
proto/osmosis/twap/v1beta1/query.yml
+5
-0
proto/osmosis/twap/v1beta1/query.yml
x/twap/client/grpc/grpc_query.go
+9
-0
x/twap/client/grpc/grpc_query.go
x/twap/client/query_proto_wrap.go
+7
-0
x/twap/client/query_proto_wrap.go
x/twap/client/queryproto/query.pb.go
+372
-40
x/twap/client/queryproto/query.pb.go
x/twap/client/queryproto/query.pb.gw.go
+65
-0
x/twap/client/queryproto/query.pb.gw.go
with
465 additions
and
40 deletions
+465
-40
proto/osmosis/twap/v1beta1/query.proto
+
7
-
0
View file @
4bbd3fb4
...
...
@@ -3,6 +3,7 @@ package osmosis.twap.v1beta1;
import
"gogoproto/gogo.proto"
;
import
"osmosis/twap/v1beta1/twap_record.proto"
;
import
"osmosis/twap/v1beta1/genesis.proto"
;
import
"cosmos/base/v1beta1/coin.proto"
;
import
"cosmos/base/query/v1beta1/pagination.proto"
;
...
...
@@ -14,6 +15,9 @@ import "google/protobuf/timestamp.proto";
option
go_package
=
"github.com/osmosis-labs/osmosis/v12/x/twap/client/queryproto"
;
service
Query
{
rpc
Params
(
ParamsRequest
)
returns
(
ParamsResponse
)
{
option
(
google.api.http
)
.
get
=
"/osmosis/twap/v1beta1/Params"
;
}
rpc
GetArithmeticTwap
(
GetArithmeticTwapRequest
)
returns
(
GetArithmeticTwapResponse
)
{
option
(
google.api.http
)
.
get
=
"/osmosis/twap/v1beta1/GetArithmeticTwap"
;
...
...
@@ -65,3 +69,6 @@ message GetArithmeticTwapToNowResponse {
(
gogoproto.nullable
)
=
false
];
}
message
ParamsRequest
{}
message
ParamsResponse
{
Params
params
=
1
[
(
gogoproto.nullable
)
=
false
];
}
This diff is collapsed.
Click to expand it.
proto/osmosis/twap/v1beta1/query.yml
+
5
-
0
View file @
4bbd3fb4
...
...
@@ -13,5 +13,10 @@ queries:
GetArithmeticTwapToNow
:
proto_wrapper
:
query_func
:
"
k.GetArithmeticTwapToNow"
cli
:
cmd
:
"
GetArithmeticTwapToNow"
Params
:
proto_wrapper
:
query_func
:
"
k.GetParams"
cli
:
cmd
:
"
GetArithmeticTwapToNow"
\ No newline at end of file
This diff is collapsed.
Click to expand it.
x/twap/client/grpc/grpc_query.go
+
9
-
0
View file @
4bbd3fb4
...
...
@@ -38,3 +38,12 @@ func (q Querier) GetArithmeticTwapToNow(grpcCtx context.Context,
ctx
:=
sdk
.
UnwrapSDKContext
(
grpcCtx
)
return
q
.
Q
.
GetArithmeticTwapToNow
(
ctx
,
*
req
)
}
func
(
q
Querier
)
Params
(
grpcCtx
context
.
Context
,
req
*
queryproto
.
ParamsRequest
,
)
(
*
queryproto
.
ParamsResponse
,
error
)
{
if
req
==
nil
{
return
nil
,
status
.
Error
(
codes
.
InvalidArgument
,
"empty request"
)
}
ctx
:=
sdk
.
UnwrapSDKContext
(
grpcCtx
)
return
q
.
Q
.
Params
(
ctx
,
*
req
)
}
This diff is collapsed.
Click to expand it.
x/twap/client/query_proto_wrap.go
+
7
-
0
View file @
4bbd3fb4
...
...
@@ -32,3 +32,10 @@ func (q Querier) GetArithmeticTwapToNow(ctx sdk.Context,
twap
,
err
:=
q
.
K
.
GetArithmeticTwapToNow
(
ctx
,
req
.
PoolId
,
req
.
BaseAsset
,
req
.
QuoteAsset
,
req
.
StartTime
)
return
&
queryproto
.
GetArithmeticTwapToNowResponse
{
ArithmeticTwap
:
twap
},
err
}
func
(
q
Querier
)
Params
(
ctx
sdk
.
Context
,
req
queryproto
.
ParamsRequest
,
)
(
*
queryproto
.
ParamsResponse
,
error
)
{
params
:=
q
.
K
.
GetParams
(
ctx
)
return
&
queryproto
.
ParamsResponse
{
Params
:
params
},
nil
}
This diff is collapsed.
Click to expand it.
x/twap/client/queryproto/query.pb.go
+
372
-
40
View file @
4bbd3fb4
...
...
@@ -16,7 +16,7 @@ import (
proto
"github.com/gogo/protobuf/proto"
_
"github.com/gogo/protobuf/types"
github_com_gogo_protobuf_types
"github.com/gogo/protobuf/types"
_
"github.com/osmosis-labs/osmosis/v12/x/twap/types"
types1
"github.com/osmosis-labs/osmosis/v12/x/twap/types"
_
"google.golang.org/genproto/googleapis/api/annotations"
grpc
"google.golang.org/grpc"
codes
"google.golang.org/grpc/codes"
...
...
@@ -257,55 +257,142 @@ func (m *GetArithmeticTwapToNowResponse) XXX_DiscardUnknown() {
var
xxx_messageInfo_GetArithmeticTwapToNowResponse
proto
.
InternalMessageInfo
type
ParamsRequest
struct
{
}
func
(
m
*
ParamsRequest
)
Reset
()
{
*
m
=
ParamsRequest
{}
}
func
(
m
*
ParamsRequest
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
ParamsRequest
)
ProtoMessage
()
{}
func
(
*
ParamsRequest
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_141a22dba58615af
,
[]
int
{
4
}
}
func
(
m
*
ParamsRequest
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
return
m
.
Unmarshal
(
b
)
}
func
(
m
*
ParamsRequest
)
XXX_Marshal
(
b
[]
byte
,
deterministic
bool
)
([]
byte
,
error
)
{
if
deterministic
{
return
xxx_messageInfo_ParamsRequest
.
Marshal
(
b
,
m
,
deterministic
)
}
else
{
b
=
b
[
:
cap
(
b
)]
n
,
err
:=
m
.
MarshalToSizedBuffer
(
b
)
if
err
!=
nil
{
return
nil
,
err
}
return
b
[
:
n
],
nil
}
}
func
(
m
*
ParamsRequest
)
XXX_Merge
(
src
proto
.
Message
)
{
xxx_messageInfo_ParamsRequest
.
Merge
(
m
,
src
)
}
func
(
m
*
ParamsRequest
)
XXX_Size
()
int
{
return
m
.
Size
()
}
func
(
m
*
ParamsRequest
)
XXX_DiscardUnknown
()
{
xxx_messageInfo_ParamsRequest
.
DiscardUnknown
(
m
)
}
var
xxx_messageInfo_ParamsRequest
proto
.
InternalMessageInfo
type
ParamsResponse
struct
{
Params
types1
.
Params
`protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}
func
(
m
*
ParamsResponse
)
Reset
()
{
*
m
=
ParamsResponse
{}
}
func
(
m
*
ParamsResponse
)
String
()
string
{
return
proto
.
CompactTextString
(
m
)
}
func
(
*
ParamsResponse
)
ProtoMessage
()
{}
func
(
*
ParamsResponse
)
Descriptor
()
([]
byte
,
[]
int
)
{
return
fileDescriptor_141a22dba58615af
,
[]
int
{
5
}
}
func
(
m
*
ParamsResponse
)
XXX_Unmarshal
(
b
[]
byte
)
error
{
return
m
.
Unmarshal
(
b
)
}
func
(
m
*
ParamsResponse
)
XXX_Marshal
(
b
[]
byte
,
deterministic
bool
)
([]
byte
,
error
)
{
if
deterministic
{
return
xxx_messageInfo_ParamsResponse
.
Marshal
(
b
,
m
,
deterministic
)
}
else
{
b
=
b
[
:
cap
(
b
)]
n
,
err
:=
m
.
MarshalToSizedBuffer
(
b
)
if
err
!=
nil
{
return
nil
,
err
}
return
b
[
:
n
],
nil
}
}
func
(
m
*
ParamsResponse
)
XXX_Merge
(
src
proto
.
Message
)
{
xxx_messageInfo_ParamsResponse
.
Merge
(
m
,
src
)
}
func
(
m
*
ParamsResponse
)
XXX_Size
()
int
{
return
m
.
Size
()
}
func
(
m
*
ParamsResponse
)
XXX_DiscardUnknown
()
{
xxx_messageInfo_ParamsResponse
.
DiscardUnknown
(
m
)
}
var
xxx_messageInfo_ParamsResponse
proto
.
InternalMessageInfo
func
(
m
*
ParamsResponse
)
GetParams
()
types1
.
Params
{
if
m
!=
nil
{
return
m
.
Params
}
return
types1
.
Params
{}
}
func
init
()
{
proto
.
RegisterType
((
*
GetArithmeticTwapRequest
)(
nil
),
"osmosis.twap.v1beta1.GetArithmeticTwapRequest"
)
proto
.
RegisterType
((
*
GetArithmeticTwapResponse
)(
nil
),
"osmosis.twap.v1beta1.GetArithmeticTwapResponse"
)
proto
.
RegisterType
((
*
GetArithmeticTwapToNowRequest
)(
nil
),
"osmosis.twap.v1beta1.GetArithmeticTwapToNowRequest"
)
proto
.
RegisterType
((
*
GetArithmeticTwapToNowResponse
)(
nil
),
"osmosis.twap.v1beta1.GetArithmeticTwapToNowResponse"
)
proto
.
RegisterType
((
*
ParamsRequest
)(
nil
),
"osmosis.twap.v1beta1.ParamsRequest"
)
proto
.
RegisterType
((
*
ParamsResponse
)(
nil
),
"osmosis.twap.v1beta1.ParamsResponse"
)
}
func
init
()
{
proto
.
RegisterFile
(
"osmosis/twap/v1beta1/query.proto"
,
fileDescriptor_141a22dba58615af
)
}
var
fileDescriptor_141a22dba58615af
=
[]
byte
{
// 601 bytes of a gzipped FileDescriptorProto
0x1f
,
0x8b
,
0x08
,
0x00
,
0x00
,
0x00
,
0x00
,
0x00
,
0x02
,
0xff
,
0xd4
,
0x54
,
0xcb
,
0x6e
,
0xd3
,
0x40
,
0x14
,
0xcd
,
0x84
,
0x3e
,
0xc8
,
0x54
,
0xa2
,
0xaa
,
0x55
,
0x95
,
0x34
,
0x50
,
0x3b
,
0xf2
,
0xa2
,
0x14
,
0x44
,
0x67
,
0xd4
,
0xc7
,
0x0a
,
0xb1
,
0x69
,
0x85
,
0x04
,
0x6c
,
0x90
,
0xb0
,
0x2a
,
0x84
,
0xd8
,
0x58
,
0x13
,
0x7b
,
0x70
,
0x2d
,
0x62
,
0x8f
,
0xe3
,
0x99
,
0x34
,
0x64
,
0xcb
,
0x07
,
0xa0
,
0x4a
,
0xfd
,
0x02
,
0x16
,
0x7c
,
0x04
,
0x7f
,
0x90
,
0x65
,
0x05
,
0x1b
,
0xc4
,
0xc2
,
0xa0
,
0x84
,
0x1d
,
0xbb
,
0x7c
,
0x01
,
0x9a
,
0x19
,
0x3b
,
0x84
,
0x26
,
0x15
,
0x61
,
0x85
,
0x58
,
0xd9
,
0x73
,
0xcf
,
0xb9
,
0xe7
,
0x9e
,
0x7b
,
0xe7
,
0x01
,
0xeb
,
0x8c
,
0x47
,
0x8c
,
0x87
,
0x1c
,
0x8b
,
0x0e
,
0x49
,
0xf0
,
0xc9
,
0x4e
,
0x83
,
0x0a
,
0xb2
,
0x83
,
0x5b
,
0x6d
,
0x9a
,
0x76
,
0x51
,
0x92
,
0x32
,
0xc1
,
0x8c
,
0xd5
,
0x9c
,
0x81
,
0x24
,
0x03
,
0xe5
,
0x8c
,
0xda
,
0x6a
,
0xc0
,
0x02
,
0xa6
,
0x08
,
0x58
,
0xfe
,
0x69
,
0x6e
,
0x6d
,
0x73
,
0xaa
,
0x9a
,
0x5c
,
0xb8
,
0x29
,
0xf5
,
0x58
,
0xea
,
0xe7
,
0x3c
,
0xd3
,
0x53
,
0x44
,
0xdc
,
0x20
,
0x9c
,
0x8e
,
0x68
,
0x1e
,
0x0b
,
0xe3
,
0x1c
,
0xbf
,
0x33
,
0x8e
,
0x2b
,
0x33
,
0x23
,
0x56
,
0x42
,
0x82
,
0x30
,
0x26
,
0x22
,
0x64
,
0x05
,
0xf7
,
0x66
,
0xc0
,
0x58
,
0xd0
,
0xa4
,
0x98
,
0x24
,
0x21
,
0x26
,
0x71
,
0xcc
,
0x84
,
0x02
,
0x79
,
0x8e
,
0xae
,
0xe7
,
0xa8
,
0x5a
,
0x35
,
0xda
,
0x2f
,
0x31
,
0x89
,
0xbb
,
0x05
,
0xa4
,
0x8b
,
0xb8
,
0xba
,
0x0b
,
0xbd
,
0xc8
,
0x21
,
0xeb
,
0x62
,
0x96
,
0x08
,
0x23
,
0xca
,
0x05
,
0x89
,
0x12
,
0x4d
,
0xb0
,
0xdf
,
0x95
,
0x61
,
0xf5
,
0x21
,
0x15
,
0x07
,
0x69
,
0x28
,
0x8e
,
0x23
,
0x2a
,
0x42
,
0xef
,
0xa8
,
0x43
,
0x12
,
0x87
,
0xb6
,
0xda
,
0x94
,
0x0b
,
0xe3
,
0x3a
,
0x5c
,
0x4c
,
0x18
,
0x6b
,
0xba
,
0xa1
,
0x5f
,
0x05
,
0x75
,
0xb0
,
0x35
,
0xe7
,
0x2c
,
0xc8
,
0xe5
,
0x63
,
0xdf
,
0xd8
,
0x80
,
0x50
,
0x76
,
0xe4
,
0x12
,
0xce
,
0xa9
,
0xa8
,
0x96
,
0xeb
,
0x60
,
0xab
,
0xe2
,
0x54
,
0x64
,
0xe4
,
0x40
,
0x06
,
0x0c
,
0x0b
,
0x2e
,
0xb5
,
0xda
,
0x4c
,
0x14
,
0xf8
,
0x15
,
0x85
,
0x43
,
0x15
,
0xd2
,
0x84
,
0xe7
,
0x10
,
0x72
,
0x41
,
0x52
,
0xe1
,
0x4a
,
0x3b
,
0xd5
,
0xb9
,
0x3a
,
0xd8
,
0x5a
,
0xda
,
0xad
,
0x21
,
0xed
,
0x15
,
0x15
,
0x5e
,
0xd1
,
0x51
,
0xe1
,
0xf5
,
0x70
,
0xa3
,
0x97
,
0x59
,
0xa5
,
0x61
,
0x66
,
0xad
,
0x74
,
0x49
,
0xd4
,
0xbc
,
0x67
,
0xff
,
0xca
,
0xb5
,
0x4f
,
0xbf
,
0x5a
,
0xc0
,
0xa9
,
0xa8
,
0x80
,
0xa4
,
0x1b
,
0x0e
,
0xbc
,
0x4a
,
0x63
,
0x5f
,
0xeb
,
0xce
,
0xff
,
0x51
,
0xf7
,
0x46
,
0x2f
,
0xb3
,
0xc0
,
0x30
,
0xb3
,
0x96
,
0xb5
,
0x6e
,
0x91
,
0xa9
,
0x55
,
0x17
,
0x69
,
0xec
,
0x4b
,
0xaa
,
0xfd
,
0x16
,
0xc0
,
0xf5
,
0x29
,
0x33
,
0xe2
,
0x09
,
0x8b
,
0x39
,
0x35
,
0x5a
,
0x70
,
0x99
,
0x8c
,
0x10
,
0x57
,
0x1e
,
0x11
,
0x35
,
0xac
,
0xca
,
0xe1
,
0x23
,
0x69
,
0xfa
,
0x4b
,
0x66
,
0x6d
,
0x06
,
0xa1
,
0x38
,
0x6e
,
0x37
,
0x90
,
0xc7
,
0xa2
,
0x7c
,
0x73
,
0xf2
,
0xcf
,
0x36
,
0xf7
,
0x5f
,
0x61
,
0xd1
,
0x4d
,
0x28
,
0x47
,
0x0f
,
0xa8
,
0x37
,
0xcc
,
0xac
,
0x35
,
0x6d
,
0xe3
,
0x82
,
0x9c
,
0xed
,
0x5c
,
0x23
,
0xbf
,
0x95
,
0xb6
,
0x3f
,
0x02
,
0xb8
,
0x31
,
0x61
,
0xe8
,
0x88
,
0x3d
,
0x61
,
0x9d
,
0xff
,
0x77
,
0xe7
,
0xec
,
0x33
,
0x00
,
0xcd
,
0xcb
,
0x9a
,
0xfa
,
0x67
,
0xa3
,
0xde
,
0xfd
,
0x51
,
0x86
,
0xf3
,
0x4f
,
0xe5
,
0xbd
,
0x35
,
0xde
,
0x03
,
0xb8
,
0x32
,
0xe1
,
0xcf
,
0x40
,
0x68
,
0xda
,
0xab
,
0x82
,
0x2e
,
0xbb
,
0x52
,
0x35
,
0x3c
,
0x33
,
0x5f
,
0xf7
,
0x6c
,
0xe3
,
0x37
,
0x9f
,
0xbe
,
0x9f
,
0x95
,
0x6f
,
0x1b
,
0xb7
,
0xf0
,
0xd4
,
0x27
,
0x69
,
0xd2
,
0xd1
,
0x07
,
0x00
,
0xd7
,
0xa6
,
0xcf
,
0xd1
,
0xd8
,
0x9b
,
0xb1
,
0xf8
,
0xf8
,
0x51
,
0xaa
,
0xed
,
0xff
,
0x5d
,
0x52
,
0x6e
,
0x7b
,
0x5f
,
0xd9
,
0x46
,
0xc6
,
0xdd
,
0x19
,
0x6d
,
0xab
,
0xec
,
0xc3
,
0x67
,
0xbd
,
0xbe
,
0x09
,
0xce
,
0xfb
,
0x26
,
0xf8
,
0xd6
,
0x37
,
0xc1
,
0xe9
,
0xc0
,
0x2c
,
0x9d
,
0x0f
,
0xcc
,
0xd2
,
0xe7
,
0x81
,
0x59
,
0x7a
,
0x71
,
0x7f
,
0x6c
,
0x67
,
0x73
,
0xc5
,
0xed
,
0x26
,
0x69
,
0xf0
,
0x91
,
0xfc
,
0xc9
,
0xce
,
0x2e
,
0x7e
,
0xad
,
0x8b
,
0x78
,
0xcd
,
0x90
,
0xc6
,
0x42
,
0x3f
,
0xb7
,
0xfa
,
0x48
,
0x2e
,
0xa8
,
0xcf
,
0xde
,
0xcf
,
0x00
,
0x00
,
0x00
,
0xff
,
0xff
,
0x30
,
0xf4
,
0xe3
,
0xf7
,
0x25
,
0x06
,
0x00
,
0x00
,
// 674 bytes of a gzipped FileDescriptorProto
0x1f
,
0x8b
,
0x08
,
0x00
,
0x00
,
0x00
,
0x00
,
0x00
,
0x02
,
0xff
,
0xd4
,
0x95
,
0xdd
,
0x4e
,
0x13
,
0x41
,
0x14
,
0xc7
,
0x3b
,
0x7c
,
0x14
,
0x3b
,
0x44
,
0x08
,
0x13
,
0x82
,
0xa5
,
0xc2
,
0x6e
,
0xb3
,
0x12
,
0x44
,
0x23
,
0x3b
,
0xa1
,
0x70
,
0x45
,
0xbc
,
0xa1
,
0x31
,
0x51
,
0x13
,
0x63
,
0x74
,
0x43
,
0x8c
,
0xf1
,
0xa6
,
0x99
,
0x6e
,
0xc7
,
0x65
,
0x63
,
0x77
,
0x67
,
0xbb
,
0x33
,
0x05
,
0x7b
,
0xeb
,
0x03
,
0x18
,
0x12
,
0x9e
,
0xc0
,
0x0b
,
0x1f
,
0xc2
,
0x37
,
0xe0
,
0x92
,
0xe8
,
0x8d
,
0xf1
,
0xa2
,
0x1a
,
0x30
,
0x3e
,
0x00
,
0x4f
,
0x60
,
0xe6
,
0x63
,
0x2b
,
0xc2
,
0x82
,
0x78
,
0x65
,
0xbc
,
0xda
,
0xce
,
0xf9
,
0xff
,
0xcf
,
0x39
,
0xbf
,
0x39
,
0x3b
,
0x3b
,
0x85
,
0x55
,
0xc6
,
0x23
,
0xc6
,
0x43
,
0x8e
,
0xc5
,
0x0e
,
0x49
,
0xf0
,
0xf6
,
0x4a
,
0x93
,
0x0a
,
0xb2
,
0x82
,
0x3b
,
0x5d
,
0x9a
,
0xf6
,
0xdc
,
0x24
,
0x65
,
0x82
,
0xa1
,
0x69
,
0xe3
,
0x70
,
0xa5
,
0xc3
,
0x35
,
0x8e
,
0xca
,
0x74
,
0xc0
,
0x02
,
0xa6
,
0x0c
,
0x58
,
0xfe
,
0xd2
,
0xde
,
0xca
,
0x62
,
0x6e
,
0x35
,
0xb9
,
0x68
,
0xa4
,
0xd4
,
0x67
,
0x69
,
0xcb
,
0xf8
,
0x9c
,
0x5c
,
0x5f
,
0x40
,
0x63
,
0x2a
,
0x1b
,
0x69
,
0x8f
,
0xe5
,
0x2b
,
0x13
,
0x6e
,
0x12
,
0x4e
,
0x07
,
0x16
,
0x9f
,
0x85
,
0xb1
,
0xd1
,
0x6f
,
0x9f
,
0xd4
,
0x15
,
0xf0
,
0xc0
,
0x95
,
0x90
,
0x20
,
0x8c
,
0x89
,
0x08
,
0x59
,
0xe6
,
0x9d
,
0x0b
,
0x18
,
0x0b
,
0xda
,
0x14
,
0x93
,
0x24
,
0xc4
,
0x24
,
0x8e
,
0x99
,
0x50
,
0x62
,
0xd6
,
0x69
,
0xd6
,
0xa8
,
0x6a
,
0xd5
,
0xec
,
0xbe
,
0xc4
,
0x24
,
0xee
,
0x65
,
0x92
,
0x6e
,
0xd2
,
0xd0
,
0x3b
,
0xd5
,
0x0b
,
0x23
,
0xd9
,
0xa7
,
0xb3
,
0x44
,
0x18
,
0x51
,
0x2e
,
0x48
,
0x94
,
0x68
,
0x83
,
0xf3
,
0x6e
,
0x08
,
0x96
,
0xef
,
0x53
,
0xb1
,
0x91
,
0x86
,
0x62
,
0x2b
,
0xa2
,
0x22
,
0xf4
,
0x37
,
0x77
,
0x48
,
0xe2
,
0xd1
,
0x4e
,
0x97
,
0x72
,
0x81
,
0xae
,
0xc1
,
0xb1
,
0x84
,
0xb1
,
0x76
,
0x23
,
0x6c
,
0x95
,
0x41
,
0x15
,
0x2c
,
0x8d
,
0x78
,
0x45
,
0xb9
,
0x7c
,
0xd8
,
0x42
,
0xf3
,
0x10
,
0xca
,
0x1d
,
0x35
,
0x08
,
0xe7
,
0x54
,
0x94
,
0x87
,
0xaa
,
0x60
,
0xa9
,
0xe4
,
0x95
,
0x64
,
0x64
,
0x43
,
0x06
,
0x90
,
0x0d
,
0xc7
,
0x3b
,
0x5d
,
0x26
,
0x32
,
0x7d
,
0x58
,
0xe9
,
0x50
,
0x85
,
0xb4
,
0xe1
,
0x39
,
0x84
,
0x5c
,
0x90
,
0x54
,
0x34
,
0x24
,
0x4e
,
0x79
,
0xa4
,
0x0a
,
0x96
,
0xc6
,
0x6b
,
0x15
,
0x57
,
0xb3
,
0xba
,
0x19
,
0xab
,
0xbb
,
0x99
,
0xb1
,
0xd6
,
0xe7
,
0xf7
,
0xfb
,
0x76
,
0xe1
,
0xb8
,
0x6f
,
0x4f
,
0xf5
,
0x48
,
0xd4
,
0x5e
,
0x77
,
0x7e
,
0xe5
,
0x3a
,
0xbb
,
0x5f
,
0x6d
,
0xe0
,
0x95
,
0x54
,
0x40
,
0xda
,
0x91
,
0x07
,
0xaf
,
0xd0
,
0xb8
,
0xa5
,
0xeb
,
0x8e
,
0xfe
,
0xb1
,
0xee
,
0xf5
,
0xfd
,
0xbe
,
0x0d
,
0x8e
,
0xfb
,
0xf6
,
0xa4
,
0xae
,
0x9b
,
0x65
,
0xea
,
0xaa
,
0x63
,
0x34
,
0x6e
,
0x49
,
0xab
,
0xf3
,
0x16
,
0xc0
,
0xd9
,
0x9c
,
0x19
,
0xf1
,
0x84
,
0xc5
,
0x9c
,
0xa2
,
0x0e
,
0x9c
,
0x24
,
0x03
,
0xa5
,
0x21
,
0xcf
,
0x8a
,
0x1a
,
0x56
,
0xa9
,
0xfe
,
0x40
,
0x42
,
0x7f
,
0xe9
,
0xdb
,
0x8b
,
0x41
,
0x28
,
0xb6
,
0xba
,
0x4d
,
0xd7
,
0x67
,
0x91
,
0x79
,
0x39
,
0xe6
,
0xb1
,
0xcc
,
0x5b
,
0xaf
,
0xb0
,
0xe8
,
0x25
,
0x94
,
0xbb
,
0xf7
,
0xa8
,
0x7f
,
0xdc
,
0xb7
,
0x67
,
0x34
,
0xc6
,
0xa9
,
0x72
,
0x8e
,
0x37
,
0x41
,
0x7e
,
0x6b
,
0xed
,
0x7c
,
0x04
,
0x70
,
0xfe
,
0x0c
,
0xd0
,
0x26
,
0x7b
,
0xcc
,
0x76
,
0xfe
,
0xdf
,
0x37
,
0xe7
,
0xec
,
0x01
,
0x68
,
0x9d
,
0xb7
,
0xa9
,
0x7f
,
0x37
,
0xea
,
0x49
,
0x78
,
0xf5
,
0x09
,
0x49
,
0x49
,
0xc4
,
0xcd
,
0x64
,
0x9d
,
0x47
,
0x70
,
0x22
,
0x0b
,
0x18
,
0xaa
,
0x75
,
0x58
,
0x4c
,
0x54
,
0x44
,
0xc1
,
0x8c
,
0xd7
,
0xe6
,
0xdc
,
0xbc
,
0xcb
,
0xc8
,
0xd5
,
0x59
,
0xf5
,
0x11
,
0x89
,
0xea
,
0x99
,
0x8c
,
0xda
,
0x8f
,
0x61
,
0x38
,
0xfa
,
0x54
,
0x5e
,
0x0b
,
0xa8
,
0x07
,
0x8b
,
0xda
,
0x81
,
0x6e
,
0x5c
,
0x94
,
0x6f
,
0x30
,
0x2a
,
0x0b
,
0x17
,
0x9b
,
0x34
,
0x9a
,
0xb3
,
0xf0
,
0xe6
,
0xd3
,
0xf7
,
0xbd
,
0x21
,
0x0b
,
0xcd
,
0xe1
,
0xdc
,
0xbb
,
0xcc
,
0x34
,
0x7c
,
0x0f
,
0xe0
,
0xd4
,
0x99
,
0xc9
,
0x23
,
0x37
,
0xbf
,
0xc3
,
0x79
,
0x97
,
0x45
,
0x05
,
0x5f
,
0xda
,
0x6f
,
0xe0
,
0xb0
,
0x82
,
0xbb
,
0x85
,
0x6e
,
0xe6
,
0xc3
,
0x9d
,
0x25
,
0xfa
,
0x00
,
0xe0
,
0x4c
,
0xfe
,
0x09
,
0x41
,
0xab
,
0x97
,
0x6c
,
0x7e
,
0xf2
,
0x23
,
0xa9
,
0xac
,
0xfd
,
0x5d
,
0x92
,
0xc1
,
0x5e
,
0x53
,
0xd8
,
0x2e
,
0xba
,
0x73
,
0x49
,
0x6c
,
0x95
,
0x5d
,
0x7f
,
0xb6
,
0x7f
,
0x68
,
0x81
,
0x83
,
0x43
,
0x0b
,
0x7c
,
0x3b
,
0xb4
,
0xc0
,
0xee
,
0x91
,
0x55
,
0x38
,
0x38
,
0xb2
,
0x0a
,
0x9f
,
0x8f
,
0xac
,
0xc2
,
0x8b
,
0xbb
,
0x27
,
0xce
,
0xac
,
0xa9
,
0xb8
,
0xdc
,
0x26
,
0x4d
,
0x3e
,
0x28
,
0xbf
,
0xbd
,
0x52
,
0xc3
,
0xaf
,
0x75
,
0x13
,
0xbf
,
0x1d
,
0xd2
,
0x58
,
0xe8
,
0x3f
,
0x12
,
0xfd
,
0xb1
,
0x15
,
0xd5
,
0x63
,
0xf5
,
0x67
,
0x00
,
0x00
,
0x00
,
0xff
,
0xff
,
0x90
,
0x00
,
0xfb
,
0xbe
,
0x23
,
0x07
,
0x00
,
0x00
,
}
// Reference imports to suppress errors if they are not otherwise used.
...
...
@@ -320,6 +407,7 @@ const _ = grpc.SupportPackageIsVersion4
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type
QueryClient
interface
{
Params
(
ctx
context
.
Context
,
in
*
ParamsRequest
,
opts
...
grpc
.
CallOption
)
(
*
ParamsResponse
,
error
)
GetArithmeticTwap
(
ctx
context
.
Context
,
in
*
GetArithmeticTwapRequest
,
opts
...
grpc
.
CallOption
)
(
*
GetArithmeticTwapResponse
,
error
)
GetArithmeticTwapToNow
(
ctx
context
.
Context
,
in
*
GetArithmeticTwapToNowRequest
,
opts
...
grpc
.
CallOption
)
(
*
GetArithmeticTwapToNowResponse
,
error
)
}
...
...
@@ -332,6 +420,15 @@ func NewQueryClient(cc grpc1.ClientConn) QueryClient {
return
&
queryClient
{
cc
}
}
func
(
c
*
queryClient
)
Params
(
ctx
context
.
Context
,
in
*
ParamsRequest
,
opts
...
grpc
.
CallOption
)
(
*
ParamsResponse
,
error
)
{
out
:=
new
(
ParamsResponse
)
err
:=
c
.
cc
.
Invoke
(
ctx
,
"/osmosis.twap.v1beta1.Query/Params"
,
in
,
out
,
opts
...
)
if
err
!=
nil
{
return
nil
,
err
}
return
out
,
nil
}
func
(
c
*
queryClient
)
GetArithmeticTwap
(
ctx
context
.
Context
,
in
*
GetArithmeticTwapRequest
,
opts
...
grpc
.
CallOption
)
(
*
GetArithmeticTwapResponse
,
error
)
{
out
:=
new
(
GetArithmeticTwapResponse
)
err
:=
c
.
cc
.
Invoke
(
ctx
,
"/osmosis.twap.v1beta1.Query/GetArithmeticTwap"
,
in
,
out
,
opts
...
)
...
...
@@ -352,6 +449,7 @@ func (c *queryClient) GetArithmeticTwapToNow(ctx context.Context, in *GetArithme
// QueryServer is the server API for Query service.
type
QueryServer
interface
{
Params
(
context
.
Context
,
*
ParamsRequest
)
(
*
ParamsResponse
,
error
)
GetArithmeticTwap
(
context
.
Context
,
*
GetArithmeticTwapRequest
)
(
*
GetArithmeticTwapResponse
,
error
)
GetArithmeticTwapToNow
(
context
.
Context
,
*
GetArithmeticTwapToNowRequest
)
(
*
GetArithmeticTwapToNowResponse
,
error
)
}
...
...
@@ -360,6 +458,9 @@ type QueryServer interface {
type
UnimplementedQueryServer
struct
{
}
func
(
*
UnimplementedQueryServer
)
Params
(
ctx
context
.
Context
,
req
*
ParamsRequest
)
(
*
ParamsResponse
,
error
)
{
return
nil
,
status
.
Errorf
(
codes
.
Unimplemented
,
"method Params not implemented"
)
}
func
(
*
UnimplementedQueryServer
)
GetArithmeticTwap
(
ctx
context
.
Context
,
req
*
GetArithmeticTwapRequest
)
(
*
GetArithmeticTwapResponse
,
error
)
{
return
nil
,
status
.
Errorf
(
codes
.
Unimplemented
,
"method GetArithmeticTwap not implemented"
)
}
...
...
@@ -371,6 +472,24 @@ func RegisterQueryServer(s grpc1.Server, srv QueryServer) {
s
.
RegisterService
(
&
_Query_serviceDesc
,
srv
)
}
func
_Query_Params_Handler
(
srv
interface
{},
ctx
context
.
Context
,
dec
func
(
interface
{})
error
,
interceptor
grpc
.
UnaryServerInterceptor
)
(
interface
{},
error
)
{
in
:=
new
(
ParamsRequest
)
if
err
:=
dec
(
in
);
err
!=
nil
{
return
nil
,
err
}
if
interceptor
==
nil
{
return
srv
.
(
QueryServer
)
.
Params
(
ctx
,
in
)
}
info
:=
&
grpc
.
UnaryServerInfo
{
Server
:
srv
,
FullMethod
:
"/osmosis.twap.v1beta1.Query/Params"
,
}
handler
:=
func
(
ctx
context
.
Context
,
req
interface
{})
(
interface
{},
error
)
{
return
srv
.
(
QueryServer
)
.
Params
(
ctx
,
req
.
(
*
ParamsRequest
))
}
return
interceptor
(
ctx
,
in
,
info
,
handler
)
}
func
_Query_GetArithmeticTwap_Handler
(
srv
interface
{},
ctx
context
.
Context
,
dec
func
(
interface
{})
error
,
interceptor
grpc
.
UnaryServerInterceptor
)
(
interface
{},
error
)
{
in
:=
new
(
GetArithmeticTwapRequest
)
if
err
:=
dec
(
in
);
err
!=
nil
{
...
...
@@ -411,6 +530,10 @@ var _Query_serviceDesc = grpc.ServiceDesc{
ServiceName
:
"osmosis.twap.v1beta1.Query"
,
HandlerType
:
(
*
QueryServer
)(
nil
),
Methods
:
[]
grpc
.
MethodDesc
{
{
MethodName
:
"Params"
,
Handler
:
_Query_Params_Handler
,
},
{
MethodName
:
"GetArithmeticTwap"
,
Handler
:
_Query_GetArithmeticTwap_Handler
,
...
...
@@ -600,6 +723,62 @@ func (m *GetArithmeticTwapToNowResponse) MarshalToSizedBuffer(dAtA []byte) (int,
return
len
(
dAtA
)
-
i
,
nil
}
func
(
m
*
ParamsRequest
)
Marshal
()
(
dAtA
[]
byte
,
err
error
)
{
size
:=
m
.
Size
()
dAtA
=
make
([]
byte
,
size
)
n
,
err
:=
m
.
MarshalToSizedBuffer
(
dAtA
[
:
size
])
if
err
!=
nil
{
return
nil
,
err
}
return
dAtA
[
:
n
],
nil
}
func
(
m
*
ParamsRequest
)
MarshalTo
(
dAtA
[]
byte
)
(
int
,
error
)
{
size
:=
m
.
Size
()
return
m
.
MarshalToSizedBuffer
(
dAtA
[
:
size
])
}
func
(
m
*
ParamsRequest
)
MarshalToSizedBuffer
(
dAtA
[]
byte
)
(
int
,
error
)
{
i
:=
len
(
dAtA
)
_
=
i
var
l
int
_
=
l
return
len
(
dAtA
)
-
i
,
nil
}
func
(
m
*
ParamsResponse
)
Marshal
()
(
dAtA
[]
byte
,
err
error
)
{
size
:=
m
.
Size
()
dAtA
=
make
([]
byte
,
size
)
n
,
err
:=
m
.
MarshalToSizedBuffer
(
dAtA
[
:
size
])
if
err
!=
nil
{
return
nil
,
err
}
return
dAtA
[
:
n
],
nil
}
func
(
m
*
ParamsResponse
)
MarshalTo
(
dAtA
[]
byte
)
(
int
,
error
)
{
size
:=
m
.
Size
()
return
m
.
MarshalToSizedBuffer
(
dAtA
[
:
size
])
}
func
(
m
*
ParamsResponse
)
MarshalToSizedBuffer
(
dAtA
[]
byte
)
(
int
,
error
)
{
i
:=
len
(
dAtA
)
_
=
i
var
l
int
_
=
l
{
size
,
err
:=
m
.
Params
.
MarshalToSizedBuffer
(
dAtA
[
:
i
])
if
err
!=
nil
{
return
0
,
err
}
i
-=
size
i
=
encodeVarintQuery
(
dAtA
,
i
,
uint64
(
size
))
}
i
--
dAtA
[
i
]
=
0xa
return
len
(
dAtA
)
-
i
,
nil
}
func
encodeVarintQuery
(
dAtA
[]
byte
,
offset
int
,
v
uint64
)
int
{
offset
-=
sovQuery
(
v
)
base
:=
offset
...
...
@@ -681,6 +860,26 @@ func (m *GetArithmeticTwapToNowResponse) Size() (n int) {
return
n
}
func
(
m
*
ParamsRequest
)
Size
()
(
n
int
)
{
if
m
==
nil
{
return
0
}
var
l
int
_
=
l
return
n
}
func
(
m
*
ParamsResponse
)
Size
()
(
n
int
)
{
if
m
==
nil
{
return
0
}
var
l
int
_
=
l
l
=
m
.
Params
.
Size
()
n
+=
1
+
l
+
sovQuery
(
uint64
(
l
))
return
n
}
func
sovQuery
(
x
uint64
)
(
n
int
)
{
return
(
math_bits
.
Len64
(
x
|
1
)
+
6
)
/
7
}
...
...
@@ -1223,6 +1422,139 @@ func (m *GetArithmeticTwapToNowResponse) Unmarshal(dAtA []byte) error {
}
return
nil
}
func
(
m
*
ParamsRequest
)
Unmarshal
(
dAtA
[]
byte
)
error
{
l
:=
len
(
dAtA
)
iNdEx
:=
0
for
iNdEx
<
l
{
preIndex
:=
iNdEx
var
wire
uint64
for
shift
:=
uint
(
0
);
;
shift
+=
7
{
if
shift
>=
64
{
return
ErrIntOverflowQuery
}
if
iNdEx
>=
l
{
return
io
.
ErrUnexpectedEOF
}
b
:=
dAtA
[
iNdEx
]
iNdEx
++
wire
|=
uint64
(
b
&
0x7F
)
<<
shift
if
b
<
0x80
{
break
}
}
fieldNum
:=
int32
(
wire
>>
3
)
wireType
:=
int
(
wire
&
0x7
)
if
wireType
==
4
{
return
fmt
.
Errorf
(
"proto: ParamsRequest: wiretype end group for non-group"
)
}
if
fieldNum
<=
0
{
return
fmt
.
Errorf
(
"proto: ParamsRequest: illegal tag %d (wire type %d)"
,
fieldNum
,
wire
)
}
switch
fieldNum
{
default
:
iNdEx
=
preIndex
skippy
,
err
:=
skipQuery
(
dAtA
[
iNdEx
:
])
if
err
!=
nil
{
return
err
}
if
(
skippy
<
0
)
||
(
iNdEx
+
skippy
)
<
0
{
return
ErrInvalidLengthQuery
}
if
(
iNdEx
+
skippy
)
>
l
{
return
io
.
ErrUnexpectedEOF
}
iNdEx
+=
skippy
}
}
if
iNdEx
>
l
{
return
io
.
ErrUnexpectedEOF
}
return
nil
}
func
(
m
*
ParamsResponse
)
Unmarshal
(
dAtA
[]
byte
)
error
{
l
:=
len
(
dAtA
)
iNdEx
:=
0
for
iNdEx
<
l
{
preIndex
:=
iNdEx
var
wire
uint64
for
shift
:=
uint
(
0
);
;
shift
+=
7
{
if
shift
>=
64
{
return
ErrIntOverflowQuery
}
if
iNdEx
>=
l
{
return
io
.
ErrUnexpectedEOF
}
b
:=
dAtA
[
iNdEx
]
iNdEx
++
wire
|=
uint64
(
b
&
0x7F
)
<<
shift
if
b
<
0x80
{
break
}
}
fieldNum
:=
int32
(
wire
>>
3
)
wireType
:=
int
(
wire
&
0x7
)
if
wireType
==
4
{
return
fmt
.
Errorf
(
"proto: ParamsResponse: wiretype end group for non-group"
)
}
if
fieldNum
<=
0
{
return
fmt
.
Errorf
(
"proto: ParamsResponse: illegal tag %d (wire type %d)"
,
fieldNum
,
wire
)
}
switch
fieldNum
{
case
1
:
if
wireType
!=
2
{
return
fmt
.
Errorf
(
"proto: wrong wireType = %d for field Params"
,
wireType
)
}
var
msglen
int
for
shift
:=
uint
(
0
);
;
shift
+=
7
{
if
shift
>=
64
{
return
ErrIntOverflowQuery
}
if
iNdEx
>=
l
{
return
io
.
ErrUnexpectedEOF
}
b
:=
dAtA
[
iNdEx
]
iNdEx
++
msglen
|=
int
(
b
&
0x7F
)
<<
shift
if
b
<
0x80
{
break
}
}
if
msglen
<
0
{
return
ErrInvalidLengthQuery
}
postIndex
:=
iNdEx
+
msglen
if
postIndex
<
0
{
return
ErrInvalidLengthQuery
}
if
postIndex
>
l
{
return
io
.
ErrUnexpectedEOF
}
if
err
:=
m
.
Params
.
Unmarshal
(
dAtA
[
iNdEx
:
postIndex
]);
err
!=
nil
{
return
err
}
iNdEx
=
postIndex
default
:
iNdEx
=
preIndex
skippy
,
err
:=
skipQuery
(
dAtA
[
iNdEx
:
])
if
err
!=
nil
{
return
err
}
if
(
skippy
<
0
)
||
(
iNdEx
+
skippy
)
<
0
{
return
ErrInvalidLengthQuery
}
if
(
iNdEx
+
skippy
)
>
l
{
return
io
.
ErrUnexpectedEOF
}
iNdEx
+=
skippy
}
}
if
iNdEx
>
l
{
return
io
.
ErrUnexpectedEOF
}
return
nil
}
func
skipQuery
(
dAtA
[]
byte
)
(
n
int
,
err
error
)
{
l
:=
len
(
dAtA
)
iNdEx
:=
0
...
...
This diff is collapsed.
Click to expand it.
x/twap/client/queryproto/query.pb.gw.go
+
65
-
0
View file @
4bbd3fb4
...
...
@@ -33,6 +33,24 @@ var _ = utilities.NewDoubleArray
var
_
=
descriptor
.
ForMessage
var
_
=
metadata
.
Join
func
request_Query_Params_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
client
QueryClient
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
ParamsRequest
var
metadata
runtime
.
ServerMetadata
msg
,
err
:=
client
.
Params
(
ctx
,
&
protoReq
,
grpc
.
Header
(
&
metadata
.
HeaderMD
),
grpc
.
Trailer
(
&
metadata
.
TrailerMD
))
return
msg
,
metadata
,
err
}
func
local_request_Query_Params_0
(
ctx
context
.
Context
,
marshaler
runtime
.
Marshaler
,
server
QueryServer
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
(
proto
.
Message
,
runtime
.
ServerMetadata
,
error
)
{
var
protoReq
ParamsRequest
var
metadata
runtime
.
ServerMetadata
msg
,
err
:=
server
.
Params
(
ctx
,
&
protoReq
)
return
msg
,
metadata
,
err
}
var
(
filter_Query_GetArithmeticTwap_0
=
&
utilities
.
DoubleArray
{
Encoding
:
map
[
string
]
int
{},
Base
:
[]
int
(
nil
),
Check
:
[]
int
(
nil
)}
)
...
...
@@ -111,6 +129,29 @@ func local_request_Query_GetArithmeticTwapToNow_0(ctx context.Context, marshaler
// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func
RegisterQueryHandlerServer
(
ctx
context
.
Context
,
mux
*
runtime
.
ServeMux
,
server
QueryServer
)
error
{
mux
.
Handle
(
"GET"
,
pattern_Query_Params_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
var
stream
runtime
.
ServerTransportStream
ctx
=
grpc
.
NewContextWithServerTransportStream
(
ctx
,
&
stream
)
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateIncomingContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
local_request_Query_Params_0
(
rctx
,
inboundMarshaler
,
server
,
req
,
pathParams
)
md
.
HeaderMD
,
md
.
TrailerMD
=
metadata
.
Join
(
md
.
HeaderMD
,
stream
.
Header
()),
metadata
.
Join
(
md
.
TrailerMD
,
stream
.
Trailer
())
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_Query_Params_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"GET"
,
pattern_Query_GetArithmeticTwap_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
...
...
@@ -198,6 +239,26 @@ func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc
// "QueryClient" to call the correct interceptors.
func
RegisterQueryHandlerClient
(
ctx
context
.
Context
,
mux
*
runtime
.
ServeMux
,
client
QueryClient
)
error
{
mux
.
Handle
(
"GET"
,
pattern_Query_Params_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
inboundMarshaler
,
outboundMarshaler
:=
runtime
.
MarshalerForRequest
(
mux
,
req
)
rctx
,
err
:=
runtime
.
AnnotateContext
(
ctx
,
mux
,
req
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
resp
,
md
,
err
:=
request_Query_Params_0
(
rctx
,
inboundMarshaler
,
client
,
req
,
pathParams
)
ctx
=
runtime
.
NewServerMetadataContext
(
ctx
,
md
)
if
err
!=
nil
{
runtime
.
HTTPError
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
err
)
return
}
forward_Query_Params_0
(
ctx
,
mux
,
outboundMarshaler
,
w
,
req
,
resp
,
mux
.
GetForwardResponseOptions
()
...
)
})
mux
.
Handle
(
"GET"
,
pattern_Query_GetArithmeticTwap_0
,
func
(
w
http
.
ResponseWriter
,
req
*
http
.
Request
,
pathParams
map
[
string
]
string
)
{
ctx
,
cancel
:=
context
.
WithCancel
(
req
.
Context
())
defer
cancel
()
...
...
@@ -242,12 +303,16 @@ func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, clie
}
var
(
pattern_Query_Params_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
,
2
,
3
},
[]
string
{
"osmosis"
,
"twap"
,
"v1beta1"
,
"Params"
},
""
,
runtime
.
AssumeColonVerbOpt
(
false
)))
pattern_Query_GetArithmeticTwap_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
,
2
,
3
},
[]
string
{
"osmosis"
,
"twap"
,
"v1beta1"
,
"GetArithmeticTwap"
},
""
,
runtime
.
AssumeColonVerbOpt
(
false
)))
pattern_Query_GetArithmeticTwapToNow_0
=
runtime
.
MustPattern
(
runtime
.
NewPattern
(
1
,
[]
int
{
2
,
0
,
2
,
1
,
2
,
2
,
2
,
3
},
[]
string
{
"osmosis"
,
"twap"
,
"v1beta1"
,
"GetArithmeticTwapToNow"
},
""
,
runtime
.
AssumeColonVerbOpt
(
false
)))
)
var
(
forward_Query_Params_0
=
runtime
.
ForwardResponseMessage
forward_Query_GetArithmeticTwap_0
=
runtime
.
ForwardResponseMessage
forward_Query_GetArithmeticTwapToNow_0
=
runtime
.
ForwardResponseMessage
...
...
This diff is collapsed.
Click to expand it.
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment