v3

package
v12.0.0-rc5 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2024 License: Apache-2.0 Imports: 32 Imported by: 1

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 (
	ErrInvalidLengthProof        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProof          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProof = 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 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 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 {
	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"`
	DownloadBytes string        `protobuf:"bytes,4,opt,name=download_bytes,json=downloadBytes,proto3" json:"download_bytes,omitempty"`
	UploadBytes   string        `protobuf:"bytes,5,opt,name=upload_bytes,json=uploadBytes,proto3" json:"upload_bytes,omitempty"`
	Duration      time.Duration `protobuf:"bytes,6,opt,name=duration,proto3,stdduration" json:"duration"`
}

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 {
	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"`
	Status      v1.Status `protobuf:"varint,4,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	StatusAt    string    `protobuf:"bytes,5,opt,name=status_at,json=statusAt,proto3" json:"status_at,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 {
	Sessions []types.Any `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	Params   v2.Params   `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(_ []Session, params v2.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 MsgCancelSessionRequest 

type MsgCancelSessionRequest struct {
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID   uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

func NewMsgCancelSessionRequest 

func NewMsgCancelSessionRequest(from sdk.AccAddress, id uint64) *MsgCancelSessionRequest

func (*MsgCancelSessionRequest) Descriptor 

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

func (*MsgCancelSessionRequest) GetSigners 

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

func (*MsgCancelSessionRequest) Marshal 

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

func (*MsgCancelSessionRequest) MarshalTo 

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

func (*MsgCancelSessionRequest) MarshalToSizedBuffer 

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

func (*MsgCancelSessionRequest) ProtoMessage 

func (*MsgCancelSessionRequest) ProtoMessage()

func (*MsgCancelSessionRequest) Reset 

func (m *MsgCancelSessionRequest) Reset()

func (*MsgCancelSessionRequest) Size 

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

func (*MsgCancelSessionRequest) String 

func (m *MsgCancelSessionRequest) String() string

func (*MsgCancelSessionRequest) Unmarshal 

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

func (*MsgCancelSessionRequest) ValidateBasic 

func (m *MsgCancelSessionRequest) ValidateBasic() error

func (*MsgCancelSessionRequest) XXX_DiscardUnknown 

func (m *MsgCancelSessionRequest) XXX_DiscardUnknown()

func (*MsgCancelSessionRequest) XXX_Marshal 

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

func (*MsgCancelSessionRequest) XXX_Merge 

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

func (*MsgCancelSessionRequest) XXX_Size 

func (m *MsgCancelSessionRequest) XXX_Size() int

func (*MsgCancelSessionRequest) XXX_Unmarshal 

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

type MsgCancelSessionResponse 

type MsgCancelSessionResponse struct {
}

func (*MsgCancelSessionResponse) Descriptor 

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

func (*MsgCancelSessionResponse) Marshal 

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

func (*MsgCancelSessionResponse) MarshalTo 

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

func (*MsgCancelSessionResponse) MarshalToSizedBuffer 

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

func (*MsgCancelSessionResponse) ProtoMessage 

func (*MsgCancelSessionResponse) ProtoMessage()

func (*MsgCancelSessionResponse) Reset 

func (m *MsgCancelSessionResponse) Reset()

func (*MsgCancelSessionResponse) Size 

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

func (*MsgCancelSessionResponse) String 

func (m *MsgCancelSessionResponse) String() string

func (*MsgCancelSessionResponse) Unmarshal 

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

func (*MsgCancelSessionResponse) XXX_DiscardUnknown 

func (m *MsgCancelSessionResponse) XXX_DiscardUnknown()

func (*MsgCancelSessionResponse) XXX_Marshal 

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

func (*MsgCancelSessionResponse) XXX_Merge 

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

func (*MsgCancelSessionResponse) XXX_Size 

func (m *MsgCancelSessionResponse) XXX_Size() int

func (*MsgCancelSessionResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	MsgCancelSession(ctx context.Context, in *MsgCancelSessionRequest, opts ...grpc.CallOption) (*MsgCancelSessionResponse, error)
	MsgUpdateSession(ctx context.Context, in *MsgUpdateSessionRequest, opts ...grpc.CallOption) (*MsgUpdateSessionResponse, 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 {
	MsgCancelSession(context.Context, *MsgCancelSessionRequest) (*MsgCancelSessionResponse, error)
	MsgUpdateSession(context.Context, *MsgUpdateSessionRequest) (*MsgUpdateSessionResponse, error)
	MsgUpdateParams(context.Context, *MsgUpdateParamsRequest) (*MsgUpdateParamsResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgUpdateParamsRequest 

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

func NewMsgUpdateParamsRequest 

func NewMsgUpdateParamsRequest(from sdk.AccAddress, params v2.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 MsgUpdateSessionRequest 

type MsgUpdateSessionRequest struct {
	From          string                `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ID            uint64                `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	DownloadBytes cosmossdk_io_math.Int `protobuf:"bytes,3,opt,name=download_bytes,json=downloadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"download_bytes"`
	UploadBytes   cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=upload_bytes,json=uploadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"upload_bytes"`
	Duration      time.Duration         `protobuf:"bytes,5,opt,name=duration,proto3,stdduration" json:"duration"`
	Signature     []byte                `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
}

func NewMsgUpdateSessionRequest 

func NewMsgUpdateSessionRequest(from base.NodeAddress, id uint64, downloadBytes, uploadBytes sdkmath.Int, duration time.Duration, signature []byte) *MsgUpdateSessionRequest

func (*MsgUpdateSessionRequest) Descriptor 

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

func (*MsgUpdateSessionRequest) GetSigners 

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

func (*MsgUpdateSessionRequest) Marshal 

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

func (*MsgUpdateSessionRequest) MarshalTo 

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

func (*MsgUpdateSessionRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateSessionRequest) Proof 

func (m *MsgUpdateSessionRequest) Proof() *Proof

func (*MsgUpdateSessionRequest) ProtoMessage 

func (*MsgUpdateSessionRequest) ProtoMessage()

func (*MsgUpdateSessionRequest) Reset 

func (m *MsgUpdateSessionRequest) Reset()

func (*MsgUpdateSessionRequest) Size 

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

func (*MsgUpdateSessionRequest) String 

func (m *MsgUpdateSessionRequest) String() string

func (*MsgUpdateSessionRequest) Unmarshal 

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

func (*MsgUpdateSessionRequest) ValidateBasic 

func (m *MsgUpdateSessionRequest) ValidateBasic() error

func (*MsgUpdateSessionRequest) XXX_DiscardUnknown 

func (m *MsgUpdateSessionRequest) XXX_DiscardUnknown()

func (*MsgUpdateSessionRequest) XXX_Marshal 

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

func (*MsgUpdateSessionRequest) XXX_Merge 

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

func (*MsgUpdateSessionRequest) XXX_Size 

func (m *MsgUpdateSessionRequest) XXX_Size() int

func (*MsgUpdateSessionRequest) XXX_Unmarshal 

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

type MsgUpdateSessionResponse 

type MsgUpdateSessionResponse struct {
}

func (*MsgUpdateSessionResponse) Descriptor 

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

func (*MsgUpdateSessionResponse) Marshal 

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

func (*MsgUpdateSessionResponse) MarshalTo 

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

func (*MsgUpdateSessionResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateSessionResponse) ProtoMessage 

func (*MsgUpdateSessionResponse) ProtoMessage()

func (*MsgUpdateSessionResponse) Reset 

func (m *MsgUpdateSessionResponse) Reset()

func (*MsgUpdateSessionResponse) Size 

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

func (*MsgUpdateSessionResponse) String 

func (m *MsgUpdateSessionResponse) String() string

func (*MsgUpdateSessionResponse) Unmarshal 

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

func (*MsgUpdateSessionResponse) XXX_DiscardUnknown 

func (m *MsgUpdateSessionResponse) XXX_DiscardUnknown()

func (*MsgUpdateSessionResponse) XXX_Marshal 

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

func (*MsgUpdateSessionResponse) XXX_Merge 

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

func (*MsgUpdateSessionResponse) XXX_Size 

func (m *MsgUpdateSessionResponse) XXX_Size() int

func (*MsgUpdateSessionResponse) XXX_Unmarshal 

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

type Proof 

type Proof struct {
	ID            uint64                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	DownloadBytes cosmossdk_io_math.Int `protobuf:"bytes,2,opt,name=download_bytes,json=downloadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"download_bytes"`
	UploadBytes   cosmossdk_io_math.Int `protobuf:"bytes,3,opt,name=upload_bytes,json=uploadBytes,proto3,customtype=cosmossdk.io/math.Int" json:"upload_bytes"`
	Duration      time.Duration         `protobuf:"bytes,4,opt,name=duration,proto3,stdduration" json:"duration"`
}

func (*Proof) Descriptor 

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

func (*Proof) Marshal 

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

func (*Proof) MarshalTo 

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

func (*Proof) MarshalToSizedBuffer 

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

func (*Proof) ProtoMessage 

func (*Proof) ProtoMessage()

func (*Proof) Reset 

func (m *Proof) Reset()

func (*Proof) Size 

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

func (*Proof) String 

func (m *Proof) String() string

func (*Proof) Unmarshal 

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

func (*Proof) XXX_DiscardUnknown 

func (m *Proof) XXX_DiscardUnknown()

func (*Proof) XXX_Marshal 

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

func (*Proof) XXX_Merge 

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

func (*Proof) XXX_Size 

func (m *Proof) XXX_Size() int

func (*Proof) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	QuerySessions(ctx context.Context, in *QuerySessionsRequest, opts ...grpc.CallOption) (*QuerySessionsResponse, error)
	QuerySessionsForAccount(ctx context.Context, in *QuerySessionsForAccountRequest, opts ...grpc.CallOption) (*QuerySessionsForAccountResponse, error)
	QuerySessionsForNode(ctx context.Context, in *QuerySessionsForNodeRequest, opts ...grpc.CallOption) (*QuerySessionsForNodeResponse, error)
	QuerySessionsForSubscription(ctx context.Context, in *QuerySessionsForSubscriptionRequest, opts ...grpc.CallOption) (*QuerySessionsForSubscriptionResponse, error)
	QuerySessionsForAllocation(ctx context.Context, in *QuerySessionsForAllocationRequest, opts ...grpc.CallOption) (*QuerySessionsForAllocationResponse, error)
	QuerySession(ctx context.Context, in *QuerySessionRequest, opts ...grpc.CallOption) (*QuerySessionResponse, 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 {
	QuerySessions(context.Context, *QuerySessionsRequest) (*QuerySessionsResponse, error)
	QuerySessionsForAccount(context.Context, *QuerySessionsForAccountRequest) (*QuerySessionsForAccountResponse, error)
	QuerySessionsForNode(context.Context, *QuerySessionsForNodeRequest) (*QuerySessionsForNodeResponse, error)
	QuerySessionsForSubscription(context.Context, *QuerySessionsForSubscriptionRequest) (*QuerySessionsForSubscriptionResponse, error)
	QuerySessionsForAllocation(context.Context, *QuerySessionsForAllocationRequest) (*QuerySessionsForAllocationResponse, error)
	QuerySession(context.Context, *QuerySessionRequest) (*QuerySessionResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type QuerySessionRequest 

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

func NewQuerySessionRequest 

func NewQuerySessionRequest(id uint64) *QuerySessionRequest

func (*QuerySessionRequest) Descriptor 

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

func (*QuerySessionRequest) Marshal 

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

func (*QuerySessionRequest) MarshalTo 

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

func (*QuerySessionRequest) MarshalToSizedBuffer 

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

func (*QuerySessionRequest) ProtoMessage 

func (*QuerySessionRequest) ProtoMessage()

func (*QuerySessionRequest) Reset 

func (m *QuerySessionRequest) Reset()

func (*QuerySessionRequest) Size 

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

func (*QuerySessionRequest) String 

func (m *QuerySessionRequest) String() string

func (*QuerySessionRequest) Unmarshal 

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

func (*QuerySessionRequest) XXX_DiscardUnknown 

func (m *QuerySessionRequest) XXX_DiscardUnknown()

func (*QuerySessionRequest) XXX_Marshal 

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

func (*QuerySessionRequest) XXX_Merge 

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

func (*QuerySessionRequest) XXX_Size 

func (m *QuerySessionRequest) XXX_Size() int

func (*QuerySessionRequest) XXX_Unmarshal 

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

type QuerySessionResponse 

type QuerySessionResponse struct {
	Session *types.Any `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
}

func (*QuerySessionResponse) Descriptor 

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

func (*QuerySessionResponse) Marshal 

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

func (*QuerySessionResponse) MarshalTo 

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

func (*QuerySessionResponse) MarshalToSizedBuffer 

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

func (*QuerySessionResponse) ProtoMessage 

func (*QuerySessionResponse) ProtoMessage()

func (*QuerySessionResponse) Reset 

func (m *QuerySessionResponse) Reset()

func (*QuerySessionResponse) Size 

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

func (*QuerySessionResponse) String 

func (m *QuerySessionResponse) String() string

func (*QuerySessionResponse) Unmarshal 

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

func (*QuerySessionResponse) XXX_DiscardUnknown 

func (m *QuerySessionResponse) XXX_DiscardUnknown()

func (*QuerySessionResponse) XXX_Marshal 

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

func (*QuerySessionResponse) XXX_Merge 

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

func (*QuerySessionResponse) XXX_Size 

func (m *QuerySessionResponse) XXX_Size() int

func (*QuerySessionResponse) XXX_Unmarshal 

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

type QuerySessionsForAccountRequest 

type QuerySessionsForAccountRequest struct {
	Address    string             `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySessionsForAccountRequest 

func NewQuerySessionsForAccountRequest(addr sdk.AccAddress, pagination *sdkquery.PageRequest) *QuerySessionsForAccountRequest

func (*QuerySessionsForAccountRequest) Descriptor 

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

func (*QuerySessionsForAccountRequest) Marshal 

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

func (*QuerySessionsForAccountRequest) MarshalTo 

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

func (*QuerySessionsForAccountRequest) MarshalToSizedBuffer 

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

func (*QuerySessionsForAccountRequest) ProtoMessage 

func (*QuerySessionsForAccountRequest) ProtoMessage()

func (*QuerySessionsForAccountRequest) Reset 

func (m *QuerySessionsForAccountRequest) Reset()

func (*QuerySessionsForAccountRequest) Size 

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

func (*QuerySessionsForAccountRequest) String 

func (m *QuerySessionsForAccountRequest) String() string

func (*QuerySessionsForAccountRequest) Unmarshal 

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

func (*QuerySessionsForAccountRequest) XXX_DiscardUnknown 

func (m *QuerySessionsForAccountRequest) XXX_DiscardUnknown()

func (*QuerySessionsForAccountRequest) XXX_Marshal 

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

func (*QuerySessionsForAccountRequest) XXX_Merge 

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

func (*QuerySessionsForAccountRequest) XXX_Size 

func (m *QuerySessionsForAccountRequest) XXX_Size() int

func (*QuerySessionsForAccountRequest) XXX_Unmarshal 

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

type QuerySessionsForAccountResponse 

type QuerySessionsForAccountResponse struct {
	Sessions   []*types.Any        `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QuerySessionsForAccountResponse) Descriptor 

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

func (*QuerySessionsForAccountResponse) Marshal 

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

func (*QuerySessionsForAccountResponse) MarshalTo 

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

func (*QuerySessionsForAccountResponse) MarshalToSizedBuffer 

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

func (*QuerySessionsForAccountResponse) ProtoMessage 

func (*QuerySessionsForAccountResponse) ProtoMessage()

func (*QuerySessionsForAccountResponse) Reset 

func (m *QuerySessionsForAccountResponse) Reset()

func (*QuerySessionsForAccountResponse) Size 

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

func (*QuerySessionsForAccountResponse) String 

func (m *QuerySessionsForAccountResponse) String() string

func (*QuerySessionsForAccountResponse) Unmarshal 

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

func (*QuerySessionsForAccountResponse) XXX_DiscardUnknown 

func (m *QuerySessionsForAccountResponse) XXX_DiscardUnknown()

func (*QuerySessionsForAccountResponse) XXX_Marshal 

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

func (*QuerySessionsForAccountResponse) XXX_Merge 

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

func (*QuerySessionsForAccountResponse) XXX_Size 

func (m *QuerySessionsForAccountResponse) XXX_Size() int

func (*QuerySessionsForAccountResponse) XXX_Unmarshal 

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

type QuerySessionsForAllocationRequest 

type QuerySessionsForAllocationRequest struct {
	Id         uint64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Address    string             `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySessionsForAllocationRequest 

func NewQuerySessionsForAllocationRequest(id uint64, addr sdk.AccAddress, pagination *sdkquery.PageRequest) *QuerySessionsForAllocationRequest

func (*QuerySessionsForAllocationRequest) Descriptor 

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

func (*QuerySessionsForAllocationRequest) Marshal 

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

func (*QuerySessionsForAllocationRequest) MarshalTo 

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

func (*QuerySessionsForAllocationRequest) MarshalToSizedBuffer 

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

func (*QuerySessionsForAllocationRequest) ProtoMessage 

func (*QuerySessionsForAllocationRequest) ProtoMessage()

func (*QuerySessionsForAllocationRequest) Reset 

func (m *QuerySessionsForAllocationRequest) Reset()

func (*QuerySessionsForAllocationRequest) Size 

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

func (*QuerySessionsForAllocationRequest) String 

func (m *QuerySessionsForAllocationRequest) String() string

func (*QuerySessionsForAllocationRequest) Unmarshal 

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

func (*QuerySessionsForAllocationRequest) XXX_DiscardUnknown 

func (m *QuerySessionsForAllocationRequest) XXX_DiscardUnknown()

func (*QuerySessionsForAllocationRequest) XXX_Marshal 

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

func (*QuerySessionsForAllocationRequest) XXX_Merge 

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

func (*QuerySessionsForAllocationRequest) XXX_Size 

func (m *QuerySessionsForAllocationRequest) XXX_Size() int

func (*QuerySessionsForAllocationRequest) XXX_Unmarshal 

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

type QuerySessionsForAllocationResponse 

type QuerySessionsForAllocationResponse struct {
	Sessions   []*types.Any        `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QuerySessionsForAllocationResponse) Descriptor 

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

func (*QuerySessionsForAllocationResponse) Marshal 

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

func (*QuerySessionsForAllocationResponse) MarshalTo 

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

func (*QuerySessionsForAllocationResponse) MarshalToSizedBuffer 

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

func (*QuerySessionsForAllocationResponse) ProtoMessage 

func (*QuerySessionsForAllocationResponse) ProtoMessage()

func (*QuerySessionsForAllocationResponse) Reset 

func (m *QuerySessionsForAllocationResponse) Reset()

func (*QuerySessionsForAllocationResponse) Size 

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

func (*QuerySessionsForAllocationResponse) String 

func (m *QuerySessionsForAllocationResponse) String() string

func (*QuerySessionsForAllocationResponse) Unmarshal 

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

func (*QuerySessionsForAllocationResponse) XXX_DiscardUnknown 

func (m *QuerySessionsForAllocationResponse) XXX_DiscardUnknown()

func (*QuerySessionsForAllocationResponse) XXX_Marshal 

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

func (*QuerySessionsForAllocationResponse) XXX_Merge 

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

func (*QuerySessionsForAllocationResponse) XXX_Size 

func (m *QuerySessionsForAllocationResponse) XXX_Size() int

func (*QuerySessionsForAllocationResponse) XXX_Unmarshal 

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

type QuerySessionsForNodeRequest 

type QuerySessionsForNodeRequest struct {
	Address    string             `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySessionsForNodeRequest 

func NewQuerySessionsForNodeRequest(addr base.NodeAddress, pagination *sdkquery.PageRequest) *QuerySessionsForNodeRequest

func (*QuerySessionsForNodeRequest) Descriptor 

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

func (*QuerySessionsForNodeRequest) Marshal 

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

func (*QuerySessionsForNodeRequest) MarshalTo 

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

func (*QuerySessionsForNodeRequest) MarshalToSizedBuffer 

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

func (*QuerySessionsForNodeRequest) ProtoMessage 

func (*QuerySessionsForNodeRequest) ProtoMessage()

func (*QuerySessionsForNodeRequest) Reset 

func (m *QuerySessionsForNodeRequest) Reset()

func (*QuerySessionsForNodeRequest) Size 

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

func (*QuerySessionsForNodeRequest) String 

func (m *QuerySessionsForNodeRequest) String() string

func (*QuerySessionsForNodeRequest) Unmarshal 

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

func (*QuerySessionsForNodeRequest) XXX_DiscardUnknown 

func (m *QuerySessionsForNodeRequest) XXX_DiscardUnknown()

func (*QuerySessionsForNodeRequest) XXX_Marshal 

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

func (*QuerySessionsForNodeRequest) XXX_Merge 

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

func (*QuerySessionsForNodeRequest) XXX_Size 

func (m *QuerySessionsForNodeRequest) XXX_Size() int

func (*QuerySessionsForNodeRequest) XXX_Unmarshal 

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

type QuerySessionsForNodeResponse 

type QuerySessionsForNodeResponse struct {
	Sessions   []*types.Any        `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QuerySessionsForNodeResponse) Descriptor 

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

func (*QuerySessionsForNodeResponse) Marshal 

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

func (*QuerySessionsForNodeResponse) MarshalTo 

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

func (*QuerySessionsForNodeResponse) MarshalToSizedBuffer 

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

func (*QuerySessionsForNodeResponse) ProtoMessage 

func (*QuerySessionsForNodeResponse) ProtoMessage()

func (*QuerySessionsForNodeResponse) Reset 

func (m *QuerySessionsForNodeResponse) Reset()

func (*QuerySessionsForNodeResponse) Size 

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

func (*QuerySessionsForNodeResponse) String 

func (m *QuerySessionsForNodeResponse) String() string

func (*QuerySessionsForNodeResponse) Unmarshal 

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

func (*QuerySessionsForNodeResponse) XXX_DiscardUnknown 

func (m *QuerySessionsForNodeResponse) XXX_DiscardUnknown()

func (*QuerySessionsForNodeResponse) XXX_Marshal 

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

func (*QuerySessionsForNodeResponse) XXX_Merge 

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

func (*QuerySessionsForNodeResponse) XXX_Size 

func (m *QuerySessionsForNodeResponse) XXX_Size() int

func (*QuerySessionsForNodeResponse) XXX_Unmarshal 

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

type QuerySessionsForSubscriptionRequest 

type QuerySessionsForSubscriptionRequest struct {
	Id         uint64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySessionsForSubscriptionRequest 

func NewQuerySessionsForSubscriptionRequest(id uint64, pagination *sdkquery.PageRequest) *QuerySessionsForSubscriptionRequest

func (*QuerySessionsForSubscriptionRequest) Descriptor 

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

func (*QuerySessionsForSubscriptionRequest) Marshal 

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

func (*QuerySessionsForSubscriptionRequest) MarshalTo 

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

func (*QuerySessionsForSubscriptionRequest) MarshalToSizedBuffer 

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

func (*QuerySessionsForSubscriptionRequest) ProtoMessage 

func (*QuerySessionsForSubscriptionRequest) ProtoMessage()

func (*QuerySessionsForSubscriptionRequest) Reset 

func (m *QuerySessionsForSubscriptionRequest) Reset()

func (*QuerySessionsForSubscriptionRequest) Size 

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

func (*QuerySessionsForSubscriptionRequest) String 

func (m *QuerySessionsForSubscriptionRequest) String() string

func (*QuerySessionsForSubscriptionRequest) Unmarshal 

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

func (*QuerySessionsForSubscriptionRequest) XXX_DiscardUnknown 

func (m *QuerySessionsForSubscriptionRequest) XXX_DiscardUnknown()

func (*QuerySessionsForSubscriptionRequest) XXX_Marshal 

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

func (*QuerySessionsForSubscriptionRequest) XXX_Merge 

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

func (*QuerySessionsForSubscriptionRequest) XXX_Size 

func (m *QuerySessionsForSubscriptionRequest) XXX_Size() int

func (*QuerySessionsForSubscriptionRequest) XXX_Unmarshal 

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

type QuerySessionsForSubscriptionResponse 

type QuerySessionsForSubscriptionResponse struct {
	Sessions   []*types.Any        `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QuerySessionsForSubscriptionResponse) Descriptor 

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

func (*QuerySessionsForSubscriptionResponse) Marshal 

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

func (*QuerySessionsForSubscriptionResponse) MarshalTo 

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

func (*QuerySessionsForSubscriptionResponse) MarshalToSizedBuffer 

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

func (*QuerySessionsForSubscriptionResponse) ProtoMessage 

func (*QuerySessionsForSubscriptionResponse) ProtoMessage()

func (*QuerySessionsForSubscriptionResponse) Reset 

func (m *QuerySessionsForSubscriptionResponse) Reset()

func (*QuerySessionsForSubscriptionResponse) Size 

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

func (*QuerySessionsForSubscriptionResponse) String 

func (m *QuerySessionsForSubscriptionResponse) String() string

func (*QuerySessionsForSubscriptionResponse) Unmarshal 

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

func (*QuerySessionsForSubscriptionResponse) XXX_DiscardUnknown 

func (m *QuerySessionsForSubscriptionResponse) XXX_DiscardUnknown()

func (*QuerySessionsForSubscriptionResponse) XXX_Marshal 

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

func (*QuerySessionsForSubscriptionResponse) XXX_Merge 

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

func (*QuerySessionsForSubscriptionResponse) XXX_Size 

func (m *QuerySessionsForSubscriptionResponse) XXX_Size() int

func (*QuerySessionsForSubscriptionResponse) XXX_Unmarshal 

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

type QuerySessionsRequest 

type QuerySessionsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func NewQuerySessionsRequest 

func NewQuerySessionsRequest(pagination *sdkquery.PageRequest) *QuerySessionsRequest

func (*QuerySessionsRequest) Descriptor 

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

func (*QuerySessionsRequest) Marshal 

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

func (*QuerySessionsRequest) MarshalTo 

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

func (*QuerySessionsRequest) MarshalToSizedBuffer 

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

func (*QuerySessionsRequest) ProtoMessage 

func (*QuerySessionsRequest) ProtoMessage()

func (*QuerySessionsRequest) Reset 

func (m *QuerySessionsRequest) Reset()

func (*QuerySessionsRequest) Size 

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

func (*QuerySessionsRequest) String 

func (m *QuerySessionsRequest) String() string

func (*QuerySessionsRequest) Unmarshal 

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

func (*QuerySessionsRequest) XXX_DiscardUnknown 

func (m *QuerySessionsRequest) XXX_DiscardUnknown()

func (*QuerySessionsRequest) XXX_Marshal 

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

func (*QuerySessionsRequest) XXX_Merge 

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

func (*QuerySessionsRequest) XXX_Size 

func (m *QuerySessionsRequest) XXX_Size() int

func (*QuerySessionsRequest) XXX_Unmarshal 

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

type QuerySessionsResponse 

type QuerySessionsResponse struct {
	Sessions   []*types.Any        `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QuerySessionsResponse) Descriptor 

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

func (*QuerySessionsResponse) Marshal 

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

func (*QuerySessionsResponse) MarshalTo 

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

func (*QuerySessionsResponse) MarshalToSizedBuffer 

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

func (*QuerySessionsResponse) ProtoMessage 

func (*QuerySessionsResponse) ProtoMessage()

func (*QuerySessionsResponse) Reset 

func (m *QuerySessionsResponse) Reset()

func (*QuerySessionsResponse) Size 

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

func (*QuerySessionsResponse) String 

func (m *QuerySessionsResponse) String() string

func (*QuerySessionsResponse) Unmarshal 

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

func (*QuerySessionsResponse) XXX_DiscardUnknown 

func (m *QuerySessionsResponse) XXX_DiscardUnknown()

func (*QuerySessionsResponse) XXX_Marshal 

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

func (*QuerySessionsResponse) XXX_Merge 

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

func (*QuerySessionsResponse) XXX_Size 

func (m *QuerySessionsResponse) XXX_Size() int

func (*QuerySessionsResponse) XXX_Unmarshal 

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

type Session 

type Session interface {
	proto.Message

	GetAccAddress() string
	GetDownloadBytes() sdkmath.Int
	GetDuration() time.Duration
	GetID() uint64
	GetInactiveAt() time.Time
	GetNodeAddress() string
	GetStatus() v1base.Status
	GetStatusAt() time.Time
	GetUploadBytes() sdkmath.Int

	SetDownloadBytes(sdkmath.Int)
	SetDuration(time.Duration)
	SetInactiveAt(time.Time)
	SetStatusAt(time.Time)
	SetStatus(v1base.Status)
	SetUploadBytes(sdkmath.Int)
}

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgCancelSession 

func (*UnimplementedMsgServiceServer) MsgCancelSession(ctx context.Context, req *MsgCancelSessionRequest) (*MsgCancelSessionResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateParams 

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

func (*UnimplementedMsgServiceServer) MsgUpdateSession 

func (*UnimplementedMsgServiceServer) MsgUpdateSession(ctx context.Context, req *MsgUpdateSessionRequest) (*MsgUpdateSessionResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QuerySession 

func (*UnimplementedQueryServiceServer) QuerySession(ctx context.Context, req *QuerySessionRequest) (*QuerySessionResponse, error)

func (*UnimplementedQueryServiceServer) QuerySessions 

func (*UnimplementedQueryServiceServer) QuerySessions(ctx context.Context, req *QuerySessionsRequest) (*QuerySessionsResponse, error)

func (*UnimplementedQueryServiceServer) QuerySessionsForAccount 

func (*UnimplementedQueryServiceServer) QuerySessionsForAccount(ctx context.Context, req *QuerySessionsForAccountRequest) (*QuerySessionsForAccountResponse, error)

func (*UnimplementedQueryServiceServer) QuerySessionsForAllocation 

func (*UnimplementedQueryServiceServer) QuerySessionsForAllocation(ctx context.Context, req *QuerySessionsForAllocationRequest) (*QuerySessionsForAllocationResponse, error)

func (*UnimplementedQueryServiceServer) QuerySessionsForNode 

func (*UnimplementedQueryServiceServer) QuerySessionsForNode(ctx context.Context, req *QuerySessionsForNodeRequest) (*QuerySessionsForNodeResponse, error)

func (*UnimplementedQueryServiceServer) QuerySessionsForSubscription 

func (*UnimplementedQueryServiceServer) QuerySessionsForSubscription(ctx context.Context, req *QuerySessionsForSubscriptionRequest) (*QuerySessionsForSubscriptionResponse, 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.