keeper

Documentation

Index

• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeKey, memKey sdk.StoreKey, ps paramtypes.Subspace, ...) *Keeper
  • func (k Keeper) DowntimeDuration(ctx sdk.Context) (res string)
  • func (k Keeper) GetAllJoin(ctx sdk.Context) (list []types.Join)
  • func (k Keeper) GetAllOracles(ctx sdk.Context) (list []types.Oracle)
  • func (k Keeper) GetJoin(ctx sdk.Context, joinID uint64) (val types.Join, found bool)
  • func (k Keeper) GetNextJoinID(ctx sdk.Context) uint64
  • func (k Keeper) GetOracle(ctx sdk.Context, operatorAddress string) (oracle types.Oracle, found bool)
  • func (k Keeper) GetOracleCount(ctx sdk.Context) uint32
  • func (k Keeper) GetOraclePubKey(ctx sdk.Context) (pubKey types.OraclePubKey, found bool)
  • func (k Keeper) GetParams(ctx sdk.Context) types.Params
  • func (k Keeper) InsertToPendingJoinQueue(ctx sdk.Context, joinID uint64)
  • func (k Keeper) IteratePendingJoinQueue(ctx sdk.Context, cb func(join types.Join) (stop bool))
  • func (k Keeper) IterateVoteForJoins(ctx sdk.Context, joinID uint64, cb func(vote types.VoteForJoin) (stop bool))
  • func (k Keeper) Join(c context.Context, req *types.QueryGetJoinRequest) (*types.QueryGetJoinResponse, error)
  • func (k Keeper) JoinAll(c context.Context, req *types.QueryAllJoinRequest) (*types.QueryAllJoinResponse, error)
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) MaxOracles(ctx sdk.Context) (res uint64)
  • func (k Keeper) Oracle(c context.Context, req *types.QueryGetOracleRequest) (*types.QueryGetOracleResponse, error)
  • func (k Keeper) OracleAll(c context.Context, req *types.QueryAllOracleRequest) (*types.QueryAllOracleResponse, error)
  • func (k Keeper) OraclePubKey(c context.Context, req *types.QueryGetOraclePubKeyRequest) (*types.QueryGetOraclePubKeyResponse, error)
  • func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) PendingJoinQueueIterator(ctx sdk.Context) sdk.Iterator
  • func (k Keeper) RemoveFromPendingJoinQueue(ctx sdk.Context, joinID uint64)
  • func (k Keeper) SetJoin(ctx sdk.Context, join types.Join)
  • func (k Keeper) SetNextJoinID(ctx sdk.Context, id uint64)
  • func (k Keeper) SetOracle(ctx sdk.Context, oracle types.Oracle)
  • func (k Keeper) SetOraclePubKey(ctx sdk.Context, pubKey types.OraclePubKey)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k Keeper) SetVoteForJoin(ctx sdk.Context, vote types.VoteForJoin) error
  • func (k Keeper) SlashFractionDowntime(ctx sdk.Context) (res string)
  • func (k Keeper) SlashFractionWrongVote(ctx sdk.Context) (res string)
  • func (k Keeper) Tally(ctx sdk.Context, join types.Join) (done bool, approved bool, tallyResults types.TallyResult)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

Types

type Keeper

type Keeper struct {
	// contains filtered or unexported fields
}

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey sdk.StoreKey,
	ps paramtypes.Subspace,

	accountKeeper types.AccountKeeper, bankKeeper types.BankKeeper,
) *Keeper

func (Keeper) DowntimeDuration

func (k Keeper) DowntimeDuration(ctx sdk.Context) (res string)

DowntimeDuration returns the DowntimeDuration param

func (Keeper) GetAllJoin

func (k Keeper) GetAllJoin(ctx sdk.Context) (list []types.Join)

GetAllJoin returns all join

func (Keeper) GetAllOracles

func (k Keeper) GetAllOracles(ctx sdk.Context) (list []types.Oracle)

func (Keeper) GetJoin

func (k Keeper) GetJoin(ctx sdk.Context, joinID uint64) (val types.Join, found bool)

GetJoin returns a join from its index

func (Keeper) GetNextJoinID

func (k Keeper) GetNextJoinID(ctx sdk.Context) uint64

func (Keeper) GetOracle

func (k Keeper) GetOracle(ctx sdk.Context, operatorAddress string) (oracle types.Oracle, found bool)

func (Keeper) GetOracleCount

func (k Keeper) GetOracleCount(ctx sdk.Context) uint32

func (Keeper) GetOraclePubKey

func (k Keeper) GetOraclePubKey(ctx sdk.Context) (pubKey types.OraclePubKey, found bool)

func (Keeper) GetParams

func (k Keeper) GetParams(ctx sdk.Context) types.Params

GetParams get all parameters as types.Params

func (Keeper) InsertToPendingJoinQueue

func (k Keeper) InsertToPendingJoinQueue(ctx sdk.Context, joinID uint64)

func (Keeper) IteratePendingJoinQueue

func (k Keeper) IteratePendingJoinQueue(ctx sdk.Context, cb func(join types.Join) (stop bool))

func (Keeper) IterateVoteForJoins

func (k Keeper) IterateVoteForJoins(ctx sdk.Context, joinID uint64, cb func(vote types.VoteForJoin) (stop bool))

func (Keeper) Join

func (k Keeper) Join(c context.Context, req *types.QueryGetJoinRequest) (*types.QueryGetJoinResponse, error)

func (Keeper) JoinAll

func (k Keeper) JoinAll(c context.Context, req *types.QueryAllJoinRequest) (*types.QueryAllJoinResponse, error)

func (Keeper) Logger

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (Keeper) MaxOracles

func (k Keeper) MaxOracles(ctx sdk.Context) (res uint64)

MaxOracles returns the MaxOracles param

func (Keeper) Oracle

func (k Keeper) Oracle(c context.Context, req *types.QueryGetOracleRequest) (*types.QueryGetOracleResponse, error)

func (Keeper) OracleAll

func (k Keeper) OracleAll(c context.Context, req *types.QueryAllOracleRequest) (*types.QueryAllOracleResponse, error)

func (Keeper) OraclePubKey

func (k Keeper) OraclePubKey(c context.Context, req *types.QueryGetOraclePubKeyRequest) (*types.QueryGetOraclePubKeyResponse, error)

func (Keeper) Params

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PendingJoinQueueIterator

func (k Keeper) PendingJoinQueueIterator(ctx sdk.Context) sdk.Iterator

func (Keeper) RemoveFromPendingJoinQueue

func (k Keeper) RemoveFromPendingJoinQueue(ctx sdk.Context, joinID uint64)

func (Keeper) SetJoin

func (k Keeper) SetJoin(ctx sdk.Context, join types.Join)

SetJoin set a specific join in the store from its index

func (Keeper) SetNextJoinID

func (k Keeper) SetNextJoinID(ctx sdk.Context, id uint64)

func (Keeper) SetOracle

func (k Keeper) SetOracle(ctx sdk.Context, oracle types.Oracle)

func (Keeper) SetOraclePubKey

func (k Keeper) SetOraclePubKey(ctx sdk.Context, pubKey types.OraclePubKey)

func (Keeper) SetParams

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams set the params

func (Keeper) SetVoteForJoin

func (k Keeper) SetVoteForJoin(ctx sdk.Context, vote types.VoteForJoin) error

AddVoteForJoin adds a vote on a specific join

func (Keeper) SlashFractionDowntime

func (k Keeper) SlashFractionDowntime(ctx sdk.Context) (res string)

SlashFractionDowntime returns the SlashFractionDowntime param

func (Keeper) SlashFractionWrongVote

func (k Keeper) SlashFractionWrongVote(ctx sdk.Context) (res string)

SlashFractionWrongVote returns the SlashFractionWrongVote param

func (Keeper) Tally

func (k Keeper) Tally(ctx sdk.Context, join types.Join) (done bool, approved bool, tallyResults types.TallyResult)