types

package
v12.0.0-rc4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 1, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName = "node"
)

Variables

View Source 
var (
	ErrorInvalidMessage = sdkerrors.Register(ModuleName, 101, "invalid message")

	ErrorDuplicateNode    = sdkerrors.Register(ModuleName, 201, "duplicate node")
	ErrorInvalidGigabytes = sdkerrors.Register(ModuleName, 202, "invalid gigabytes")
	ErrorInvalidHours     = sdkerrors.Register(ModuleName, 203, "invalid hours")
	ErrorInvalidPrices    = sdkerrors.Register(ModuleName, 204, "invalid prices")
	ErrorNodeNotFound     = sdkerrors.Register(ModuleName, 205, "node not found")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	NodeKeyPrefix              = []byte{0x10}
	ActiveNodeKeyPrefix        = append(NodeKeyPrefix, 0x01)
	InactiveNodeKeyPrefix      = append(NodeKeyPrefix, 0x02)
	NodeForInactiveAtKeyPrefix = []byte{0x11}
	NodeForPlanKeyPrefix       = []byte{0x12}
)
View Source 
var (
	ErrInvalidLengthMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNode        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DefaultDeposit                        = sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(10))
	DefaultActiveDuration                 = 30 * time.Second
	DefaultMaxGigabytePrices              = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(100)))
	DefaultMinGigabytePrices              = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(1)))
	DefaultMaxHourlyPrices                = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(100)))
	DefaultMinHourlyPrices                = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(1)))
	DefaultMaxSubscriptionGigabytes int64 = 10
	DefaultMinSubscriptionGigabytes int64 = 1
	DefaultMaxSubscriptionHours     int64 = 10
	DefaultMinSubscriptionHours     int64 = 1
	DefaultStakingShare                   = sdkmath.LegacyNewDecWithPrec(1, 1)
)
View Source 
var (
	KeyDeposit                  = []byte("Deposit")
	KeyActiveDuration           = []byte("ActiveDuration")
	KeyMaxGigabytePrices        = []byte("MaxGigabytePrices")
	KeyMinGigabytePrices        = []byte("MinGigabytePrices")
	KeyMaxHourlyPrices          = []byte("MaxHourlyPrices")
	KeyMinHourlyPrices          = []byte("MinHourlyPrices")
	KeyMaxSubscriptionGigabytes = []byte("MaxSubscriptionGigabytes")
	KeyMinSubscriptionGigabytes = []byte("MinSubscriptionGigabytes")
	KeyMaxSubscriptionHours     = []byte("MaxSubscriptionHours")
	KeyMinSubscriptionHours     = []byte("MinSubscriptionHours")
	KeyStakingShare             = []byte("StakingShare")
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuerier        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuerier          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuerier = fmt.Errorf("proto: unexpected end of group")
)

Functions

func ActiveNodeKey 

func ActiveNodeKey(addr hubtypes.NodeAddress) []byte

func AddressFromNodeForInactiveAtKey 

func AddressFromNodeForInactiveAtKey(key []byte) hubtypes.NodeAddress

func AddressFromNodeForPlanKey 

func AddressFromNodeForPlanKey(key []byte) hubtypes.NodeAddress

func GetNodeForInactiveAtKeyPrefix 

func GetNodeForInactiveAtKeyPrefix(at time.Time) []byte

func GetNodeForPlanKeyPrefix 

func GetNodeForPlanKeyPrefix(id uint64) []byte

func InactiveNodeKey 

func InactiveNodeKey(addr hubtypes.NodeAddress) []byte

func NewErrorDuplicateNode 

func NewErrorDuplicateNode(addr interface{}) error

func NewErrorInvalidGigabytes 

func NewErrorInvalidGigabytes(gigabytes int64) error

func NewErrorInvalidHours 

func NewErrorInvalidHours(hours int64) error

func NewErrorInvalidPrices 

func NewErrorInvalidPrices(prices sdk.Coins) error

func NewErrorNodeNotFound 

func NewErrorNodeNotFound(addr interface{}) error

func NodeForInactiveAtKey 

func NodeForInactiveAtKey(at time.Time, addr hubtypes.NodeAddress) []byte

func NodeForPlanKey 

func NodeForPlanKey(id uint64, addr hubtypes.NodeAddress) []byte

func ParamsKeyTable 

func ParamsKeyTable() params.KeyTable

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

func RegisterMsgServiceServer 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServiceHandler 

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 

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 

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 

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 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

func ValidateGenesis 

func ValidateGenesis(state *GenesisState) error

Types

type EventCreateSubscription 

type EventCreateSubscription struct {
	// Field 1: Address associated with the create subscription event.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Node address associated with the create subscription event.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 3: ID associated with the create subscription event.
	ID uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
}

EventCreateSubscription represents an event for creating a subscription.

func (*EventCreateSubscription) Descriptor 

func (*EventCreateSubscription) Descriptor() ([]byte, []int)

func (*EventCreateSubscription) Marshal 

func (m *EventCreateSubscription) Marshal() (dAtA []byte, err error)

func (*EventCreateSubscription) MarshalTo 

func (m *EventCreateSubscription) MarshalTo(dAtA []byte) (int, error)

func (*EventCreateSubscription) MarshalToSizedBuffer 

func (m *EventCreateSubscription) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventCreateSubscription) ProtoMessage 

func (*EventCreateSubscription) ProtoMessage()

func (*EventCreateSubscription) Reset 

func (m *EventCreateSubscription) Reset()

func (*EventCreateSubscription) Size 

func (m *EventCreateSubscription) Size() (n int)

func (*EventCreateSubscription) String 

func (m *EventCreateSubscription) String() string

func (*EventCreateSubscription) Unmarshal 

func (m *EventCreateSubscription) Unmarshal(dAtA []byte) error

func (*EventCreateSubscription) XXX_DiscardUnknown 

func (m *EventCreateSubscription) XXX_DiscardUnknown()

func (*EventCreateSubscription) XXX_Marshal 

func (m *EventCreateSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventCreateSubscription) XXX_Merge 

func (m *EventCreateSubscription) XXX_Merge(src proto.Message)

func (*EventCreateSubscription) XXX_Size 

func (m *EventCreateSubscription) XXX_Size() int

func (*EventCreateSubscription) XXX_Unmarshal 

func (m *EventCreateSubscription) XXX_Unmarshal(b []byte) error

type EventRegister 

type EventRegister struct {
	// Field 1: Address associated with the registration event.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
}

EventRegister represents an event for registration.

func (*EventRegister) Descriptor 

func (*EventRegister) Descriptor() ([]byte, []int)

func (*EventRegister) Marshal 

func (m *EventRegister) Marshal() (dAtA []byte, err error)

func (*EventRegister) MarshalTo 

func (m *EventRegister) MarshalTo(dAtA []byte) (int, error)

func (*EventRegister) MarshalToSizedBuffer 

func (m *EventRegister) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventRegister) ProtoMessage 

func (*EventRegister) ProtoMessage()

func (*EventRegister) Reset 

func (m *EventRegister) Reset()

func (*EventRegister) Size 

func (m *EventRegister) Size() (n int)

func (*EventRegister) String 

func (m *EventRegister) String() string

func (*EventRegister) Unmarshal 

func (m *EventRegister) Unmarshal(dAtA []byte) error

func (*EventRegister) XXX_DiscardUnknown 

func (m *EventRegister) XXX_DiscardUnknown()

func (*EventRegister) XXX_Marshal 

func (m *EventRegister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventRegister) XXX_Merge 

func (m *EventRegister) XXX_Merge(src proto.Message)

func (*EventRegister) XXX_Size 

func (m *EventRegister) XXX_Size() int

func (*EventRegister) XXX_Unmarshal 

func (m *EventRegister) XXX_Unmarshal(b []byte) error

type EventUpdateDetails 

type EventUpdateDetails struct {
	Address        string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	GigabytePrices string `` /* 126-byte string literal not displayed */
	HourlyPrices   string `protobuf:"bytes,3,opt,name=hourly_prices,json=hourlyPrices,proto3" json:"hourly_prices,omitempty" yaml:"hourly_prices"`
	RemoteURL      string `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

EventUpdateDetails represents an event for updating details.

func (*EventUpdateDetails) Descriptor 

func (*EventUpdateDetails) Descriptor() ([]byte, []int)

func (*EventUpdateDetails) Marshal 

func (m *EventUpdateDetails) Marshal() (dAtA []byte, err error)

func (*EventUpdateDetails) MarshalTo 

func (m *EventUpdateDetails) MarshalTo(dAtA []byte) (int, error)

func (*EventUpdateDetails) MarshalToSizedBuffer 

func (m *EventUpdateDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventUpdateDetails) ProtoMessage 

func (*EventUpdateDetails) ProtoMessage()

func (*EventUpdateDetails) Reset 

func (m *EventUpdateDetails) Reset()

func (*EventUpdateDetails) Size 

func (m *EventUpdateDetails) Size() (n int)

func (*EventUpdateDetails) String 

func (m *EventUpdateDetails) String() string

func (*EventUpdateDetails) Unmarshal 

func (m *EventUpdateDetails) Unmarshal(dAtA []byte) error

func (*EventUpdateDetails) XXX_DiscardUnknown 

func (m *EventUpdateDetails) XXX_DiscardUnknown()

func (*EventUpdateDetails) XXX_Marshal 

func (m *EventUpdateDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventUpdateDetails) XXX_Merge 

func (m *EventUpdateDetails) XXX_Merge(src proto.Message)

func (*EventUpdateDetails) XXX_Size 

func (m *EventUpdateDetails) XXX_Size() int

func (*EventUpdateDetails) XXX_Unmarshal 

func (m *EventUpdateDetails) XXX_Unmarshal(b []byte) error

type EventUpdateStatus 

type EventUpdateStatus struct {
	// Field 1: Status to be updated in the event.
	Status types.Status `protobuf:"varint,1,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty" yaml:"status"`
	// Field 2: Address associated with the update status event.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
}

EventUpdateStatus represents an event for updating status.

func (*EventUpdateStatus) Descriptor 

func (*EventUpdateStatus) Descriptor() ([]byte, []int)

func (*EventUpdateStatus) Marshal 

func (m *EventUpdateStatus) Marshal() (dAtA []byte, err error)

func (*EventUpdateStatus) MarshalTo 

func (m *EventUpdateStatus) MarshalTo(dAtA []byte) (int, error)

func (*EventUpdateStatus) MarshalToSizedBuffer 

func (m *EventUpdateStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventUpdateStatus) ProtoMessage 

func (*EventUpdateStatus) ProtoMessage()

func (*EventUpdateStatus) Reset 

func (m *EventUpdateStatus) Reset()

func (*EventUpdateStatus) Size 

func (m *EventUpdateStatus) Size() (n int)

func (*EventUpdateStatus) String 

func (m *EventUpdateStatus) String() string

func (*EventUpdateStatus) Unmarshal 

func (m *EventUpdateStatus) Unmarshal(dAtA []byte) error

func (*EventUpdateStatus) XXX_DiscardUnknown 

func (m *EventUpdateStatus) XXX_DiscardUnknown()

func (*EventUpdateStatus) XXX_Marshal 

func (m *EventUpdateStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventUpdateStatus) XXX_Merge 

func (m *EventUpdateStatus) XXX_Merge(src proto.Message)

func (*EventUpdateStatus) XXX_Size 

func (m *EventUpdateStatus) XXX_Size() int

func (*EventUpdateStatus) XXX_Unmarshal 

func (m *EventUpdateStatus) XXX_Unmarshal(b []byte) error

type GenesisState 

type GenesisState struct {
	// Field 1: List of nodes included in the genesis state.
	// - (gogoproto.nullable) = false: Field is not nullable.
	Nodes []Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
	// Field 2: Parameters associated with the genesis state.
	// - (gogoproto.nullable) = false: Field is not nullable.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

GenesisState represents the genesis state for the module.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(nodes Nodes, params Params) *GenesisState

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, 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) 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 MsgRegisterRequest 

type MsgRegisterRequest struct {
	// Field 1: Sender's address initiating the registration.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Prices in gigabytes for the registered node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	GigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	// Field 3: Hourly prices for the registered node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	HourlyPrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	// Field 4: Remote URL associated with the registered node.
	// - (gogoproto.customname) = "RemoteURL": Custom name for the field.
	RemoteURL string `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

MsgRegisterRequest defines the SDK message for registering a node.

func NewMsgRegisterRequest 

func NewMsgRegisterRequest(from sdk.AccAddress, gigabytePrices, hourlyPrices sdk.Coins, remoteURL string) *MsgRegisterRequest

NewMsgRegisterRequest creates a new MsgRegisterRequest instance with the given parameters.

func (*MsgRegisterRequest) Descriptor 

func (*MsgRegisterRequest) Descriptor() ([]byte, []int)

func (*MsgRegisterRequest) GetSigners 

func (m *MsgRegisterRequest) GetSigners() []sdk.AccAddress

GetSigners returns an array containing the signer's account address extracted from the 'From' field of the MsgRegisterRequest.

func (*MsgRegisterRequest) Marshal 

func (m *MsgRegisterRequest) Marshal() (dAtA []byte, err error)

func (*MsgRegisterRequest) MarshalTo 

func (m *MsgRegisterRequest) MarshalTo(dAtA []byte) (int, error)

func (*MsgRegisterRequest) MarshalToSizedBuffer 

func (m *MsgRegisterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRegisterRequest) ProtoMessage 

func (*MsgRegisterRequest) ProtoMessage()

func (*MsgRegisterRequest) Reset 

func (m *MsgRegisterRequest) Reset()

func (*MsgRegisterRequest) Size 

func (m *MsgRegisterRequest) Size() (n int)

func (*MsgRegisterRequest) String 

func (m *MsgRegisterRequest) String() string

func (*MsgRegisterRequest) Unmarshal 

func (m *MsgRegisterRequest) Unmarshal(dAtA []byte) error

func (*MsgRegisterRequest) ValidateBasic 

func (m *MsgRegisterRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgRegisterRequest fields. It checks if the 'From' field is not empty and represents a valid account address, if the 'GigabytePrices' and 'HourlyPrices' fields are valid coins (not empty, not containing nil coins, and having valid coin denominations), and if the 'RemoteURL' field is valid (not empty, not longer than 64 characters, and has a valid "https" scheme and non-empty port).

func (*MsgRegisterRequest) XXX_DiscardUnknown 

func (m *MsgRegisterRequest) XXX_DiscardUnknown()

func (*MsgRegisterRequest) XXX_Marshal 

func (m *MsgRegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRegisterRequest) XXX_Merge 

func (m *MsgRegisterRequest) XXX_Merge(src proto.Message)

func (*MsgRegisterRequest) XXX_Size 

func (m *MsgRegisterRequest) XXX_Size() int

func (*MsgRegisterRequest) XXX_Unmarshal 

func (m *MsgRegisterRequest) XXX_Unmarshal(b []byte) error

type MsgRegisterResponse 

type MsgRegisterResponse struct {
}

MsgRegisterResponse defines the response of message MsgRegisterRequest.

func (*MsgRegisterResponse) Descriptor 

func (*MsgRegisterResponse) Descriptor() ([]byte, []int)

func (*MsgRegisterResponse) Marshal 

func (m *MsgRegisterResponse) Marshal() (dAtA []byte, err error)

func (*MsgRegisterResponse) MarshalTo 

func (m *MsgRegisterResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgRegisterResponse) MarshalToSizedBuffer 

func (m *MsgRegisterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRegisterResponse) ProtoMessage 

func (*MsgRegisterResponse) ProtoMessage()

func (*MsgRegisterResponse) Reset 

func (m *MsgRegisterResponse) Reset()

func (*MsgRegisterResponse) Size 

func (m *MsgRegisterResponse) Size() (n int)

func (*MsgRegisterResponse) String 

func (m *MsgRegisterResponse) String() string

func (*MsgRegisterResponse) Unmarshal 

func (m *MsgRegisterResponse) Unmarshal(dAtA []byte) error

func (*MsgRegisterResponse) XXX_DiscardUnknown 

func (m *MsgRegisterResponse) XXX_DiscardUnknown()

func (*MsgRegisterResponse) XXX_Marshal 

func (m *MsgRegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRegisterResponse) XXX_Merge 

func (m *MsgRegisterResponse) XXX_Merge(src proto.Message)

func (*MsgRegisterResponse) XXX_Size 

func (m *MsgRegisterResponse) XXX_Size() int

func (*MsgRegisterResponse) XXX_Unmarshal 

func (m *MsgRegisterResponse) XXX_Unmarshal(b []byte) error

type MsgServiceClient 

type MsgServiceClient interface {
	// RPC method for registering a node.
	MsgRegister(ctx context.Context, in *MsgRegisterRequest, opts ...grpc.CallOption) (*MsgRegisterResponse, error)
	// RPC method for updating node details.
	MsgUpdateDetails(ctx context.Context, in *MsgUpdateDetailsRequest, opts ...grpc.CallOption) (*MsgUpdateDetailsResponse, error)
	// RPC method for updating node status.
	MsgUpdateStatus(ctx context.Context, in *MsgUpdateStatusRequest, opts ...grpc.CallOption) (*MsgUpdateStatusResponse, error)
	// RPC method for subscribing to a node.
	MsgSubscribe(ctx context.Context, in *MsgSubscribeRequest, opts ...grpc.CallOption) (*MsgSubscribeResponse, 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 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	// RPC method for registering a node.
	MsgRegister(context.Context, *MsgRegisterRequest) (*MsgRegisterResponse, error)
	// RPC method for updating node details.
	MsgUpdateDetails(context.Context, *MsgUpdateDetailsRequest) (*MsgUpdateDetailsResponse, error)
	// RPC method for updating node status.
	MsgUpdateStatus(context.Context, *MsgUpdateStatusRequest) (*MsgUpdateStatusResponse, error)
	// RPC method for subscribing to a node.
	MsgSubscribe(context.Context, *MsgSubscribeRequest) (*MsgSubscribeResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgSubscribeRequest 

type MsgSubscribeRequest struct {
	// Field 1: Sender's address initiating the subscription.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Node address to subscribe to.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// Field 3: Number of gigabytes for the subscription.
	Gigabytes int64 `protobuf:"varint,3,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"`
	// Field 4: Number of hours for the subscription.
	Hours int64 `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"`
	// Field 5: Denomination for the subscription.
	Denom string `protobuf:"bytes,5,opt,name=denom,proto3" json:"denom,omitempty"`
}

MsgSubscribeRequest defines the SDK message for subscribing to a node.

func NewMsgSubscribeRequest 

func NewMsgSubscribeRequest(from sdk.AccAddress, addr hubtypes.NodeAddress, gigabytes, hours int64, denom string) *MsgSubscribeRequest

NewMsgSubscribeRequest creates a new MsgSubscribeRequest instance with the given parameters.

func (*MsgSubscribeRequest) Descriptor 

func (*MsgSubscribeRequest) Descriptor() ([]byte, []int)

func (*MsgSubscribeRequest) GetSigners 

func (m *MsgSubscribeRequest) GetSigners() []sdk.AccAddress

GetSigners returns an array containing the signer's account address extracted from the 'From' field of the MsgSubscribeRequest.

func (*MsgSubscribeRequest) Marshal 

func (m *MsgSubscribeRequest) Marshal() (dAtA []byte, err error)

func (*MsgSubscribeRequest) MarshalTo 

func (m *MsgSubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*MsgSubscribeRequest) MarshalToSizedBuffer 

func (m *MsgSubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgSubscribeRequest) ProtoMessage 

func (*MsgSubscribeRequest) ProtoMessage()

func (*MsgSubscribeRequest) Reset 

func (m *MsgSubscribeRequest) Reset()

func (*MsgSubscribeRequest) Size 

func (m *MsgSubscribeRequest) Size() (n int)

func (*MsgSubscribeRequest) String 

func (m *MsgSubscribeRequest) String() string

func (*MsgSubscribeRequest) Unmarshal 

func (m *MsgSubscribeRequest) Unmarshal(dAtA []byte) error

func (*MsgSubscribeRequest) ValidateBasic 

func (m *MsgSubscribeRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgSubscribeRequest fields. It checks if the 'From' field is not empty and represents a valid account address, if the 'NodeAddress' field is not empty and represents a valid node address, if either 'Gigabytes' or 'Hours' field (but not both) are non-zero and non-negative, and if the 'Denom' field is valid according to the Cosmos SDK's ValidateDenom function.

func (*MsgSubscribeRequest) XXX_DiscardUnknown 

func (m *MsgSubscribeRequest) XXX_DiscardUnknown()

func (*MsgSubscribeRequest) XXX_Marshal 

func (m *MsgSubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgSubscribeRequest) XXX_Merge 

func (m *MsgSubscribeRequest) XXX_Merge(src proto.Message)

func (*MsgSubscribeRequest) XXX_Size 

func (m *MsgSubscribeRequest) XXX_Size() int

func (*MsgSubscribeRequest) XXX_Unmarshal 

func (m *MsgSubscribeRequest) XXX_Unmarshal(b []byte) error

type MsgSubscribeResponse 

type MsgSubscribeResponse struct {
}

MsgSubscribeResponse defines the response of message MsgSubscribeRequest.

func (*MsgSubscribeResponse) Descriptor 

func (*MsgSubscribeResponse) Descriptor() ([]byte, []int)

func (*MsgSubscribeResponse) Marshal 

func (m *MsgSubscribeResponse) Marshal() (dAtA []byte, err error)

func (*MsgSubscribeResponse) MarshalTo 

func (m *MsgSubscribeResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgSubscribeResponse) MarshalToSizedBuffer 

func (m *MsgSubscribeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgSubscribeResponse) ProtoMessage 

func (*MsgSubscribeResponse) ProtoMessage()

func (*MsgSubscribeResponse) Reset 

func (m *MsgSubscribeResponse) Reset()

func (*MsgSubscribeResponse) Size 

func (m *MsgSubscribeResponse) Size() (n int)

func (*MsgSubscribeResponse) String 

func (m *MsgSubscribeResponse) String() string

func (*MsgSubscribeResponse) Unmarshal 

func (m *MsgSubscribeResponse) Unmarshal(dAtA []byte) error

func (*MsgSubscribeResponse) XXX_DiscardUnknown 

func (m *MsgSubscribeResponse) XXX_DiscardUnknown()

func (*MsgSubscribeResponse) XXX_Marshal 

func (m *MsgSubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgSubscribeResponse) XXX_Merge 

func (m *MsgSubscribeResponse) XXX_Merge(src proto.Message)

func (*MsgSubscribeResponse) XXX_Size 

func (m *MsgSubscribeResponse) XXX_Size() int

func (*MsgSubscribeResponse) XXX_Unmarshal 

func (m *MsgSubscribeResponse) XXX_Unmarshal(b []byte) error

type MsgUpdateDetailsRequest 

type MsgUpdateDetailsRequest struct {
	// Field 1: Sender's address initiating the update.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Updated prices in gigabytes for the node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	GigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	// Field 3: Updated hourly prices for the node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	HourlyPrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	// Field 4: Updated remote URL for the node.
	// - (gogoproto.customname) = "RemoteURL": Custom name for the field.
	RemoteURL string `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

MsgUpdateDetailsRequest defines the SDK message for updating node details.

func NewMsgUpdateDetailsRequest 

func NewMsgUpdateDetailsRequest(from hubtypes.NodeAddress, gigabytePrices, hourlyPrices sdk.Coins, remoteURL string) *MsgUpdateDetailsRequest

NewMsgUpdateDetailsRequest creates a new MsgUpdateDetailsRequest instance with the given parameters.

func (*MsgUpdateDetailsRequest) Descriptor 

func (*MsgUpdateDetailsRequest) Descriptor() ([]byte, []int)

func (*MsgUpdateDetailsRequest) GetSigners 

func (m *MsgUpdateDetailsRequest) GetSigners() []sdk.AccAddress

GetSigners returns an array containing the signer's account address extracted from the 'From' field of the MsgUpdateDetailsRequest.

func (*MsgUpdateDetailsRequest) Marshal 

func (m *MsgUpdateDetailsRequest) Marshal() (dAtA []byte, err error)

func (*MsgUpdateDetailsRequest) MarshalTo 

func (m *MsgUpdateDetailsRequest) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateDetailsRequest) MarshalToSizedBuffer 

func (m *MsgUpdateDetailsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateDetailsRequest) ProtoMessage 

func (*MsgUpdateDetailsRequest) ProtoMessage()

func (*MsgUpdateDetailsRequest) Reset 

func (m *MsgUpdateDetailsRequest) Reset()

func (*MsgUpdateDetailsRequest) Size 

func (m *MsgUpdateDetailsRequest) Size() (n int)

func (*MsgUpdateDetailsRequest) String 

func (m *MsgUpdateDetailsRequest) String() string

func (*MsgUpdateDetailsRequest) Unmarshal 

func (m *MsgUpdateDetailsRequest) Unmarshal(dAtA []byte) error

func (*MsgUpdateDetailsRequest) ValidateBasic 

func (m *MsgUpdateDetailsRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgUpdateDetailsRequest fields. It checks if the 'From' field is not empty and represents a valid node address, if the 'GigabytePrices' and 'HourlyPrices' fields are valid coins (not empty, not containing nil coins, and having valid coin denominations), and if the 'RemoteURL' field is valid (not empty, not longer than 64 characters, and has a valid "https" scheme and non-empty port).

func (*MsgUpdateDetailsRequest) XXX_DiscardUnknown 

func (m *MsgUpdateDetailsRequest) XXX_DiscardUnknown()

func (*MsgUpdateDetailsRequest) XXX_Marshal 

func (m *MsgUpdateDetailsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateDetailsRequest) XXX_Merge 

func (m *MsgUpdateDetailsRequest) XXX_Merge(src proto.Message)

func (*MsgUpdateDetailsRequest) XXX_Size 

func (m *MsgUpdateDetailsRequest) XXX_Size() int

func (*MsgUpdateDetailsRequest) XXX_Unmarshal 

func (m *MsgUpdateDetailsRequest) XXX_Unmarshal(b []byte) error

type MsgUpdateDetailsResponse 

type MsgUpdateDetailsResponse struct {
}

MsgUpdateDetailsResponse defines the response of message MsgUpdateDetailsRequest.

func (*MsgUpdateDetailsResponse) Descriptor 

func (*MsgUpdateDetailsResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateDetailsResponse) Marshal 

func (m *MsgUpdateDetailsResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateDetailsResponse) MarshalTo 

func (m *MsgUpdateDetailsResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateDetailsResponse) MarshalToSizedBuffer 

func (m *MsgUpdateDetailsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateDetailsResponse) ProtoMessage 

func (*MsgUpdateDetailsResponse) ProtoMessage()

func (*MsgUpdateDetailsResponse) Reset 

func (m *MsgUpdateDetailsResponse) Reset()

func (*MsgUpdateDetailsResponse) Size 

func (m *MsgUpdateDetailsResponse) Size() (n int)

func (*MsgUpdateDetailsResponse) String 

func (m *MsgUpdateDetailsResponse) String() string

func (*MsgUpdateDetailsResponse) Unmarshal 

func (m *MsgUpdateDetailsResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateDetailsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateDetailsResponse) XXX_DiscardUnknown()

func (*MsgUpdateDetailsResponse) XXX_Marshal 

func (m *MsgUpdateDetailsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateDetailsResponse) XXX_Merge 

func (m *MsgUpdateDetailsResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateDetailsResponse) XXX_Size 

func (m *MsgUpdateDetailsResponse) XXX_Size() int

func (*MsgUpdateDetailsResponse) XXX_Unmarshal 

func (m *MsgUpdateDetailsResponse) XXX_Unmarshal(b []byte) error

type MsgUpdateStatusRequest 

type MsgUpdateStatusRequest struct {
	// Field 1: Sender's address initiating the status update.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: New status for the node.
	Status types1.Status `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
}

MsgUpdateStatusRequest defines the SDK message for updating node status.

func NewMsgUpdateStatusRequest 

func NewMsgUpdateStatusRequest(from hubtypes.NodeAddress, status hubtypes.Status) *MsgUpdateStatusRequest

NewMsgUpdateStatusRequest creates a new MsgUpdateStatusRequest instance with the given parameters.

func (*MsgUpdateStatusRequest) Descriptor 

func (*MsgUpdateStatusRequest) Descriptor() ([]byte, []int)

func (*MsgUpdateStatusRequest) GetSigners 

func (m *MsgUpdateStatusRequest) GetSigners() []sdk.AccAddress

GetSigners returns an array containing the signer's account address extracted from the 'From' field of the MsgUpdateStatusRequest.

func (*MsgUpdateStatusRequest) Marshal 

func (m *MsgUpdateStatusRequest) Marshal() (dAtA []byte, err error)

func (*MsgUpdateStatusRequest) MarshalTo 

func (m *MsgUpdateStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateStatusRequest) MarshalToSizedBuffer 

func (m *MsgUpdateStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateStatusRequest) ProtoMessage 

func (*MsgUpdateStatusRequest) ProtoMessage()

func (*MsgUpdateStatusRequest) Reset 

func (m *MsgUpdateStatusRequest) Reset()

func (*MsgUpdateStatusRequest) Size 

func (m *MsgUpdateStatusRequest) Size() (n int)

func (*MsgUpdateStatusRequest) String 

func (m *MsgUpdateStatusRequest) String() string

func (*MsgUpdateStatusRequest) Unmarshal 

func (m *MsgUpdateStatusRequest) Unmarshal(dAtA []byte) error

func (*MsgUpdateStatusRequest) ValidateBasic 

func (m *MsgUpdateStatusRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgUpdateStatusRequest fields. It checks if the 'From' field is not empty and represents a valid node address, and if the 'Status' field is one of the allowed values [active, inactive].

func (*MsgUpdateStatusRequest) XXX_DiscardUnknown 

func (m *MsgUpdateStatusRequest) XXX_DiscardUnknown()

func (*MsgUpdateStatusRequest) XXX_Marshal 

func (m *MsgUpdateStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateStatusRequest) XXX_Merge 

func (m *MsgUpdateStatusRequest) XXX_Merge(src proto.Message)

func (*MsgUpdateStatusRequest) XXX_Size 

func (m *MsgUpdateStatusRequest) XXX_Size() int

func (*MsgUpdateStatusRequest) XXX_Unmarshal 

func (m *MsgUpdateStatusRequest) XXX_Unmarshal(b []byte) error

type MsgUpdateStatusResponse 

type MsgUpdateStatusResponse struct {
}

MsgUpdateStatusResponse defines the response of message MsgUpdateStatusRequest.

func (*MsgUpdateStatusResponse) Descriptor 

func (*MsgUpdateStatusResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateStatusResponse) Marshal 

func (m *MsgUpdateStatusResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateStatusResponse) MarshalTo 

func (m *MsgUpdateStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateStatusResponse) MarshalToSizedBuffer 

func (m *MsgUpdateStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateStatusResponse) ProtoMessage 

func (*MsgUpdateStatusResponse) ProtoMessage()

func (*MsgUpdateStatusResponse) Reset 

func (m *MsgUpdateStatusResponse) Reset()

func (*MsgUpdateStatusResponse) Size 

func (m *MsgUpdateStatusResponse) Size() (n int)

func (*MsgUpdateStatusResponse) String 

func (m *MsgUpdateStatusResponse) String() string

func (*MsgUpdateStatusResponse) Unmarshal 

func (m *MsgUpdateStatusResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateStatusResponse) XXX_DiscardUnknown 

func (m *MsgUpdateStatusResponse) XXX_DiscardUnknown()

func (*MsgUpdateStatusResponse) XXX_Marshal 

func (m *MsgUpdateStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateStatusResponse) XXX_Merge 

func (m *MsgUpdateStatusResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateStatusResponse) XXX_Size 

func (m *MsgUpdateStatusResponse) XXX_Size() int

func (*MsgUpdateStatusResponse) XXX_Unmarshal 

func (m *MsgUpdateStatusResponse) XXX_Unmarshal(b []byte) error

type Node 

type Node struct {
	// Field 1: Address associated with the node.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Prices in gigabytes for the node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	GigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	// Field 3: Hourly prices for the node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	HourlyPrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	// Field 4: Remote URL associated with the node.
	// - (gogoproto.customname) = "RemoteURL": Custom name for the field.
	RemoteURL string `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
	// Field 5: Timestamp indicating when the node became inactive.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.stdtime) = true: Use standard time representation for Go.
	InactiveAt time.Time `protobuf:"bytes,5,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	// Field 6: Status of the node, using the sentinel.types.v1.Status enum.
	Status types1.Status `protobuf:"varint,6,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	// Field 7: Timestamp indicating when the status of the node was last updated.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.stdtime) = true: Use standard time representation for Go.
	StatusAt time.Time `protobuf:"bytes,7,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

Node represents a message for handling node information.

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetAddress 

func (m *Node) GetAddress() hubtypes.NodeAddress

func (*Node) GigabytePrice 

func (m *Node) GigabytePrice(denom string) (sdk.Coin, bool)

func (*Node) HourlyPrice 

func (m *Node) HourlyPrice(denom string) (sdk.Coin, bool)

func (*Node) Marshal 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) MarshalToSizedBuffer 

func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) Validate 

func (m *Node) Validate() error

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type Nodes 

type Nodes []Node

type Params 

type Params struct {
	// Field 1: Deposit required for registering a node.
	// - (gogoproto.nullable) = false: Field is not nullable.
	Deposit types.Coin `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit"`
	// Field 2: Duration for which a node remains active.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.stdduration) = true: Use standard duration representation for Go.
	ActiveDuration time.Duration `protobuf:"bytes,2,opt,name=active_duration,json=activeDuration,proto3,stdduration" json:"active_duration"`
	// Field 3: Maximum prices in gigabytes for a node's subscription.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	MaxGigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
	// Field 4: Minimum prices in gigabytes for a node's subscription.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	MinGigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
	// Field 5: Maximum prices in hours for a node's subscription.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	MaxHourlyPrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 152-byte string literal not displayed */
	// Field 6: Minimum prices in hours for a node's subscription.
	// - (gogoproto.nullable) = false: Field is not nullable.
	// - (gogoproto.castrepeated) = "github.com/cosmos/cosmos-sdk/types.Coins":
	//   Type to cast to when repeating this field.
	MinHourlyPrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 152-byte string literal not displayed */
	// Field 7: Maximum gigabytes allowed for a subscription.
	MaxSubscriptionGigabytes int64 `` /* 136-byte string literal not displayed */
	// Field 8: Minimum gigabytes required for a subscription.
	MinSubscriptionGigabytes int64 `` /* 136-byte string literal not displayed */
	// Field 9: Maximum hours allowed for a subscription.
	MaxSubscriptionHours int64 `protobuf:"varint,9,opt,name=max_subscription_hours,json=maxSubscriptionHours,proto3" json:"max_subscription_hours,omitempty"`
	// Field 10: Minimum hours required for a subscription.
	MinSubscriptionHours int64 `protobuf:"varint,10,opt,name=min_subscription_hours,json=minSubscriptionHours,proto3" json:"min_subscription_hours,omitempty"`
	// Field 11: Staking share required for a node.
	// - (gogoproto.customtype) = "cosmossdk.io/math.LegacyDec":
	//   Custom type definition for the field.
	// - (gogoproto.nullable) = false: Field is not nullable.
	StakingShare cosmossdk_io_math.LegacyDec `` /* 127-byte string literal not displayed */
}

Params represents a message for handling node parameters.

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(
	deposit sdk.Coin, activeDuration time.Duration, maxGigabytePrices, minGigabytePrices,
	maxHourlyPrices, minHourlyPrices sdk.Coins, maxSubscriptionGigabytes, minSubscriptionGigabytes int64,
	maxSubscriptionHours, minSubscriptionHours int64, stakingShare sdkmath.LegacyDec,
) Params

func (*Params) Descriptor 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ParamSetPairs 

func (m *Params) ParamSetPairs() params.ParamSetPairs

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (*Params) Validate 

func (m *Params) Validate() error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

func (m *Params) XXX_Unmarshal(b []byte) error

type QueryNodeRequest 

type QueryNodeRequest struct {
	// Field 1: Address of the node to query.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryNodeRequest represents a request to query information about a specific node.

func NewQueryNodeRequest 

func NewQueryNodeRequest(addr hubtypes.NodeAddress) *QueryNodeRequest

func (*QueryNodeRequest) Descriptor 

func (*QueryNodeRequest) Descriptor() ([]byte, []int)

func (*QueryNodeRequest) Marshal 

func (m *QueryNodeRequest) Marshal() (dAtA []byte, err error)

func (*QueryNodeRequest) MarshalTo 

func (m *QueryNodeRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryNodeRequest) MarshalToSizedBuffer 

func (m *QueryNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryNodeRequest) ProtoMessage 

func (*QueryNodeRequest) ProtoMessage()

func (*QueryNodeRequest) Reset 

func (m *QueryNodeRequest) Reset()

func (*QueryNodeRequest) Size 

func (m *QueryNodeRequest) Size() (n int)

func (*QueryNodeRequest) String 

func (m *QueryNodeRequest) String() string

func (*QueryNodeRequest) Unmarshal 

func (m *QueryNodeRequest) Unmarshal(dAtA []byte) error

func (*QueryNodeRequest) XXX_DiscardUnknown 

func (m *QueryNodeRequest) XXX_DiscardUnknown()

func (*QueryNodeRequest) XXX_Marshal 

func (m *QueryNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryNodeRequest) XXX_Merge 

func (m *QueryNodeRequest) XXX_Merge(src proto.Message)

func (*QueryNodeRequest) XXX_Size 

func (m *QueryNodeRequest) XXX_Size() int

func (*QueryNodeRequest) XXX_Unmarshal 

func (m *QueryNodeRequest) XXX_Unmarshal(b []byte) error

type QueryNodeResponse 

type QueryNodeResponse struct {
	// Field 1: Information about the queried node.
	Node Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node"`
}

QueryNodeResponse represents a response containing information about a specific node.

func (*QueryNodeResponse) Descriptor 

func (*QueryNodeResponse) Descriptor() ([]byte, []int)

func (*QueryNodeResponse) Marshal 

func (m *QueryNodeResponse) Marshal() (dAtA []byte, err error)

func (*QueryNodeResponse) MarshalTo 

func (m *QueryNodeResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryNodeResponse) MarshalToSizedBuffer 

func (m *QueryNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryNodeResponse) ProtoMessage 

func (*QueryNodeResponse) ProtoMessage()

func (*QueryNodeResponse) Reset 

func (m *QueryNodeResponse) Reset()

func (*QueryNodeResponse) Size 

func (m *QueryNodeResponse) Size() (n int)

func (*QueryNodeResponse) String 

func (m *QueryNodeResponse) String() string

func (*QueryNodeResponse) Unmarshal 

func (m *QueryNodeResponse) Unmarshal(dAtA []byte) error

func (*QueryNodeResponse) XXX_DiscardUnknown 

func (m *QueryNodeResponse) XXX_DiscardUnknown()

func (*QueryNodeResponse) XXX_Marshal 

func (m *QueryNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryNodeResponse) XXX_Merge 

func (m *QueryNodeResponse) XXX_Merge(src proto.Message)

func (*QueryNodeResponse) XXX_Size 

func (m *QueryNodeResponse) XXX_Size() int

func (*QueryNodeResponse) XXX_Unmarshal 

func (m *QueryNodeResponse) XXX_Unmarshal(b []byte) error

type QueryNodesForPlanRequest 

type QueryNodesForPlanRequest struct {
	// Field 1: Plan ID to filter nodes by.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Status to filter nodes by.
	Status types.Status `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	// Field 3: Pagination parameters for the query.
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryNodesForPlanRequest represents a request to query nodes for a specific plan with status and pagination.

func NewQueryNodesForPlanRequest 

func NewQueryNodesForPlanRequest(id uint64, status hubtypes.Status, pagination *query.PageRequest) *QueryNodesForPlanRequest

func (*QueryNodesForPlanRequest) Descriptor 

func (*QueryNodesForPlanRequest) Descriptor() ([]byte, []int)

func (*QueryNodesForPlanRequest) Marshal 

func (m *QueryNodesForPlanRequest) Marshal() (dAtA []byte, err error)

func (*QueryNodesForPlanRequest) MarshalTo 

func (m *QueryNodesForPlanRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryNodesForPlanRequest) MarshalToSizedBuffer 

func (m *QueryNodesForPlanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryNodesForPlanRequest) ProtoMessage 

func (*QueryNodesForPlanRequest) ProtoMessage()

func (*QueryNodesForPlanRequest) Reset 

func (m *QueryNodesForPlanRequest) Reset()

func (*QueryNodesForPlanRequest) Size 

func (m *QueryNodesForPlanRequest) Size() (n int)

func (*QueryNodesForPlanRequest) String 

func (m *QueryNodesForPlanRequest) String() string

func (*QueryNodesForPlanRequest) Unmarshal 

func (m *QueryNodesForPlanRequest) Unmarshal(dAtA []byte) error

func (*QueryNodesForPlanRequest) XXX_DiscardUnknown 

func (m *QueryNodesForPlanRequest) XXX_DiscardUnknown()

func (*QueryNodesForPlanRequest) XXX_Marshal 

func (m *QueryNodesForPlanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryNodesForPlanRequest) XXX_Merge 

func (m *QueryNodesForPlanRequest) XXX_Merge(src proto.Message)

func (*QueryNodesForPlanRequest) XXX_Size 

func (m *QueryNodesForPlanRequest) XXX_Size() int

func (*QueryNodesForPlanRequest) XXX_Unmarshal 

func (m *QueryNodesForPlanRequest) XXX_Unmarshal(b []byte) error

type QueryNodesForPlanResponse 

type QueryNodesForPlanResponse struct {
	// Field 1: List of nodes in the response.
	Nodes []Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
	// Field 2: Pagination information in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryNodesForPlanResponse represents a response containing a list of nodes for a specific plan and pagination information.

func (*QueryNodesForPlanResponse) Descriptor 

func (*QueryNodesForPlanResponse) Descriptor() ([]byte, []int)

func (*QueryNodesForPlanResponse) Marshal 

func (m *QueryNodesForPlanResponse) Marshal() (dAtA []byte, err error)

func (*QueryNodesForPlanResponse) MarshalTo 

func (m *QueryNodesForPlanResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryNodesForPlanResponse) MarshalToSizedBuffer 

func (m *QueryNodesForPlanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryNodesForPlanResponse) ProtoMessage 

func (*QueryNodesForPlanResponse) ProtoMessage()

func (*QueryNodesForPlanResponse) Reset 

func (m *QueryNodesForPlanResponse) Reset()

func (*QueryNodesForPlanResponse) Size 

func (m *QueryNodesForPlanResponse) Size() (n int)

func (*QueryNodesForPlanResponse) String 

func (m *QueryNodesForPlanResponse) String() string

func (*QueryNodesForPlanResponse) Unmarshal 

func (m *QueryNodesForPlanResponse) Unmarshal(dAtA []byte) error

func (*QueryNodesForPlanResponse) XXX_DiscardUnknown 

func (m *QueryNodesForPlanResponse) XXX_DiscardUnknown()

func (*QueryNodesForPlanResponse) XXX_Marshal 

func (m *QueryNodesForPlanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryNodesForPlanResponse) XXX_Merge 

func (m *QueryNodesForPlanResponse) XXX_Merge(src proto.Message)

func (*QueryNodesForPlanResponse) XXX_Size 

func (m *QueryNodesForPlanResponse) XXX_Size() int

func (*QueryNodesForPlanResponse) XXX_Unmarshal 

func (m *QueryNodesForPlanResponse) XXX_Unmarshal(b []byte) error

type QueryNodesRequest 

type QueryNodesRequest struct {
	// Field 1: Status to filter nodes by.
	Status types.Status `protobuf:"varint,1,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	// Field 2: Pagination parameters for the query.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryNodesRequest represents a request to query nodes with a specific status and pagination.

func NewQueryNodesRequest 

func NewQueryNodesRequest(status hubtypes.Status, pagination *query.PageRequest) *QueryNodesRequest

func (*QueryNodesRequest) Descriptor 

func (*QueryNodesRequest) Descriptor() ([]byte, []int)

func (*QueryNodesRequest) Marshal 

func (m *QueryNodesRequest) Marshal() (dAtA []byte, err error)

func (*QueryNodesRequest) MarshalTo 

func (m *QueryNodesRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryNodesRequest) MarshalToSizedBuffer 

func (m *QueryNodesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryNodesRequest) ProtoMessage 

func (*QueryNodesRequest) ProtoMessage()

func (*QueryNodesRequest) Reset 

func (m *QueryNodesRequest) Reset()

func (*QueryNodesRequest) Size 

func (m *QueryNodesRequest) Size() (n int)

func (*QueryNodesRequest) String 

func (m *QueryNodesRequest) String() string

func (*QueryNodesRequest) Unmarshal 

func (m *QueryNodesRequest) Unmarshal(dAtA []byte) error

func (*QueryNodesRequest) XXX_DiscardUnknown 

func (m *QueryNodesRequest) XXX_DiscardUnknown()

func (*QueryNodesRequest) XXX_Marshal 

func (m *QueryNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryNodesRequest) XXX_Merge 

func (m *QueryNodesRequest) XXX_Merge(src proto.Message)

func (*QueryNodesRequest) XXX_Size 

func (m *QueryNodesRequest) XXX_Size() int

func (*QueryNodesRequest) XXX_Unmarshal 

func (m *QueryNodesRequest) XXX_Unmarshal(b []byte) error

type QueryNodesResponse 

type QueryNodesResponse struct {
	// Field 1: List of nodes in the response.
	Nodes []Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
	// Field 2: Pagination information in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryNodesResponse represents a response containing a list of nodes and pagination information.

func (*QueryNodesResponse) Descriptor 

func (*QueryNodesResponse) Descriptor() ([]byte, []int)

func (*QueryNodesResponse) Marshal 

func (m *QueryNodesResponse) Marshal() (dAtA []byte, err error)

func (*QueryNodesResponse) MarshalTo 

func (m *QueryNodesResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryNodesResponse) MarshalToSizedBuffer 

func (m *QueryNodesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryNodesResponse) ProtoMessage 

func (*QueryNodesResponse) ProtoMessage()

func (*QueryNodesResponse) Reset 

func (m *QueryNodesResponse) Reset()

func (*QueryNodesResponse) Size 

func (m *QueryNodesResponse) Size() (n int)

func (*QueryNodesResponse) String 

func (m *QueryNodesResponse) String() string

func (*QueryNodesResponse) Unmarshal 

func (m *QueryNodesResponse) Unmarshal(dAtA []byte) error

func (*QueryNodesResponse) XXX_DiscardUnknown 

func (m *QueryNodesResponse) XXX_DiscardUnknown()

func (*QueryNodesResponse) XXX_Marshal 

func (m *QueryNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryNodesResponse) XXX_Merge 

func (m *QueryNodesResponse) XXX_Merge(src proto.Message)

func (*QueryNodesResponse) XXX_Size 

func (m *QueryNodesResponse) XXX_Size() int

func (*QueryNodesResponse) XXX_Unmarshal 

func (m *QueryNodesResponse) XXX_Unmarshal(b []byte) error

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest represents a request to query module parameters.

func NewQueryParamsRequest 

func NewQueryParamsRequest() *QueryParamsRequest

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 {
	// Field 1: Module parameters in the response.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse represents a response containing module parameters.

func (*QueryParamsResponse) Descriptor 

func (*QueryParamsResponse) Descriptor() ([]byte, []int)

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 QueryServiceClient 

type QueryServiceClient interface {
	// RPC method for querying nodes with a specific status and pagination.
	QueryNodes(ctx context.Context, in *QueryNodesRequest, opts ...grpc.CallOption) (*QueryNodesResponse, error)
	// RPC method for querying nodes for a specific plan with status and pagination.
	QueryNodesForPlan(ctx context.Context, in *QueryNodesForPlanRequest, opts ...grpc.CallOption) (*QueryNodesForPlanResponse, error)
	// RPC method for querying information about a specific node.
	QueryNode(ctx context.Context, in *QueryNodeRequest, opts ...grpc.CallOption) (*QueryNodeResponse, error)
	// RPC method for querying module parameters.
	QueryParams(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// RPC method for querying nodes with a specific status and pagination.
	QueryNodes(context.Context, *QueryNodesRequest) (*QueryNodesResponse, error)
	// RPC method for querying nodes for a specific plan with status and pagination.
	QueryNodesForPlan(context.Context, *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error)
	// RPC method for querying information about a specific node.
	QueryNode(context.Context, *QueryNodeRequest) (*QueryNodeResponse, error)
	// RPC method for querying module parameters.
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgRegister 

func (*UnimplementedMsgServiceServer) MsgRegister(ctx context.Context, req *MsgRegisterRequest) (*MsgRegisterResponse, error)

func (*UnimplementedMsgServiceServer) MsgSubscribe 

func (*UnimplementedMsgServiceServer) MsgSubscribe(ctx context.Context, req *MsgSubscribeRequest) (*MsgSubscribeResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateDetails 

func (*UnimplementedMsgServiceServer) MsgUpdateDetails(ctx context.Context, req *MsgUpdateDetailsRequest) (*MsgUpdateDetailsResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateStatus 

func (*UnimplementedMsgServiceServer) MsgUpdateStatus(ctx context.Context, req *MsgUpdateStatusRequest) (*MsgUpdateStatusResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QueryNode 

func (*UnimplementedQueryServiceServer) QueryNode(ctx context.Context, req *QueryNodeRequest) (*QueryNodeResponse, error)

func (*UnimplementedQueryServiceServer) QueryNodes 

func (*UnimplementedQueryServiceServer) QueryNodes(ctx context.Context, req *QueryNodesRequest) (*QueryNodesResponse, error)

func (*UnimplementedQueryServiceServer) QueryNodesForPlan 

func (*UnimplementedQueryServiceServer) QueryNodesForPlan(ctx context.Context, req *QueryNodesForPlanRequest) (*QueryNodesForPlanResponse, error)

func (*UnimplementedQueryServiceServer) QueryParams 

func (*UnimplementedQueryServiceServer) QueryParams(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.