Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func ActivePlanForProviderKey(address hubtypes.ProvAddress, id uint64) []byte
- func ActivePlanKey(id uint64) []byte
- func AddressFromNodeForPlanKey(key []byte) hubtypes.NodeAddress
- func CountForNodeByProviderKey(p hubtypes.ProvAddress, n hubtypes.NodeAddress) []byte
- func GetActivePlanForProviderKeyPrefix(address hubtypes.ProvAddress) []byte
- func GetInactivePlanForProviderKeyPrefix(address hubtypes.ProvAddress) []byte
- func GetNodeForPlanKeyPrefix(id uint64) []byte
- func IDFromStatusPlanForProviderKey(key []byte) uint64
- func IDFromStatusPlanKey(key []byte) uint64
- func InactivePlanForProviderKey(address hubtypes.ProvAddress, id uint64) []byte
- func InactivePlanKey(id uint64) []byte
- func NodeForPlanKey(id uint64, address hubtypes.NodeAddress) []byte
- func PlanKey(id uint64) []byte
- func RegisterInterfaces(registry types.InterfaceRegistry)
- func RegisterLegacyAminoCodec(_ *codec.LegacyAmino)
- func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)
- func RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error
- func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error
- func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)
- func ValidateGenesis(state GenesisState) error
- type EventAddNodeForPlan
- func (*EventAddNodeForPlan) Descriptor() ([]byte, []int)
- func (m *EventAddNodeForPlan) Marshal() (dAtA []byte, err error)
- func (m *EventAddNodeForPlan) MarshalTo(dAtA []byte) (int, error)
- func (m *EventAddNodeForPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventAddNodeForPlan) ProtoMessage()
- func (m *EventAddNodeForPlan) Reset()
- func (m *EventAddNodeForPlan) Size() (n int)
- func (m *EventAddNodeForPlan) String() string
- func (m *EventAddNodeForPlan) Unmarshal(dAtA []byte) error
- func (m *EventAddNodeForPlan) XXX_DiscardUnknown()
- func (m *EventAddNodeForPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventAddNodeForPlan) XXX_Merge(src proto.Message)
- func (m *EventAddNodeForPlan) XXX_Size() int
- func (m *EventAddNodeForPlan) XXX_Unmarshal(b []byte) error
- type EventAddPlan
- func (*EventAddPlan) Descriptor() ([]byte, []int)
- func (m *EventAddPlan) Marshal() (dAtA []byte, err error)
- func (m *EventAddPlan) MarshalTo(dAtA []byte) (int, error)
- func (m *EventAddPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventAddPlan) ProtoMessage()
- func (m *EventAddPlan) Reset()
- func (m *EventAddPlan) Size() (n int)
- func (m *EventAddPlan) String() string
- func (m *EventAddPlan) Unmarshal(dAtA []byte) error
- func (m *EventAddPlan) XXX_DiscardUnknown()
- func (m *EventAddPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventAddPlan) XXX_Merge(src proto.Message)
- func (m *EventAddPlan) XXX_Size() int
- func (m *EventAddPlan) XXX_Unmarshal(b []byte) error
- type EventModule
- func (*EventModule) Descriptor() ([]byte, []int)
- func (m *EventModule) Marshal() (dAtA []byte, err error)
- func (m *EventModule) MarshalTo(dAtA []byte) (int, error)
- func (m *EventModule) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventModule) ProtoMessage()
- func (m *EventModule) Reset()
- func (m *EventModule) Size() (n int)
- func (m *EventModule) String() string
- func (m *EventModule) Unmarshal(dAtA []byte) error
- func (m *EventModule) XXX_DiscardUnknown()
- func (m *EventModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventModule) XXX_Merge(src proto.Message)
- func (m *EventModule) XXX_Size() int
- func (m *EventModule) XXX_Unmarshal(b []byte) error
- type EventRemoveNodeForPlan
- func (*EventRemoveNodeForPlan) Descriptor() ([]byte, []int)
- func (m *EventRemoveNodeForPlan) Marshal() (dAtA []byte, err error)
- func (m *EventRemoveNodeForPlan) MarshalTo(dAtA []byte) (int, error)
- func (m *EventRemoveNodeForPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventRemoveNodeForPlan) ProtoMessage()
- func (m *EventRemoveNodeForPlan) Reset()
- func (m *EventRemoveNodeForPlan) Size() (n int)
- func (m *EventRemoveNodeForPlan) String() string
- func (m *EventRemoveNodeForPlan) Unmarshal(dAtA []byte) error
- func (m *EventRemoveNodeForPlan) XXX_DiscardUnknown()
- func (m *EventRemoveNodeForPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventRemoveNodeForPlan) XXX_Merge(src proto.Message)
- func (m *EventRemoveNodeForPlan) XXX_Size() int
- func (m *EventRemoveNodeForPlan) XXX_Unmarshal(b []byte) error
- type EventSetPlanCount
- func (*EventSetPlanCount) Descriptor() ([]byte, []int)
- func (m *EventSetPlanCount) Marshal() (dAtA []byte, err error)
- func (m *EventSetPlanCount) MarshalTo(dAtA []byte) (int, error)
- func (m *EventSetPlanCount) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventSetPlanCount) ProtoMessage()
- func (m *EventSetPlanCount) Reset()
- func (m *EventSetPlanCount) Size() (n int)
- func (m *EventSetPlanCount) String() string
- func (m *EventSetPlanCount) Unmarshal(dAtA []byte) error
- func (m *EventSetPlanCount) XXX_DiscardUnknown()
- func (m *EventSetPlanCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventSetPlanCount) XXX_Merge(src proto.Message)
- func (m *EventSetPlanCount) XXX_Size() int
- func (m *EventSetPlanCount) XXX_Unmarshal(b []byte) error
- type EventSetPlanStatus
- func (*EventSetPlanStatus) Descriptor() ([]byte, []int)
- func (m *EventSetPlanStatus) Marshal() (dAtA []byte, err error)
- func (m *EventSetPlanStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *EventSetPlanStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventSetPlanStatus) ProtoMessage()
- func (m *EventSetPlanStatus) Reset()
- func (m *EventSetPlanStatus) Size() (n int)
- func (m *EventSetPlanStatus) String() string
- func (m *EventSetPlanStatus) Unmarshal(dAtA []byte) error
- func (m *EventSetPlanStatus) XXX_DiscardUnknown()
- func (m *EventSetPlanStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventSetPlanStatus) XXX_Merge(src proto.Message)
- func (m *EventSetPlanStatus) XXX_Size() int
- func (m *EventSetPlanStatus) XXX_Unmarshal(b []byte) error
- type GenesisPlan
- func (*GenesisPlan) Descriptor() ([]byte, []int)
- func (m *GenesisPlan) Marshal() (dAtA []byte, err error)
- func (m *GenesisPlan) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisPlan) ProtoMessage()
- func (m *GenesisPlan) Reset()
- func (m *GenesisPlan) Size() (n int)
- func (m *GenesisPlan) String() string
- func (m *GenesisPlan) Unmarshal(dAtA []byte) error
- func (m *GenesisPlan) XXX_DiscardUnknown()
- func (m *GenesisPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisPlan) XXX_Merge(src proto.Message)
- func (m *GenesisPlan) XXX_Size() int
- func (m *GenesisPlan) XXX_Unmarshal(b []byte) error
- type GenesisPlans
- type GenesisState
- type MsgAddNodeRequest
- func (*MsgAddNodeRequest) Descriptor() ([]byte, []int)
- func (m *MsgAddNodeRequest) GetSignBytes() []byte
- func (m *MsgAddNodeRequest) GetSigners() []sdk.AccAddress
- func (m *MsgAddNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *MsgAddNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAddNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAddNodeRequest) ProtoMessage()
- func (m *MsgAddNodeRequest) Reset()
- func (m *MsgAddNodeRequest) Route() string
- func (m *MsgAddNodeRequest) Size() (n int)
- func (m *MsgAddNodeRequest) String() string
- func (m *MsgAddNodeRequest) Type() string
- func (m *MsgAddNodeRequest) Unmarshal(dAtA []byte) error
- func (m *MsgAddNodeRequest) ValidateBasic() error
- func (m *MsgAddNodeRequest) XXX_DiscardUnknown()
- func (m *MsgAddNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAddNodeRequest) XXX_Merge(src proto.Message)
- func (m *MsgAddNodeRequest) XXX_Size() int
- func (m *MsgAddNodeRequest) XXX_Unmarshal(b []byte) error
- type MsgAddNodeResponse
- func (*MsgAddNodeResponse) Descriptor() ([]byte, []int)
- func (m *MsgAddNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAddNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAddNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAddNodeResponse) ProtoMessage()
- func (m *MsgAddNodeResponse) Reset()
- func (m *MsgAddNodeResponse) Size() (n int)
- func (m *MsgAddNodeResponse) String() string
- func (m *MsgAddNodeResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAddNodeResponse) XXX_DiscardUnknown()
- func (m *MsgAddNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAddNodeResponse) XXX_Merge(src proto.Message)
- func (m *MsgAddNodeResponse) XXX_Size() int
- func (m *MsgAddNodeResponse) XXX_Unmarshal(b []byte) error
- type MsgAddRequest
- func (*MsgAddRequest) Descriptor() ([]byte, []int)
- func (m *MsgAddRequest) GetSignBytes() []byte
- func (m *MsgAddRequest) GetSigners() []sdk.AccAddress
- func (m *MsgAddRequest) Marshal() (dAtA []byte, err error)
- func (m *MsgAddRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAddRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAddRequest) ProtoMessage()
- func (m *MsgAddRequest) Reset()
- func (m *MsgAddRequest) Route() string
- func (m *MsgAddRequest) Size() (n int)
- func (m *MsgAddRequest) String() string
- func (m *MsgAddRequest) Type() string
- func (m *MsgAddRequest) Unmarshal(dAtA []byte) error
- func (m *MsgAddRequest) ValidateBasic() error
- func (m *MsgAddRequest) XXX_DiscardUnknown()
- func (m *MsgAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAddRequest) XXX_Merge(src proto.Message)
- func (m *MsgAddRequest) XXX_Size() int
- func (m *MsgAddRequest) XXX_Unmarshal(b []byte) error
- type MsgAddResponse
- func (*MsgAddResponse) Descriptor() ([]byte, []int)
- func (m *MsgAddResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAddResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAddResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAddResponse) ProtoMessage()
- func (m *MsgAddResponse) Reset()
- func (m *MsgAddResponse) Size() (n int)
- func (m *MsgAddResponse) String() string
- func (m *MsgAddResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAddResponse) XXX_DiscardUnknown()
- func (m *MsgAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAddResponse) XXX_Merge(src proto.Message)
- func (m *MsgAddResponse) XXX_Size() int
- func (m *MsgAddResponse) XXX_Unmarshal(b []byte) error
- type MsgRemoveNodeRequest
- func (*MsgRemoveNodeRequest) Descriptor() ([]byte, []int)
- func (m *MsgRemoveNodeRequest) GetSignBytes() []byte
- func (m *MsgRemoveNodeRequest) GetSigners() []sdk.AccAddress
- func (m *MsgRemoveNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *MsgRemoveNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRemoveNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRemoveNodeRequest) ProtoMessage()
- func (m *MsgRemoveNodeRequest) Reset()
- func (m *MsgRemoveNodeRequest) Route() string
- func (m *MsgRemoveNodeRequest) Size() (n int)
- func (m *MsgRemoveNodeRequest) String() string
- func (m *MsgRemoveNodeRequest) Type() string
- func (m *MsgRemoveNodeRequest) Unmarshal(dAtA []byte) error
- func (m *MsgRemoveNodeRequest) ValidateBasic() error
- func (m *MsgRemoveNodeRequest) XXX_DiscardUnknown()
- func (m *MsgRemoveNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRemoveNodeRequest) XXX_Merge(src proto.Message)
- func (m *MsgRemoveNodeRequest) XXX_Size() int
- func (m *MsgRemoveNodeRequest) XXX_Unmarshal(b []byte) error
- type MsgRemoveNodeResponse
- func (*MsgRemoveNodeResponse) Descriptor() ([]byte, []int)
- func (m *MsgRemoveNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgRemoveNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRemoveNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRemoveNodeResponse) ProtoMessage()
- func (m *MsgRemoveNodeResponse) Reset()
- func (m *MsgRemoveNodeResponse) Size() (n int)
- func (m *MsgRemoveNodeResponse) String() string
- func (m *MsgRemoveNodeResponse) Unmarshal(dAtA []byte) error
- func (m *MsgRemoveNodeResponse) XXX_DiscardUnknown()
- func (m *MsgRemoveNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRemoveNodeResponse) XXX_Merge(src proto.Message)
- func (m *MsgRemoveNodeResponse) XXX_Size() int
- func (m *MsgRemoveNodeResponse) XXX_Unmarshal(b []byte) error
- type MsgServiceClient
- type MsgServiceServer
- type MsgSetStatusRequest
- func (*MsgSetStatusRequest) Descriptor() ([]byte, []int)
- func (m *MsgSetStatusRequest) GetSignBytes() []byte
- func (m *MsgSetStatusRequest) GetSigners() []sdk.AccAddress
- func (m *MsgSetStatusRequest) Marshal() (dAtA []byte, err error)
- func (m *MsgSetStatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSetStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSetStatusRequest) ProtoMessage()
- func (m *MsgSetStatusRequest) Reset()
- func (m *MsgSetStatusRequest) Route() string
- func (m *MsgSetStatusRequest) Size() (n int)
- func (m *MsgSetStatusRequest) String() string
- func (m *MsgSetStatusRequest) Type() string
- func (m *MsgSetStatusRequest) Unmarshal(dAtA []byte) error
- func (m *MsgSetStatusRequest) ValidateBasic() error
- func (m *MsgSetStatusRequest) XXX_DiscardUnknown()
- func (m *MsgSetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSetStatusRequest) XXX_Merge(src proto.Message)
- func (m *MsgSetStatusRequest) XXX_Size() int
- func (m *MsgSetStatusRequest) XXX_Unmarshal(b []byte) error
- type MsgSetStatusResponse
- func (*MsgSetStatusResponse) Descriptor() ([]byte, []int)
- func (m *MsgSetStatusResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgSetStatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSetStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSetStatusResponse) ProtoMessage()
- func (m *MsgSetStatusResponse) Reset()
- func (m *MsgSetStatusResponse) Size() (n int)
- func (m *MsgSetStatusResponse) String() string
- func (m *MsgSetStatusResponse) Unmarshal(dAtA []byte) error
- func (m *MsgSetStatusResponse) XXX_DiscardUnknown()
- func (m *MsgSetStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSetStatusResponse) XXX_Merge(src proto.Message)
- func (m *MsgSetStatusResponse) XXX_Size() int
- func (m *MsgSetStatusResponse) XXX_Unmarshal(b []byte) error
- type Plan
- func (*Plan) Descriptor() ([]byte, []int)
- func (p *Plan) GetProvider() hubtypes.ProvAddress
- func (m *Plan) Marshal() (dAtA []byte, err error)
- func (m *Plan) MarshalTo(dAtA []byte) (int, error)
- func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (p *Plan) PriceForDenom(d string) (sdk.Coin, bool)
- func (*Plan) ProtoMessage()
- func (m *Plan) Reset()
- func (m *Plan) Size() (n int)
- func (m *Plan) String() string
- func (m *Plan) Unmarshal(dAtA []byte) error
- func (p *Plan) Validate() error
- func (m *Plan) XXX_DiscardUnknown()
- func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Plan) XXX_Merge(src proto.Message)
- func (m *Plan) XXX_Size() int
- func (m *Plan) XXX_Unmarshal(b []byte) error
- type Plans
- type QueryNodesForPlanRequest
- func (*QueryNodesForPlanRequest) Descriptor() ([]byte, []int)
- func (m *QueryNodesForPlanRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryNodesForPlanRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryNodesForPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryNodesForPlanRequest) ProtoMessage()
- func (m *QueryNodesForPlanRequest) Reset()
- func (m *QueryNodesForPlanRequest) Size() (n int)
- func (m *QueryNodesForPlanRequest) String() string
- func (m *QueryNodesForPlanRequest) Unmarshal(dAtA []byte) error
- func (m *QueryNodesForPlanRequest) XXX_DiscardUnknown()
- func (m *QueryNodesForPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryNodesForPlanRequest) XXX_Merge(src proto.Message)
- func (m *QueryNodesForPlanRequest) XXX_Size() int
- func (m *QueryNodesForPlanRequest) XXX_Unmarshal(b []byte) error
- type QueryNodesForPlanResponse
- func (*QueryNodesForPlanResponse) Descriptor() ([]byte, []int)
- func (m *QueryNodesForPlanResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryNodesForPlanResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryNodesForPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryNodesForPlanResponse) ProtoMessage()
- func (m *QueryNodesForPlanResponse) Reset()
- func (m *QueryNodesForPlanResponse) Size() (n int)
- func (m *QueryNodesForPlanResponse) String() string
- func (m *QueryNodesForPlanResponse) Unmarshal(dAtA []byte) error
- func (m *QueryNodesForPlanResponse) XXX_DiscardUnknown()
- func (m *QueryNodesForPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryNodesForPlanResponse) XXX_Merge(src proto.Message)
- func (m *QueryNodesForPlanResponse) XXX_Size() int
- func (m *QueryNodesForPlanResponse) XXX_Unmarshal(b []byte) error
- type QueryPlanRequest
- func (*QueryPlanRequest) Descriptor() ([]byte, []int)
- func (m *QueryPlanRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPlanRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPlanRequest) ProtoMessage()
- func (m *QueryPlanRequest) Reset()
- func (m *QueryPlanRequest) Size() (n int)
- func (m *QueryPlanRequest) String() string
- func (m *QueryPlanRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPlanRequest) XXX_DiscardUnknown()
- func (m *QueryPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPlanRequest) XXX_Merge(src proto.Message)
- func (m *QueryPlanRequest) XXX_Size() int
- func (m *QueryPlanRequest) XXX_Unmarshal(b []byte) error
- type QueryPlanResponse
- func (*QueryPlanResponse) Descriptor() ([]byte, []int)
- func (m *QueryPlanResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPlanResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPlanResponse) ProtoMessage()
- func (m *QueryPlanResponse) Reset()
- func (m *QueryPlanResponse) Size() (n int)
- func (m *QueryPlanResponse) String() string
- func (m *QueryPlanResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPlanResponse) XXX_DiscardUnknown()
- func (m *QueryPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPlanResponse) XXX_Merge(src proto.Message)
- func (m *QueryPlanResponse) XXX_Size() int
- func (m *QueryPlanResponse) XXX_Unmarshal(b []byte) error
- type QueryPlansForProviderRequest
- func (*QueryPlansForProviderRequest) Descriptor() ([]byte, []int)
- func (m *QueryPlansForProviderRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPlansForProviderRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPlansForProviderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPlansForProviderRequest) ProtoMessage()
- func (m *QueryPlansForProviderRequest) Reset()
- func (m *QueryPlansForProviderRequest) Size() (n int)
- func (m *QueryPlansForProviderRequest) String() string
- func (m *QueryPlansForProviderRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPlansForProviderRequest) XXX_DiscardUnknown()
- func (m *QueryPlansForProviderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPlansForProviderRequest) XXX_Merge(src proto.Message)
- func (m *QueryPlansForProviderRequest) XXX_Size() int
- func (m *QueryPlansForProviderRequest) XXX_Unmarshal(b []byte) error
- type QueryPlansForProviderResponse
- func (*QueryPlansForProviderResponse) Descriptor() ([]byte, []int)
- func (m *QueryPlansForProviderResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPlansForProviderResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPlansForProviderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPlansForProviderResponse) ProtoMessage()
- func (m *QueryPlansForProviderResponse) Reset()
- func (m *QueryPlansForProviderResponse) Size() (n int)
- func (m *QueryPlansForProviderResponse) String() string
- func (m *QueryPlansForProviderResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPlansForProviderResponse) XXX_DiscardUnknown()
- func (m *QueryPlansForProviderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPlansForProviderResponse) XXX_Merge(src proto.Message)
- func (m *QueryPlansForProviderResponse) XXX_Size() int
- func (m *QueryPlansForProviderResponse) XXX_Unmarshal(b []byte) error
- type QueryPlansRequest
- func (*QueryPlansRequest) Descriptor() ([]byte, []int)
- func (m *QueryPlansRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPlansRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPlansRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPlansRequest) ProtoMessage()
- func (m *QueryPlansRequest) Reset()
- func (m *QueryPlansRequest) Size() (n int)
- func (m *QueryPlansRequest) String() string
- func (m *QueryPlansRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPlansRequest) XXX_DiscardUnknown()
- func (m *QueryPlansRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPlansRequest) XXX_Merge(src proto.Message)
- func (m *QueryPlansRequest) XXX_Size() int
- func (m *QueryPlansRequest) XXX_Unmarshal(b []byte) error
- type QueryPlansResponse
- func (*QueryPlansResponse) Descriptor() ([]byte, []int)
- func (m *QueryPlansResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPlansResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPlansResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPlansResponse) ProtoMessage()
- func (m *QueryPlansResponse) Reset()
- func (m *QueryPlansResponse) Size() (n int)
- func (m *QueryPlansResponse) String() string
- func (m *QueryPlansResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPlansResponse) XXX_DiscardUnknown()
- func (m *QueryPlansResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPlansResponse) XXX_Merge(src proto.Message)
- func (m *QueryPlansResponse) XXX_Size() int
- func (m *QueryPlansResponse) XXX_Unmarshal(b []byte) error
- type QueryServiceClient
- type QueryServiceServer
- type UnimplementedMsgServiceServer
- func (*UnimplementedMsgServiceServer) MsgAdd(ctx context.Context, req *MsgAddRequest) (*MsgAddResponse, error)
- func (*UnimplementedMsgServiceServer) MsgAddNode(ctx context.Context, req *MsgAddNodeRequest) (*MsgAddNodeResponse, error)
- func (*UnimplementedMsgServiceServer) MsgRemoveNode(ctx context.Context, req *MsgRemoveNodeRequest) (*MsgRemoveNodeResponse, error)
- func (*UnimplementedMsgServiceServer) MsgSetStatus(ctx context.Context, req *MsgSetStatusRequest) (*MsgSetStatusResponse, error)
- type UnimplementedQueryServiceServer
- func (*UnimplementedQueryServiceServer) QueryNodesForPlan(ctx context.Context, req *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPlan(ctx context.Context, req *QueryPlanRequest) (*QueryPlanResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPlans(ctx context.Context, req *QueryPlansRequest) (*QueryPlansResponse, error)
- func (*UnimplementedQueryServiceServer) QueryPlansForProvider(ctx context.Context, req *QueryPlansForProviderRequest) (*QueryPlansForProviderResponse, error)
Constants ¶
const ( ModuleName = "plan" QuerierRoute = ModuleName )
Variables ¶
var ( ErrorInvalidField = errors.Register(ModuleName, 101, "invalid field") ErrorProviderDoesNotExist = errors.Register(ModuleName, 102, "provider does not exist") ErrorPlanDoesNotExist = errors.Register(ModuleName, 103, "plan does not exist") ErrorNodeDoesNotExist = errors.Register(ModuleName, 104, "node does not exist") DuplicateNodeForPlan = errors.Register(ModuleName, 106, "duplicate node for plan") )
var ( ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group") )
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 ( RouterKey = ModuleName StoreKey = ModuleName )
var ( CountKey = []byte{0x00} PlanKeyPrefix = []byte{0x10} ActivePlanKeyPrefix = []byte{0x20} InactivePlanKeyPrefix = []byte{0x21} ActivePlanForProviderKeyPrefix = []byte{0x30} InactivePlanForProviderKeyPrefix = []byte{0x31} NodeForPlanKeyPrefix = []byte{0x40} CountForNodeByProviderKeyPrefix = []byte{0x50} )
var ( ErrInvalidLengthMsg = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMsg = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPlan = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPlan = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPlan = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuerier = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuerier = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuerier = fmt.Errorf("proto: unexpected end of group") )
var (
EventModuleName = EventModule{Name: ModuleName}
)
var (
ModuleCdc = codec.NewAminoCodec(amino)
)
Functions ¶
func ActivePlanForProviderKey ¶ added in v0.4.0
func ActivePlanForProviderKey(address hubtypes.ProvAddress, id uint64) []byte
func ActivePlanKey ¶ added in v0.4.0
func AddressFromNodeForPlanKey ¶ added in v0.4.0
func AddressFromNodeForPlanKey(key []byte) hubtypes.NodeAddress
func CountForNodeByProviderKey ¶ added in v0.6.1
func CountForNodeByProviderKey(p hubtypes.ProvAddress, n hubtypes.NodeAddress) []byte
func GetActivePlanForProviderKeyPrefix ¶ added in v0.4.0
func GetActivePlanForProviderKeyPrefix(address hubtypes.ProvAddress) []byte
func GetInactivePlanForProviderKeyPrefix ¶ added in v0.4.0
func GetInactivePlanForProviderKeyPrefix(address hubtypes.ProvAddress) []byte
func GetNodeForPlanKeyPrefix ¶
func IDFromStatusPlanForProviderKey ¶ added in v0.4.0
func IDFromStatusPlanKey ¶ added in v0.4.0
func InactivePlanForProviderKey ¶ added in v0.4.0
func InactivePlanForProviderKey(address hubtypes.ProvAddress, id uint64) []byte
func InactivePlanKey ¶ added in v0.4.0
func NodeForPlanKey ¶
func NodeForPlanKey(id uint64, address hubtypes.NodeAddress) []byte
func RegisterInterfaces ¶ added in v0.6.0
func RegisterInterfaces(registry types.InterfaceRegistry)
func RegisterLegacyAminoCodec ¶ added in v0.6.0
func RegisterLegacyAminoCodec(_ *codec.LegacyAmino)
func RegisterMsgServiceServer ¶ added in v0.6.0
func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)
func RegisterQueryServiceHandler ¶ added in v0.6.0
func RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterQueryServiceHandler registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryServiceHandlerClient ¶ added in v0.6.0
func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error
RegisterQueryServiceHandlerClient registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryServiceClient" to call the correct interceptors.
func RegisterQueryServiceHandlerFromEndpoint ¶ added in v0.6.0
func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryServiceHandlerFromEndpoint is same as RegisterQueryServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryServiceHandlerServer ¶ added in v0.6.0
func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error
RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer 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 RegisterQueryServiceHandlerFromEndpoint instead.
func RegisterQueryServiceServer ¶ added in v0.6.0
func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)
func ValidateGenesis ¶ added in v0.6.0
func ValidateGenesis(state GenesisState) error
Types ¶
type EventAddNodeForPlan ¶ added in v0.6.0
type EventAddNodeForPlan struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"` Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"` }
func (*EventAddNodeForPlan) Descriptor ¶ added in v0.6.0
func (*EventAddNodeForPlan) Descriptor() ([]byte, []int)
func (*EventAddNodeForPlan) Marshal ¶ added in v0.6.0
func (m *EventAddNodeForPlan) Marshal() (dAtA []byte, err error)
func (*EventAddNodeForPlan) MarshalTo ¶ added in v0.6.0
func (m *EventAddNodeForPlan) MarshalTo(dAtA []byte) (int, error)
func (*EventAddNodeForPlan) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *EventAddNodeForPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventAddNodeForPlan) ProtoMessage ¶ added in v0.6.0
func (*EventAddNodeForPlan) ProtoMessage()
func (*EventAddNodeForPlan) Reset ¶ added in v0.6.0
func (m *EventAddNodeForPlan) Reset()
func (*EventAddNodeForPlan) Size ¶ added in v0.6.0
func (m *EventAddNodeForPlan) Size() (n int)
func (*EventAddNodeForPlan) String ¶ added in v0.6.0
func (m *EventAddNodeForPlan) String() string
func (*EventAddNodeForPlan) Unmarshal ¶ added in v0.6.0
func (m *EventAddNodeForPlan) Unmarshal(dAtA []byte) error
func (*EventAddNodeForPlan) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *EventAddNodeForPlan) XXX_DiscardUnknown()
func (*EventAddNodeForPlan) XXX_Marshal ¶ added in v0.6.0
func (m *EventAddNodeForPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventAddNodeForPlan) XXX_Merge ¶ added in v0.6.0
func (m *EventAddNodeForPlan) XXX_Merge(src proto.Message)
func (*EventAddNodeForPlan) XXX_Size ¶ added in v0.6.0
func (m *EventAddNodeForPlan) XXX_Size() int
func (*EventAddNodeForPlan) XXX_Unmarshal ¶ added in v0.6.0
func (m *EventAddNodeForPlan) XXX_Unmarshal(b []byte) error
type EventAddPlan ¶ added in v0.6.0
type EventAddPlan struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"` Price github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=price,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"price"` Validity time.Duration `protobuf:"bytes,4,opt,name=validity,proto3,stdduration" json:"validity"` Bytes github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,5,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"` }
func (*EventAddPlan) Descriptor ¶ added in v0.6.0
func (*EventAddPlan) Descriptor() ([]byte, []int)
func (*EventAddPlan) Marshal ¶ added in v0.6.0
func (m *EventAddPlan) Marshal() (dAtA []byte, err error)
func (*EventAddPlan) MarshalTo ¶ added in v0.6.0
func (m *EventAddPlan) MarshalTo(dAtA []byte) (int, error)
func (*EventAddPlan) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *EventAddPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventAddPlan) ProtoMessage ¶ added in v0.6.0
func (*EventAddPlan) ProtoMessage()
func (*EventAddPlan) Reset ¶ added in v0.6.0
func (m *EventAddPlan) Reset()
func (*EventAddPlan) Size ¶ added in v0.6.0
func (m *EventAddPlan) Size() (n int)
func (*EventAddPlan) String ¶ added in v0.6.0
func (m *EventAddPlan) String() string
func (*EventAddPlan) Unmarshal ¶ added in v0.6.0
func (m *EventAddPlan) Unmarshal(dAtA []byte) error
func (*EventAddPlan) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *EventAddPlan) XXX_DiscardUnknown()
func (*EventAddPlan) XXX_Marshal ¶ added in v0.6.0
func (m *EventAddPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventAddPlan) XXX_Merge ¶ added in v0.6.0
func (m *EventAddPlan) XXX_Merge(src proto.Message)
func (*EventAddPlan) XXX_Size ¶ added in v0.6.0
func (m *EventAddPlan) XXX_Size() int
func (*EventAddPlan) XXX_Unmarshal ¶ added in v0.6.0
func (m *EventAddPlan) XXX_Unmarshal(b []byte) error
type EventModule ¶ added in v0.6.0
type EventModule struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*EventModule) Descriptor ¶ added in v0.6.0
func (*EventModule) Descriptor() ([]byte, []int)
func (*EventModule) Marshal ¶ added in v0.6.0
func (m *EventModule) Marshal() (dAtA []byte, err error)
func (*EventModule) MarshalTo ¶ added in v0.6.0
func (m *EventModule) MarshalTo(dAtA []byte) (int, error)
func (*EventModule) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *EventModule) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventModule) ProtoMessage ¶ added in v0.6.0
func (*EventModule) ProtoMessage()
func (*EventModule) Reset ¶ added in v0.6.0
func (m *EventModule) Reset()
func (*EventModule) Size ¶ added in v0.6.0
func (m *EventModule) Size() (n int)
func (*EventModule) String ¶ added in v0.6.0
func (m *EventModule) String() string
func (*EventModule) Unmarshal ¶ added in v0.6.0
func (m *EventModule) Unmarshal(dAtA []byte) error
func (*EventModule) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *EventModule) XXX_DiscardUnknown()
func (*EventModule) XXX_Marshal ¶ added in v0.6.0
func (m *EventModule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventModule) XXX_Merge ¶ added in v0.6.0
func (m *EventModule) XXX_Merge(src proto.Message)
func (*EventModule) XXX_Size ¶ added in v0.6.0
func (m *EventModule) XXX_Size() int
func (*EventModule) XXX_Unmarshal ¶ added in v0.6.0
func (m *EventModule) XXX_Unmarshal(b []byte) error
type EventRemoveNodeForPlan ¶ added in v0.6.0
type EventRemoveNodeForPlan struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` }
func (*EventRemoveNodeForPlan) Descriptor ¶ added in v0.6.0
func (*EventRemoveNodeForPlan) Descriptor() ([]byte, []int)
func (*EventRemoveNodeForPlan) Marshal ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) Marshal() (dAtA []byte, err error)
func (*EventRemoveNodeForPlan) MarshalTo ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) MarshalTo(dAtA []byte) (int, error)
func (*EventRemoveNodeForPlan) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventRemoveNodeForPlan) ProtoMessage ¶ added in v0.6.0
func (*EventRemoveNodeForPlan) ProtoMessage()
func (*EventRemoveNodeForPlan) Reset ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) Reset()
func (*EventRemoveNodeForPlan) Size ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) Size() (n int)
func (*EventRemoveNodeForPlan) String ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) String() string
func (*EventRemoveNodeForPlan) Unmarshal ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) Unmarshal(dAtA []byte) error
func (*EventRemoveNodeForPlan) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) XXX_DiscardUnknown()
func (*EventRemoveNodeForPlan) XXX_Marshal ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventRemoveNodeForPlan) XXX_Merge ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) XXX_Merge(src proto.Message)
func (*EventRemoveNodeForPlan) XXX_Size ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) XXX_Size() int
func (*EventRemoveNodeForPlan) XXX_Unmarshal ¶ added in v0.6.0
func (m *EventRemoveNodeForPlan) XXX_Unmarshal(b []byte) error
type EventSetPlanCount ¶ added in v0.6.0
type EventSetPlanCount struct {
Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}
func (*EventSetPlanCount) Descriptor ¶ added in v0.6.0
func (*EventSetPlanCount) Descriptor() ([]byte, []int)
func (*EventSetPlanCount) Marshal ¶ added in v0.6.0
func (m *EventSetPlanCount) Marshal() (dAtA []byte, err error)
func (*EventSetPlanCount) MarshalTo ¶ added in v0.6.0
func (m *EventSetPlanCount) MarshalTo(dAtA []byte) (int, error)
func (*EventSetPlanCount) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *EventSetPlanCount) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSetPlanCount) ProtoMessage ¶ added in v0.6.0
func (*EventSetPlanCount) ProtoMessage()
func (*EventSetPlanCount) Reset ¶ added in v0.6.0
func (m *EventSetPlanCount) Reset()
func (*EventSetPlanCount) Size ¶ added in v0.6.0
func (m *EventSetPlanCount) Size() (n int)
func (*EventSetPlanCount) String ¶ added in v0.6.0
func (m *EventSetPlanCount) String() string
func (*EventSetPlanCount) Unmarshal ¶ added in v0.6.0
func (m *EventSetPlanCount) Unmarshal(dAtA []byte) error
func (*EventSetPlanCount) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *EventSetPlanCount) XXX_DiscardUnknown()
func (*EventSetPlanCount) XXX_Marshal ¶ added in v0.6.0
func (m *EventSetPlanCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSetPlanCount) XXX_Merge ¶ added in v0.6.0
func (m *EventSetPlanCount) XXX_Merge(src proto.Message)
func (*EventSetPlanCount) XXX_Size ¶ added in v0.6.0
func (m *EventSetPlanCount) XXX_Size() int
func (*EventSetPlanCount) XXX_Unmarshal ¶ added in v0.6.0
func (m *EventSetPlanCount) XXX_Unmarshal(b []byte) error
type EventSetPlanStatus ¶ added in v0.6.0
type EventSetPlanStatus struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"` Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Status types1.Status `protobuf:"varint,4,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"` }
func (*EventSetPlanStatus) Descriptor ¶ added in v0.6.0
func (*EventSetPlanStatus) Descriptor() ([]byte, []int)
func (*EventSetPlanStatus) Marshal ¶ added in v0.6.0
func (m *EventSetPlanStatus) Marshal() (dAtA []byte, err error)
func (*EventSetPlanStatus) MarshalTo ¶ added in v0.6.0
func (m *EventSetPlanStatus) MarshalTo(dAtA []byte) (int, error)
func (*EventSetPlanStatus) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *EventSetPlanStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSetPlanStatus) ProtoMessage ¶ added in v0.6.0
func (*EventSetPlanStatus) ProtoMessage()
func (*EventSetPlanStatus) Reset ¶ added in v0.6.0
func (m *EventSetPlanStatus) Reset()
func (*EventSetPlanStatus) Size ¶ added in v0.6.0
func (m *EventSetPlanStatus) Size() (n int)
func (*EventSetPlanStatus) String ¶ added in v0.6.0
func (m *EventSetPlanStatus) String() string
func (*EventSetPlanStatus) Unmarshal ¶ added in v0.6.0
func (m *EventSetPlanStatus) Unmarshal(dAtA []byte) error
func (*EventSetPlanStatus) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *EventSetPlanStatus) XXX_DiscardUnknown()
func (*EventSetPlanStatus) XXX_Marshal ¶ added in v0.6.0
func (m *EventSetPlanStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSetPlanStatus) XXX_Merge ¶ added in v0.6.0
func (m *EventSetPlanStatus) XXX_Merge(src proto.Message)
func (*EventSetPlanStatus) XXX_Size ¶ added in v0.6.0
func (m *EventSetPlanStatus) XXX_Size() int
func (*EventSetPlanStatus) XXX_Unmarshal ¶ added in v0.6.0
func (m *EventSetPlanStatus) XXX_Unmarshal(b []byte) error
type GenesisPlan ¶
type GenesisPlan struct { Plan Plan `protobuf:"bytes,1,opt,name=plan,proto3" json:"_,omitempty"` Nodes []string `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"` }
func (*GenesisPlan) Descriptor ¶ added in v0.6.0
func (*GenesisPlan) Descriptor() ([]byte, []int)
func (*GenesisPlan) Marshal ¶ added in v0.6.0
func (m *GenesisPlan) Marshal() (dAtA []byte, err error)
func (*GenesisPlan) MarshalTo ¶ added in v0.6.0
func (m *GenesisPlan) MarshalTo(dAtA []byte) (int, error)
func (*GenesisPlan) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *GenesisPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisPlan) ProtoMessage ¶ added in v0.6.0
func (*GenesisPlan) ProtoMessage()
func (*GenesisPlan) Reset ¶ added in v0.6.0
func (m *GenesisPlan) Reset()
func (*GenesisPlan) Size ¶ added in v0.6.0
func (m *GenesisPlan) Size() (n int)
func (*GenesisPlan) String ¶ added in v0.6.0
func (m *GenesisPlan) String() string
func (*GenesisPlan) Unmarshal ¶ added in v0.6.0
func (m *GenesisPlan) Unmarshal(dAtA []byte) error
func (*GenesisPlan) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *GenesisPlan) XXX_DiscardUnknown()
func (*GenesisPlan) XXX_Marshal ¶ added in v0.6.0
func (m *GenesisPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisPlan) XXX_Merge ¶ added in v0.6.0
func (m *GenesisPlan) XXX_Merge(src proto.Message)
func (*GenesisPlan) XXX_Size ¶ added in v0.6.0
func (m *GenesisPlan) XXX_Size() int
func (*GenesisPlan) XXX_Unmarshal ¶ added in v0.6.0
func (m *GenesisPlan) XXX_Unmarshal(b []byte) error
type GenesisPlans ¶
type GenesisPlans []GenesisPlan
type GenesisState ¶
type GenesisState GenesisPlans
func DefaultGenesisState ¶
func DefaultGenesisState() GenesisState
func NewGenesisState ¶
func NewGenesisState(plans GenesisPlans) GenesisState
type MsgAddNodeRequest ¶ added in v0.6.0
type MsgAddNodeRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` }
MsgAddNodeRequest defines the SDK message for adding a node to a plan
func NewMsgAddNodeRequest ¶ added in v0.6.0
func NewMsgAddNodeRequest(from hubtypes.ProvAddress, id uint64, address hubtypes.NodeAddress) *MsgAddNodeRequest
func (*MsgAddNodeRequest) Descriptor ¶ added in v0.6.0
func (*MsgAddNodeRequest) Descriptor() ([]byte, []int)
func (*MsgAddNodeRequest) GetSignBytes ¶ added in v0.6.0
func (m *MsgAddNodeRequest) GetSignBytes() []byte
func (*MsgAddNodeRequest) GetSigners ¶ added in v0.6.0
func (m *MsgAddNodeRequest) GetSigners() []sdk.AccAddress
func (*MsgAddNodeRequest) Marshal ¶ added in v0.6.0
func (m *MsgAddNodeRequest) Marshal() (dAtA []byte, err error)
func (*MsgAddNodeRequest) MarshalTo ¶ added in v0.6.0
func (m *MsgAddNodeRequest) MarshalTo(dAtA []byte) (int, error)
func (*MsgAddNodeRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgAddNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAddNodeRequest) ProtoMessage ¶ added in v0.6.0
func (*MsgAddNodeRequest) ProtoMessage()
func (*MsgAddNodeRequest) Reset ¶ added in v0.6.0
func (m *MsgAddNodeRequest) Reset()
func (*MsgAddNodeRequest) Route ¶ added in v0.6.0
func (m *MsgAddNodeRequest) Route() string
func (*MsgAddNodeRequest) Size ¶ added in v0.6.0
func (m *MsgAddNodeRequest) Size() (n int)
func (*MsgAddNodeRequest) String ¶ added in v0.6.0
func (m *MsgAddNodeRequest) String() string
func (*MsgAddNodeRequest) Type ¶ added in v0.6.0
func (m *MsgAddNodeRequest) Type() string
func (*MsgAddNodeRequest) Unmarshal ¶ added in v0.6.0
func (m *MsgAddNodeRequest) Unmarshal(dAtA []byte) error
func (*MsgAddNodeRequest) ValidateBasic ¶ added in v0.6.0
func (m *MsgAddNodeRequest) ValidateBasic() error
func (*MsgAddNodeRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgAddNodeRequest) XXX_DiscardUnknown()
func (*MsgAddNodeRequest) XXX_Marshal ¶ added in v0.6.0
func (m *MsgAddNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAddNodeRequest) XXX_Merge ¶ added in v0.6.0
func (m *MsgAddNodeRequest) XXX_Merge(src proto.Message)
func (*MsgAddNodeRequest) XXX_Size ¶ added in v0.6.0
func (m *MsgAddNodeRequest) XXX_Size() int
func (*MsgAddNodeRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgAddNodeRequest) XXX_Unmarshal(b []byte) error
type MsgAddNodeResponse ¶ added in v0.6.0
type MsgAddNodeResponse struct { }
MsgAddNodeResponse defines the response of message MsgAddNodeRequest
func (*MsgAddNodeResponse) Descriptor ¶ added in v0.6.0
func (*MsgAddNodeResponse) Descriptor() ([]byte, []int)
func (*MsgAddNodeResponse) Marshal ¶ added in v0.6.0
func (m *MsgAddNodeResponse) Marshal() (dAtA []byte, err error)
func (*MsgAddNodeResponse) MarshalTo ¶ added in v0.6.0
func (m *MsgAddNodeResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAddNodeResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgAddNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAddNodeResponse) ProtoMessage ¶ added in v0.6.0
func (*MsgAddNodeResponse) ProtoMessage()
func (*MsgAddNodeResponse) Reset ¶ added in v0.6.0
func (m *MsgAddNodeResponse) Reset()
func (*MsgAddNodeResponse) Size ¶ added in v0.6.0
func (m *MsgAddNodeResponse) Size() (n int)
func (*MsgAddNodeResponse) String ¶ added in v0.6.0
func (m *MsgAddNodeResponse) String() string
func (*MsgAddNodeResponse) Unmarshal ¶ added in v0.6.0
func (m *MsgAddNodeResponse) Unmarshal(dAtA []byte) error
func (*MsgAddNodeResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgAddNodeResponse) XXX_DiscardUnknown()
func (*MsgAddNodeResponse) XXX_Marshal ¶ added in v0.6.0
func (m *MsgAddNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAddNodeResponse) XXX_Merge ¶ added in v0.6.0
func (m *MsgAddNodeResponse) XXX_Merge(src proto.Message)
func (*MsgAddNodeResponse) XXX_Size ¶ added in v0.6.0
func (m *MsgAddNodeResponse) XXX_Size() int
func (*MsgAddNodeResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgAddNodeResponse) XXX_Unmarshal(b []byte) error
type MsgAddRequest ¶ added in v0.6.0
type MsgAddRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Price github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=price,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"price"` Validity time.Duration `protobuf:"bytes,3,opt,name=validity,proto3,stdduration" json:"validity"` Bytes github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,4,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"` }
MsgAddRequest defines the SDK message for adding a plan
func NewMsgAddRequest ¶ added in v0.6.0
func NewMsgAddRequest(from hubtypes.ProvAddress, price sdk.Coins, validity time.Duration, bytes sdk.Int) *MsgAddRequest
func (*MsgAddRequest) Descriptor ¶ added in v0.6.0
func (*MsgAddRequest) Descriptor() ([]byte, []int)
func (*MsgAddRequest) GetSignBytes ¶ added in v0.6.0
func (m *MsgAddRequest) GetSignBytes() []byte
func (*MsgAddRequest) GetSigners ¶ added in v0.6.0
func (m *MsgAddRequest) GetSigners() []sdk.AccAddress
func (*MsgAddRequest) Marshal ¶ added in v0.6.0
func (m *MsgAddRequest) Marshal() (dAtA []byte, err error)
func (*MsgAddRequest) MarshalTo ¶ added in v0.6.0
func (m *MsgAddRequest) MarshalTo(dAtA []byte) (int, error)
func (*MsgAddRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgAddRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAddRequest) ProtoMessage ¶ added in v0.6.0
func (*MsgAddRequest) ProtoMessage()
func (*MsgAddRequest) Reset ¶ added in v0.6.0
func (m *MsgAddRequest) Reset()
func (*MsgAddRequest) Route ¶ added in v0.6.0
func (m *MsgAddRequest) Route() string
func (*MsgAddRequest) Size ¶ added in v0.6.0
func (m *MsgAddRequest) Size() (n int)
func (*MsgAddRequest) String ¶ added in v0.6.0
func (m *MsgAddRequest) String() string
func (*MsgAddRequest) Type ¶ added in v0.6.0
func (m *MsgAddRequest) Type() string
func (*MsgAddRequest) Unmarshal ¶ added in v0.6.0
func (m *MsgAddRequest) Unmarshal(dAtA []byte) error
func (*MsgAddRequest) ValidateBasic ¶ added in v0.6.0
func (m *MsgAddRequest) ValidateBasic() error
func (*MsgAddRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgAddRequest) XXX_DiscardUnknown()
func (*MsgAddRequest) XXX_Marshal ¶ added in v0.6.0
func (m *MsgAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAddRequest) XXX_Merge ¶ added in v0.6.0
func (m *MsgAddRequest) XXX_Merge(src proto.Message)
func (*MsgAddRequest) XXX_Size ¶ added in v0.6.0
func (m *MsgAddRequest) XXX_Size() int
func (*MsgAddRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgAddRequest) XXX_Unmarshal(b []byte) error
type MsgAddResponse ¶ added in v0.6.0
type MsgAddResponse struct { }
MsgAddResponse defines the response of message MsgRegisterRequest
func (*MsgAddResponse) Descriptor ¶ added in v0.6.0
func (*MsgAddResponse) Descriptor() ([]byte, []int)
func (*MsgAddResponse) Marshal ¶ added in v0.6.0
func (m *MsgAddResponse) Marshal() (dAtA []byte, err error)
func (*MsgAddResponse) MarshalTo ¶ added in v0.6.0
func (m *MsgAddResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAddResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgAddResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAddResponse) ProtoMessage ¶ added in v0.6.0
func (*MsgAddResponse) ProtoMessage()
func (*MsgAddResponse) Reset ¶ added in v0.6.0
func (m *MsgAddResponse) Reset()
func (*MsgAddResponse) Size ¶ added in v0.6.0
func (m *MsgAddResponse) Size() (n int)
func (*MsgAddResponse) String ¶ added in v0.6.0
func (m *MsgAddResponse) String() string
func (*MsgAddResponse) Unmarshal ¶ added in v0.6.0
func (m *MsgAddResponse) Unmarshal(dAtA []byte) error
func (*MsgAddResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgAddResponse) XXX_DiscardUnknown()
func (*MsgAddResponse) XXX_Marshal ¶ added in v0.6.0
func (m *MsgAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAddResponse) XXX_Merge ¶ added in v0.6.0
func (m *MsgAddResponse) XXX_Merge(src proto.Message)
func (*MsgAddResponse) XXX_Size ¶ added in v0.6.0
func (m *MsgAddResponse) XXX_Size() int
func (*MsgAddResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgAddResponse) XXX_Unmarshal(b []byte) error
type MsgRemoveNodeRequest ¶ added in v0.6.0
type MsgRemoveNodeRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` }
MsgRemoveNodeRequest defines the SDK message for removing a node from a plan
func NewMsgRemoveNodeRequest ¶ added in v0.6.0
func NewMsgRemoveNodeRequest(from sdk.AccAddress, id uint64, address hubtypes.NodeAddress) *MsgRemoveNodeRequest
func (*MsgRemoveNodeRequest) Descriptor ¶ added in v0.6.0
func (*MsgRemoveNodeRequest) Descriptor() ([]byte, []int)
func (*MsgRemoveNodeRequest) GetSignBytes ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) GetSignBytes() []byte
func (*MsgRemoveNodeRequest) GetSigners ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) GetSigners() []sdk.AccAddress
func (*MsgRemoveNodeRequest) Marshal ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) Marshal() (dAtA []byte, err error)
func (*MsgRemoveNodeRequest) MarshalTo ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) MarshalTo(dAtA []byte) (int, error)
func (*MsgRemoveNodeRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRemoveNodeRequest) ProtoMessage ¶ added in v0.6.0
func (*MsgRemoveNodeRequest) ProtoMessage()
func (*MsgRemoveNodeRequest) Reset ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) Reset()
func (*MsgRemoveNodeRequest) Route ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) Route() string
func (*MsgRemoveNodeRequest) Size ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) Size() (n int)
func (*MsgRemoveNodeRequest) String ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) String() string
func (*MsgRemoveNodeRequest) Type ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) Type() string
func (*MsgRemoveNodeRequest) Unmarshal ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) Unmarshal(dAtA []byte) error
func (*MsgRemoveNodeRequest) ValidateBasic ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) ValidateBasic() error
func (*MsgRemoveNodeRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) XXX_DiscardUnknown()
func (*MsgRemoveNodeRequest) XXX_Marshal ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRemoveNodeRequest) XXX_Merge ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) XXX_Merge(src proto.Message)
func (*MsgRemoveNodeRequest) XXX_Size ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) XXX_Size() int
func (*MsgRemoveNodeRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgRemoveNodeRequest) XXX_Unmarshal(b []byte) error
type MsgRemoveNodeResponse ¶ added in v0.6.0
type MsgRemoveNodeResponse struct { }
MsgRemoveNodeResponse defines the response of message MsgRemoveNodeRequest
func (*MsgRemoveNodeResponse) Descriptor ¶ added in v0.6.0
func (*MsgRemoveNodeResponse) Descriptor() ([]byte, []int)
func (*MsgRemoveNodeResponse) Marshal ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) Marshal() (dAtA []byte, err error)
func (*MsgRemoveNodeResponse) MarshalTo ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgRemoveNodeResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRemoveNodeResponse) ProtoMessage ¶ added in v0.6.0
func (*MsgRemoveNodeResponse) ProtoMessage()
func (*MsgRemoveNodeResponse) Reset ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) Reset()
func (*MsgRemoveNodeResponse) Size ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) Size() (n int)
func (*MsgRemoveNodeResponse) String ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) String() string
func (*MsgRemoveNodeResponse) Unmarshal ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) Unmarshal(dAtA []byte) error
func (*MsgRemoveNodeResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) XXX_DiscardUnknown()
func (*MsgRemoveNodeResponse) XXX_Marshal ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRemoveNodeResponse) XXX_Merge ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) XXX_Merge(src proto.Message)
func (*MsgRemoveNodeResponse) XXX_Size ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) XXX_Size() int
func (*MsgRemoveNodeResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgRemoveNodeResponse) XXX_Unmarshal(b []byte) error
type MsgServiceClient ¶ added in v0.6.0
type MsgServiceClient interface { MsgAdd(ctx context.Context, in *MsgAddRequest, opts ...grpc.CallOption) (*MsgAddResponse, error) MsgSetStatus(ctx context.Context, in *MsgSetStatusRequest, opts ...grpc.CallOption) (*MsgSetStatusResponse, error) MsgAddNode(ctx context.Context, in *MsgAddNodeRequest, opts ...grpc.CallOption) (*MsgAddNodeResponse, error) MsgRemoveNode(ctx context.Context, in *MsgRemoveNodeRequest, opts ...grpc.CallOption) (*MsgRemoveNodeResponse, error) }
MsgServiceClient is the client API for MsgService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgServiceClient ¶ added in v0.6.0
func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient
type MsgServiceServer ¶ added in v0.6.0
type MsgServiceServer interface { MsgAdd(context.Context, *MsgAddRequest) (*MsgAddResponse, error) MsgSetStatus(context.Context, *MsgSetStatusRequest) (*MsgSetStatusResponse, error) MsgAddNode(context.Context, *MsgAddNodeRequest) (*MsgAddNodeResponse, error) MsgRemoveNode(context.Context, *MsgRemoveNodeRequest) (*MsgRemoveNodeResponse, error) }
MsgServiceServer is the server API for MsgService service.
type MsgSetStatusRequest ¶ added in v0.6.0
type MsgSetStatusRequest struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Status types1.Status `protobuf:"varint,3,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"` }
MsgSetStatusRequest defines the SDK message for modifying the status of a plan
func NewMsgSetStatusRequest ¶ added in v0.6.0
func NewMsgSetStatusRequest(from hubtypes.ProvAddress, id uint64, status hubtypes.Status) *MsgSetStatusRequest
func (*MsgSetStatusRequest) Descriptor ¶ added in v0.6.0
func (*MsgSetStatusRequest) Descriptor() ([]byte, []int)
func (*MsgSetStatusRequest) GetSignBytes ¶ added in v0.6.0
func (m *MsgSetStatusRequest) GetSignBytes() []byte
func (*MsgSetStatusRequest) GetSigners ¶ added in v0.6.0
func (m *MsgSetStatusRequest) GetSigners() []sdk.AccAddress
func (*MsgSetStatusRequest) Marshal ¶ added in v0.6.0
func (m *MsgSetStatusRequest) Marshal() (dAtA []byte, err error)
func (*MsgSetStatusRequest) MarshalTo ¶ added in v0.6.0
func (m *MsgSetStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*MsgSetStatusRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgSetStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSetStatusRequest) ProtoMessage ¶ added in v0.6.0
func (*MsgSetStatusRequest) ProtoMessage()
func (*MsgSetStatusRequest) Reset ¶ added in v0.6.0
func (m *MsgSetStatusRequest) Reset()
func (*MsgSetStatusRequest) Route ¶ added in v0.6.0
func (m *MsgSetStatusRequest) Route() string
func (*MsgSetStatusRequest) Size ¶ added in v0.6.0
func (m *MsgSetStatusRequest) Size() (n int)
func (*MsgSetStatusRequest) String ¶ added in v0.6.0
func (m *MsgSetStatusRequest) String() string
func (*MsgSetStatusRequest) Type ¶ added in v0.6.0
func (m *MsgSetStatusRequest) Type() string
func (*MsgSetStatusRequest) Unmarshal ¶ added in v0.6.0
func (m *MsgSetStatusRequest) Unmarshal(dAtA []byte) error
func (*MsgSetStatusRequest) ValidateBasic ¶ added in v0.6.0
func (m *MsgSetStatusRequest) ValidateBasic() error
func (*MsgSetStatusRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgSetStatusRequest) XXX_DiscardUnknown()
func (*MsgSetStatusRequest) XXX_Marshal ¶ added in v0.6.0
func (m *MsgSetStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSetStatusRequest) XXX_Merge ¶ added in v0.6.0
func (m *MsgSetStatusRequest) XXX_Merge(src proto.Message)
func (*MsgSetStatusRequest) XXX_Size ¶ added in v0.6.0
func (m *MsgSetStatusRequest) XXX_Size() int
func (*MsgSetStatusRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgSetStatusRequest) XXX_Unmarshal(b []byte) error
type MsgSetStatusResponse ¶ added in v0.6.0
type MsgSetStatusResponse struct { }
MsgSetStatusResponse defines the response of message MsgSetStatusRequest
func (*MsgSetStatusResponse) Descriptor ¶ added in v0.6.0
func (*MsgSetStatusResponse) Descriptor() ([]byte, []int)
func (*MsgSetStatusResponse) Marshal ¶ added in v0.6.0
func (m *MsgSetStatusResponse) Marshal() (dAtA []byte, err error)
func (*MsgSetStatusResponse) MarshalTo ¶ added in v0.6.0
func (m *MsgSetStatusResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgSetStatusResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *MsgSetStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSetStatusResponse) ProtoMessage ¶ added in v0.6.0
func (*MsgSetStatusResponse) ProtoMessage()
func (*MsgSetStatusResponse) Reset ¶ added in v0.6.0
func (m *MsgSetStatusResponse) Reset()
func (*MsgSetStatusResponse) Size ¶ added in v0.6.0
func (m *MsgSetStatusResponse) Size() (n int)
func (*MsgSetStatusResponse) String ¶ added in v0.6.0
func (m *MsgSetStatusResponse) String() string
func (*MsgSetStatusResponse) Unmarshal ¶ added in v0.6.0
func (m *MsgSetStatusResponse) Unmarshal(dAtA []byte) error
func (*MsgSetStatusResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *MsgSetStatusResponse) XXX_DiscardUnknown()
func (*MsgSetStatusResponse) XXX_Marshal ¶ added in v0.6.0
func (m *MsgSetStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSetStatusResponse) XXX_Merge ¶ added in v0.6.0
func (m *MsgSetStatusResponse) XXX_Merge(src proto.Message)
func (*MsgSetStatusResponse) XXX_Size ¶ added in v0.6.0
func (m *MsgSetStatusResponse) XXX_Size() int
func (*MsgSetStatusResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *MsgSetStatusResponse) XXX_Unmarshal(b []byte) error
type Plan ¶
type Plan struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"` Price github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=price,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"price"` Validity time.Duration `protobuf:"bytes,4,opt,name=validity,proto3,stdduration" json:"validity"` Bytes github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,5,opt,name=bytes,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"bytes"` Status types1.Status `protobuf:"varint,6,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"` StatusAt time.Time `protobuf:"bytes,7,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"` }
func (*Plan) Descriptor ¶ added in v0.6.0
func (*Plan) GetProvider ¶ added in v0.6.0
func (p *Plan) GetProvider() hubtypes.ProvAddress
func (*Plan) MarshalToSizedBuffer ¶ added in v0.6.0
func (*Plan) ProtoMessage ¶ added in v0.6.0
func (*Plan) ProtoMessage()
func (*Plan) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *Plan) XXX_DiscardUnknown()
func (*Plan) XXX_Marshal ¶ added in v0.6.0
func (*Plan) XXX_Unmarshal ¶ added in v0.6.0
type QueryNodesForPlanRequest ¶ added in v0.6.0
type QueryNodesForPlanRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQueryNodesForPlanRequest ¶ added in v0.6.0
func NewQueryNodesForPlanRequest(id uint64, pagination *query.PageRequest) *QueryNodesForPlanRequest
func (*QueryNodesForPlanRequest) Descriptor ¶ added in v0.6.0
func (*QueryNodesForPlanRequest) Descriptor() ([]byte, []int)
func (*QueryNodesForPlanRequest) Marshal ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) Marshal() (dAtA []byte, err error)
func (*QueryNodesForPlanRequest) MarshalTo ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryNodesForPlanRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryNodesForPlanRequest) ProtoMessage ¶ added in v0.6.0
func (*QueryNodesForPlanRequest) ProtoMessage()
func (*QueryNodesForPlanRequest) Reset ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) Reset()
func (*QueryNodesForPlanRequest) Size ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) Size() (n int)
func (*QueryNodesForPlanRequest) String ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) String() string
func (*QueryNodesForPlanRequest) Unmarshal ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) Unmarshal(dAtA []byte) error
func (*QueryNodesForPlanRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) XXX_DiscardUnknown()
func (*QueryNodesForPlanRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryNodesForPlanRequest) XXX_Merge ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) XXX_Merge(src proto.Message)
func (*QueryNodesForPlanRequest) XXX_Size ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) XXX_Size() int
func (*QueryNodesForPlanRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryNodesForPlanRequest) XXX_Unmarshal(b []byte) error
type QueryNodesForPlanResponse ¶ added in v0.6.0
type QueryNodesForPlanResponse struct { Nodes []types1.Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryNodesForPlanResponse) Descriptor ¶ added in v0.6.0
func (*QueryNodesForPlanResponse) Descriptor() ([]byte, []int)
func (*QueryNodesForPlanResponse) Marshal ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) Marshal() (dAtA []byte, err error)
func (*QueryNodesForPlanResponse) MarshalTo ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryNodesForPlanResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryNodesForPlanResponse) ProtoMessage ¶ added in v0.6.0
func (*QueryNodesForPlanResponse) ProtoMessage()
func (*QueryNodesForPlanResponse) Reset ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) Reset()
func (*QueryNodesForPlanResponse) Size ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) Size() (n int)
func (*QueryNodesForPlanResponse) String ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) String() string
func (*QueryNodesForPlanResponse) Unmarshal ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) Unmarshal(dAtA []byte) error
func (*QueryNodesForPlanResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) XXX_DiscardUnknown()
func (*QueryNodesForPlanResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryNodesForPlanResponse) XXX_Merge ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) XXX_Merge(src proto.Message)
func (*QueryNodesForPlanResponse) XXX_Size ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) XXX_Size() int
func (*QueryNodesForPlanResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryNodesForPlanResponse) XXX_Unmarshal(b []byte) error
type QueryPlanRequest ¶ added in v0.6.0
type QueryPlanRequest struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func NewQueryPlanRequest ¶ added in v0.6.0
func NewQueryPlanRequest(id uint64) *QueryPlanRequest
func (*QueryPlanRequest) Descriptor ¶ added in v0.6.0
func (*QueryPlanRequest) Descriptor() ([]byte, []int)
func (*QueryPlanRequest) Marshal ¶ added in v0.6.0
func (m *QueryPlanRequest) Marshal() (dAtA []byte, err error)
func (*QueryPlanRequest) MarshalTo ¶ added in v0.6.0
func (m *QueryPlanRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlanRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPlanRequest) ProtoMessage ¶ added in v0.6.0
func (*QueryPlanRequest) ProtoMessage()
func (*QueryPlanRequest) Reset ¶ added in v0.6.0
func (m *QueryPlanRequest) Reset()
func (*QueryPlanRequest) Size ¶ added in v0.6.0
func (m *QueryPlanRequest) Size() (n int)
func (*QueryPlanRequest) String ¶ added in v0.6.0
func (m *QueryPlanRequest) String() string
func (*QueryPlanRequest) Unmarshal ¶ added in v0.6.0
func (m *QueryPlanRequest) Unmarshal(dAtA []byte) error
func (*QueryPlanRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryPlanRequest) XXX_DiscardUnknown()
func (*QueryPlanRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QueryPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPlanRequest) XXX_Merge ¶ added in v0.6.0
func (m *QueryPlanRequest) XXX_Merge(src proto.Message)
func (*QueryPlanRequest) XXX_Size ¶ added in v0.6.0
func (m *QueryPlanRequest) XXX_Size() int
func (*QueryPlanRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryPlanRequest) XXX_Unmarshal(b []byte) error
type QueryPlanResponse ¶ added in v0.6.0
type QueryPlanResponse struct {
Plan Plan `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan"`
}
func (*QueryPlanResponse) Descriptor ¶ added in v0.6.0
func (*QueryPlanResponse) Descriptor() ([]byte, []int)
func (*QueryPlanResponse) Marshal ¶ added in v0.6.0
func (m *QueryPlanResponse) Marshal() (dAtA []byte, err error)
func (*QueryPlanResponse) MarshalTo ¶ added in v0.6.0
func (m *QueryPlanResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlanResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPlanResponse) ProtoMessage ¶ added in v0.6.0
func (*QueryPlanResponse) ProtoMessage()
func (*QueryPlanResponse) Reset ¶ added in v0.6.0
func (m *QueryPlanResponse) Reset()
func (*QueryPlanResponse) Size ¶ added in v0.6.0
func (m *QueryPlanResponse) Size() (n int)
func (*QueryPlanResponse) String ¶ added in v0.6.0
func (m *QueryPlanResponse) String() string
func (*QueryPlanResponse) Unmarshal ¶ added in v0.6.0
func (m *QueryPlanResponse) Unmarshal(dAtA []byte) error
func (*QueryPlanResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryPlanResponse) XXX_DiscardUnknown()
func (*QueryPlanResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QueryPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPlanResponse) XXX_Merge ¶ added in v0.6.0
func (m *QueryPlanResponse) XXX_Merge(src proto.Message)
func (*QueryPlanResponse) XXX_Size ¶ added in v0.6.0
func (m *QueryPlanResponse) XXX_Size() int
func (*QueryPlanResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryPlanResponse) XXX_Unmarshal(b []byte) error
type QueryPlansForProviderRequest ¶ added in v0.6.0
type QueryPlansForProviderRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Status types.Status `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQueryPlansForProviderRequest ¶ added in v0.6.0
func NewQueryPlansForProviderRequest(address hubtypes.ProvAddress, status hubtypes.Status, pagination *query.PageRequest) *QueryPlansForProviderRequest
func (*QueryPlansForProviderRequest) Descriptor ¶ added in v0.6.0
func (*QueryPlansForProviderRequest) Descriptor() ([]byte, []int)
func (*QueryPlansForProviderRequest) Marshal ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) Marshal() (dAtA []byte, err error)
func (*QueryPlansForProviderRequest) MarshalTo ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlansForProviderRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPlansForProviderRequest) ProtoMessage ¶ added in v0.6.0
func (*QueryPlansForProviderRequest) ProtoMessage()
func (*QueryPlansForProviderRequest) Reset ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) Reset()
func (*QueryPlansForProviderRequest) Size ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) Size() (n int)
func (*QueryPlansForProviderRequest) String ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) String() string
func (*QueryPlansForProviderRequest) Unmarshal ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) Unmarshal(dAtA []byte) error
func (*QueryPlansForProviderRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) XXX_DiscardUnknown()
func (*QueryPlansForProviderRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPlansForProviderRequest) XXX_Merge ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) XXX_Merge(src proto.Message)
func (*QueryPlansForProviderRequest) XXX_Size ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) XXX_Size() int
func (*QueryPlansForProviderRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryPlansForProviderRequest) XXX_Unmarshal(b []byte) error
type QueryPlansForProviderResponse ¶ added in v0.6.0
type QueryPlansForProviderResponse struct { Plans []Plan `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPlansForProviderResponse) Descriptor ¶ added in v0.6.0
func (*QueryPlansForProviderResponse) Descriptor() ([]byte, []int)
func (*QueryPlansForProviderResponse) Marshal ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) Marshal() (dAtA []byte, err error)
func (*QueryPlansForProviderResponse) MarshalTo ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlansForProviderResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPlansForProviderResponse) ProtoMessage ¶ added in v0.6.0
func (*QueryPlansForProviderResponse) ProtoMessage()
func (*QueryPlansForProviderResponse) Reset ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) Reset()
func (*QueryPlansForProviderResponse) Size ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) Size() (n int)
func (*QueryPlansForProviderResponse) String ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) String() string
func (*QueryPlansForProviderResponse) Unmarshal ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) Unmarshal(dAtA []byte) error
func (*QueryPlansForProviderResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) XXX_DiscardUnknown()
func (*QueryPlansForProviderResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPlansForProviderResponse) XXX_Merge ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) XXX_Merge(src proto.Message)
func (*QueryPlansForProviderResponse) XXX_Size ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) XXX_Size() int
func (*QueryPlansForProviderResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryPlansForProviderResponse) XXX_Unmarshal(b []byte) error
type QueryPlansRequest ¶ added in v0.6.0
type QueryPlansRequest struct { Status types.Status `protobuf:"varint,1,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"` Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func NewQueryPlansRequest ¶ added in v0.6.0
func NewQueryPlansRequest(status hubtypes.Status, pagination *query.PageRequest) *QueryPlansRequest
func (*QueryPlansRequest) Descriptor ¶ added in v0.6.0
func (*QueryPlansRequest) Descriptor() ([]byte, []int)
func (*QueryPlansRequest) Marshal ¶ added in v0.6.0
func (m *QueryPlansRequest) Marshal() (dAtA []byte, err error)
func (*QueryPlansRequest) MarshalTo ¶ added in v0.6.0
func (m *QueryPlansRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlansRequest) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryPlansRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPlansRequest) ProtoMessage ¶ added in v0.6.0
func (*QueryPlansRequest) ProtoMessage()
func (*QueryPlansRequest) Reset ¶ added in v0.6.0
func (m *QueryPlansRequest) Reset()
func (*QueryPlansRequest) Size ¶ added in v0.6.0
func (m *QueryPlansRequest) Size() (n int)
func (*QueryPlansRequest) String ¶ added in v0.6.0
func (m *QueryPlansRequest) String() string
func (*QueryPlansRequest) Unmarshal ¶ added in v0.6.0
func (m *QueryPlansRequest) Unmarshal(dAtA []byte) error
func (*QueryPlansRequest) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryPlansRequest) XXX_DiscardUnknown()
func (*QueryPlansRequest) XXX_Marshal ¶ added in v0.6.0
func (m *QueryPlansRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPlansRequest) XXX_Merge ¶ added in v0.6.0
func (m *QueryPlansRequest) XXX_Merge(src proto.Message)
func (*QueryPlansRequest) XXX_Size ¶ added in v0.6.0
func (m *QueryPlansRequest) XXX_Size() int
func (*QueryPlansRequest) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryPlansRequest) XXX_Unmarshal(b []byte) error
type QueryPlansResponse ¶ added in v0.6.0
type QueryPlansResponse struct { Plans []Plan `protobuf:"bytes,1,rep,name=plans,proto3" json:"plans"` Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
func (*QueryPlansResponse) Descriptor ¶ added in v0.6.0
func (*QueryPlansResponse) Descriptor() ([]byte, []int)
func (*QueryPlansResponse) Marshal ¶ added in v0.6.0
func (m *QueryPlansResponse) Marshal() (dAtA []byte, err error)
func (*QueryPlansResponse) MarshalTo ¶ added in v0.6.0
func (m *QueryPlansResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPlansResponse) MarshalToSizedBuffer ¶ added in v0.6.0
func (m *QueryPlansResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPlansResponse) ProtoMessage ¶ added in v0.6.0
func (*QueryPlansResponse) ProtoMessage()
func (*QueryPlansResponse) Reset ¶ added in v0.6.0
func (m *QueryPlansResponse) Reset()
func (*QueryPlansResponse) Size ¶ added in v0.6.0
func (m *QueryPlansResponse) Size() (n int)
func (*QueryPlansResponse) String ¶ added in v0.6.0
func (m *QueryPlansResponse) String() string
func (*QueryPlansResponse) Unmarshal ¶ added in v0.6.0
func (m *QueryPlansResponse) Unmarshal(dAtA []byte) error
func (*QueryPlansResponse) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *QueryPlansResponse) XXX_DiscardUnknown()
func (*QueryPlansResponse) XXX_Marshal ¶ added in v0.6.0
func (m *QueryPlansResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPlansResponse) XXX_Merge ¶ added in v0.6.0
func (m *QueryPlansResponse) XXX_Merge(src proto.Message)
func (*QueryPlansResponse) XXX_Size ¶ added in v0.6.0
func (m *QueryPlansResponse) XXX_Size() int
func (*QueryPlansResponse) XXX_Unmarshal ¶ added in v0.6.0
func (m *QueryPlansResponse) XXX_Unmarshal(b []byte) error
type QueryServiceClient ¶ added in v0.6.0
type QueryServiceClient interface { QueryPlans(ctx context.Context, in *QueryPlansRequest, opts ...grpc.CallOption) (*QueryPlansResponse, error) QueryPlansForProvider(ctx context.Context, in *QueryPlansForProviderRequest, opts ...grpc.CallOption) (*QueryPlansForProviderResponse, error) QueryPlan(ctx context.Context, in *QueryPlanRequest, opts ...grpc.CallOption) (*QueryPlanResponse, error) QueryNodesForPlan(ctx context.Context, in *QueryNodesForPlanRequest, opts ...grpc.CallOption) (*QueryNodesForPlanResponse, error) }
QueryServiceClient is the client API for QueryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryServiceClient ¶ added in v0.6.0
func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient
type QueryServiceServer ¶ added in v0.6.0
type QueryServiceServer interface { QueryPlans(context.Context, *QueryPlansRequest) (*QueryPlansResponse, error) QueryPlansForProvider(context.Context, *QueryPlansForProviderRequest) (*QueryPlansForProviderResponse, error) QueryPlan(context.Context, *QueryPlanRequest) (*QueryPlanResponse, error) QueryNodesForPlan(context.Context, *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error) }
QueryServiceServer is the server API for QueryService service.
type UnimplementedMsgServiceServer ¶ added in v0.6.0
type UnimplementedMsgServiceServer struct { }
UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServiceServer) MsgAdd ¶ added in v0.6.0
func (*UnimplementedMsgServiceServer) MsgAdd(ctx context.Context, req *MsgAddRequest) (*MsgAddResponse, error)
func (*UnimplementedMsgServiceServer) MsgAddNode ¶ added in v0.6.0
func (*UnimplementedMsgServiceServer) MsgAddNode(ctx context.Context, req *MsgAddNodeRequest) (*MsgAddNodeResponse, error)
func (*UnimplementedMsgServiceServer) MsgRemoveNode ¶ added in v0.6.0
func (*UnimplementedMsgServiceServer) MsgRemoveNode(ctx context.Context, req *MsgRemoveNodeRequest) (*MsgRemoveNodeResponse, error)
func (*UnimplementedMsgServiceServer) MsgSetStatus ¶ added in v0.6.0
func (*UnimplementedMsgServiceServer) MsgSetStatus(ctx context.Context, req *MsgSetStatusRequest) (*MsgSetStatusResponse, error)
type UnimplementedQueryServiceServer ¶ added in v0.6.0
type UnimplementedQueryServiceServer struct { }
UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServiceServer) QueryNodesForPlan ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QueryNodesForPlan(ctx context.Context, req *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error)
func (*UnimplementedQueryServiceServer) QueryPlan ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QueryPlan(ctx context.Context, req *QueryPlanRequest) (*QueryPlanResponse, error)
func (*UnimplementedQueryServiceServer) QueryPlans ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QueryPlans(ctx context.Context, req *QueryPlansRequest) (*QueryPlansResponse, error)
func (*UnimplementedQueryServiceServer) QueryPlansForProvider ¶ added in v0.6.0
func (*UnimplementedQueryServiceServer) QueryPlansForProvider(ctx context.Context, req *QueryPlansForProviderRequest) (*QueryPlansForProviderResponse, error)