types

package
v0.3.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Aug 10, 2020 License: Apache-2.0 Imports: 8 Imported by: 14

Documentation

Index

Constants

View Source 
const (
	EventTypeSetSessionsCount = "sessions_count"
	EventTypeSetActiveSession = "set_active_session"
	EventTypeUpdateSession    = "update_session"
)
View Source 
const (
	AttributeKeyCount        = "count"
	AttributeKeyID           = "id"
	AttributeKeySubscription = "subscription"
	AttributeKeyNode         = "node"
	AttributeKeyAddress      = "address"
)
View Source 
const (
	ModuleName     = "session"
	ParamsSubspace = ModuleName
	QuerierRoute   = ModuleName
)
View Source 
const (
	QuerySession                 = "query_session"
	QuerySessions                = "query_sessions"
	QuerySessionsForSubscription = "query_sessions_for_subscription"
	QuerySessionsForNode         = "query_sessions_for_node"
	QuerySessionsForAddress      = "query_sessions_for_address"
)
View Source 
const (
	Codespace = sdk.CodespaceType("session")
)
View Source 
const (
	DefaultInactiveDuration = 30 * time.Minute
)

Variables

View Source 
var (
	RouterKey = ModuleName
	StoreKey  = ModuleName
)
View Source 
var (
	SessionsCountKey       = []byte{0x00}
	SessionKeyPrefix       = []byte{0x01}
	ActiveSessionKeyPrefix = []byte{0x02}
)
View Source 
var (
	EventModuleName = sdk.NewEvent(
		sdk.EventTypeMessage,
		sdk.NewAttribute(sdk.AttributeKeyModule, ModuleName),
	)
)
View Source 
var (
	KeyInactiveDuration = []byte("InactiveDuration")
)
View Source 
var (
	ModuleCdc *codec.Codec
)

Functions

func ActiveSessionKey 

func ActiveSessionKey(s uint64, n hub.NodeAddress, a sdk.AccAddress) []byte

func ErrorAddressWasNotAdded 

func ErrorAddressWasNotAdded() sdk.Error

func ErrorInvalidBandwidth 

func ErrorInvalidBandwidth() sdk.Error

func ErrorInvalidDuration 

func ErrorInvalidDuration() sdk.Error

func ErrorInvalidField 

func ErrorInvalidField(v string) sdk.Error

func ErrorInvalidSubscriptionStatus 

func ErrorInvalidSubscriptionStatus() sdk.Error

func ErrorMarshal 

func ErrorMarshal() sdk.Error

func ErrorSubscriptionDoesNotExit 

func ErrorSubscriptionDoesNotExit() sdk.Error

func ErrorUnauthorized 

func ErrorUnauthorized() sdk.Error

func ErrorUnknownMsgType 

func ErrorUnknownMsgType(v string) sdk.Error

func ErrorUnknownQueryType 

func ErrorUnknownQueryType(v string) sdk.Error

func ErrorUnmarshal 

func ErrorUnmarshal() sdk.Error

func ParamsKeyTable 

func ParamsKeyTable() params.KeyTable

func RegisterCodec 

func RegisterCodec(cdc *codec.Codec)

func SessionKey 

func SessionKey(id uint64) []byte

Types

type GenesisState 

type GenesisState struct {
	Sessions Sessions `json:"_"`
	Params   Params   `json:"params"`
}

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

func NewGenesisState 

func NewGenesisState(sessions Sessions, params Params) GenesisState

type MsgUpdate 

type MsgUpdate struct {
	From         hub.NodeAddress `json:"from"`
	Subscription uint64          `json:"subscription"`
	Address      sdk.AccAddress  `json:"address"`
	Duration     time.Duration   `json:"duration"`
	Bandwidth    hub.Bandwidth   `json:"bandwidth"`
}

MsgUpdate is for updating the session of a plan.

func NewMsgUpdate 

func NewMsgUpdate(from hub.NodeAddress, subscription uint64,
	address sdk.AccAddress, duration time.Duration, bandwidth hub.Bandwidth) MsgUpdate

func (MsgUpdate) GetSignBytes 

func (m MsgUpdate) GetSignBytes() []byte

func (MsgUpdate) GetSigners 

func (m MsgUpdate) GetSigners() []sdk.AccAddress

func (MsgUpdate) Route 

func (m MsgUpdate) Route() string

func (MsgUpdate) Type 

func (m MsgUpdate) Type() string

func (MsgUpdate) ValidateBasic 

func (m MsgUpdate) ValidateBasic() sdk.Error

type Params 

type Params struct {
	InactiveDuration time.Duration `json:"inactive_duration"`
}

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(inactiveDuration time.Duration) Params

func (*Params) ParamSetPairs 

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

func (Params) String 

func (p Params) String() string

type QuerySessionParams 

type QuerySessionParams struct {
	ID uint64 `json:"id"`
}

func NewQuerySessionParams 

func NewQuerySessionParams(id uint64) QuerySessionParams

type QuerySessionsForAddressParams 

type QuerySessionsForAddressParams struct {
	Address sdk.AccAddress `json:"address"`
}

func NewQuerySessionsForAddressParams 

func NewQuerySessionsForAddressParams(address sdk.AccAddress) QuerySessionsForAddressParams

type QuerySessionsForNodeParams 

type QuerySessionsForNodeParams struct {
	Address hub.NodeAddress `json:"address"`
}

func NewQuerySessionsForNodeParams 

func NewQuerySessionsForNodeParams(address hub.NodeAddress) QuerySessionsForNodeParams

type QuerySessionsForSubscriptionParams 

type QuerySessionsForSubscriptionParams struct {
	ID uint64 `json:"id"`
}

func NewQuerySessionsForSubscriptionParams 

func NewQuerySessionsForSubscriptionParams(id uint64) QuerySessionsForSubscriptionParams

type Session 

type Session struct {
	ID           uint64          `json:"id"`
	Subscription uint64          `json:"subscription"`
	Node         hub.NodeAddress `json:"node"`
	Address      sdk.AccAddress  `json:"address"`
	Duration     time.Duration   `json:"duration"`
	Bandwidth    hub.Bandwidth   `json:"bandwidth"`
	Status       hub.Status      `json:"status"`
	StatusAt     time.Time       `json:"status_at"`
}

func (Session) String 

func (s Session) String() string

type Sessions 

type Sessions []Session

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.