Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- 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 AccountKeeper
- type BankKeeper
- type ChannelKeeper
- type ClientKeeper
- type ConnectionChannelID
- func (*ConnectionChannelID) Descriptor() ([]byte, []int)
- func (m *ConnectionChannelID) GetChannelId() string
- func (m *ConnectionChannelID) Marshal() (dAtA []byte, err error)
- func (m *ConnectionChannelID) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnectionChannelID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnectionChannelID) ProtoMessage()
- func (m *ConnectionChannelID) Reset()
- func (m *ConnectionChannelID) Size() (n int)
- func (m *ConnectionChannelID) String() string
- func (m *ConnectionChannelID) Unmarshal(dAtA []byte) error
- func (m *ConnectionChannelID) XXX_DiscardUnknown()
- func (m *ConnectionChannelID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectionChannelID) XXX_Merge(src proto.Message)
- func (m *ConnectionChannelID) XXX_Size() int
- func (m *ConnectionChannelID) XXX_Unmarshal(b []byte) error
- type ConnectionKeeper
- type ConsumerClientID
- func (*ConsumerClientID) Descriptor() ([]byte, []int)
- func (m *ConsumerClientID) GetClientId() string
- func (m *ConsumerClientID) Marshal() (dAtA []byte, err error)
- func (m *ConsumerClientID) MarshalTo(dAtA []byte) (int, error)
- func (m *ConsumerClientID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConsumerClientID) ProtoMessage()
- func (m *ConsumerClientID) Reset()
- func (m *ConsumerClientID) Size() (n int)
- func (m *ConsumerClientID) String() string
- func (m *ConsumerClientID) Unmarshal(dAtA []byte) error
- func (m *ConsumerClientID) XXX_DiscardUnknown()
- func (m *ConsumerClientID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConsumerClientID) XXX_Merge(src proto.Message)
- func (m *ConsumerClientID) XXX_Size() int
- func (m *ConsumerClientID) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetConnectionChannelId() *ConnectionChannelID
- func (m *GenesisState) GetConsumerClientId() *ConsumerClientID
- func (m *GenesisState) GetMonitoringInfo() *MonitoringInfo
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) GetPortId() string
- 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 MonitoringInfo
- func (*MonitoringInfo) Descriptor() ([]byte, []int)
- func (m *MonitoringInfo) GetSignatureCounts() types.SignatureCounts
- func (m *MonitoringInfo) GetTransmitted() bool
- func (m *MonitoringInfo) Marshal() (dAtA []byte, err error)
- func (m *MonitoringInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *MonitoringInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MonitoringInfo) ProtoMessage()
- func (m *MonitoringInfo) Reset()
- func (m *MonitoringInfo) Size() (n int)
- func (m *MonitoringInfo) String() string
- func (m *MonitoringInfo) Unmarshal(dAtA []byte) error
- func (m *MonitoringInfo) XXX_DiscardUnknown()
- func (m *MonitoringInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitoringInfo) XXX_Merge(src proto.Message)
- func (m *MonitoringInfo) XXX_Size() int
- func (m *MonitoringInfo) XXX_Unmarshal(b []byte) error
- type MonitoringpPacketData
- func (*MonitoringpPacketData) Descriptor() ([]byte, []int)
- func (m *MonitoringpPacketData) GetNoData() *NoData
- func (m *MonitoringpPacketData) GetPacket() isMonitoringpPacketData_Packet
- func (m *MonitoringpPacketData) Marshal() (dAtA []byte, err error)
- func (m *MonitoringpPacketData) MarshalTo(dAtA []byte) (int, error)
- func (m *MonitoringpPacketData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MonitoringpPacketData) ProtoMessage()
- func (m *MonitoringpPacketData) Reset()
- func (m *MonitoringpPacketData) Size() (n int)
- func (m *MonitoringpPacketData) String() string
- func (m *MonitoringpPacketData) Unmarshal(dAtA []byte) error
- func (m *MonitoringpPacketData) XXX_DiscardUnknown()
- func (m *MonitoringpPacketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitoringpPacketData) XXX_Merge(src proto.Message)
- func (*MonitoringpPacketData) XXX_OneofWrappers() []interface{}
- func (m *MonitoringpPacketData) XXX_Size() int
- func (m *MonitoringpPacketData) XXX_Unmarshal(b []byte) error
- type MonitoringpPacketData_NoData
- type MsgClient
- type MsgServer
- type MsgUpdateParams
- func (*MsgUpdateParams) Descriptor() ([]byte, []int)
- func (m *MsgUpdateParams) GetAuthority() string
- func (m *MsgUpdateParams) GetParams() Params
- func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateParams) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateParams) ProtoMessage()
- func (m *MsgUpdateParams) Reset()
- func (m *MsgUpdateParams) Size() (n int)
- func (m *MsgUpdateParams) String() string
- func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateParams) XXX_DiscardUnknown()
- func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateParams) XXX_Merge(src proto.Message)
- func (m *MsgUpdateParams) XXX_Size() int
- func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error
- type MsgUpdateParamsResponse
- func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
- func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgUpdateParamsResponse) ProtoMessage()
- func (m *MsgUpdateParamsResponse) Reset()
- func (m *MsgUpdateParamsResponse) Size() (n int)
- func (m *MsgUpdateParamsResponse) String() string
- func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error
- func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()
- func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)
- func (m *MsgUpdateParamsResponse) XXX_Size() int
- func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error
- type NoData
- func (*NoData) Descriptor() ([]byte, []int)
- func (m *NoData) Marshal() (dAtA []byte, err error)
- func (m *NoData) MarshalTo(dAtA []byte) (int, error)
- func (m *NoData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NoData) ProtoMessage()
- func (m *NoData) Reset()
- func (m *NoData) Size() (n int)
- func (m *NoData) String() string
- func (m *NoData) Unmarshal(dAtA []byte) error
- func (m *NoData) XXX_DiscardUnknown()
- func (m *NoData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NoData) XXX_Merge(src proto.Message)
- func (m *NoData) XXX_Size() int
- func (m *NoData) XXX_Unmarshal(b []byte) error
- type ParamSubspace
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (this *Params) Equal(that interface{}) bool
- func (m *Params) GetConsumerChainId() string
- func (m *Params) GetConsumerConsensusState() types.ConsensusState
- func (m *Params) GetConsumerRevisionHeight() uint64
- func (m *Params) GetConsumerUnbondingPeriod() int64
- func (m *Params) GetLastBlockHeight() int64
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type PortKeeper
- type QueryClient
- type QueryGetConnectionChannelIDRequest
- func (*QueryGetConnectionChannelIDRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetConnectionChannelIDRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetConnectionChannelIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetConnectionChannelIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetConnectionChannelIDRequest) ProtoMessage()
- func (m *QueryGetConnectionChannelIDRequest) Reset()
- func (m *QueryGetConnectionChannelIDRequest) Size() (n int)
- func (m *QueryGetConnectionChannelIDRequest) String() string
- func (m *QueryGetConnectionChannelIDRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetConnectionChannelIDRequest) XXX_DiscardUnknown()
- func (m *QueryGetConnectionChannelIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetConnectionChannelIDRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetConnectionChannelIDRequest) XXX_Size() int
- func (m *QueryGetConnectionChannelIDRequest) XXX_Unmarshal(b []byte) error
- type QueryGetConnectionChannelIDResponse
- func (*QueryGetConnectionChannelIDResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetConnectionChannelIDResponse) GetConnectionChannelId() ConnectionChannelID
- func (m *QueryGetConnectionChannelIDResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetConnectionChannelIDResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetConnectionChannelIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetConnectionChannelIDResponse) ProtoMessage()
- func (m *QueryGetConnectionChannelIDResponse) Reset()
- func (m *QueryGetConnectionChannelIDResponse) Size() (n int)
- func (m *QueryGetConnectionChannelIDResponse) String() string
- func (m *QueryGetConnectionChannelIDResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetConnectionChannelIDResponse) XXX_DiscardUnknown()
- func (m *QueryGetConnectionChannelIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetConnectionChannelIDResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetConnectionChannelIDResponse) XXX_Size() int
- func (m *QueryGetConnectionChannelIDResponse) XXX_Unmarshal(b []byte) error
- type QueryGetConsumerClientIDRequest
- func (*QueryGetConsumerClientIDRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetConsumerClientIDRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetConsumerClientIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetConsumerClientIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetConsumerClientIDRequest) ProtoMessage()
- func (m *QueryGetConsumerClientIDRequest) Reset()
- func (m *QueryGetConsumerClientIDRequest) Size() (n int)
- func (m *QueryGetConsumerClientIDRequest) String() string
- func (m *QueryGetConsumerClientIDRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetConsumerClientIDRequest) XXX_DiscardUnknown()
- func (m *QueryGetConsumerClientIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetConsumerClientIDRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetConsumerClientIDRequest) XXX_Size() int
- func (m *QueryGetConsumerClientIDRequest) XXX_Unmarshal(b []byte) error
- type QueryGetConsumerClientIDResponse
- func (*QueryGetConsumerClientIDResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetConsumerClientIDResponse) GetConsumerClientId() ConsumerClientID
- func (m *QueryGetConsumerClientIDResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetConsumerClientIDResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetConsumerClientIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetConsumerClientIDResponse) ProtoMessage()
- func (m *QueryGetConsumerClientIDResponse) Reset()
- func (m *QueryGetConsumerClientIDResponse) Size() (n int)
- func (m *QueryGetConsumerClientIDResponse) String() string
- func (m *QueryGetConsumerClientIDResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetConsumerClientIDResponse) XXX_DiscardUnknown()
- func (m *QueryGetConsumerClientIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetConsumerClientIDResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetConsumerClientIDResponse) XXX_Size() int
- func (m *QueryGetConsumerClientIDResponse) XXX_Unmarshal(b []byte) error
- type QueryGetMonitoringInfoRequest
- func (*QueryGetMonitoringInfoRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetMonitoringInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetMonitoringInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetMonitoringInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetMonitoringInfoRequest) ProtoMessage()
- func (m *QueryGetMonitoringInfoRequest) Reset()
- func (m *QueryGetMonitoringInfoRequest) Size() (n int)
- func (m *QueryGetMonitoringInfoRequest) String() string
- func (m *QueryGetMonitoringInfoRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetMonitoringInfoRequest) XXX_DiscardUnknown()
- func (m *QueryGetMonitoringInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetMonitoringInfoRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetMonitoringInfoRequest) XXX_Size() int
- func (m *QueryGetMonitoringInfoRequest) XXX_Unmarshal(b []byte) error
- type QueryGetMonitoringInfoResponse
- func (*QueryGetMonitoringInfoResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetMonitoringInfoResponse) GetMonitoringInfo() MonitoringInfo
- func (m *QueryGetMonitoringInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetMonitoringInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetMonitoringInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetMonitoringInfoResponse) ProtoMessage()
- func (m *QueryGetMonitoringInfoResponse) Reset()
- func (m *QueryGetMonitoringInfoResponse) Size() (n int)
- func (m *QueryGetMonitoringInfoResponse) String() string
- func (m *QueryGetMonitoringInfoResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetMonitoringInfoResponse) XXX_DiscardUnknown()
- func (m *QueryGetMonitoringInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetMonitoringInfoResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetMonitoringInfoResponse) XXX_Size() int
- func (m *QueryGetMonitoringInfoResponse) XXX_Unmarshal(b []byte) error
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) GetParams() Params
- func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsResponse) ProtoMessage()
- func (m *QueryParamsResponse) Reset()
- func (m *QueryParamsResponse) Size() (n int)
- func (m *QueryParamsResponse) String() string
- func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsResponse) XXX_DiscardUnknown()
- func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsResponse) XXX_Size() int
- func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type ScopedKeeper
- type StakingKeeper
- type UnimplementedMsgServer
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) GetConnectionChannelID(ctx context.Context, req *QueryGetConnectionChannelIDRequest) (*QueryGetConnectionChannelIDResponse, error)
- func (*UnimplementedQueryServer) GetConsumerClientID(ctx context.Context, req *QueryGetConsumerClientIDRequest) (*QueryGetConsumerClientIDResponse, error)
- func (*UnimplementedQueryServer) GetMonitoringInfo(ctx context.Context, req *QueryGetMonitoringInfoRequest) (*QueryGetMonitoringInfoResponse, error)
- func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
Constants ¶
const ( EventTypeTimeout = "timeout" EventTypeMonitoringPacket = "monitoring_packet" AttributeKeyAckSuccess = "success" AttributeKeyAck = "acknowledgement" AttributeKeyAckError = "error" )
IBC events
const ( // ModuleName defines the module name ModuleName = "monitoringp" // StoreKey defines the primary module store key StoreKey = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_monitoringp" // Version defines the current version the IBC module supports Version = "monitoring-1" // PortID is the default port id that module binds to PortID = "monitoringp" )
Variables ¶
var ( ErrInvalidLengthConnectionChannelId = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowConnectionChannelId = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupConnectionChannelId = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthConsumerClientId = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowConsumerClientId = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupConsumerClientId = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidSigner = sdkerrors.Register(ModuleName, 1101, "expected gov account as only signer for proposal message") ErrInvalidPacketTimeout = sdkerrors.Register(ModuleName, 1102, "invalid packet timeout") ErrInvalidVersion = sdkerrors.Register(ModuleName, 1103, "invalid version") ErrInvalidClientState = sdkerrors.Register(ModuleName, 1104, "invalid client state") ErrInvalidConsensusState = sdkerrors.Register(ModuleName, 1105, "invalid consensus state") ErrClientCreationFailure = sdkerrors.Register(ModuleName, 1106, "failed to create an IBC client") ErrInvalidHandshake = sdkerrors.Register(ModuleName, 1107, "invalid handshake") ErrNoConsumerClient = sdkerrors.Register(ModuleName, 1108, "consumer IBC client doesn't exist") ErrConsumerConnectionEstablished = sdkerrors.Register(ModuleName, 1109, "consumer connection already established") ErrInvalidClient = sdkerrors.Register(ModuleName, 1110, "invalid IBC client") ErrJSONUnmarshal = sdkerrors.Register(ModuleName, 1111, "failed to unmarshal JSON") ErrJSONMarshal = sdkerrors.Register(ModuleName, 1112, "failed to marshal JSON") ErrNotImplemented = sdkerrors.Register(ModuleName, 1113, "not implemented") ErrUnrecognizedAckType = sdkerrors.Register(ModuleName, 1114, "unrecognized acknowledgement type") ErrUnrecognizedPacketType = sdkerrors.Register(ModuleName, 1115, "unrecognized packet type") ErrCannotCloseChannel = sdkerrors.Register(ModuleName, 1116, "user cannot close channel") )
x/monitoringp module sentinel errors
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 ( // ParamsKey is the prefix to retrieve all Params ParamsKey = collections.NewPrefix("p_monitoringp") // PortKey defines the key to store the port ID in store PortKey = collections.NewPrefix("monitoringp-port-") // MonitoringInfoKey is the prefix to retrieve all MonitoringInfo MonitoringInfoKey = collections.NewPrefix("monitoringInfo/value/") // ConnectionChannelIDKey is the prefix to retrieve all ConnectionChannelID ConnectionChannelIDKey = collections.NewPrefix("connectionChannelID/value/") // ConsumerClientIDKey is the prefix to retrieve all ConsumerClientID ConsumerClientIDKey = collections.NewPrefix("consumerClientID/value/") )
var ( ErrInvalidLengthMonitoringInfo = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMonitoringInfo = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMonitoringInfo = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPacket = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPacket = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group") )
var ( DefaultLastBlockHeight int64 = 1 DefaultConsumerChainID = "spn-1" )
var ( ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowParams = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupParams = 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 ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
ModuleCdc references the global x/ibc-transfer module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding.
The actual codec used for serialization should be provided to x/ibc transfer and defined at the application level.
var Msg_serviceDesc = _Msg_serviceDesc
var Query_serviceDesc = _Query_serviceDesc
Functions ¶
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 AccountKeeper ¶
type AccountKeeper interface {
GetAccount(context.Context, sdk.AccAddress) sdk.AccountI // only used for simulation
}
AccountKeeper defines the expected interface for the Account module.
type BankKeeper ¶
BankKeeper defines the expected interface for the Bank module.
type ChannelKeeper ¶
type ChannelKeeper interface { GetChannel(ctx sdk.Context, portID, channelID string) (channeltypes.Channel, bool) GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool) SendPacket( ctx sdk.Context, channelCap *capabilitytypes.Capability, sourcePort string, sourceChannel string, timeoutHeight clienttypes.Height, timeoutTimestamp uint64, data []byte, ) (uint64, error) ChanCloseInit(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability) error }
ChannelKeeper defines the expected IBC channel keeper.
type ClientKeeper ¶
type ClientKeeper interface {
CreateClient(ctx sdk.Context, clientState exported.ClientState, consensusState exported.ConsensusState) (string, error)
}
ClientKeeper is imported to add the ability to create IBC Client from the module
type ConnectionChannelID ¶
type ConnectionChannelID struct {
ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}
func (*ConnectionChannelID) Descriptor ¶
func (*ConnectionChannelID) Descriptor() ([]byte, []int)
func (*ConnectionChannelID) GetChannelId ¶
func (m *ConnectionChannelID) GetChannelId() string
func (*ConnectionChannelID) Marshal ¶
func (m *ConnectionChannelID) Marshal() (dAtA []byte, err error)
func (*ConnectionChannelID) MarshalTo ¶
func (m *ConnectionChannelID) MarshalTo(dAtA []byte) (int, error)
func (*ConnectionChannelID) MarshalToSizedBuffer ¶
func (m *ConnectionChannelID) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnectionChannelID) ProtoMessage ¶
func (*ConnectionChannelID) ProtoMessage()
func (*ConnectionChannelID) Reset ¶
func (m *ConnectionChannelID) Reset()
func (*ConnectionChannelID) Size ¶
func (m *ConnectionChannelID) Size() (n int)
func (*ConnectionChannelID) String ¶
func (m *ConnectionChannelID) String() string
func (*ConnectionChannelID) Unmarshal ¶
func (m *ConnectionChannelID) Unmarshal(dAtA []byte) error
func (*ConnectionChannelID) XXX_DiscardUnknown ¶
func (m *ConnectionChannelID) XXX_DiscardUnknown()
func (*ConnectionChannelID) XXX_Marshal ¶
func (m *ConnectionChannelID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectionChannelID) XXX_Merge ¶
func (m *ConnectionChannelID) XXX_Merge(src proto.Message)
func (*ConnectionChannelID) XXX_Size ¶
func (m *ConnectionChannelID) XXX_Size() int
func (*ConnectionChannelID) XXX_Unmarshal ¶
func (m *ConnectionChannelID) XXX_Unmarshal(b []byte) error
type ConnectionKeeper ¶
type ConnectionKeeper interface {
GetConnection(ctx sdk.Context, connectionID string) (connectiontypes.ConnectionEnd, bool)
}
ConnectionKeeper is imported to check client ID during IBC handshake
type ConsumerClientID ¶
type ConsumerClientID struct {
ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
}
func (*ConsumerClientID) Descriptor ¶
func (*ConsumerClientID) Descriptor() ([]byte, []int)
func (*ConsumerClientID) GetClientId ¶
func (m *ConsumerClientID) GetClientId() string
func (*ConsumerClientID) Marshal ¶
func (m *ConsumerClientID) Marshal() (dAtA []byte, err error)
func (*ConsumerClientID) MarshalToSizedBuffer ¶
func (m *ConsumerClientID) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConsumerClientID) ProtoMessage ¶
func (*ConsumerClientID) ProtoMessage()
func (*ConsumerClientID) Reset ¶
func (m *ConsumerClientID) Reset()
func (*ConsumerClientID) Size ¶
func (m *ConsumerClientID) Size() (n int)
func (*ConsumerClientID) String ¶
func (m *ConsumerClientID) String() string
func (*ConsumerClientID) Unmarshal ¶
func (m *ConsumerClientID) Unmarshal(dAtA []byte) error
func (*ConsumerClientID) XXX_DiscardUnknown ¶
func (m *ConsumerClientID) XXX_DiscardUnknown()
func (*ConsumerClientID) XXX_Marshal ¶
func (m *ConsumerClientID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConsumerClientID) XXX_Merge ¶
func (m *ConsumerClientID) XXX_Merge(src proto.Message)
func (*ConsumerClientID) XXX_Size ¶
func (m *ConsumerClientID) XXX_Size() int
func (*ConsumerClientID) XXX_Unmarshal ¶
func (m *ConsumerClientID) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { // params defines all the parameters of the module. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` PortId string `protobuf:"bytes,2,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` MonitoringInfo *MonitoringInfo `protobuf:"bytes,3,opt,name=monitoring_info,json=monitoringInfo,proto3" json:"monitoring_info,omitempty"` ConnectionChannelId *ConnectionChannelID `protobuf:"bytes,4,opt,name=connection_channel_id,json=connectionChannelId,proto3" json:"connection_channel_id,omitempty"` ConsumerClientId *ConsumerClientID `protobuf:"bytes,5,opt,name=consumer_client_id,json=consumerClientId,proto3" json:"consumer_client_id,omitempty"` }
GenesisState defines the monitoringp module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetConnectionChannelId ¶
func (m *GenesisState) GetConnectionChannelId() *ConnectionChannelID
func (*GenesisState) GetConsumerClientId ¶
func (m *GenesisState) GetConsumerClientId() *ConsumerClientID
func (*GenesisState) GetMonitoringInfo ¶
func (m *GenesisState) GetMonitoringInfo() *MonitoringInfo
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) GetPortId ¶
func (m *GenesisState) GetPortId() string
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 MonitoringInfo ¶
type MonitoringInfo struct { Transmitted bool `protobuf:"varint,1,opt,name=transmitted,proto3" json:"transmitted,omitempty"` SignatureCounts types.SignatureCounts `protobuf:"bytes,2,opt,name=signature_counts,json=signatureCounts,proto3" json:"signature_counts"` }
func (*MonitoringInfo) Descriptor ¶
func (*MonitoringInfo) Descriptor() ([]byte, []int)
func (*MonitoringInfo) GetSignatureCounts ¶
func (m *MonitoringInfo) GetSignatureCounts() types.SignatureCounts
func (*MonitoringInfo) GetTransmitted ¶
func (m *MonitoringInfo) GetTransmitted() bool
func (*MonitoringInfo) Marshal ¶
func (m *MonitoringInfo) Marshal() (dAtA []byte, err error)
func (*MonitoringInfo) MarshalToSizedBuffer ¶
func (m *MonitoringInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MonitoringInfo) ProtoMessage ¶
func (*MonitoringInfo) ProtoMessage()
func (*MonitoringInfo) Reset ¶
func (m *MonitoringInfo) Reset()
func (*MonitoringInfo) Size ¶
func (m *MonitoringInfo) Size() (n int)
func (*MonitoringInfo) String ¶
func (m *MonitoringInfo) String() string
func (*MonitoringInfo) Unmarshal ¶
func (m *MonitoringInfo) Unmarshal(dAtA []byte) error
func (*MonitoringInfo) XXX_DiscardUnknown ¶
func (m *MonitoringInfo) XXX_DiscardUnknown()
func (*MonitoringInfo) XXX_Marshal ¶
func (m *MonitoringInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitoringInfo) XXX_Merge ¶
func (m *MonitoringInfo) XXX_Merge(src proto.Message)
func (*MonitoringInfo) XXX_Size ¶
func (m *MonitoringInfo) XXX_Size() int
func (*MonitoringInfo) XXX_Unmarshal ¶
func (m *MonitoringInfo) XXX_Unmarshal(b []byte) error
type MonitoringpPacketData ¶
type MonitoringpPacketData struct { // Types that are valid to be assigned to Packet: // *MonitoringpPacketData_NoData Packet isMonitoringpPacketData_Packet `protobuf_oneof:"packet"` }
func (*MonitoringpPacketData) Descriptor ¶
func (*MonitoringpPacketData) Descriptor() ([]byte, []int)
func (*MonitoringpPacketData) GetNoData ¶
func (m *MonitoringpPacketData) GetNoData() *NoData
func (*MonitoringpPacketData) GetPacket ¶
func (m *MonitoringpPacketData) GetPacket() isMonitoringpPacketData_Packet
func (*MonitoringpPacketData) Marshal ¶
func (m *MonitoringpPacketData) Marshal() (dAtA []byte, err error)
func (*MonitoringpPacketData) MarshalTo ¶
func (m *MonitoringpPacketData) MarshalTo(dAtA []byte) (int, error)
func (*MonitoringpPacketData) MarshalToSizedBuffer ¶
func (m *MonitoringpPacketData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MonitoringpPacketData) ProtoMessage ¶
func (*MonitoringpPacketData) ProtoMessage()
func (*MonitoringpPacketData) Reset ¶
func (m *MonitoringpPacketData) Reset()
func (*MonitoringpPacketData) Size ¶
func (m *MonitoringpPacketData) Size() (n int)
func (*MonitoringpPacketData) String ¶
func (m *MonitoringpPacketData) String() string
func (*MonitoringpPacketData) Unmarshal ¶
func (m *MonitoringpPacketData) Unmarshal(dAtA []byte) error
func (*MonitoringpPacketData) XXX_DiscardUnknown ¶
func (m *MonitoringpPacketData) XXX_DiscardUnknown()
func (*MonitoringpPacketData) XXX_Marshal ¶
func (m *MonitoringpPacketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitoringpPacketData) XXX_Merge ¶
func (m *MonitoringpPacketData) XXX_Merge(src proto.Message)
func (*MonitoringpPacketData) XXX_OneofWrappers ¶
func (*MonitoringpPacketData) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*MonitoringpPacketData) XXX_Size ¶
func (m *MonitoringpPacketData) XXX_Size() int
func (*MonitoringpPacketData) XXX_Unmarshal ¶
func (m *MonitoringpPacketData) XXX_Unmarshal(b []byte) error
type MonitoringpPacketData_NoData ¶
type MonitoringpPacketData_NoData struct {
NoData *NoData `protobuf:"bytes,1,opt,name=noData,proto3,oneof" json:"noData,omitempty"`
}
func (*MonitoringpPacketData_NoData) MarshalTo ¶
func (m *MonitoringpPacketData_NoData) MarshalTo(dAtA []byte) (int, error)
func (*MonitoringpPacketData_NoData) MarshalToSizedBuffer ¶
func (m *MonitoringpPacketData_NoData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MonitoringpPacketData_NoData) Size ¶
func (m *MonitoringpPacketData_NoData) Size() (n int)
type MsgClient ¶
type MsgClient interface { // UpdateParams defines a (governance) operation for updating the module // parameters. The authority defaults to the x/gov module account. UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgServer ¶
type MsgServer interface { // UpdateParams defines a (governance) operation for updating the module // parameters. The authority defaults to the x/gov module account. UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error) }
MsgServer is the server API for Msg service.
type MsgUpdateParams ¶
type MsgUpdateParams struct { // authority is the address that controls the module (defaults to x/gov unless overwritten). Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"` // params defines the module parameters to update. // // NOTE: All parameters must be supplied. Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"` }
MsgUpdateParams is the Msg/UpdateParams request type.
func (*MsgUpdateParams) Descriptor ¶
func (*MsgUpdateParams) Descriptor() ([]byte, []int)
func (*MsgUpdateParams) GetAuthority ¶
func (m *MsgUpdateParams) GetAuthority() string
func (*MsgUpdateParams) GetParams ¶
func (m *MsgUpdateParams) GetParams() Params
func (*MsgUpdateParams) Marshal ¶
func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)
func (*MsgUpdateParams) MarshalToSizedBuffer ¶
func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateParams) ProtoMessage ¶
func (*MsgUpdateParams) ProtoMessage()
func (*MsgUpdateParams) Reset ¶
func (m *MsgUpdateParams) Reset()
func (*MsgUpdateParams) Size ¶
func (m *MsgUpdateParams) Size() (n int)
func (*MsgUpdateParams) String ¶
func (m *MsgUpdateParams) String() string
func (*MsgUpdateParams) Unmarshal ¶
func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error
func (*MsgUpdateParams) XXX_DiscardUnknown ¶
func (m *MsgUpdateParams) XXX_DiscardUnknown()
func (*MsgUpdateParams) XXX_Marshal ¶
func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateParams) XXX_Merge ¶
func (m *MsgUpdateParams) XXX_Merge(src proto.Message)
func (*MsgUpdateParams) XXX_Size ¶
func (m *MsgUpdateParams) XXX_Size() int
func (*MsgUpdateParams) XXX_Unmarshal ¶
func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error
type MsgUpdateParamsResponse ¶
type MsgUpdateParamsResponse struct { }
MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.
func (*MsgUpdateParamsResponse) Descriptor ¶
func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
func (*MsgUpdateParamsResponse) Marshal ¶
func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)
func (*MsgUpdateParamsResponse) MarshalTo ¶
func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgUpdateParamsResponse) MarshalToSizedBuffer ¶
func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgUpdateParamsResponse) ProtoMessage ¶
func (*MsgUpdateParamsResponse) ProtoMessage()
func (*MsgUpdateParamsResponse) Reset ¶
func (m *MsgUpdateParamsResponse) Reset()
func (*MsgUpdateParamsResponse) Size ¶
func (m *MsgUpdateParamsResponse) Size() (n int)
func (*MsgUpdateParamsResponse) String ¶
func (m *MsgUpdateParamsResponse) String() string
func (*MsgUpdateParamsResponse) Unmarshal ¶
func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error
func (*MsgUpdateParamsResponse) XXX_DiscardUnknown ¶
func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()
func (*MsgUpdateParamsResponse) XXX_Marshal ¶
func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgUpdateParamsResponse) XXX_Merge ¶
func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)
func (*MsgUpdateParamsResponse) XXX_Size ¶
func (m *MsgUpdateParamsResponse) XXX_Size() int
func (*MsgUpdateParamsResponse) XXX_Unmarshal ¶
func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error
type NoData ¶
type NoData struct { }
func (*NoData) Descriptor ¶
func (*NoData) MarshalToSizedBuffer ¶
func (*NoData) ProtoMessage ¶
func (*NoData) ProtoMessage()
func (*NoData) XXX_DiscardUnknown ¶
func (m *NoData) XXX_DiscardUnknown()
func (*NoData) XXX_Marshal ¶
func (*NoData) XXX_Unmarshal ¶
type ParamSubspace ¶
type ParamSubspace interface { Get(context.Context, []byte, interface{}) Set(context.Context, []byte, interface{}) }
ParamSubspace defines the expected Subspace interface for parameters.
type Params ¶
type Params struct { LastBlockHeight int64 `protobuf:"varint,1,opt,name=last_block_height,json=lastBlockHeight,proto3" json:"last_block_height,omitempty"` ConsumerChainId string `protobuf:"bytes,2,opt,name=consumer_chain_id,json=consumerChainId,proto3" json:"consumer_chain_id,omitempty"` ConsumerConsensusState types.ConsensusState `protobuf:"bytes,3,opt,name=consumer_consensus_state,json=consumerConsensusState,proto3" json:"consumer_consensus_state"` ConsumerUnbondingPeriod int64 `` /* 133-byte string literal not displayed */ ConsumerRevisionHeight uint64 `` /* 130-byte string literal not displayed */ }
Params defines the parameters for the module.
func DefaultParams ¶
func DefaultParams() Params
DefaultParams returns a default set of parameters. DefaultParams returns a default set of parameters
func NewParams ¶
func NewParams( lastBlockHeight int64, consumerChainID string, ccs networktypes.ConsensusState, consumerUnbondingpPeriod int64, consumerRevisionHeight uint64, ) Params
NewParams creates a new Params instance.
func (*Params) Descriptor ¶
func (*Params) GetConsumerChainId ¶
func (*Params) GetConsumerConsensusState ¶
func (m *Params) GetConsumerConsensusState() types.ConsensusState
func (*Params) GetConsumerRevisionHeight ¶
func (*Params) GetConsumerUnbondingPeriod ¶
func (*Params) GetLastBlockHeight ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type PortKeeper ¶
type PortKeeper interface {
BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability
}
PortKeeper defines the expected IBC port keeper.
type QueryClient ¶
type QueryClient interface { // Parameters queries the parameters of the module. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) // Queries a MonitoringInfo by index. GetMonitoringInfo(ctx context.Context, in *QueryGetMonitoringInfoRequest, opts ...grpc.CallOption) (*QueryGetMonitoringInfoResponse, error) // Queries a ConnectionChannelID by index. GetConnectionChannelID(ctx context.Context, in *QueryGetConnectionChannelIDRequest, opts ...grpc.CallOption) (*QueryGetConnectionChannelIDResponse, error) // Queries a ConsumerClientID by index. GetConsumerClientID(ctx context.Context, in *QueryGetConsumerClientIDRequest, opts ...grpc.CallOption) (*QueryGetConsumerClientIDResponse, 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 QueryGetConnectionChannelIDRequest ¶
type QueryGetConnectionChannelIDRequest struct { }
func (*QueryGetConnectionChannelIDRequest) Descriptor ¶
func (*QueryGetConnectionChannelIDRequest) Descriptor() ([]byte, []int)
func (*QueryGetConnectionChannelIDRequest) Marshal ¶
func (m *QueryGetConnectionChannelIDRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetConnectionChannelIDRequest) MarshalTo ¶
func (m *QueryGetConnectionChannelIDRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetConnectionChannelIDRequest) MarshalToSizedBuffer ¶
func (m *QueryGetConnectionChannelIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetConnectionChannelIDRequest) ProtoMessage ¶
func (*QueryGetConnectionChannelIDRequest) ProtoMessage()
func (*QueryGetConnectionChannelIDRequest) Reset ¶
func (m *QueryGetConnectionChannelIDRequest) Reset()
func (*QueryGetConnectionChannelIDRequest) Size ¶
func (m *QueryGetConnectionChannelIDRequest) Size() (n int)
func (*QueryGetConnectionChannelIDRequest) String ¶
func (m *QueryGetConnectionChannelIDRequest) String() string
func (*QueryGetConnectionChannelIDRequest) Unmarshal ¶
func (m *QueryGetConnectionChannelIDRequest) Unmarshal(dAtA []byte) error
func (*QueryGetConnectionChannelIDRequest) XXX_DiscardUnknown ¶
func (m *QueryGetConnectionChannelIDRequest) XXX_DiscardUnknown()
func (*QueryGetConnectionChannelIDRequest) XXX_Marshal ¶
func (m *QueryGetConnectionChannelIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetConnectionChannelIDRequest) XXX_Merge ¶
func (m *QueryGetConnectionChannelIDRequest) XXX_Merge(src proto.Message)
func (*QueryGetConnectionChannelIDRequest) XXX_Size ¶
func (m *QueryGetConnectionChannelIDRequest) XXX_Size() int
func (*QueryGetConnectionChannelIDRequest) XXX_Unmarshal ¶
func (m *QueryGetConnectionChannelIDRequest) XXX_Unmarshal(b []byte) error
type QueryGetConnectionChannelIDResponse ¶
type QueryGetConnectionChannelIDResponse struct {
ConnectionChannelId ConnectionChannelID `protobuf:"bytes,1,opt,name=connection_channel_id,json=connectionChannelId,proto3" json:"connection_channel_id"`
}
func (*QueryGetConnectionChannelIDResponse) Descriptor ¶
func (*QueryGetConnectionChannelIDResponse) Descriptor() ([]byte, []int)
func (*QueryGetConnectionChannelIDResponse) GetConnectionChannelId ¶
func (m *QueryGetConnectionChannelIDResponse) GetConnectionChannelId() ConnectionChannelID
func (*QueryGetConnectionChannelIDResponse) Marshal ¶
func (m *QueryGetConnectionChannelIDResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetConnectionChannelIDResponse) MarshalTo ¶
func (m *QueryGetConnectionChannelIDResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetConnectionChannelIDResponse) MarshalToSizedBuffer ¶
func (m *QueryGetConnectionChannelIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetConnectionChannelIDResponse) ProtoMessage ¶
func (*QueryGetConnectionChannelIDResponse) ProtoMessage()
func (*QueryGetConnectionChannelIDResponse) Reset ¶
func (m *QueryGetConnectionChannelIDResponse) Reset()
func (*QueryGetConnectionChannelIDResponse) Size ¶
func (m *QueryGetConnectionChannelIDResponse) Size() (n int)
func (*QueryGetConnectionChannelIDResponse) String ¶
func (m *QueryGetConnectionChannelIDResponse) String() string
func (*QueryGetConnectionChannelIDResponse) Unmarshal ¶
func (m *QueryGetConnectionChannelIDResponse) Unmarshal(dAtA []byte) error
func (*QueryGetConnectionChannelIDResponse) XXX_DiscardUnknown ¶
func (m *QueryGetConnectionChannelIDResponse) XXX_DiscardUnknown()
func (*QueryGetConnectionChannelIDResponse) XXX_Marshal ¶
func (m *QueryGetConnectionChannelIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetConnectionChannelIDResponse) XXX_Merge ¶
func (m *QueryGetConnectionChannelIDResponse) XXX_Merge(src proto.Message)
func (*QueryGetConnectionChannelIDResponse) XXX_Size ¶
func (m *QueryGetConnectionChannelIDResponse) XXX_Size() int
func (*QueryGetConnectionChannelIDResponse) XXX_Unmarshal ¶
func (m *QueryGetConnectionChannelIDResponse) XXX_Unmarshal(b []byte) error
type QueryGetConsumerClientIDRequest ¶
type QueryGetConsumerClientIDRequest struct { }
func (*QueryGetConsumerClientIDRequest) Descriptor ¶
func (*QueryGetConsumerClientIDRequest) Descriptor() ([]byte, []int)
func (*QueryGetConsumerClientIDRequest) Marshal ¶
func (m *QueryGetConsumerClientIDRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetConsumerClientIDRequest) MarshalTo ¶
func (m *QueryGetConsumerClientIDRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetConsumerClientIDRequest) MarshalToSizedBuffer ¶
func (m *QueryGetConsumerClientIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetConsumerClientIDRequest) ProtoMessage ¶
func (*QueryGetConsumerClientIDRequest) ProtoMessage()
func (*QueryGetConsumerClientIDRequest) Reset ¶
func (m *QueryGetConsumerClientIDRequest) Reset()
func (*QueryGetConsumerClientIDRequest) Size ¶
func (m *QueryGetConsumerClientIDRequest) Size() (n int)
func (*QueryGetConsumerClientIDRequest) String ¶
func (m *QueryGetConsumerClientIDRequest) String() string
func (*QueryGetConsumerClientIDRequest) Unmarshal ¶
func (m *QueryGetConsumerClientIDRequest) Unmarshal(dAtA []byte) error
func (*QueryGetConsumerClientIDRequest) XXX_DiscardUnknown ¶
func (m *QueryGetConsumerClientIDRequest) XXX_DiscardUnknown()
func (*QueryGetConsumerClientIDRequest) XXX_Marshal ¶
func (m *QueryGetConsumerClientIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetConsumerClientIDRequest) XXX_Merge ¶
func (m *QueryGetConsumerClientIDRequest) XXX_Merge(src proto.Message)
func (*QueryGetConsumerClientIDRequest) XXX_Size ¶
func (m *QueryGetConsumerClientIDRequest) XXX_Size() int
func (*QueryGetConsumerClientIDRequest) XXX_Unmarshal ¶
func (m *QueryGetConsumerClientIDRequest) XXX_Unmarshal(b []byte) error
type QueryGetConsumerClientIDResponse ¶
type QueryGetConsumerClientIDResponse struct {
ConsumerClientId ConsumerClientID `protobuf:"bytes,1,opt,name=consumer_client_id,json=consumerClientId,proto3" json:"consumer_client_id"`
}
func (*QueryGetConsumerClientIDResponse) Descriptor ¶
func (*QueryGetConsumerClientIDResponse) Descriptor() ([]byte, []int)
func (*QueryGetConsumerClientIDResponse) GetConsumerClientId ¶
func (m *QueryGetConsumerClientIDResponse) GetConsumerClientId() ConsumerClientID
func (*QueryGetConsumerClientIDResponse) Marshal ¶
func (m *QueryGetConsumerClientIDResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetConsumerClientIDResponse) MarshalTo ¶
func (m *QueryGetConsumerClientIDResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetConsumerClientIDResponse) MarshalToSizedBuffer ¶
func (m *QueryGetConsumerClientIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetConsumerClientIDResponse) ProtoMessage ¶
func (*QueryGetConsumerClientIDResponse) ProtoMessage()
func (*QueryGetConsumerClientIDResponse) Reset ¶
func (m *QueryGetConsumerClientIDResponse) Reset()
func (*QueryGetConsumerClientIDResponse) Size ¶
func (m *QueryGetConsumerClientIDResponse) Size() (n int)
func (*QueryGetConsumerClientIDResponse) String ¶
func (m *QueryGetConsumerClientIDResponse) String() string
func (*QueryGetConsumerClientIDResponse) Unmarshal ¶
func (m *QueryGetConsumerClientIDResponse) Unmarshal(dAtA []byte) error
func (*QueryGetConsumerClientIDResponse) XXX_DiscardUnknown ¶
func (m *QueryGetConsumerClientIDResponse) XXX_DiscardUnknown()
func (*QueryGetConsumerClientIDResponse) XXX_Marshal ¶
func (m *QueryGetConsumerClientIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetConsumerClientIDResponse) XXX_Merge ¶
func (m *QueryGetConsumerClientIDResponse) XXX_Merge(src proto.Message)
func (*QueryGetConsumerClientIDResponse) XXX_Size ¶
func (m *QueryGetConsumerClientIDResponse) XXX_Size() int
func (*QueryGetConsumerClientIDResponse) XXX_Unmarshal ¶
func (m *QueryGetConsumerClientIDResponse) XXX_Unmarshal(b []byte) error
type QueryGetMonitoringInfoRequest ¶
type QueryGetMonitoringInfoRequest struct { }
func (*QueryGetMonitoringInfoRequest) Descriptor ¶
func (*QueryGetMonitoringInfoRequest) Descriptor() ([]byte, []int)
func (*QueryGetMonitoringInfoRequest) Marshal ¶
func (m *QueryGetMonitoringInfoRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetMonitoringInfoRequest) MarshalTo ¶
func (m *QueryGetMonitoringInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetMonitoringInfoRequest) MarshalToSizedBuffer ¶
func (m *QueryGetMonitoringInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetMonitoringInfoRequest) ProtoMessage ¶
func (*QueryGetMonitoringInfoRequest) ProtoMessage()
func (*QueryGetMonitoringInfoRequest) Reset ¶
func (m *QueryGetMonitoringInfoRequest) Reset()
func (*QueryGetMonitoringInfoRequest) Size ¶
func (m *QueryGetMonitoringInfoRequest) Size() (n int)
func (*QueryGetMonitoringInfoRequest) String ¶
func (m *QueryGetMonitoringInfoRequest) String() string
func (*QueryGetMonitoringInfoRequest) Unmarshal ¶
func (m *QueryGetMonitoringInfoRequest) Unmarshal(dAtA []byte) error
func (*QueryGetMonitoringInfoRequest) XXX_DiscardUnknown ¶
func (m *QueryGetMonitoringInfoRequest) XXX_DiscardUnknown()
func (*QueryGetMonitoringInfoRequest) XXX_Marshal ¶
func (m *QueryGetMonitoringInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetMonitoringInfoRequest) XXX_Merge ¶
func (m *QueryGetMonitoringInfoRequest) XXX_Merge(src proto.Message)
func (*QueryGetMonitoringInfoRequest) XXX_Size ¶
func (m *QueryGetMonitoringInfoRequest) XXX_Size() int
func (*QueryGetMonitoringInfoRequest) XXX_Unmarshal ¶
func (m *QueryGetMonitoringInfoRequest) XXX_Unmarshal(b []byte) error
type QueryGetMonitoringInfoResponse ¶
type QueryGetMonitoringInfoResponse struct {
MonitoringInfo MonitoringInfo `protobuf:"bytes,1,opt,name=monitoring_info,json=monitoringInfo,proto3" json:"monitoring_info"`
}
func (*QueryGetMonitoringInfoResponse) Descriptor ¶
func (*QueryGetMonitoringInfoResponse) Descriptor() ([]byte, []int)
func (*QueryGetMonitoringInfoResponse) GetMonitoringInfo ¶
func (m *QueryGetMonitoringInfoResponse) GetMonitoringInfo() MonitoringInfo
func (*QueryGetMonitoringInfoResponse) Marshal ¶
func (m *QueryGetMonitoringInfoResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetMonitoringInfoResponse) MarshalTo ¶
func (m *QueryGetMonitoringInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetMonitoringInfoResponse) MarshalToSizedBuffer ¶
func (m *QueryGetMonitoringInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetMonitoringInfoResponse) ProtoMessage ¶
func (*QueryGetMonitoringInfoResponse) ProtoMessage()
func (*QueryGetMonitoringInfoResponse) Reset ¶
func (m *QueryGetMonitoringInfoResponse) Reset()
func (*QueryGetMonitoringInfoResponse) Size ¶
func (m *QueryGetMonitoringInfoResponse) Size() (n int)
func (*QueryGetMonitoringInfoResponse) String ¶
func (m *QueryGetMonitoringInfoResponse) String() string
func (*QueryGetMonitoringInfoResponse) Unmarshal ¶
func (m *QueryGetMonitoringInfoResponse) Unmarshal(dAtA []byte) error
func (*QueryGetMonitoringInfoResponse) XXX_DiscardUnknown ¶
func (m *QueryGetMonitoringInfoResponse) XXX_DiscardUnknown()
func (*QueryGetMonitoringInfoResponse) XXX_Marshal ¶
func (m *QueryGetMonitoringInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetMonitoringInfoResponse) XXX_Merge ¶
func (m *QueryGetMonitoringInfoResponse) XXX_Merge(src proto.Message)
func (*QueryGetMonitoringInfoResponse) XXX_Size ¶
func (m *QueryGetMonitoringInfoResponse) XXX_Size() int
func (*QueryGetMonitoringInfoResponse) XXX_Unmarshal ¶
func (m *QueryGetMonitoringInfoResponse) XXX_Unmarshal(b []byte) error
type QueryParamsRequest ¶
type QueryParamsRequest struct { }
QueryParamsRequest is request type for the Query/Params RPC method.
func (*QueryParamsRequest) Descriptor ¶
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
func (*QueryParamsRequest) Marshal ¶
func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
func (*QueryParamsRequest) MarshalTo ¶
func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsRequest) MarshalToSizedBuffer ¶
func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsRequest) ProtoMessage ¶
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) Reset ¶
func (m *QueryParamsRequest) Reset()
func (*QueryParamsRequest) Size ¶
func (m *QueryParamsRequest) Size() (n int)
func (*QueryParamsRequest) String ¶
func (m *QueryParamsRequest) String() string
func (*QueryParamsRequest) Unmarshal ¶
func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
func (*QueryParamsRequest) XXX_DiscardUnknown ¶
func (m *QueryParamsRequest) XXX_DiscardUnknown()
func (*QueryParamsRequest) XXX_Marshal ¶
func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsRequest) XXX_Merge ¶
func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
func (*QueryParamsRequest) XXX_Size ¶
func (m *QueryParamsRequest) XXX_Size() int
func (*QueryParamsRequest) XXX_Unmarshal ¶
func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
type QueryParamsResponse ¶
type QueryParamsResponse struct { // params holds all the parameters of this module. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` }
QueryParamsResponse is response type for the Query/Params RPC method.
func (*QueryParamsResponse) Descriptor ¶
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
func (*QueryParamsResponse) GetParams ¶
func (m *QueryParamsResponse) GetParams() Params
func (*QueryParamsResponse) Marshal ¶
func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
func (*QueryParamsResponse) MarshalTo ¶
func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsResponse) MarshalToSizedBuffer ¶
func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsResponse) ProtoMessage ¶
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) Reset ¶
func (m *QueryParamsResponse) Reset()
func (*QueryParamsResponse) Size ¶
func (m *QueryParamsResponse) Size() (n int)
func (*QueryParamsResponse) String ¶
func (m *QueryParamsResponse) String() string
func (*QueryParamsResponse) Unmarshal ¶
func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
func (*QueryParamsResponse) XXX_DiscardUnknown ¶
func (m *QueryParamsResponse) XXX_DiscardUnknown()
func (*QueryParamsResponse) XXX_Marshal ¶
func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsResponse) XXX_Merge ¶
func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
func (*QueryParamsResponse) XXX_Size ¶
func (m *QueryParamsResponse) XXX_Size() int
func (*QueryParamsResponse) XXX_Unmarshal ¶
func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Parameters queries the parameters of the module. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) // Queries a MonitoringInfo by index. GetMonitoringInfo(context.Context, *QueryGetMonitoringInfoRequest) (*QueryGetMonitoringInfoResponse, error) // Queries a ConnectionChannelID by index. GetConnectionChannelID(context.Context, *QueryGetConnectionChannelIDRequest) (*QueryGetConnectionChannelIDResponse, error) // Queries a ConsumerClientID by index. GetConsumerClientID(context.Context, *QueryGetConsumerClientIDRequest) (*QueryGetConsumerClientIDResponse, error) }
QueryServer is the server API for Query service.
type ScopedKeeper ¶
type ScopedKeeper interface { GetCapability(ctx sdk.Context, name string) (*capabilitytypes.Capability, bool) AuthenticateCapability(ctx sdk.Context, cap *capabilitytypes.Capability, name string) bool ClaimCapability(ctx sdk.Context, cap *capabilitytypes.Capability, name string) error }
ScopedKeeper defines the expected IBC scoped keeper.
type StakingKeeper ¶
type StakingKeeper interface {
GetValidatorByConsAddr(ctx context.Context, consAddr sdk.ConsAddress) (stakingtypes.Validator, error)
}
StakingKeeper defines the expected interface to retrieve the operator address from a consensus address
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) UpdateParams ¶
func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) GetConnectionChannelID ¶
func (*UnimplementedQueryServer) GetConnectionChannelID(ctx context.Context, req *QueryGetConnectionChannelIDRequest) (*QueryGetConnectionChannelIDResponse, error)
func (*UnimplementedQueryServer) GetConsumerClientID ¶
func (*UnimplementedQueryServer) GetConsumerClientID(ctx context.Context, req *QueryGetConsumerClientIDRequest) (*QueryGetConsumerClientIDResponse, error)
func (*UnimplementedQueryServer) GetMonitoringInfo ¶
func (*UnimplementedQueryServer) GetMonitoringInfo(ctx context.Context, req *QueryGetMonitoringInfoRequest) (*QueryGetMonitoringInfoResponse, error)
func (*UnimplementedQueryServer) Params ¶
func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)