types

package
v0.11.0-rc5 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2023 License: Apache-2.0 Imports: 31 Imported by: 14

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 (
	ErrorDuplicate         = errors.Register(ModuleName, 201, "duplicate")
	ErrorInvalidAllocation = errors.Register(ModuleName, 202, "invalid allocation")
	ErrorInvalidSignature  = errors.Register(ModuleName, 203, "invalid signature")
	ErrorInvalidStatus     = errors.Register(ModuleName, 204, "invalid status")
	ErrorNotFound          = errors.Register(ModuleName, 205, "not found")
	ErrorUnauthorized      = errors.Register(ModuleName, 209, "unauthorized")
	ErrorInvalidNode       = errors.Register(ModuleName, 210, "invalid node")
	ErrorInvalidType       = errors.Register(ModuleName, 211, "invalid type")
)
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")
)
View Source 
var (
	ErrorInvalidMessage = errors.Register(ModuleName, 101, "invalid message")
)

Functions

func GetSessionForAccountKeyPrefix added in v0.11.0 

func GetSessionForAccountKeyPrefix(addr sdk.AccAddress) []byte

func GetSessionForAllocationKeyPrefix added in v0.11.0 

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

func GetSessionForInactiveAtKeyPrefix added in v0.11.0 

func GetSessionForInactiveAtKeyPrefix(at time.Time) []byte

func GetSessionForNodeKeyPrefix 

func GetSessionForNodeKeyPrefix(addr hubtypes.NodeAddress) []byte

func GetSessionForSubscriptionKeyPrefix 

func GetSessionForSubscriptionKeyPrefix(id uint64) []byte

func IDFromSessionForAccountKey added in v0.11.0 

func IDFromSessionForAccountKey(key []byte) uint64

func IDFromSessionForAllocationKey added in v0.11.0 

func IDFromSessionForAllocationKey(key []byte) uint64

func IDFromSessionForInactiveAtKey added in v0.11.0 

func IDFromSessionForInactiveAtKey(key []byte) uint64

func IDFromSessionForNodeKey added in v0.4.0 

func IDFromSessionForNodeKey(key []byte) uint64

func IDFromSessionForSubscriptionKey added in v0.4.0 

func IDFromSessionForSubscriptionKey(key []byte) uint64

func NewErrorAllocationNotFound added in v0.11.0 

func NewErrorAllocationNotFound(id uint64, addr sdk.AccAddress) error

func NewErrorDuplicateActiveSession added in v0.11.0 

func NewErrorDuplicateActiveSession(subscriptionID uint64, addr sdk.AccAddress, sessionID uint64) error

func NewErrorInvalidAllocation added in v0.11.0 

func NewErrorInvalidAllocation(id uint64, addr sdk.AccAddress) error

func NewErrorInvalidNode added in v0.11.0 

func NewErrorInvalidNode(addr string) error

func NewErrorInvalidNodeStatus added in v0.11.0 

func NewErrorInvalidNodeStatus(addr hubtypes.NodeAddress, status hubtypes.Status) error

func NewErrorInvalidSessionStatus added in v0.11.0 

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

func NewErrorInvalidSignature added in v0.11.0 

func NewErrorInvalidSignature(signature []byte) error

func NewErrorInvalidSubscriptionStatus added in v0.11.0 

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

func NewErrorInvalidSubscriptionType added in v0.11.0 

func NewErrorInvalidSubscriptionType(id uint64, t string) error

func NewErrorNodeNotFound added in v0.11.0 

func NewErrorNodeNotFound(addr hubtypes.NodeAddress) error

func NewErrorPayoutNotFound added in v0.11.0 

func NewErrorPayoutNotFound(accAddr sdk.AccAddress, nodeAddr hubtypes.NodeAddress) error

func NewErrorPlanNotFound added in v0.11.0 

func NewErrorPlanNotFound(id uint64) error

func NewErrorSessionNotFound added in v0.11.0 

func NewErrorSessionNotFound(id uint64) error

func NewErrorSubscriptionNotFound added in v0.11.0 

func NewErrorSubscriptionNotFound(id uint64) error

func NewErrorUnauthorized added in v0.11.0 

func NewErrorUnauthorized(addr string) error

func ParamsKeyTable 

func ParamsKeyTable() params.KeyTable

func RegisterInterfaces added in v0.6.0 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

func RegisterMsgServiceServer added in v0.6.0 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServiceHandler added in v0.6.0 

func RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryServiceHandler registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryServiceHandlerClient added in v0.6.0 

func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error

RegisterQueryServiceHandlerClient registers the http handlers for service QueryService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryServiceClient" to call the correct interceptors.

func RegisterQueryServiceHandlerFromEndpoint added in v0.6.0 

func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryServiceHandlerFromEndpoint is same as RegisterQueryServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryServiceHandlerServer added in v0.6.0 

func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error

RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryServiceHandlerFromEndpoint instead.

func RegisterQueryServiceServer added in v0.6.0 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

func SessionForAccountKey added in v0.11.0 

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

func SessionForAllocationKey added in v0.11.0 

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

func SessionForInactiveAtKey added in v0.11.0 

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 added in v0.6.0 

func ValidateGenesis(state *GenesisState) error

Types

type EventStart added in v0.8.0 

type EventStart struct {
	ID             uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	SubscriptionID uint64 `` /* 127-byte string literal not displayed */
	NodeAddress    string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
}

func (*EventStart) Descriptor added in v0.8.0 

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

func (*EventStart) Marshal added in v0.8.0 

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

func (*EventStart) MarshalTo added in v0.8.0 

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

func (*EventStart) MarshalToSizedBuffer added in v0.8.0 

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

func (*EventStart) ProtoMessage added in v0.8.0 

func (*EventStart) ProtoMessage()

func (*EventStart) Reset added in v0.8.0 

func (m *EventStart) Reset()

func (*EventStart) Size added in v0.8.0 

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

func (*EventStart) String added in v0.8.0 

func (m *EventStart) String() string

func (*EventStart) Unmarshal added in v0.8.0 

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

func (*EventStart) XXX_DiscardUnknown added in v0.8.0 

func (m *EventStart) XXX_DiscardUnknown()

func (*EventStart) XXX_Marshal added in v0.8.0 

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

func (*EventStart) XXX_Merge added in v0.8.0 

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

func (*EventStart) XXX_Size added in v0.8.0 

func (m *EventStart) XXX_Size() int

func (*EventStart) XXX_Unmarshal added in v0.8.0 

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

type EventUpdateDetails added in v0.11.0 

type EventUpdateDetails struct {
	ID             uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	SubscriptionID uint64 `` /* 127-byte string literal not displayed */
	NodeAddress    string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
}

func (*EventUpdateDetails) Descriptor added in v0.11.0 

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

func (*EventUpdateDetails) Marshal added in v0.11.0 

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

func (*EventUpdateDetails) MarshalTo added in v0.11.0 

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

func (*EventUpdateDetails) MarshalToSizedBuffer added in v0.11.0 

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

func (*EventUpdateDetails) ProtoMessage added in v0.11.0 

func (*EventUpdateDetails) ProtoMessage()

func (*EventUpdateDetails) Reset added in v0.11.0 

func (m *EventUpdateDetails) Reset()

func (*EventUpdateDetails) Size added in v0.11.0 

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

func (*EventUpdateDetails) String added in v0.11.0 

func (m *EventUpdateDetails) String() string

func (*EventUpdateDetails) Unmarshal added in v0.11.0 

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

func (*EventUpdateDetails) XXX_DiscardUnknown added in v0.11.0 

func (m *EventUpdateDetails) XXX_DiscardUnknown()

func (*EventUpdateDetails) XXX_Marshal added in v0.11.0 

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

func (*EventUpdateDetails) XXX_Merge added in v0.11.0 

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

func (*EventUpdateDetails) XXX_Size added in v0.11.0 

func (m *EventUpdateDetails) XXX_Size() int

func (*EventUpdateDetails) XXX_Unmarshal added in v0.11.0 

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

type EventUpdateStatus added in v0.11.0 

type EventUpdateStatus struct {
	ID             uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	SubscriptionID uint64       `` /* 127-byte string literal not displayed */
	NodeAddress    string       `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty" yaml:"node_address"`
	Status         types.Status `protobuf:"varint,4,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty" yaml:"status"`
}

func (*EventUpdateStatus) Descriptor added in v0.11.0 

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

func (*EventUpdateStatus) Marshal added in v0.11.0 

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

func (*EventUpdateStatus) MarshalTo added in v0.11.0 

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

func (*EventUpdateStatus) MarshalToSizedBuffer added in v0.11.0 

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

func (*EventUpdateStatus) ProtoMessage added in v0.11.0 

func (*EventUpdateStatus) ProtoMessage()

func (*EventUpdateStatus) Reset added in v0.11.0 

func (m *EventUpdateStatus) Reset()

func (*EventUpdateStatus) Size added in v0.11.0 

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

func (*EventUpdateStatus) String added in v0.11.0 

func (m *EventUpdateStatus) String() string

func (*EventUpdateStatus) Unmarshal added in v0.11.0 

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

func (*EventUpdateStatus) XXX_DiscardUnknown added in v0.11.0 

func (m *EventUpdateStatus) XXX_DiscardUnknown()

func (*EventUpdateStatus) XXX_Marshal added in v0.11.0 

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

func (*EventUpdateStatus) XXX_Merge added in v0.11.0 

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

func (*EventUpdateStatus) XXX_Size added in v0.11.0 

func (m *EventUpdateStatus) XXX_Size() int

func (*EventUpdateStatus) XXX_Unmarshal added in v0.11.0 

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

type GenesisState 

type GenesisState struct {
	Sessions []Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions"`
	Params   Params    `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(sessions Sessions, params Params) *GenesisState

func (*GenesisState) Descriptor added in v0.6.0 

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

func (*GenesisState) Marshal added in v0.6.0 

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

func (*GenesisState) MarshalTo added in v0.6.0 

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

func (*GenesisState) MarshalToSizedBuffer added in v0.6.0 

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

func (*GenesisState) ProtoMessage added in v0.6.0 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset added in v0.6.0 

func (m *GenesisState) Reset()

func (*GenesisState) Size added in v0.6.0 

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

func (*GenesisState) String added in v0.6.0 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal added in v0.6.0 

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

func (*GenesisState) XXX_DiscardUnknown added in v0.6.0 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal added in v0.6.0 

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

func (*GenesisState) XXX_Merge added in v0.6.0 

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

func (*GenesisState) XXX_Size added in v0.6.0 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal added in v0.6.0 

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

type MsgEndRequest added in v0.6.1 

type MsgEndRequest 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"`
	Rating uint64 `protobuf:"varint,3,opt,name=rating,proto3" json:"rating,omitempty"`
}

MsgEndRequest defines the SDK message for ending a session

func NewMsgEndRequest added in v0.6.1 

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

NewMsgEndRequest creates a new MsgEndRequest instance with the given parameters.

func (*MsgEndRequest) Descriptor added in v0.6.1 

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

func (*MsgEndRequest) GetSigners added in v0.6.1 

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 added in v0.6.1 

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

func (*MsgEndRequest) MarshalTo added in v0.6.1 

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

func (*MsgEndRequest) MarshalToSizedBuffer added in v0.6.1 

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

func (*MsgEndRequest) ProtoMessage added in v0.6.1 

func (*MsgEndRequest) ProtoMessage()

func (*MsgEndRequest) Reset added in v0.6.1 

func (m *MsgEndRequest) Reset()

func (*MsgEndRequest) Size added in v0.6.1 

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

func (*MsgEndRequest) String added in v0.6.1 

func (m *MsgEndRequest) String() string

func (*MsgEndRequest) Unmarshal added in v0.6.1 

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

func (*MsgEndRequest) ValidateBasic added in v0.6.1 

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 added in v0.6.1 

func (m *MsgEndRequest) XXX_DiscardUnknown()

func (*MsgEndRequest) XXX_Marshal added in v0.6.1 

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

func (*MsgEndRequest) XXX_Merge added in v0.6.1 

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

func (*MsgEndRequest) XXX_Size added in v0.6.1 

func (m *MsgEndRequest) XXX_Size() int

func (*MsgEndRequest) XXX_Unmarshal added in v0.6.1 

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

type MsgEndResponse added in v0.6.1 

type MsgEndResponse struct {
}

MsgEndResponse defines the response of message MsgEndRequest

func (*MsgEndResponse) Descriptor added in v0.6.1 

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

func (*MsgEndResponse) Marshal added in v0.6.1 

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

func (*MsgEndResponse) MarshalTo added in v0.6.1 

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

func (*MsgEndResponse) MarshalToSizedBuffer added in v0.6.1 

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

func (*MsgEndResponse) ProtoMessage added in v0.6.1 

func (*MsgEndResponse) ProtoMessage()

func (*MsgEndResponse) Reset added in v0.6.1 

func (m *MsgEndResponse) Reset()

func (*MsgEndResponse) Size added in v0.6.1 

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

func (*MsgEndResponse) String added in v0.6.1 

func (m *MsgEndResponse) String() string

func (*MsgEndResponse) Unmarshal added in v0.6.1 

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

func (*MsgEndResponse) XXX_DiscardUnknown added in v0.6.1 

func (m *MsgEndResponse) XXX_DiscardUnknown()

func (*MsgEndResponse) XXX_Marshal added in v0.6.1 

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

func (*MsgEndResponse) XXX_Merge added in v0.6.1 

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

func (*MsgEndResponse) XXX_Size added in v0.6.1 

func (m *MsgEndResponse) XXX_Size() int

func (*MsgEndResponse) XXX_Unmarshal added in v0.6.1 

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

type MsgServiceClient added in v0.6.0 

type MsgServiceClient interface {
	MsgStart(ctx context.Context, in *MsgStartRequest, opts ...grpc.CallOption) (*MsgStartResponse, error)
	MsgUpdateDetails(ctx context.Context, in *MsgUpdateDetailsRequest, opts ...grpc.CallOption) (*MsgUpdateDetailsResponse, error)
	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 added in v0.6.0 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer added in v0.6.0 

type MsgServiceServer interface {
	MsgStart(context.Context, *MsgStartRequest) (*MsgStartResponse, error)
	MsgUpdateDetails(context.Context, *MsgUpdateDetailsRequest) (*MsgUpdateDetailsResponse, error)
	MsgEnd(context.Context, *MsgEndRequest) (*MsgEndResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgStartRequest added in v0.6.1 

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

MsgStartRequest defines the SDK message for starting a session

func NewMsgStartRequest added in v0.6.1 

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

NewMsgStartRequest creates a new MsgStartRequest instance with the given parameters.

func (*MsgStartRequest) Descriptor added in v0.6.1 

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

func (*MsgStartRequest) GetSigners added in v0.6.1 

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 added in v0.6.1 

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

func (*MsgStartRequest) MarshalTo added in v0.6.1 

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

func (*MsgStartRequest) MarshalToSizedBuffer added in v0.6.1 

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

func (*MsgStartRequest) ProtoMessage added in v0.6.1 

func (*MsgStartRequest) ProtoMessage()

func (*MsgStartRequest) Reset added in v0.6.1 

func (m *MsgStartRequest) Reset()

func (*MsgStartRequest) Size added in v0.6.1 

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

func (*MsgStartRequest) String added in v0.6.1 

func (m *MsgStartRequest) String() string

func (*MsgStartRequest) Unmarshal added in v0.6.1 

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

func (*MsgStartRequest) ValidateBasic added in v0.6.1 

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 added in v0.6.1 

func (m *MsgStartRequest) XXX_DiscardUnknown()

func (*MsgStartRequest) XXX_Marshal added in v0.6.1 

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

func (*MsgStartRequest) XXX_Merge added in v0.6.1 

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

func (*MsgStartRequest) XXX_Size added in v0.6.1 

func (m *MsgStartRequest) XXX_Size() int

func (*MsgStartRequest) XXX_Unmarshal added in v0.6.1 

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

type MsgStartResponse added in v0.6.1 

type MsgStartResponse struct {
}

MsgStartResponse defines the response of message MsgStartRequest

func (*MsgStartResponse) Descriptor added in v0.6.1 

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

func (*MsgStartResponse) Marshal added in v0.6.1 

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

func (*MsgStartResponse) MarshalTo added in v0.6.1 

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

func (*MsgStartResponse) MarshalToSizedBuffer added in v0.6.1 

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

func (*MsgStartResponse) ProtoMessage added in v0.6.1 

func (*MsgStartResponse) ProtoMessage()

func (*MsgStartResponse) Reset added in v0.6.1 

func (m *MsgStartResponse) Reset()

func (*MsgStartResponse) Size added in v0.6.1 

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

func (*MsgStartResponse) String added in v0.6.1 

func (m *MsgStartResponse) String() string

func (*MsgStartResponse) Unmarshal added in v0.6.1 

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

func (*MsgStartResponse) XXX_DiscardUnknown added in v0.6.1 

func (m *MsgStartResponse) XXX_DiscardUnknown()

func (*MsgStartResponse) XXX_Marshal added in v0.6.1 

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

func (*MsgStartResponse) XXX_Merge added in v0.6.1 

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

func (*MsgStartResponse) XXX_Size added in v0.6.1 

func (m *MsgStartResponse) XXX_Size() int

func (*MsgStartResponse) XXX_Unmarshal added in v0.6.1 

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

type MsgUpdateDetailsRequest added in v0.11.0 

type MsgUpdateDetailsRequest struct {
	From      string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Proof     Proof  `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof"`
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

MsgUpdateDetailsRequest defines the SDK message for updating a session

func NewMsgUpdateDetailsRequest added in v0.11.0 

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

NewMsgUpdateDetailsRequest creates a new MsgUpdateDetailsRequest instance with the given parameters.

func (*MsgUpdateDetailsRequest) Descriptor added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) GetSigners added in v0.11.0 

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 added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) MarshalTo added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) ProtoMessage added in v0.11.0 

func (*MsgUpdateDetailsRequest) ProtoMessage()

func (*MsgUpdateDetailsRequest) Reset added in v0.11.0 

func (m *MsgUpdateDetailsRequest) Reset()

func (*MsgUpdateDetailsRequest) Size added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) String added in v0.11.0 

func (m *MsgUpdateDetailsRequest) String() string

func (*MsgUpdateDetailsRequest) Unmarshal added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) ValidateBasic added in v0.11.0 

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 added in v0.11.0 

func (m *MsgUpdateDetailsRequest) XXX_DiscardUnknown()

func (*MsgUpdateDetailsRequest) XXX_Marshal added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) XXX_Merge added in v0.11.0 

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

func (*MsgUpdateDetailsRequest) XXX_Size added in v0.11.0 

func (m *MsgUpdateDetailsRequest) XXX_Size() int

func (*MsgUpdateDetailsRequest) XXX_Unmarshal added in v0.11.0 

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

type MsgUpdateDetailsResponse added in v0.11.0 

type MsgUpdateDetailsResponse struct {
}

MsgUpdateDetailsResponse defines the response of message MsgUpdateDetailsRequest

func (*MsgUpdateDetailsResponse) Descriptor added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) Marshal added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) MarshalTo added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) MarshalToSizedBuffer added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) ProtoMessage added in v0.11.0 

func (*MsgUpdateDetailsResponse) ProtoMessage()

func (*MsgUpdateDetailsResponse) Reset added in v0.11.0 

func (m *MsgUpdateDetailsResponse) Reset()

func (*MsgUpdateDetailsResponse) Size added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) String added in v0.11.0 

func (m *MsgUpdateDetailsResponse) String() string

func (*MsgUpdateDetailsResponse) Unmarshal added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *MsgUpdateDetailsResponse) XXX_DiscardUnknown()

func (*MsgUpdateDetailsResponse) XXX_Marshal added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) XXX_Merge added in v0.11.0 

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

func (*MsgUpdateDetailsResponse) XXX_Size added in v0.11.0 

func (m *MsgUpdateDetailsResponse) XXX_Size() int

func (*MsgUpdateDetailsResponse) XXX_Unmarshal added in v0.11.0 

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

type Params 

type Params struct {
	StatusChangeDelay        time.Duration `protobuf:"bytes,1,opt,name=status_change_delay,json=statusChangeDelay,proto3,stdduration" json:"status_change_delay"`
	ProofVerificationEnabled bool          `` /* 136-byte string literal not displayed */
}

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(statusChangeDelay time.Duration, proofVerificationEnabled bool) Params

func (*Params) Descriptor added in v0.6.0 

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

func (*Params) Marshal added in v0.6.0 

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

func (*Params) MarshalTo added in v0.6.0 

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

func (*Params) MarshalToSizedBuffer added in v0.6.0 

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

func (*Params) ParamSetPairs 

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

func (*Params) ProtoMessage added in v0.6.0 

func (*Params) ProtoMessage()

func (*Params) Reset added in v0.6.0 

func (m *Params) Reset()

func (*Params) Size added in v0.6.0 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal added in v0.6.0 

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

func (*Params) Validate 

func (m *Params) Validate() error

func (*Params) XXX_DiscardUnknown added in v0.6.0 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v0.6.0 

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

func (*Params) XXX_Merge added in v0.6.0 

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

func (*Params) XXX_Size added in v0.6.0 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v0.6.0 

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

type Proof added in v0.5.0 

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

func (*Proof) Descriptor added in v0.6.0 

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

func (*Proof) Marshal added in v0.6.0 

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

func (*Proof) MarshalTo added in v0.6.0 

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

func (*Proof) MarshalToSizedBuffer added in v0.6.0 

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

func (*Proof) ProtoMessage added in v0.6.0 

func (*Proof) ProtoMessage()

func (*Proof) Reset added in v0.6.0 

func (m *Proof) Reset()

func (*Proof) Size added in v0.6.0 

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

func (*Proof) String added in v0.6.0 

func (m *Proof) String() string

func (*Proof) Unmarshal added in v0.6.0 

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

func (*Proof) XXX_DiscardUnknown added in v0.6.0 

func (m *Proof) XXX_DiscardUnknown()

func (*Proof) XXX_Marshal added in v0.6.0 

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

func (*Proof) XXX_Merge added in v0.6.0 

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

func (*Proof) XXX_Size added in v0.6.0 

func (m *Proof) XXX_Size() int

func (*Proof) XXX_Unmarshal added in v0.6.0 

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

type QueryParamsRequest added in v0.6.1 

type QueryParamsRequest struct {
}

func NewQueryParamsRequest added in v0.6.1 

func NewQueryParamsRequest() *QueryParamsRequest

func (*QueryParamsRequest) Descriptor added in v0.6.1 

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

func (*QueryParamsRequest) Marshal added in v0.6.1 

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

func (*QueryParamsRequest) MarshalTo added in v0.6.1 

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

func (*QueryParamsRequest) MarshalToSizedBuffer added in v0.6.1 

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

func (*QueryParamsRequest) ProtoMessage added in v0.6.1 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v0.6.1 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v0.6.1 

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

func (*QueryParamsRequest) String added in v0.6.1 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v0.6.1 

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

func (*QueryParamsRequest) XXX_DiscardUnknown added in v0.6.1 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v0.6.1 

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

func (*QueryParamsRequest) XXX_Merge added in v0.6.1 

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

func (*QueryParamsRequest) XXX_Size added in v0.6.1 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v0.6.1 

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

type QueryParamsResponse added in v0.6.1 

type QueryParamsResponse struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

func (*QueryParamsResponse) Descriptor added in v0.6.1 

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

func (*QueryParamsResponse) Marshal added in v0.6.1 

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

func (*QueryParamsResponse) MarshalTo added in v0.6.1 

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

func (*QueryParamsResponse) MarshalToSizedBuffer added in v0.6.1 

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

func (*QueryParamsResponse) ProtoMessage added in v0.6.1 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v0.6.1 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v0.6.1 

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

func (*QueryParamsResponse) String added in v0.6.1 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v0.6.1 

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

func (*QueryParamsResponse) XXX_DiscardUnknown added in v0.6.1 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v0.6.1 

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

func (*QueryParamsResponse) XXX_Merge added in v0.6.1 

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

func (*QueryParamsResponse) XXX_Size added in v0.6.1 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v0.6.1 

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

type QueryServiceClient added in v0.6.0 

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)
	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 added in v0.6.0 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer added in v0.6.0 

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

QueryServiceServer is the server API for QueryService service.

type QuerySessionRequest added in v0.6.0 

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

func NewQuerySessionRequest added in v0.6.0 

func NewQuerySessionRequest(id uint64) *QuerySessionRequest

func (*QuerySessionRequest) Descriptor added in v0.6.0 

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

func (*QuerySessionRequest) Marshal added in v0.6.0 

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

func (*QuerySessionRequest) MarshalTo added in v0.6.0 

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

func (*QuerySessionRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionRequest) ProtoMessage added in v0.6.0 

func (*QuerySessionRequest) ProtoMessage()

func (*QuerySessionRequest) Reset added in v0.6.0 

func (m *QuerySessionRequest) Reset()

func (*QuerySessionRequest) Size added in v0.6.0 

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

func (*QuerySessionRequest) String added in v0.6.0 

func (m *QuerySessionRequest) String() string

func (*QuerySessionRequest) Unmarshal added in v0.6.0 

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

func (*QuerySessionRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionRequest) XXX_DiscardUnknown()

func (*QuerySessionRequest) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionRequest) XXX_Merge added in v0.6.0 

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

func (*QuerySessionRequest) XXX_Size added in v0.6.0 

func (m *QuerySessionRequest) XXX_Size() int

func (*QuerySessionRequest) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionResponse added in v0.6.0 

type QuerySessionResponse struct {
	Session Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session"`
}

func (*QuerySessionResponse) Descriptor added in v0.6.0 

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

func (*QuerySessionResponse) Marshal added in v0.6.0 

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

func (*QuerySessionResponse) MarshalTo added in v0.6.0 

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

func (*QuerySessionResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionResponse) ProtoMessage added in v0.6.0 

func (*QuerySessionResponse) ProtoMessage()

func (*QuerySessionResponse) Reset added in v0.6.0 

func (m *QuerySessionResponse) Reset()

func (*QuerySessionResponse) Size added in v0.6.0 

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

func (*QuerySessionResponse) String added in v0.6.0 

func (m *QuerySessionResponse) String() string

func (*QuerySessionResponse) Unmarshal added in v0.6.0 

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

func (*QuerySessionResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionResponse) XXX_DiscardUnknown()

func (*QuerySessionResponse) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionResponse) XXX_Merge added in v0.6.0 

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

func (*QuerySessionResponse) XXX_Size added in v0.6.0 

func (m *QuerySessionResponse) XXX_Size() int

func (*QuerySessionResponse) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionsForAccountRequest added in v0.11.0 

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 added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) Descriptor added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) Marshal added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) MarshalTo added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) ProtoMessage added in v0.11.0 

func (*QuerySessionsForAccountRequest) ProtoMessage()

func (*QuerySessionsForAccountRequest) Reset added in v0.11.0 

func (m *QuerySessionsForAccountRequest) Reset()

func (*QuerySessionsForAccountRequest) Size added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) String added in v0.11.0 

func (m *QuerySessionsForAccountRequest) String() string

func (*QuerySessionsForAccountRequest) Unmarshal added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) XXX_DiscardUnknown added in v0.11.0 

func (m *QuerySessionsForAccountRequest) XXX_DiscardUnknown()

func (*QuerySessionsForAccountRequest) XXX_Marshal added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) XXX_Merge added in v0.11.0 

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

func (*QuerySessionsForAccountRequest) XXX_Size added in v0.11.0 

func (m *QuerySessionsForAccountRequest) XXX_Size() int

func (*QuerySessionsForAccountRequest) XXX_Unmarshal added in v0.11.0 

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

type QuerySessionsForAccountResponse added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) Descriptor added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) Marshal added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) MarshalTo added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) MarshalToSizedBuffer added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) ProtoMessage added in v0.11.0 

func (*QuerySessionsForAccountResponse) ProtoMessage()

func (*QuerySessionsForAccountResponse) Reset added in v0.11.0 

func (m *QuerySessionsForAccountResponse) Reset()

func (*QuerySessionsForAccountResponse) Size added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) String added in v0.11.0 

func (m *QuerySessionsForAccountResponse) String() string

func (*QuerySessionsForAccountResponse) Unmarshal added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *QuerySessionsForAccountResponse) XXX_DiscardUnknown()

func (*QuerySessionsForAccountResponse) XXX_Marshal added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) XXX_Merge added in v0.11.0 

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

func (*QuerySessionsForAccountResponse) XXX_Size added in v0.11.0 

func (m *QuerySessionsForAccountResponse) XXX_Size() int

func (*QuerySessionsForAccountResponse) XXX_Unmarshal added in v0.11.0 

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

type QuerySessionsForAllocationRequest added in v0.11.0 

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 added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) Descriptor added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) Marshal added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) MarshalTo added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) ProtoMessage added in v0.11.0 

func (*QuerySessionsForAllocationRequest) ProtoMessage()

func (*QuerySessionsForAllocationRequest) Reset added in v0.11.0 

func (m *QuerySessionsForAllocationRequest) Reset()

func (*QuerySessionsForAllocationRequest) Size added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) String added in v0.11.0 

func (m *QuerySessionsForAllocationRequest) String() string

func (*QuerySessionsForAllocationRequest) Unmarshal added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) XXX_DiscardUnknown added in v0.11.0 

func (m *QuerySessionsForAllocationRequest) XXX_DiscardUnknown()

func (*QuerySessionsForAllocationRequest) XXX_Marshal added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) XXX_Merge added in v0.11.0 

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

func (*QuerySessionsForAllocationRequest) XXX_Size added in v0.11.0 

func (m *QuerySessionsForAllocationRequest) XXX_Size() int

func (*QuerySessionsForAllocationRequest) XXX_Unmarshal added in v0.11.0 

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

type QuerySessionsForAllocationResponse added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) Descriptor added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) Marshal added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) MarshalTo added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) MarshalToSizedBuffer added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) ProtoMessage added in v0.11.0 

func (*QuerySessionsForAllocationResponse) ProtoMessage()

func (*QuerySessionsForAllocationResponse) Reset added in v0.11.0 

func (m *QuerySessionsForAllocationResponse) Reset()

func (*QuerySessionsForAllocationResponse) Size added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) String added in v0.11.0 

func (m *QuerySessionsForAllocationResponse) String() string

func (*QuerySessionsForAllocationResponse) Unmarshal added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *QuerySessionsForAllocationResponse) XXX_DiscardUnknown()

func (*QuerySessionsForAllocationResponse) XXX_Marshal added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) XXX_Merge added in v0.11.0 

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

func (*QuerySessionsForAllocationResponse) XXX_Size added in v0.11.0 

func (m *QuerySessionsForAllocationResponse) XXX_Size() int

func (*QuerySessionsForAllocationResponse) XXX_Unmarshal added in v0.11.0 

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

type QuerySessionsForNodeRequest added in v0.6.0 

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 added in v0.6.0 

func NewQuerySessionsForNodeRequest(addr hubtypes.NodeAddress, pagination *query.PageRequest) *QuerySessionsForNodeRequest

func (*QuerySessionsForNodeRequest) Descriptor added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) Marshal added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) MarshalTo added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) ProtoMessage added in v0.6.0 

func (*QuerySessionsForNodeRequest) ProtoMessage()

func (*QuerySessionsForNodeRequest) Reset added in v0.6.0 

func (m *QuerySessionsForNodeRequest) Reset()

func (*QuerySessionsForNodeRequest) Size added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) String added in v0.6.0 

func (m *QuerySessionsForNodeRequest) String() string

func (*QuerySessionsForNodeRequest) Unmarshal added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionsForNodeRequest) XXX_DiscardUnknown()

func (*QuerySessionsForNodeRequest) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) XXX_Merge added in v0.6.0 

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

func (*QuerySessionsForNodeRequest) XXX_Size added in v0.6.0 

func (m *QuerySessionsForNodeRequest) XXX_Size() int

func (*QuerySessionsForNodeRequest) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionsForNodeResponse added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) Descriptor added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) Marshal added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) MarshalTo added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) ProtoMessage added in v0.6.0 

func (*QuerySessionsForNodeResponse) ProtoMessage()

func (*QuerySessionsForNodeResponse) Reset added in v0.6.0 

func (m *QuerySessionsForNodeResponse) Reset()

func (*QuerySessionsForNodeResponse) Size added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) String added in v0.6.0 

func (m *QuerySessionsForNodeResponse) String() string

func (*QuerySessionsForNodeResponse) Unmarshal added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionsForNodeResponse) XXX_DiscardUnknown()

func (*QuerySessionsForNodeResponse) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) XXX_Merge added in v0.6.0 

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

func (*QuerySessionsForNodeResponse) XXX_Size added in v0.6.0 

func (m *QuerySessionsForNodeResponse) XXX_Size() int

func (*QuerySessionsForNodeResponse) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionsForSubscriptionRequest added in v0.6.0 

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 added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) Descriptor added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) Marshal added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) MarshalTo added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) ProtoMessage added in v0.6.0 

func (*QuerySessionsForSubscriptionRequest) ProtoMessage()

func (*QuerySessionsForSubscriptionRequest) Reset added in v0.6.0 

func (m *QuerySessionsForSubscriptionRequest) Reset()

func (*QuerySessionsForSubscriptionRequest) Size added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) String added in v0.6.0 

func (m *QuerySessionsForSubscriptionRequest) String() string

func (*QuerySessionsForSubscriptionRequest) Unmarshal added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionsForSubscriptionRequest) XXX_DiscardUnknown()

func (*QuerySessionsForSubscriptionRequest) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) XXX_Merge added in v0.6.0 

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

func (*QuerySessionsForSubscriptionRequest) XXX_Size added in v0.6.0 

func (m *QuerySessionsForSubscriptionRequest) XXX_Size() int

func (*QuerySessionsForSubscriptionRequest) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionsForSubscriptionResponse added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) Descriptor added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) Marshal added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) MarshalTo added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) ProtoMessage added in v0.6.0 

func (*QuerySessionsForSubscriptionResponse) ProtoMessage()

func (*QuerySessionsForSubscriptionResponse) Reset added in v0.6.0 

func (m *QuerySessionsForSubscriptionResponse) Reset()

func (*QuerySessionsForSubscriptionResponse) Size added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) String added in v0.6.0 

func (m *QuerySessionsForSubscriptionResponse) String() string

func (*QuerySessionsForSubscriptionResponse) Unmarshal added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionsForSubscriptionResponse) XXX_DiscardUnknown()

func (*QuerySessionsForSubscriptionResponse) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) XXX_Merge added in v0.6.0 

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

func (*QuerySessionsForSubscriptionResponse) XXX_Size added in v0.6.0 

func (m *QuerySessionsForSubscriptionResponse) XXX_Size() int

func (*QuerySessionsForSubscriptionResponse) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionsRequest added in v0.6.0 

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

func NewQuerySessionsRequest added in v0.6.0 

func NewQuerySessionsRequest(pagination *query.PageRequest) *QuerySessionsRequest

func (*QuerySessionsRequest) Descriptor added in v0.6.0 

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

func (*QuerySessionsRequest) Marshal added in v0.6.0 

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

func (*QuerySessionsRequest) MarshalTo added in v0.6.0 

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

func (*QuerySessionsRequest) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionsRequest) ProtoMessage added in v0.6.0 

func (*QuerySessionsRequest) ProtoMessage()

func (*QuerySessionsRequest) Reset added in v0.6.0 

func (m *QuerySessionsRequest) Reset()

func (*QuerySessionsRequest) Size added in v0.6.0 

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

func (*QuerySessionsRequest) String added in v0.6.0 

func (m *QuerySessionsRequest) String() string

func (*QuerySessionsRequest) Unmarshal added in v0.6.0 

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

func (*QuerySessionsRequest) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionsRequest) XXX_DiscardUnknown()

func (*QuerySessionsRequest) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionsRequest) XXX_Merge added in v0.6.0 

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

func (*QuerySessionsRequest) XXX_Size added in v0.6.0 

func (m *QuerySessionsRequest) XXX_Size() int

func (*QuerySessionsRequest) XXX_Unmarshal added in v0.6.0 

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

type QuerySessionsResponse added in v0.6.0 

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

func (*QuerySessionsResponse) Descriptor added in v0.6.0 

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

func (*QuerySessionsResponse) Marshal added in v0.6.0 

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

func (*QuerySessionsResponse) MarshalTo added in v0.6.0 

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

func (*QuerySessionsResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*QuerySessionsResponse) ProtoMessage added in v0.6.0 

func (*QuerySessionsResponse) ProtoMessage()

func (*QuerySessionsResponse) Reset added in v0.6.0 

func (m *QuerySessionsResponse) Reset()

func (*QuerySessionsResponse) Size added in v0.6.0 

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

func (*QuerySessionsResponse) String added in v0.6.0 

func (m *QuerySessionsResponse) String() string

func (*QuerySessionsResponse) Unmarshal added in v0.6.0 

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

func (*QuerySessionsResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *QuerySessionsResponse) XXX_DiscardUnknown()

func (*QuerySessionsResponse) XXX_Marshal added in v0.6.0 

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

func (*QuerySessionsResponse) XXX_Merge added in v0.6.0 

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

func (*QuerySessionsResponse) XXX_Size added in v0.6.0 

func (m *QuerySessionsResponse) XXX_Size() int

func (*QuerySessionsResponse) XXX_Unmarshal added in v0.6.0 

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

type Session 

type Session struct {
	ID             uint64          `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SubscriptionID uint64          `protobuf:"varint,2,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	NodeAddress    string          `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Address        string          `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	Bandwidth      types.Bandwidth `protobuf:"bytes,5,opt,name=bandwidth,proto3" json:"bandwidth"`
	Duration       time.Duration   `protobuf:"bytes,6,opt,name=duration,proto3,stdduration" json:"duration"`
	InactiveAt     time.Time       `protobuf:"bytes,7,opt,name=inactive_at,json=inactiveAt,proto3,stdtime" json:"inactive_at"`
	Status         types.Status    `protobuf:"varint,8,opt,name=status,proto3,enum=sentinel.types.v1.Status" json:"status,omitempty"`
	StatusAt       time.Time       `protobuf:"bytes,9,opt,name=status_at,json=statusAt,proto3,stdtime" json:"status_at"`
}

func (*Session) Descriptor added in v0.6.0 

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

func (*Session) GetAddress added in v0.6.0 

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

func (*Session) GetNodeAddress added in v0.11.0 

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

func (*Session) Marshal added in v0.6.0 

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

func (*Session) MarshalTo added in v0.6.0 

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

func (*Session) MarshalToSizedBuffer added in v0.6.0 

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

func (*Session) ProtoMessage added in v0.6.0 

func (*Session) ProtoMessage()

func (*Session) Reset added in v0.6.0 

func (m *Session) Reset()

func (*Session) Size added in v0.6.0 

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

func (*Session) String 

func (m *Session) String() string

func (*Session) Unmarshal added in v0.6.0 

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

func (*Session) Validate 

func (m *Session) Validate() error

func (*Session) XXX_DiscardUnknown added in v0.6.0 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal added in v0.6.0 

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

func (*Session) XXX_Merge added in v0.6.0 

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

func (*Session) XXX_Size added in v0.6.0 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal added in v0.6.0 

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

type Sessions 

type Sessions []Session

type UnimplementedMsgServiceServer added in v0.6.0 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgEnd added in v0.6.1 

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

func (*UnimplementedMsgServiceServer) MsgStart added in v0.6.1 

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

func (*UnimplementedMsgServiceServer) MsgUpdateDetails added in v0.11.0 

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

type UnimplementedQueryServiceServer added in v0.6.0 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QueryParams added in v0.6.1 

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

func (*UnimplementedQueryServiceServer) QuerySession added in v0.6.0 

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

func (*UnimplementedQueryServiceServer) QuerySessions added in v0.6.0 

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

func (*UnimplementedQueryServiceServer) QuerySessionsForAccount added in v0.11.0 

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

func (*UnimplementedQueryServiceServer) QuerySessionsForAllocation added in v0.11.0 

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

func (*UnimplementedQueryServiceServer) QuerySessionsForNode added in v0.6.0 

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

func (*UnimplementedQueryServiceServer) QuerySessionsForSubscription added in v0.6.0 

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.