v3

package
v12.0.0-rc6 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Package v3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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 (
	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 (
	DefaultDeposit                   = sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(10))
	DefaultActiveDuration            = 30 * time.Second
	DefaultMinGigabytePrices         = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(1)))
	DefaultMinHourlyPrices           = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdkmath.NewInt(1)))
	DefaultMaxSessionGigabytes int64 = 10
	DefaultMinSessionGigabytes int64 = 1
	DefaultMaxSessionHours     int64 = 10
	DefaultMinSessionHours     int64 = 1
	DefaultStakingShare              = sdkmath.LegacyNewDecWithPrec(1, 1)
)
View Source 
var (
	KeyDeposit             = []byte("Deposit")
	KeyActiveDuration      = []byte("ActiveDuration")
	KeyMinGigabytePrices   = []byte("MinGigabytePrices")
	KeyMinHourlyPrices     = []byte("MinHourlyPrices")
	KeyMaxSessionGigabytes = []byte("MaxSessionGigabytes")
	KeyMinSessionGigabytes = []byte("MinSessionGigabytes")
	KeyMaxSessionHours     = []byte("MaxSessionHours")
	KeyMinSessionHours     = []byte("MinSessionHours")
	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")
)
View Source 
var (
	ErrInvalidLengthSession        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSession          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSession = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MsgService_serviceDesc = _MsgService_serviceDesc
View Source 
var QueryService_serviceDesc = _QueryService_serviceDesc

Functions

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 EventCreate 

type EventCreate struct {
	NodeAddress    string `protobuf:"bytes,1,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	GigabytePrices string `protobuf:"bytes,2,opt,name=gigabyte_prices,json=gigabytePrices,proto3" json:"gigabyte_prices,omitempty"`
	HourlyPrices   string `protobuf:"bytes,3,opt,name=hourly_prices,json=hourlyPrices,proto3" json:"hourly_prices,omitempty"`
	RemoteURL      string `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

func (*EventCreate) Descriptor 

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

func (*EventCreate) Marshal 

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

func (*EventCreate) MarshalTo 

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

func (*EventCreate) MarshalToSizedBuffer 

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

func (*EventCreate) ProtoMessage 

func (*EventCreate) ProtoMessage()

func (*EventCreate) Reset 

func (m *EventCreate) Reset()

func (*EventCreate) Size 

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

func (*EventCreate) String 

func (m *EventCreate) String() string

func (*EventCreate) Unmarshal 

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

func (*EventCreate) XXX_DiscardUnknown 

func (m *EventCreate) XXX_DiscardUnknown()

func (*EventCreate) XXX_Marshal 

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

func (*EventCreate) XXX_Merge 

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

func (*EventCreate) XXX_Size 

func (m *EventCreate) XXX_Size() int

func (*EventCreate) XXX_Unmarshal 

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

type EventCreateSession 

type EventCreateSession struct {
	ID           uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress   string `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	NodeAddress  string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Price        string `protobuf:"bytes,4,opt,name=price,proto3" json:"price,omitempty"`
	MaxGigabytes int64  `protobuf:"varint,5,opt,name=max_gigabytes,json=maxGigabytes,proto3" json:"max_gigabytes,omitempty"`
	MaxHours     int64  `protobuf:"varint,6,opt,name=max_hours,json=maxHours,proto3" json:"max_hours,omitempty"`
}

func (*EventCreateSession) Descriptor 

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

func (*EventCreateSession) Marshal 

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

func (*EventCreateSession) MarshalTo 

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

func (*EventCreateSession) MarshalToSizedBuffer 

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

func (*EventCreateSession) ProtoMessage 

func (*EventCreateSession) ProtoMessage()

func (*EventCreateSession) Reset 

func (m *EventCreateSession) Reset()

func (*EventCreateSession) Size 

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

func (*EventCreateSession) String 

func (m *EventCreateSession) String() string

func (*EventCreateSession) Unmarshal 

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

func (*EventCreateSession) XXX_DiscardUnknown 

func (m *EventCreateSession) XXX_DiscardUnknown()

func (*EventCreateSession) XXX_Marshal 

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

func (*EventCreateSession) XXX_Merge 

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

func (*EventCreateSession) XXX_Size 

func (m *EventCreateSession) XXX_Size() int

func (*EventCreateSession) XXX_Unmarshal 

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

type EventPay 

type EventPay struct {
	ID            uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress    string `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	NodeAddress   string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Payment       string `protobuf:"bytes,4,opt,name=payment,proto3" json:"payment,omitempty"`
	StakingReward string `protobuf:"bytes,5,opt,name=staking_reward,json=stakingReward,proto3" json:"staking_reward,omitempty"`
}

func (*EventPay) Descriptor 

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

func (*EventPay) Marshal 

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

func (*EventPay) MarshalTo 

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

func (*EventPay) MarshalToSizedBuffer 

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

func (*EventPay) ProtoMessage 

func (*EventPay) ProtoMessage()

func (*EventPay) Reset 

func (m *EventPay) Reset()

func (*EventPay) Size 

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

func (*EventPay) String 

func (m *EventPay) String() string

func (*EventPay) Unmarshal 

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

func (*EventPay) XXX_DiscardUnknown 

func (m *EventPay) XXX_DiscardUnknown()

func (*EventPay) XXX_Marshal 

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

func (*EventPay) XXX_Merge 

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

func (*EventPay) XXX_Size 

func (m *EventPay) XXX_Size() int

func (*EventPay) XXX_Unmarshal 

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

type EventRefund 

type EventRefund struct {
	ID         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress string `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	Amount     string `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
}

func (*EventRefund) Descriptor 

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

func (*EventRefund) Marshal 

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

func (*EventRefund) MarshalTo 

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

func (*EventRefund) MarshalToSizedBuffer 

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

func (*EventRefund) ProtoMessage 

func (*EventRefund) ProtoMessage()

func (*EventRefund) Reset 

func (m *EventRefund) Reset()

func (*EventRefund) Size 

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

func (*EventRefund) String 

func (m *EventRefund) String() string

func (*EventRefund) Unmarshal 

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

func (*EventRefund) XXX_DiscardUnknown 

func (m *EventRefund) XXX_DiscardUnknown()

func (*EventRefund) XXX_Marshal 

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

func (*EventRefund) XXX_Merge 

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

func (*EventRefund) XXX_Size 

func (m *EventRefund) XXX_Size() int

func (*EventRefund) XXX_Unmarshal 

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

type EventUpdateDetails 

type EventUpdateDetails struct {
	NodeAddress    string `protobuf:"bytes,1,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	GigabytePrices string `protobuf:"bytes,2,opt,name=gigabyte_prices,json=gigabytePrices,proto3" json:"gigabyte_prices,omitempty"`
	HourlyPrices   string `protobuf:"bytes,3,opt,name=hourly_prices,json=hourlyPrices,proto3" json:"hourly_prices,omitempty"`
	RemoteURL      string `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

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 {
	NodeAddress string    `protobuf:"bytes,1,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Status      v1.Status `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
}

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 {
	Nodes  []v2.Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
	Params Params    `protobuf:"bytes,3,opt,name=params,proto3" json:"params"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(nodes []v2.Node, 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 MsgRegisterNodeRequest 

type MsgRegisterNodeRequest struct {
	From           string                                   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	GigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	HourlyPrices   github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	RemoteURL      string                                   `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

func NewMsgRegisterNodeRequest 

func NewMsgRegisterNodeRequest(from sdk.AccAddress, gigabytePrices, hourlyPrices sdk.Coins, remoteURL string) *MsgRegisterNodeRequest

func (*MsgRegisterNodeRequest) Descriptor 

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

func (*MsgRegisterNodeRequest) GetSigners 

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

func (*MsgRegisterNodeRequest) Marshal 

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

func (*MsgRegisterNodeRequest) MarshalTo 

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

func (*MsgRegisterNodeRequest) MarshalToSizedBuffer 

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

func (*MsgRegisterNodeRequest) ProtoMessage 

func (*MsgRegisterNodeRequest) ProtoMessage()

func (*MsgRegisterNodeRequest) Reset 

func (m *MsgRegisterNodeRequest) Reset()

func (*MsgRegisterNodeRequest) Size 

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

func (*MsgRegisterNodeRequest) String 

func (m *MsgRegisterNodeRequest) String() string

func (*MsgRegisterNodeRequest) Unmarshal 

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

func (*MsgRegisterNodeRequest) ValidateBasic 

func (m *MsgRegisterNodeRequest) ValidateBasic() error

func (*MsgRegisterNodeRequest) XXX_DiscardUnknown 

func (m *MsgRegisterNodeRequest) XXX_DiscardUnknown()

func (*MsgRegisterNodeRequest) XXX_Marshal 

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

func (*MsgRegisterNodeRequest) XXX_Merge 

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

func (*MsgRegisterNodeRequest) XXX_Size 

func (m *MsgRegisterNodeRequest) XXX_Size() int

func (*MsgRegisterNodeRequest) XXX_Unmarshal 

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

type MsgRegisterNodeResponse 

type MsgRegisterNodeResponse struct {
}

func (*MsgRegisterNodeResponse) Descriptor 

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

func (*MsgRegisterNodeResponse) Marshal 

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

func (*MsgRegisterNodeResponse) MarshalTo 

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

func (*MsgRegisterNodeResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterNodeResponse) ProtoMessage 

func (*MsgRegisterNodeResponse) ProtoMessage()

func (*MsgRegisterNodeResponse) Reset 

func (m *MsgRegisterNodeResponse) Reset()

func (*MsgRegisterNodeResponse) Size 

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

func (*MsgRegisterNodeResponse) String 

func (m *MsgRegisterNodeResponse) String() string

func (*MsgRegisterNodeResponse) Unmarshal 

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

func (*MsgRegisterNodeResponse) XXX_DiscardUnknown 

func (m *MsgRegisterNodeResponse) XXX_DiscardUnknown()

func (*MsgRegisterNodeResponse) XXX_Marshal 

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

func (*MsgRegisterNodeResponse) XXX_Merge 

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

func (*MsgRegisterNodeResponse) XXX_Size 

func (m *MsgRegisterNodeResponse) XXX_Size() int

func (*MsgRegisterNodeResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	MsgRegisterNode(ctx context.Context, in *MsgRegisterNodeRequest, opts ...grpc.CallOption) (*MsgRegisterNodeResponse, error)
	MsgUpdateNodeDetails(ctx context.Context, in *MsgUpdateNodeDetailsRequest, opts ...grpc.CallOption) (*MsgUpdateNodeDetailsResponse, error)
	MsgUpdateNodeStatus(ctx context.Context, in *MsgUpdateNodeStatusRequest, opts ...grpc.CallOption) (*MsgUpdateNodeStatusResponse, error)
	MsgStartSession(ctx context.Context, in *MsgStartSessionRequest, opts ...grpc.CallOption) (*MsgStartSessionResponse, error)
	MsgUpdateParams(ctx context.Context, in *MsgUpdateParamsRequest, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 {
	MsgRegisterNode(context.Context, *MsgRegisterNodeRequest) (*MsgRegisterNodeResponse, error)
	MsgUpdateNodeDetails(context.Context, *MsgUpdateNodeDetailsRequest) (*MsgUpdateNodeDetailsResponse, error)
	MsgUpdateNodeStatus(context.Context, *MsgUpdateNodeStatusRequest) (*MsgUpdateNodeStatusResponse, error)
	MsgStartSession(context.Context, *MsgStartSessionRequest) (*MsgStartSessionResponse, error)
	MsgUpdateParams(context.Context, *MsgUpdateParamsRequest) (*MsgUpdateParamsResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgStartSessionRequest 

type MsgStartSessionRequest struct {
	From        string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Gigabytes   int64  `protobuf:"varint,3,opt,name=gigabytes,proto3" json:"gigabytes,omitempty"`
	Hours       int64  `protobuf:"varint,4,opt,name=hours,proto3" json:"hours,omitempty"`
	Denom       string `protobuf:"bytes,5,opt,name=denom,proto3" json:"denom,omitempty"`
}

func NewMsgStartSessionRequest 

func NewMsgStartSessionRequest(from sdk.AccAddress, nodeAddr base.NodeAddress, gigabytes, hours int64, denom string) *MsgStartSessionRequest

func (*MsgStartSessionRequest) Descriptor 

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

func (*MsgStartSessionRequest) GetSigners 

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

func (*MsgStartSessionRequest) Marshal 

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

func (*MsgStartSessionRequest) MarshalTo 

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

func (*MsgStartSessionRequest) MarshalToSizedBuffer 

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

func (*MsgStartSessionRequest) ProtoMessage 

func (*MsgStartSessionRequest) ProtoMessage()

func (*MsgStartSessionRequest) Reset 

func (m *MsgStartSessionRequest) Reset()

func (*MsgStartSessionRequest) Size 

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

func (*MsgStartSessionRequest) String 

func (m *MsgStartSessionRequest) String() string

func (*MsgStartSessionRequest) Unmarshal 

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

func (*MsgStartSessionRequest) ValidateBasic 

func (m *MsgStartSessionRequest) ValidateBasic() error

func (*MsgStartSessionRequest) XXX_DiscardUnknown 

func (m *MsgStartSessionRequest) XXX_DiscardUnknown()

func (*MsgStartSessionRequest) XXX_Marshal 

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

func (*MsgStartSessionRequest) XXX_Merge 

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

func (*MsgStartSessionRequest) XXX_Size 

func (m *MsgStartSessionRequest) XXX_Size() int

func (*MsgStartSessionRequest) XXX_Unmarshal 

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

type MsgStartSessionResponse 

type MsgStartSessionResponse struct {
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*MsgStartSessionResponse) Descriptor 

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

func (*MsgStartSessionResponse) Marshal 

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

func (*MsgStartSessionResponse) MarshalTo 

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

func (*MsgStartSessionResponse) MarshalToSizedBuffer 

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

func (*MsgStartSessionResponse) ProtoMessage 

func (*MsgStartSessionResponse) ProtoMessage()

func (*MsgStartSessionResponse) Reset 

func (m *MsgStartSessionResponse) Reset()

func (*MsgStartSessionResponse) Size 

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

func (*MsgStartSessionResponse) String 

func (m *MsgStartSessionResponse) String() string

func (*MsgStartSessionResponse) Unmarshal 

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

func (*MsgStartSessionResponse) XXX_DiscardUnknown 

func (m *MsgStartSessionResponse) XXX_DiscardUnknown()

func (*MsgStartSessionResponse) XXX_Marshal 

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

func (*MsgStartSessionResponse) XXX_Merge 

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

func (*MsgStartSessionResponse) XXX_Size 

func (m *MsgStartSessionResponse) XXX_Size() int

func (*MsgStartSessionResponse) XXX_Unmarshal 

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

type MsgUpdateNodeDetailsRequest 

type MsgUpdateNodeDetailsRequest struct {
	From           string                                   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	GigabytePrices github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	HourlyPrices   github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	RemoteURL      string                                   `protobuf:"bytes,4,opt,name=remote_url,json=remoteUrl,proto3" json:"remote_url,omitempty"`
}

func NewMsgUpdateNodeDetailsRequest 

func NewMsgUpdateNodeDetailsRequest(from base.NodeAddress, gigabytePrices, hourlyPrices sdk.Coins, remoteURL string) *MsgUpdateNodeDetailsRequest

func (*MsgUpdateNodeDetailsRequest) Descriptor 

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

func (*MsgUpdateNodeDetailsRequest) GetSigners 

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

func (*MsgUpdateNodeDetailsRequest) Marshal 

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

func (*MsgUpdateNodeDetailsRequest) MarshalTo 

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

func (*MsgUpdateNodeDetailsRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateNodeDetailsRequest) ProtoMessage 

func (*MsgUpdateNodeDetailsRequest) ProtoMessage()

func (*MsgUpdateNodeDetailsRequest) Reset 

func (m *MsgUpdateNodeDetailsRequest) Reset()

func (*MsgUpdateNodeDetailsRequest) Size 

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

func (*MsgUpdateNodeDetailsRequest) String 

func (m *MsgUpdateNodeDetailsRequest) String() string

func (*MsgUpdateNodeDetailsRequest) Unmarshal 

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

func (*MsgUpdateNodeDetailsRequest) ValidateBasic 

func (m *MsgUpdateNodeDetailsRequest) ValidateBasic() error

func (*MsgUpdateNodeDetailsRequest) XXX_DiscardUnknown 

func (m *MsgUpdateNodeDetailsRequest) XXX_DiscardUnknown()

func (*MsgUpdateNodeDetailsRequest) XXX_Marshal 

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

func (*MsgUpdateNodeDetailsRequest) XXX_Merge 

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

func (*MsgUpdateNodeDetailsRequest) XXX_Size 

func (m *MsgUpdateNodeDetailsRequest) XXX_Size() int

func (*MsgUpdateNodeDetailsRequest) XXX_Unmarshal 

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

type MsgUpdateNodeDetailsResponse 

type MsgUpdateNodeDetailsResponse struct {
}

func (*MsgUpdateNodeDetailsResponse) Descriptor 

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

func (*MsgUpdateNodeDetailsResponse) Marshal 

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

func (*MsgUpdateNodeDetailsResponse) MarshalTo 

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

func (*MsgUpdateNodeDetailsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateNodeDetailsResponse) ProtoMessage 

func (*MsgUpdateNodeDetailsResponse) ProtoMessage()

func (*MsgUpdateNodeDetailsResponse) Reset 

func (m *MsgUpdateNodeDetailsResponse) Reset()

func (*MsgUpdateNodeDetailsResponse) Size 

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

func (*MsgUpdateNodeDetailsResponse) String 

func (m *MsgUpdateNodeDetailsResponse) String() string

func (*MsgUpdateNodeDetailsResponse) Unmarshal 

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

func (*MsgUpdateNodeDetailsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateNodeDetailsResponse) XXX_DiscardUnknown()

func (*MsgUpdateNodeDetailsResponse) XXX_Marshal 

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

func (*MsgUpdateNodeDetailsResponse) XXX_Merge 

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

func (*MsgUpdateNodeDetailsResponse) XXX_Size 

func (m *MsgUpdateNodeDetailsResponse) XXX_Size() int

func (*MsgUpdateNodeDetailsResponse) XXX_Unmarshal 

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

type MsgUpdateNodeStatusRequest 

type MsgUpdateNodeStatusRequest struct {
	From   string    `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Status v1.Status `protobuf:"varint,2,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
}

func NewMsgUpdateNodeStatusRequest 

func NewMsgUpdateNodeStatusRequest(from base.NodeAddress, status v1base.Status) *MsgUpdateNodeStatusRequest

func (*MsgUpdateNodeStatusRequest) Descriptor 

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

func (*MsgUpdateNodeStatusRequest) GetSigners 

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

func (*MsgUpdateNodeStatusRequest) Marshal 

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

func (*MsgUpdateNodeStatusRequest) MarshalTo 

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

func (*MsgUpdateNodeStatusRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateNodeStatusRequest) ProtoMessage 

func (*MsgUpdateNodeStatusRequest) ProtoMessage()

func (*MsgUpdateNodeStatusRequest) Reset 

func (m *MsgUpdateNodeStatusRequest) Reset()

func (*MsgUpdateNodeStatusRequest) Size 

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

func (*MsgUpdateNodeStatusRequest) String 

func (m *MsgUpdateNodeStatusRequest) String() string

func (*MsgUpdateNodeStatusRequest) Unmarshal 

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

func (*MsgUpdateNodeStatusRequest) ValidateBasic 

func (m *MsgUpdateNodeStatusRequest) ValidateBasic() error

func (*MsgUpdateNodeStatusRequest) XXX_DiscardUnknown 

func (m *MsgUpdateNodeStatusRequest) XXX_DiscardUnknown()

func (*MsgUpdateNodeStatusRequest) XXX_Marshal 

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

func (*MsgUpdateNodeStatusRequest) XXX_Merge 

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

func (*MsgUpdateNodeStatusRequest) XXX_Size 

func (m *MsgUpdateNodeStatusRequest) XXX_Size() int

func (*MsgUpdateNodeStatusRequest) XXX_Unmarshal 

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

type MsgUpdateNodeStatusResponse 

type MsgUpdateNodeStatusResponse struct {
}

func (*MsgUpdateNodeStatusResponse) Descriptor 

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

func (*MsgUpdateNodeStatusResponse) Marshal 

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

func (*MsgUpdateNodeStatusResponse) MarshalTo 

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

func (*MsgUpdateNodeStatusResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateNodeStatusResponse) ProtoMessage 

func (*MsgUpdateNodeStatusResponse) ProtoMessage()

func (*MsgUpdateNodeStatusResponse) Reset 

func (m *MsgUpdateNodeStatusResponse) Reset()

func (*MsgUpdateNodeStatusResponse) Size 

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

func (*MsgUpdateNodeStatusResponse) String 

func (m *MsgUpdateNodeStatusResponse) String() string

func (*MsgUpdateNodeStatusResponse) Unmarshal 

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

func (*MsgUpdateNodeStatusResponse) XXX_DiscardUnknown 

func (m *MsgUpdateNodeStatusResponse) XXX_DiscardUnknown()

func (*MsgUpdateNodeStatusResponse) XXX_Marshal 

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

func (*MsgUpdateNodeStatusResponse) XXX_Merge 

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

func (*MsgUpdateNodeStatusResponse) XXX_Size 

func (m *MsgUpdateNodeStatusResponse) XXX_Size() int

func (*MsgUpdateNodeStatusResponse) XXX_Unmarshal 

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

type MsgUpdateParamsRequest 

type MsgUpdateParamsRequest struct {
	From   string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

func NewMsgUpdateParamsRequest 

func NewMsgUpdateParamsRequest(from sdk.AccAddress, params Params) *MsgUpdateParamsRequest

func (*MsgUpdateParamsRequest) Descriptor 

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

func (*MsgUpdateParamsRequest) GetSigners 

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

func (*MsgUpdateParamsRequest) Marshal 

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

func (*MsgUpdateParamsRequest) MarshalTo 

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

func (*MsgUpdateParamsRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsRequest) ProtoMessage 

func (*MsgUpdateParamsRequest) ProtoMessage()

func (*MsgUpdateParamsRequest) Reset 

func (m *MsgUpdateParamsRequest) Reset()

func (*MsgUpdateParamsRequest) Size 

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

func (*MsgUpdateParamsRequest) String 

func (m *MsgUpdateParamsRequest) String() string

func (*MsgUpdateParamsRequest) Unmarshal 

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

func (*MsgUpdateParamsRequest) ValidateBasic 

func (m *MsgUpdateParamsRequest) ValidateBasic() error

func (*MsgUpdateParamsRequest) XXX_DiscardUnknown 

func (m *MsgUpdateParamsRequest) XXX_DiscardUnknown()

func (*MsgUpdateParamsRequest) XXX_Marshal 

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

func (*MsgUpdateParamsRequest) XXX_Merge 

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

func (*MsgUpdateParamsRequest) XXX_Size 

func (m *MsgUpdateParamsRequest) XXX_Size() int

func (*MsgUpdateParamsRequest) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	Deposit             types.Coin                               `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit"`
	ActiveDuration      time.Duration                            `protobuf:"bytes,2,opt,name=active_duration,json=activeDuration,proto3,stdduration" json:"active_duration"`
	MinGigabytePrices   github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
	MinHourlyPrices     github_com_cosmos_cosmos_sdk_types.Coins `` /* 152-byte string literal not displayed */
	MaxSessionGigabytes int64                                    `protobuf:"varint,5,opt,name=max_session_gigabytes,json=maxSessionGigabytes,proto3" json:"max_session_gigabytes,omitempty"`
	MinSessionGigabytes int64                                    `protobuf:"varint,6,opt,name=min_session_gigabytes,json=minSessionGigabytes,proto3" json:"min_session_gigabytes,omitempty"`
	MaxSessionHours     int64                                    `protobuf:"varint,7,opt,name=max_session_hours,json=maxSessionHours,proto3" json:"max_session_hours,omitempty"`
	MinSessionHours     int64                                    `protobuf:"varint,8,opt,name=min_session_hours,json=minSessionHours,proto3" json:"min_session_hours,omitempty"`
	StakingShare        cosmossdk_io_math.LegacyDec              `` /* 126-byte string literal not displayed */
}

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(
	deposit sdk.Coin, activeDuration time.Duration, minGigabytePrices, minHourlyPrices sdk.Coins, maxSessionGigabytes,
	minSessionGigabytes, maxSessionHours, minSessionHours 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 QueryParamsRequest 

type QueryParamsRequest struct {
}

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 {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

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 {
	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 {
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type Session 

type Session struct {
	ID            uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	AccAddress    string                `protobuf:"bytes,2,opt,name=acc_address,json=accAddress,proto3" json:"acc_address,omitempty"`
	NodeAddress   string                `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Price         types.Coin            `protobuf:"bytes,4,opt,name=price,proto3" json:"price"`
	DownloadBytes cosmossdk_io_math.Int `protobuf:"bytes,5,opt,name=download_bytes,json=downloadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"download_bytes"`
	UploadBytes   cosmossdk_io_math.Int `protobuf:"bytes,6,opt,name=upload_bytes,json=uploadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"upload_bytes"`
	MaxGigabytes  int64                 `protobuf:"varint,7,opt,name=max_gigabytes,json=maxGigabytes,proto3" json:"max_gigabytes,omitempty"`
	Duration      time.Duration         `protobuf:"bytes,8,opt,name=duration,proto3,stdduration" json:"duration"`
	MaxHours      int64                 `protobuf:"varint,9,opt,name=max_hours,json=maxHours,proto3" json:"max_hours,omitempty"`
	Status        v1.Status             `protobuf:"varint,10,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	InactiveAt    time.Time             `protobuf:"bytes,11,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	StatusAt      time.Time             `protobuf:"bytes,12,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

func (*Session) DepositAmount 

func (m *Session) DepositAmount() sdk.Coin

func (*Session) Descriptor 

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

func (*Session) GetAccAddress 

func (m *Session) GetAccAddress() string

func (*Session) GetDownloadBytes 

func (m *Session) GetDownloadBytes() sdkmath.Int

func (*Session) GetDuration 

func (m *Session) GetDuration() time.Duration

func (*Session) GetID 

func (m *Session) GetID() uint64

func (*Session) GetInactiveAt 

func (m *Session) GetInactiveAt() time.Time

func (*Session) GetMaxGigabytes 

func (m *Session) GetMaxGigabytes() int64

func (*Session) GetMaxHours 

func (m *Session) GetMaxHours() int64

func (*Session) GetNodeAddress 

func (m *Session) GetNodeAddress() string

func (*Session) GetPrice 

func (m *Session) GetPrice() types.Coin

func (*Session) GetStatus 

func (m *Session) GetStatus() v1.Status

func (*Session) GetStatusAt 

func (m *Session) GetStatusAt() time.Time

func (*Session) GetUploadBytes 

func (m *Session) GetUploadBytes() sdkmath.Int

func (*Session) Marshal 

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

func (*Session) MarshalTo 

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

func (*Session) MarshalToSizedBuffer 

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

func (*Session) PaymentAmount 

func (m *Session) PaymentAmount() sdk.Coin

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) RefundAmount 

func (m *Session) RefundAmount() sdk.Coin

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) SetDownloadBytes 

func (m *Session) SetDownloadBytes(v sdkmath.Int)

func (*Session) SetDuration 

func (m *Session) SetDuration(v time.Duration)

func (*Session) SetInactiveAt 

func (m *Session) SetInactiveAt(v time.Time)

func (*Session) SetStatus 

func (m *Session) SetStatus(v v1base.Status)

func (*Session) SetStatusAt 

func (m *Session) SetStatusAt(v time.Time)

func (*Session) SetUploadBytes 

func (m *Session) SetUploadBytes(v sdkmath.Int)

func (*Session) Size 

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

func (*Session) String 

func (m *Session) String() string

func (*Session) Unmarshal 

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

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgRegisterNode 

func (*UnimplementedMsgServiceServer) MsgRegisterNode(ctx context.Context, req *MsgRegisterNodeRequest) (*MsgRegisterNodeResponse, error)

func (*UnimplementedMsgServiceServer) MsgStartSession 

func (*UnimplementedMsgServiceServer) MsgStartSession(ctx context.Context, req *MsgStartSessionRequest) (*MsgStartSessionResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateNodeDetails 

func (*UnimplementedMsgServiceServer) MsgUpdateNodeDetails(ctx context.Context, req *MsgUpdateNodeDetailsRequest) (*MsgUpdateNodeDetailsResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateNodeStatus 

func (*UnimplementedMsgServiceServer) MsgUpdateNodeStatus(ctx context.Context, req *MsgUpdateNodeStatusRequest) (*MsgUpdateNodeStatusResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateParams 

func (*UnimplementedMsgServiceServer) MsgUpdateParams(ctx context.Context, req *MsgUpdateParamsRequest) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

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.