types

package
v12.0.0-rc4 Latest Latest
Warning

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

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

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName = "session"
)

Variables

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

	ErrorAllocationNotFound             = sdkerrors.Register(ModuleName, 201, "allocation not found")
	ErrorDuplicateActiveSession         = sdkerrors.Register(ModuleName, 202, "duplicate active session")
	ErrorInvalidAllocation              = sdkerrors.Register(ModuleName, 203, "invalid allocation")
	ErrorInvalidNode                    = sdkerrors.Register(ModuleName, 204, "invalid node")
	ErrorInvalidNodeStatus              = sdkerrors.Register(ModuleName, 205, "invalid node status")
	ErrorInvalidSessionStatus           = sdkerrors.Register(ModuleName, 206, "invalid session status")
	ErrorInvalidSignature               = sdkerrors.Register(ModuleName, 207, "invalid signature")
	ErrorInvalidSubscription            = sdkerrors.Register(ModuleName, 208, "invalid subscription")
	ErrorInvalidSubscriptionStatus      = sdkerrors.Register(ModuleName, 209, "invalid subscription status")
	ErrorNodeNotFound                   = sdkerrors.Register(ModuleName, 210, "node not found")
	ErrorPayoutForAddressByNodeNotFound = sdkerrors.Register(ModuleName, 211, "payout for address by node not found")
	ErrorPlanNotFound                   = sdkerrors.Register(ModuleName, 212, "plan not found")
	ErrorSessionNotFound                = sdkerrors.Register(ModuleName, 213, "session not found")
	ErrorSubscriptionNotFound           = sdkerrors.Register(ModuleName, 214, "subscription not found")
	ErrorUnauthorized                   = sdkerrors.Register(ModuleName, 215, "unauthorised")
)
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 (
	CountKey = []byte{0x00}

	SessionKeyPrefix                = []byte{0x10}
	SessionForInactiveAtKeyPrefix   = []byte{0x11}
	SessionForAccountKeyPrefix      = []byte{0x12}
	SessionForNodeKeyPrefix         = []byte{0x13}
	SessionForSubscriptionKeyPrefix = []byte{0x14}
	SessionForAllocationKeyPrefix   = []byte{0x15}
)
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 (
	DefaultStatusChangeDelay        = 1 * time.Minute
	DefaultProofVerificationEnabled = false
)
View Source 
var (
	KeyStatusChangeDelay        = []byte("StatusChangeDelay")
	KeyProofVerificationEnabled = []byte("ProofVerificationEnabled")
)
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 (
	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")
)
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")
)

Functions

func GetSessionForAccountKeyPrefix 

func GetSessionForAccountKeyPrefix(addr sdk.AccAddress) []byte

func GetSessionForAllocationKeyPrefix 

func GetSessionForAllocationKeyPrefix(id uint64, addr sdk.AccAddress) []byte

func GetSessionForInactiveAtKeyPrefix 

func GetSessionForInactiveAtKeyPrefix(at time.Time) []byte

func GetSessionForNodeKeyPrefix 

func GetSessionForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte

func GetSessionForSubscriptionKeyPrefix 

func GetSessionForSubscriptionKeyPrefix(id uint64) []byte

func IDFromSessionForAccountKey 

func IDFromSessionForAccountKey(key []byte) uint64

func IDFromSessionForAllocationKey 

func IDFromSessionForAllocationKey(key []byte) uint64

func IDFromSessionForInactiveAtKey 

func IDFromSessionForInactiveAtKey(key []byte) uint64

func IDFromSessionForNodeKey 

func IDFromSessionForNodeKey(key []byte) uint64

func IDFromSessionForSubscriptionKey 

func IDFromSessionForSubscriptionKey(key []byte) uint64

func NewErrorAllocationNotFound 

func NewErrorAllocationNotFound(id uint64, addr interface{}) error

func NewErrorDuplicateActiveSession 

func NewErrorDuplicateActiveSession(id uint64) error

func NewErrorInvalidAllocation 

func NewErrorInvalidAllocation(id uint64, addr interface{}) error

func NewErrorInvalidNode 

func NewErrorInvalidNode(addr interface{}) error

func NewErrorInvalidNodeStatus 

func NewErrorInvalidNodeStatus(addr interface{}, status hubtypes.Status) error

func NewErrorInvalidSessionStatus 

func NewErrorInvalidSessionStatus(id uint64, status hubtypes.Status) error

func NewErrorInvalidSignature 

func NewErrorInvalidSignature(signature []byte) error

func NewErrorInvalidSubscription 

func NewErrorInvalidSubscription(id uint64) error

func NewErrorInvalidSubscriptionStatus 

func NewErrorInvalidSubscriptionStatus(id uint64, status hubtypes.Status) error

func NewErrorNodeNotFound 

func NewErrorNodeNotFound(addr interface{}) error

func NewErrorPayoutForAddressByNodeNotFound 

func NewErrorPayoutForAddressByNodeNotFound(accAddr, nodeAddr interface{}) error

func NewErrorPlanNotFound 

func NewErrorPlanNotFound(id uint64) error

func NewErrorSessionNotFound 

func NewErrorSessionNotFound(id uint64) error

func NewErrorSubscriptionNotFound 

func NewErrorSubscriptionNotFound(id uint64) error

func NewErrorUnauthorized 

func NewErrorUnauthorized(addr interface{}) error

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 SessionForAccountKey 

func SessionForAccountKey(addr sdk.AccAddress, id uint64) []byte

func SessionForAllocationKey 

func SessionForAllocationKey(subscriptionID uint64, addr sdk.AccAddress, sessionID uint64) []byte

func SessionForInactiveAtKey 

func SessionForInactiveAtKey(at time.Time, id uint64) []byte

func SessionForNodeKey 

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

func SessionForSubscriptionKey 

func SessionForSubscriptionKey(subscriptionID, sessionID uint64) []byte

func SessionKey 

func SessionKey(id uint64) []byte

func ValidateGenesis 

func ValidateGenesis(state *GenesisState) error

Types

type EventStart 

type EventStart struct {
	// Field 1: Address associated with the event.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Node address associated with the event.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 3: Identifier of the event.
	ID uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	// Field 4: Identifier of the plan associated with the event.
	PlanID uint64 `protobuf:"varint,4,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty" yaml:"plan_id"`
	// Field 5: Identifier of the subscription associated with the event.
	SubscriptionID uint64 `` /* 127-byte string literal not displayed */
}

EventStart represents an event signaling the start of a subscription.

func (*EventStart) Descriptor 

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

func (*EventStart) Marshal 

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

func (*EventStart) MarshalTo 

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

func (*EventStart) MarshalToSizedBuffer 

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

func (*EventStart) ProtoMessage 

func (*EventStart) ProtoMessage()

func (*EventStart) Reset 

func (m *EventStart) Reset()

func (*EventStart) Size 

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

func (*EventStart) String 

func (m *EventStart) String() string

func (*EventStart) Unmarshal 

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

func (*EventStart) XXX_DiscardUnknown 

func (m *EventStart) XXX_DiscardUnknown()

func (*EventStart) XXX_Marshal 

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

func (*EventStart) XXX_Merge 

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

func (*EventStart) XXX_Size 

func (m *EventStart) XXX_Size() int

func (*EventStart) XXX_Unmarshal 

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

type EventUpdateDetails 

type EventUpdateDetails struct {
	// Field 1: Address associated with the event.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 2: Node address associated with the event.
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 3: Identifier of the event.
	ID uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	// Field 4: Identifier of the plan associated with the event.
	PlanID uint64 `protobuf:"varint,4,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty" yaml:"plan_id"`
	// Field 5: Identifier of the subscription associated with the event.
	SubscriptionID uint64 `` /* 127-byte string literal not displayed */
}

EventUpdateDetails represents an event signaling an update in subscription details.

func (*EventUpdateDetails) Descriptor 

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

func (*EventUpdateDetails) Marshal 

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

func (*EventUpdateDetails) MarshalTo 

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

func (*EventUpdateDetails) MarshalToSizedBuffer 

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

func (*EventUpdateDetails) ProtoMessage 

func (*EventUpdateDetails) ProtoMessage()

func (*EventUpdateDetails) Reset 

func (m *EventUpdateDetails) Reset()

func (*EventUpdateDetails) Size 

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

func (*EventUpdateDetails) String 

func (m *EventUpdateDetails) String() string

func (*EventUpdateDetails) Unmarshal 

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

func (*EventUpdateDetails) XXX_DiscardUnknown 

func (m *EventUpdateDetails) XXX_DiscardUnknown()

func (*EventUpdateDetails) XXX_Marshal 

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

func (*EventUpdateDetails) XXX_Merge 

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

func (*EventUpdateDetails) XXX_Size 

func (m *EventUpdateDetails) XXX_Size() int

func (*EventUpdateDetails) XXX_Unmarshal 

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

type EventUpdateStatus 

type EventUpdateStatus struct {
	// Field 1: Status associated with the event.
	Status types.Status `protobuf:"varint,1,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty" yaml:"status"`
	// Field 2: Address associated with the event.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Field 3: Node address associated with the event.
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	// Field 4: Identifier of the event.
	ID uint64 `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	// Field 5: Identifier of the plan associated with the event.
	PlanID uint64 `protobuf:"varint,5,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty" yaml:"plan_id"`
	// Field 6: Identifier of the subscription associated with the event.
	SubscriptionID uint64 `` /* 127-byte string literal not displayed */
}

EventUpdateStatus represents an event signaling an update in subscription status.

func (*EventUpdateStatus) Descriptor 

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

func (*EventUpdateStatus) Marshal 

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

func (*EventUpdateStatus) MarshalTo 

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

func (*EventUpdateStatus) MarshalToSizedBuffer 

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

func (*EventUpdateStatus) ProtoMessage 

func (*EventUpdateStatus) ProtoMessage()

func (*EventUpdateStatus) Reset 

func (m *EventUpdateStatus) Reset()

func (*EventUpdateStatus) Size 

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

func (*EventUpdateStatus) String 

func (m *EventUpdateStatus) String() string

func (*EventUpdateStatus) Unmarshal 

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

func (*EventUpdateStatus) XXX_DiscardUnknown 

func (m *EventUpdateStatus) XXX_DiscardUnknown()

func (*EventUpdateStatus) XXX_Marshal 

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

func (*EventUpdateStatus) XXX_Merge 

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

func (*EventUpdateStatus) XXX_Size 

func (m *EventUpdateStatus) XXX_Size() int

func (*EventUpdateStatus) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// Field 1: List of sessions.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	// Field 2: Parameters for the sessions module.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

GenesisState represents the initial state for the sessions module.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(sessions Sessions, 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 MsgEndRequest 

type MsgEndRequest struct {
	// Field 1: Sender's address.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Identifier of the session.
	ID uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Field 3: Rating associated with the session.
	Rating uint64 `protobuf:"varint,3,opt,name=rating,proto3" json:"rating,omitempty"`
}

MsgEndRequest defines the SDK message for ending a session.

func NewMsgEndRequest 

func NewMsgEndRequest(from sdk.AccAddress, id uint64, rating uint64) *MsgEndRequest

NewMsgEndRequest creates a new MsgEndRequest instance with the given parameters.

func (*MsgEndRequest) Descriptor 

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

func (*MsgEndRequest) GetSigners 

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

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

func (*MsgEndRequest) Marshal 

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

func (*MsgEndRequest) MarshalTo 

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

func (*MsgEndRequest) MarshalToSizedBuffer 

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

func (*MsgEndRequest) ProtoMessage 

func (*MsgEndRequest) ProtoMessage()

func (*MsgEndRequest) Reset 

func (m *MsgEndRequest) Reset()

func (*MsgEndRequest) Size 

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

func (*MsgEndRequest) String 

func (m *MsgEndRequest) String() string

func (*MsgEndRequest) Unmarshal 

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

func (*MsgEndRequest) ValidateBasic 

func (m *MsgEndRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgEndRequest fields. It checks if the 'From' field is not empty and represents a valid account address, if the 'ID' field is not zero, and if the 'Rating' field is not greater than 10.

func (*MsgEndRequest) XXX_DiscardUnknown 

func (m *MsgEndRequest) XXX_DiscardUnknown()

func (*MsgEndRequest) XXX_Marshal 

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

func (*MsgEndRequest) XXX_Merge 

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

func (*MsgEndRequest) XXX_Size 

func (m *MsgEndRequest) XXX_Size() int

func (*MsgEndRequest) XXX_Unmarshal 

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

type MsgEndResponse 

type MsgEndResponse struct {
}

MsgEndResponse defines the response of message MsgEndRequest.

func (*MsgEndResponse) Descriptor 

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

func (*MsgEndResponse) Marshal 

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

func (*MsgEndResponse) MarshalTo 

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

func (*MsgEndResponse) MarshalToSizedBuffer 

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

func (*MsgEndResponse) ProtoMessage 

func (*MsgEndResponse) ProtoMessage()

func (*MsgEndResponse) Reset 

func (m *MsgEndResponse) Reset()

func (*MsgEndResponse) Size 

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

func (*MsgEndResponse) String 

func (m *MsgEndResponse) String() string

func (*MsgEndResponse) Unmarshal 

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

func (*MsgEndResponse) XXX_DiscardUnknown 

func (m *MsgEndResponse) XXX_DiscardUnknown()

func (*MsgEndResponse) XXX_Marshal 

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

func (*MsgEndResponse) XXX_Merge 

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

func (*MsgEndResponse) XXX_Size 

func (m *MsgEndResponse) XXX_Size() int

func (*MsgEndResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	// RPC method for handling MsgStart messages.
	MsgStart(ctx context.Context, in *MsgStartRequest, opts ...grpc.CallOption) (*MsgStartResponse, error)
	// RPC method for handling MsgUpdateDetails messages.
	MsgUpdateDetails(ctx context.Context, in *MsgUpdateDetailsRequest, opts ...grpc.CallOption) (*MsgUpdateDetailsResponse, error)
	// RPC method for handling MsgEnd messages.
	MsgEnd(ctx context.Context, in *MsgEndRequest, opts ...grpc.CallOption) (*MsgEndResponse, error)
}

MsgServiceClient is the client API for MsgService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgServiceClient 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	// RPC method for handling MsgStart messages.
	MsgStart(context.Context, *MsgStartRequest) (*MsgStartResponse, error)
	// RPC method for handling MsgUpdateDetails messages.
	MsgUpdateDetails(context.Context, *MsgUpdateDetailsRequest) (*MsgUpdateDetailsResponse, error)
	// RPC method for handling MsgEnd messages.
	MsgEnd(context.Context, *MsgEndRequest) (*MsgEndResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgStartRequest 

type MsgStartRequest struct {
	// Field 1: Sender's address.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Identifier of the session.
	ID uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Field 3: Address associated with the session.
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
}

MsgStartRequest defines the SDK message for starting a session.

func NewMsgStartRequest 

func NewMsgStartRequest(from sdk.AccAddress, id uint64, addr hubtypes.NodeAddress) *MsgStartRequest

NewMsgStartRequest creates a new MsgStartRequest instance with the given parameters.

func (*MsgStartRequest) Descriptor 

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

func (*MsgStartRequest) GetSigners 

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

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

func (*MsgStartRequest) Marshal 

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

func (*MsgStartRequest) MarshalTo 

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

func (*MsgStartRequest) MarshalToSizedBuffer 

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

func (*MsgStartRequest) ProtoMessage 

func (*MsgStartRequest) ProtoMessage()

func (*MsgStartRequest) Reset 

func (m *MsgStartRequest) Reset()

func (*MsgStartRequest) Size 

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

func (*MsgStartRequest) String 

func (m *MsgStartRequest) String() string

func (*MsgStartRequest) Unmarshal 

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

func (*MsgStartRequest) ValidateBasic 

func (m *MsgStartRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgStartRequest fields. It checks if the 'From' field is not empty and represents a valid account address, if the 'ID' field is not zero, if the 'Address' field is not empty and represents a valid node address.

func (*MsgStartRequest) XXX_DiscardUnknown 

func (m *MsgStartRequest) XXX_DiscardUnknown()

func (*MsgStartRequest) XXX_Marshal 

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

func (*MsgStartRequest) XXX_Merge 

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

func (*MsgStartRequest) XXX_Size 

func (m *MsgStartRequest) XXX_Size() int

func (*MsgStartRequest) XXX_Unmarshal 

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

type MsgStartResponse 

type MsgStartResponse struct {
}

MsgStartResponse defines the response of message MsgStartRequest.

func (*MsgStartResponse) Descriptor 

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

func (*MsgStartResponse) Marshal 

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

func (*MsgStartResponse) MarshalTo 

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

func (*MsgStartResponse) MarshalToSizedBuffer 

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

func (*MsgStartResponse) ProtoMessage 

func (*MsgStartResponse) ProtoMessage()

func (*MsgStartResponse) Reset 

func (m *MsgStartResponse) Reset()

func (*MsgStartResponse) Size 

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

func (*MsgStartResponse) String 

func (m *MsgStartResponse) String() string

func (*MsgStartResponse) Unmarshal 

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

func (*MsgStartResponse) XXX_DiscardUnknown 

func (m *MsgStartResponse) XXX_DiscardUnknown()

func (*MsgStartResponse) XXX_Marshal 

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

func (*MsgStartResponse) XXX_Merge 

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

func (*MsgStartResponse) XXX_Size 

func (m *MsgStartResponse) XXX_Size() int

func (*MsgStartResponse) XXX_Unmarshal 

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

type MsgUpdateDetailsRequest 

type MsgUpdateDetailsRequest struct {
	// Field 1: Sender's address.
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Field 2: Proof associated with the session.
	Proof Proof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof"`
	// Field 3: Signature associated with the session.
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

MsgUpdateDetailsRequest defines the SDK message for updating a session.

func NewMsgUpdateDetailsRequest 

func NewMsgUpdateDetailsRequest(from hubtypes.NodeAddress, proof Proof, signature []byte) *MsgUpdateDetailsRequest

NewMsgUpdateDetailsRequest creates a new MsgUpdateDetailsRequest instance with the given parameters.

func (*MsgUpdateDetailsRequest) Descriptor 

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

func (*MsgUpdateDetailsRequest) GetSigners 

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

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

func (*MsgUpdateDetailsRequest) Marshal 

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

func (*MsgUpdateDetailsRequest) MarshalTo 

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

func (*MsgUpdateDetailsRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateDetailsRequest) ProtoMessage 

func (*MsgUpdateDetailsRequest) ProtoMessage()

func (*MsgUpdateDetailsRequest) Reset 

func (m *MsgUpdateDetailsRequest) Reset()

func (*MsgUpdateDetailsRequest) Size 

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

func (*MsgUpdateDetailsRequest) String 

func (m *MsgUpdateDetailsRequest) String() string

func (*MsgUpdateDetailsRequest) Unmarshal 

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

func (*MsgUpdateDetailsRequest) ValidateBasic 

func (m *MsgUpdateDetailsRequest) ValidateBasic() error

ValidateBasic performs basic validation checks on the MsgUpdateDetailsRequest fields. It checks if the 'From' field is not empty and represents a valid node address, if the 'Proof.ID' field is not zero, if the 'Proof.Bandwidth' field does not contain nil or negative values, if the 'Proof.Duration' field is not negative, and if the 'Signature' field has a length of exactly 64 bytes (if not nil).

func (*MsgUpdateDetailsRequest) XXX_DiscardUnknown 

func (m *MsgUpdateDetailsRequest) XXX_DiscardUnknown()

func (*MsgUpdateDetailsRequest) XXX_Marshal 

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

func (*MsgUpdateDetailsRequest) XXX_Merge 

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

func (*MsgUpdateDetailsRequest) XXX_Size 

func (m *MsgUpdateDetailsRequest) XXX_Size() int

func (*MsgUpdateDetailsRequest) XXX_Unmarshal 

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

type MsgUpdateDetailsResponse 

type MsgUpdateDetailsResponse struct {
}

MsgUpdateDetailsResponse defines the response of message MsgUpdateDetailsRequest.

func (*MsgUpdateDetailsResponse) Descriptor 

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

func (*MsgUpdateDetailsResponse) Marshal 

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

func (*MsgUpdateDetailsResponse) MarshalTo 

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

func (*MsgUpdateDetailsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateDetailsResponse) ProtoMessage 

func (*MsgUpdateDetailsResponse) ProtoMessage()

func (*MsgUpdateDetailsResponse) Reset 

func (m *MsgUpdateDetailsResponse) Reset()

func (*MsgUpdateDetailsResponse) Size 

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

func (*MsgUpdateDetailsResponse) String 

func (m *MsgUpdateDetailsResponse) String() string

func (*MsgUpdateDetailsResponse) Unmarshal 

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

func (*MsgUpdateDetailsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateDetailsResponse) XXX_DiscardUnknown()

func (*MsgUpdateDetailsResponse) XXX_Marshal 

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

func (*MsgUpdateDetailsResponse) XXX_Merge 

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

func (*MsgUpdateDetailsResponse) XXX_Size 

func (m *MsgUpdateDetailsResponse) XXX_Size() int

func (*MsgUpdateDetailsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// Field 1: Duration for status change delay.
	StatusChangeDelay time.Duration `protobuf:"bytes,1,opt,name=status_change_delay,json=statusChangeDelay,proto3,stdduration" json:"status_change_delay"`
	// Field 2: Flag indicating whether proof verification is enabled.
	ProofVerificationEnabled bool `` /* 136-byte string literal not displayed */
}

Params represents the parameters for the sessions module.

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(statusChangeDelay time.Duration, proofVerificationEnabled bool) 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 Proof 

type Proof struct {
	// Field 1: Identifier of the proof.
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Bandwidth information for the proof.
	Bandwidth types.Bandwidth `protobuf:"bytes,2,opt,name=bandwidth,proto3" json:"bandwidth"`
	// Field 3: Duration of the proof.
	Duration time.Duration `protobuf:"bytes,3,opt,name=duration,proto3,stdduration" json:"duration"`
}

Proof represents the proof associated with a session.

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 QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest represents the request to query session parameters.

func NewQueryParamsRequest 

func NewQueryParamsRequest() *QueryParamsRequest

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// Field 1: Session parameters.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse represents the response for querying session parameters.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	// RPC method to query sessions.
	QuerySessions(ctx context.Context, in *QuerySessionsRequest, opts ...grpc.CallOption) (*QuerySessionsResponse, error)
	// RPC method to query sessions for an account.
	QuerySessionsForAccount(ctx context.Context, in *QuerySessionsForAccountRequest, opts ...grpc.CallOption) (*QuerySessionsForAccountResponse, error)
	// RPC method to query sessions for a node.
	QuerySessionsForNode(ctx context.Context, in *QuerySessionsForNodeRequest, opts ...grpc.CallOption) (*QuerySessionsForNodeResponse, error)
	// RPC method to query sessions for a subscription.
	QuerySessionsForSubscription(ctx context.Context, in *QuerySessionsForSubscriptionRequest, opts ...grpc.CallOption) (*QuerySessionsForSubscriptionResponse, error)
	// RPC method to query sessions for an allocation.
	QuerySessionsForAllocation(ctx context.Context, in *QuerySessionsForAllocationRequest, opts ...grpc.CallOption) (*QuerySessionsForAllocationResponse, error)
	// RPC method to query a specific session.
	QuerySession(ctx context.Context, in *QuerySessionRequest, opts ...grpc.CallOption) (*QuerySessionResponse, error)
	// RPC method to query session parameters.
	QueryParams(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryServiceClient is the client API for QueryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// RPC method to query sessions.
	QuerySessions(context.Context, *QuerySessionsRequest) (*QuerySessionsResponse, error)
	// RPC method to query sessions for an account.
	QuerySessionsForAccount(context.Context, *QuerySessionsForAccountRequest) (*QuerySessionsForAccountResponse, error)
	// RPC method to query sessions for a node.
	QuerySessionsForNode(context.Context, *QuerySessionsForNodeRequest) (*QuerySessionsForNodeResponse, error)
	// RPC method to query sessions for a subscription.
	QuerySessionsForSubscription(context.Context, *QuerySessionsForSubscriptionRequest) (*QuerySessionsForSubscriptionResponse, error)
	// RPC method to query sessions for an allocation.
	QuerySessionsForAllocation(context.Context, *QuerySessionsForAllocationRequest) (*QuerySessionsForAllocationResponse, error)
	// RPC method to query a specific session.
	QuerySession(context.Context, *QuerySessionRequest) (*QuerySessionResponse, error)
	// RPC method to query session parameters.
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type QuerySessionRequest 

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

QuerySessionRequest represents the request to query a specific session.

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 {
	// Field 1: Session details.
	Session Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session"`
}

QuerySessionResponse represents the response for querying a specific session.

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 {
	// Field 1: Account address.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Pagination parameters.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForAccountRequest represents the request to query sessions for an account.

func NewQuerySessionsForAccountRequest 

func NewQuerySessionsForAccountRequest(addr sdk.AccAddress, pagination *query.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 {
	// Field 1: List of sessions.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	// Field 2: Pagination details.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForAccountResponse represents the response for querying sessions for an account.

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 {
	// Field 1: Subscription ID.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Allocation address.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// Field 3: Pagination parameters.
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForAllocationRequest represents the request to query sessions for an allocation.

func NewQuerySessionsForAllocationRequest 

func NewQuerySessionsForAllocationRequest(id uint64, addr sdk.AccAddress, pagination *query.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 {
	// Field 1: List of sessions.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	// Field 2: Pagination details.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForAllocationResponse represents the response for querying sessions for an allocation.

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 {
	// Field 1: Node address.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Field 2: Pagination parameters.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForNodeRequest represents the request to query sessions for a node.

func NewQuerySessionsForNodeRequest 

func NewQuerySessionsForNodeRequest(addr hubtypes.NodeAddress, pagination *query.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 {
	// Field 1: List of sessions.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	// Field 2: Pagination details.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForNodeResponse represents the response for querying sessions for a node.

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 {
	// Field 1: Subscription ID.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Pagination parameters.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForSubscriptionRequest represents the request to query sessions for a subscription.

func NewQuerySessionsForSubscriptionRequest 

func NewQuerySessionsForSubscriptionRequest(id uint64, pagination *query.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 {
	// Field 1: List of sessions.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	// Field 2: Pagination details.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsForSubscriptionResponse represents the response for querying sessions for a subscription.

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 {
	// Field 1: Pagination parameters.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsRequest represents the request to query sessions.

func NewQuerySessionsRequest 

func NewQuerySessionsRequest(pagination *query.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 {
	// Field 1: List of sessions.
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	// Field 2: Pagination details.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QuerySessionsResponse represents the response for querying sessions.

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 struct {
	// Field 1: Session ID.
	ID uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Field 2: Subscription ID.
	SubscriptionID uint64 `protobuf:"varint,2,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// Field 3: Node address.
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// Field 4: Account address.
	Address string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	// Field 5: Bandwidth details.
	Bandwidth types.Bandwidth `protobuf:"bytes,5,opt,name=bandwidth,proto3" json:"bandwidth"`
	// Field 6: Session duration.
	Duration time.Duration `protobuf:"bytes,6,opt,name=duration,proto3,stdduration" json:"duration"`
	// Field 7: Inactive timestamp.
	InactiveAt time.Time `protobuf:"bytes,7,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	// Field 8: Session status.
	Status types.Status `protobuf:"varint,8,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	// Field 9: Status timestamp.
	StatusAt time.Time `protobuf:"bytes,9,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

Session represents a session.

func (*Session) Descriptor 

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

func (*Session) GetAddress 

func (m *Session) GetAddress() sdk.AccAddress

func (*Session) GetNodeAddress 

func (m *Session) GetNodeAddress() hubtypes.NodeAddress

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) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

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) Validate 

func (m *Session) Validate() 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 Sessions 

type Sessions []Session

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgEnd 

func (*UnimplementedMsgServiceServer) MsgEnd(ctx context.Context, req *MsgEndRequest) (*MsgEndResponse, error)

func (*UnimplementedMsgServiceServer) MsgStart 

func (*UnimplementedMsgServiceServer) MsgStart(ctx context.Context, req *MsgStartRequest) (*MsgStartResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateDetails 

func (*UnimplementedMsgServiceServer) MsgUpdateDetails(ctx context.Context, req *MsgUpdateDetailsRequest) (*MsgUpdateDetailsResponse, 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)

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.