keeper

func (Keeper) AcknowledgeBridges ¶

func (k Keeper) AcknowledgeBridges(
	ctx sdk.Context,
	bridgeEvents []types.BridgeEvent,
) (err error)

AcknowledgeBridges acknowledges a list of bridge events and returns an error if any of following - bridging is disabled. - fails to delay a `MsgCompleteBridge` for any bridge event. - fails to update `AcknowledgedEventInfo` in state.

func (Keeper) AcknowledgedEventInfo ¶

func (k Keeper) AcknowledgedEventInfo(
	c context.Context,
	req *types.QueryAcknowledgedEventInfoRequest,
) (
	*types.QueryAcknowledgedEventInfoResponse,
	error,
)

AcknowledgedEventInfo processes a query request/response for `AcknowledgedEventInfo` from state.

func (Keeper) CompleteBridge ¶

func (k Keeper) CompleteBridge(
	ctx sdk.Context,
	bridge types.BridgeEvent,
) (err error)

`CompleteBridge` processes a bridge event by transferring the specified coin from bridge module account to the given address. The id of the bridge is not validated as it should have already been validated by AcknowledgeBridges.

func (Keeper) DelayedCompleteBridgeMessages ¶

func (k Keeper) DelayedCompleteBridgeMessages(
	c context.Context,
	req *types.QueryDelayedCompleteBridgeMessagesRequest,
) (
	*types.QueryDelayedCompleteBridgeMessagesResponse,
	error,
)

func (Keeper) EventParams ¶

func (k Keeper) EventParams(
	c context.Context,
	req *types.QueryEventParamsRequest,
) (
	*types.QueryEventParamsResponse,
	error,
)

EventParams processes a query request/response for the EventParams from state.

func (Keeper) GetAcknowledgeBridges ¶

func (k Keeper) GetAcknowledgeBridges(
	ctx sdk.Context,
	blockTimestamp time.Time,
) (msg *types.MsgAcknowledgeBridges)

GetAcknowledgeBridges returns a `MsgAcknowledgeBridges` for recognized but not-yet-acknowledged bridge events, up to a maximum number of `ProposeParams.MaxBridgesPerBlock`.

func (Keeper) GetAcknowledgedEventInfo ¶

func (k Keeper) GetAcknowledgedEventInfo(
	ctx sdk.Context,
) (acknowledgedEventInfo types.BridgeEventInfo)

GetAcknowledgedEventInfo returns `AcknowledgedEventInfo` from state.

func (Keeper) GetBridgeEventFromServer ¶

func (k Keeper) GetBridgeEventFromServer(ctx sdk.Context, id uint32) (event types.BridgeEvent, found bool)

`GetBridgeEventFromServer` returns the bridge event with the given id from the server. `found` is false if the event is not found.

func (Keeper) GetDelayedCompleteBridgeMessages ¶

func (k Keeper) GetDelayedCompleteBridgeMessages(
	ctx sdk.Context,
	address string,
) (
	messages []types.DelayedCompleteBridgeMessage,
)

`GetDelayedCompleteBridgeMessages` returns all delayed complete bridge messages and corresponding block heights at which they'll execute. If `address` is given, only returns messages for that address.

func (Keeper) GetEventParams ¶

func (k Keeper) GetEventParams(
	ctx sdk.Context,
) (
	params types.EventParams,
)

GetEventParams returns the EventParams in state.

func (Keeper) GetProposeParams ¶

func (k Keeper) GetProposeParams(
	ctx sdk.Context,
) (
	params types.ProposeParams,
)

GetProposeParams returns the ProposeParams in state.

func (Keeper) GetRecognizedEventInfo ¶

func (k Keeper) GetRecognizedEventInfo(
	ctx sdk.Context,
) (recognizedEventInfo types.BridgeEventInfo)

GetRecognizedEventInfo returns `RecognizedEventInfo` from `BridgeEventManager`. This has the next event id that has not yet been recognized by this node’s daemon. This also has the height of the highest Ethereum block at which a bridge event was recognized. These values are not in-consensus.

func (Keeper) GetSafetyParams ¶

func (k Keeper) GetSafetyParams(
	ctx sdk.Context,
) (
	params types.SafetyParams,
)

GetSafetyParams returns the SafetyParams in state.

func (Keeper) HasAuthority ¶

func (k Keeper) HasAuthority(authority string) bool

HasAuthority returns whether `authority` exists in `k.authorities`.

func (Keeper) InitializeForGenesis ¶

func (k Keeper) InitializeForGenesis(ctx sdk.Context)

func (Keeper) Logger ¶

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

func (Keeper) ProposeParams ¶

func (k Keeper) ProposeParams(
	c context.Context,
	req *types.QueryProposeParamsRequest,
) (
	*types.QueryProposeParamsResponse,
	error,
)

ProposeParams processes a query request/response for the ProposeParams from state.

func (Keeper) RecognizedEventInfo ¶

func (k Keeper) RecognizedEventInfo(
	c context.Context,
	req *types.QueryRecognizedEventInfoRequest,
) (
	*types.QueryRecognizedEventInfoResponse,
	error,
)

RecognizedEventInfo processes a query request/response for the following that has a greater `NextId`: - the `AcknowledgedEventInfo` from state - the `RecognizedEventInfo` from memory Since RecognizedEventInfo is from memory, the value is not deterministic based on state and therefore may be different between nodes.

func (Keeper) SafetyParams ¶

func (k Keeper) SafetyParams(
	c context.Context,
	req *types.QuerySafetyParamsRequest,
) (
	*types.QuerySafetyParamsResponse,
	error,
)

SafetyParams processes a query request/response for the SafetyParams from state.

func (Keeper) SetAcknowledgedEventInfo ¶

func (k Keeper) SetAcknowledgedEventInfo(
	ctx sdk.Context,
	acknowledgedEventInfo types.BridgeEventInfo,
) error

SetAcknowledgedEventInfo sets `AcknowledgedEventInfo` in state.

func (Keeper) UpdateEventParams ¶

func (k Keeper) UpdateEventParams(
	ctx sdk.Context,
	params types.EventParams,
) error

UpdateEventParams updates the EventParams in state. Returns an error iff validation fails.

func (Keeper) UpdateProposeParams ¶

func (k Keeper) UpdateProposeParams(
	ctx sdk.Context,
	params types.ProposeParams,
) error

UpdateProposeParams updates the ProposeParams in state. Returns an error iff validation fails.

func (Keeper) UpdateSafetyParams ¶

func (k Keeper) UpdateSafetyParams(
	ctx sdk.Context,
	params types.SafetyParams,
) error

UpdateSafetyParams updates the SafetyParams in state. Returns an error iff validation fails.