types

package
v0.34.1 Latest Latest
Warning

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

Go to latest
Published: Jun 9, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	BeansPerFeeUnit           = "feeUnit"
	BeansPerInboundTx         = "inboundTx"
	BeansPerBlockComputeLimit = "blockComputeLimit"
	BeansPerMessage           = "message"
	BeansPerMessageByte       = "messageByte"
	BeansPerMinFeeDebit       = "minFeeDebit"
	BeansPerStorageByte       = "storageByte"
	BeansPerVatCreation       = "vatCreation"
	BeansPerXsnapComputron    = "xsnapComputron"

	// QueueSize keys.
	// Keep up-to-date with updateQueueAllowed() in packanges/cosmic-swingset/src/launch-chain.js
	QueueInbound        = "inbound"
	QueueInboundMempool = "inbound_mempool"
)
View Source
const (
	// module name
	ModuleName = "swingset"

	// StoreKey to be used when creating the KVStore
	StoreKey = ModuleName
)
View Source
const EmptyMailboxValue = `"{\"outbox\":[], \"ack\":0}"`
View Source
const (
	// ProposalTypeCoreEval defines the type for a CoreEvalProposal
	ProposalTypeCoreEval = "CoreEval"
)
View Source
const RouterKey = ModuleName // this was defined in your key.go file

Variables

View Source
var (
	DefaultBeansPerXsnapComputron = sdk.NewUint(100)

	// DefaultBeansPerBlockComputeLimit is how many computron beans we allow
	// before starting a new block.  Some analysis (#3459) suggests this leads to
	// about 2/3rds utilization, based on 5 sec voting time and up to 10 sec of
	// computation.
	DefaultBeansPerBlockComputeLimit = sdk.NewUint(8000000).Mul(DefaultBeansPerXsnapComputron)
	// observed: 0.385 sec
	DefaultBeansPerVatCreation = sdk.NewUint(300000).Mul(DefaultBeansPerXsnapComputron)

	// Fees are denominated in this unit.
	DefaultFeeUnitPrice = sdk.NewCoins(sdk.NewInt64Coin("uist", 1_000_000)) // $1

	// TODO: create the cost model we want, and update these to be more principled.
	// These defaults currently make deploying an ag-solo cost less than $1.00.
	DefaultBeansPerFeeUnit     = sdk.NewUint(1_000_000_000_000)                  // $1
	DefaultBeansPerInboundTx   = DefaultBeansPerFeeUnit.Quo(sdk.NewUint(100))    // $0.01
	DefaultBeansPerMessage     = DefaultBeansPerFeeUnit.Quo(sdk.NewUint(1_000))  // $0.001
	DefaultBeansPerMessageByte = DefaultBeansPerFeeUnit.Quo(sdk.NewUint(50_000)) // $0.00002
	DefaultBeansPerMinFeeDebit = DefaultBeansPerFeeUnit.Quo(sdk.NewUint(5))      // $0.2
	DefaultBeansPerStorageByte = DefaultBeansPerFeeUnit.Quo(sdk.NewUint(500))    // $0.002

	DefaultBootstrapVatConfig = "@agoric/vats/decentral-core-config.json"

	DefaultPowerFlagFees = []PowerFlagFee{
		NewPowerFlagFee("SMART_WALLET", sdk.NewCoins(sdk.NewInt64Coin("ubld", 10_000_000))),
	}

	DefaultInboundQueueMax = int32(1_000)

	DefaultQueueMax = []QueueSize{
		NewQueueSize(QueueInbound, DefaultInboundQueueMax),
	}
)
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 (
	ErrInvalidLengthMsgs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgs = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ParamStoreKeyBeansPerUnit       = []byte("beans_per_unit")
	ParamStoreKeyBootstrapVatConfig = []byte("bootstrap_vat_config")
	ParamStoreKeyFeeUnitPrice       = []byte("fee_unit_price")
	ParamStoreKeyPowerFlagFees      = []byte("power_flag_fees")
	ParamStoreKeyQueueMax           = []byte("queue_max")
)

Parameter keys

View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthSwingset        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSwingset          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSwingset = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (

	// ModuleCdc references the global x/swingset module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/swingset and
	// defined at the application level.
	ModuleAminoCdc = codec.NewAminoCodec(amino)
)

Functions

func Nat

func Nat(num float64) (uint64, error)

FIXME: Should have @endo/nat

func NewCoreEvalProposal

func NewCoreEvalProposal(title, description string, evals []CoreEval) govtypes.Content

NewCoreEvalProposal creates a new core eval proposal.

func NewMailbox

func NewMailbox() *vstoragetypes.Data

Returns a new Mailbox with an empty mailbox

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable returns the parameter key table.

func QueueSizeEntry added in v0.32.0

func QueueSizeEntry(qs []QueueSize, key string) (int32, bool)

func RegisterCodec

func RegisterCodec(cdc *codec.LegacyAmino)

RegisterCodec registers concrete types on the Amino codec

func RegisterInterfaces

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers the x/swingset interfaces types with the interface registry

func RegisterMsgServer

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler

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

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

func RegisterQueryHandlerClient

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint

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

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

func RegisterQueryHandlerServer

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer 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 RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	NewAccountWithAddress(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	SetAccount(ctx sdk.Context, acc authtypes.AccountI)
}

type CoreEval

type CoreEval struct {
	// Grant these JSON-stringified core bootstrap permits to the jsCode, as the
	// `powers` endowment.
	JsonPermits string `protobuf:"bytes,1,opt,name=json_permits,json=jsonPermits,proto3" json:"json_permits,omitempty" yaml:"json_permits"`
	// Evaluate this JavaScript code in a Compartment endowed with `powers` as
	// well as some powerless helpers.
	JsCode string `protobuf:"bytes,2,opt,name=js_code,json=jsCode,proto3" json:"js_code,omitempty" yaml:"js_code"`
}

CoreEval defines an individual SwingSet core evaluation, for use in CoreEvalProposal.

func (*CoreEval) Descriptor

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

func (*CoreEval) GetJsCode

func (m *CoreEval) GetJsCode() string

func (*CoreEval) GetJsonPermits

func (m *CoreEval) GetJsonPermits() string

func (*CoreEval) Marshal

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

func (*CoreEval) MarshalTo

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

func (*CoreEval) MarshalToSizedBuffer

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

func (*CoreEval) ProtoMessage

func (*CoreEval) ProtoMessage()

func (*CoreEval) Reset

func (m *CoreEval) Reset()

func (*CoreEval) Size

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

func (*CoreEval) String

func (m *CoreEval) String() string

func (*CoreEval) Unmarshal

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

func (CoreEval) ValidateBasic

func (ce CoreEval) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*CoreEval) XXX_DiscardUnknown

func (m *CoreEval) XXX_DiscardUnknown()

func (*CoreEval) XXX_Marshal

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

func (*CoreEval) XXX_Merge

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

func (*CoreEval) XXX_Size

func (m *CoreEval) XXX_Size() int

func (*CoreEval) XXX_Unmarshal

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

type CoreEvalProposal

type CoreEvalProposal struct {
	Title       string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Although evals are sequential, they may run concurrently, since they each
	// can return a Promise.
	Evals []CoreEval `protobuf:"bytes,3,rep,name=evals,proto3" json:"evals"`
}

CoreEvalProposal is a gov Content type for evaluating code in the SwingSet core. See `agoric-sdk/packages/vats/src/core/eval.js`.

func (*CoreEvalProposal) Descriptor

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

func (*CoreEvalProposal) GetDescription

func (cep *CoreEvalProposal) GetDescription() string

GetDescription returns the description of a client update proposal.

func (*CoreEvalProposal) GetTitle

func (cep *CoreEvalProposal) GetTitle() string

GetTitle returns the title of a client update proposal.

func (*CoreEvalProposal) Marshal

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

func (*CoreEvalProposal) MarshalTo

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

func (*CoreEvalProposal) MarshalToSizedBuffer

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

func (*CoreEvalProposal) ProposalRoute

func (cep *CoreEvalProposal) ProposalRoute() string

ProposalRoute returns the routing key of a client update proposal.

func (*CoreEvalProposal) ProposalType

func (cep *CoreEvalProposal) ProposalType() string

ProposalType returns the type of a client update proposal.

func (*CoreEvalProposal) ProtoMessage

func (*CoreEvalProposal) ProtoMessage()

func (*CoreEvalProposal) Reset

func (m *CoreEvalProposal) Reset()

func (*CoreEvalProposal) Size

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

func (*CoreEvalProposal) String

func (m *CoreEvalProposal) String() string

func (*CoreEvalProposal) Unmarshal

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

func (*CoreEvalProposal) ValidateBasic

func (cep *CoreEvalProposal) ValidateBasic() error

ValidateBasic runs basic stateless validity checks

func (*CoreEvalProposal) XXX_DiscardUnknown

func (m *CoreEvalProposal) XXX_DiscardUnknown()

func (*CoreEvalProposal) XXX_Marshal

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

func (*CoreEvalProposal) XXX_Merge

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

func (*CoreEvalProposal) XXX_Size

func (m *CoreEvalProposal) XXX_Size() int

func (*CoreEvalProposal) XXX_Unmarshal

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

type Egress

type Egress struct {
	Nickname string                                        `protobuf:"bytes,1,opt,name=nickname,proto3" json:"nickname" yaml:"nickname"`
	Peer     github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=peer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"peer" yaml:"peer"`
	// TODO: Remove these power flags as they are deprecated and have no effect.
	PowerFlags []string `protobuf:"bytes,3,rep,name=power_flags,json=powerFlags,proto3" json:"powerFlags" yaml:"powerFlags"`
}

Egress is the format for a swingset egress.

func NewEgress

func NewEgress(nickname string, peer sdk.AccAddress, powerFlags []string) *Egress

func (*Egress) Descriptor

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

func (*Egress) GetNickname

func (m *Egress) GetNickname() string

func (*Egress) GetPeer

func (*Egress) GetPowerFlags

func (m *Egress) GetPowerFlags() []string

func (*Egress) Marshal

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

func (*Egress) MarshalTo

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

func (*Egress) MarshalToSizedBuffer

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

func (*Egress) ProtoMessage

func (*Egress) ProtoMessage()

func (*Egress) Reset

func (m *Egress) Reset()

func (*Egress) Size

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

func (*Egress) String

func (m *Egress) String() string

func (*Egress) Unmarshal

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

func (*Egress) XXX_DiscardUnknown

func (m *Egress) XXX_DiscardUnknown()

func (*Egress) XXX_Marshal

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

func (*Egress) XXX_Merge

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

func (*Egress) XXX_Size

func (m *Egress) XXX_Size() int

func (*Egress) XXX_Unmarshal

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

type ExtensionSnapshotterArtifactPayload added in v0.34.0

type ExtensionSnapshotterArtifactPayload struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data" yaml:"data"`
}

The payload messages used by swingset state-sync

func (*ExtensionSnapshotterArtifactPayload) Descriptor added in v0.34.0

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

func (*ExtensionSnapshotterArtifactPayload) GetData added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) GetName added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) Marshal added in v0.34.0

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

func (*ExtensionSnapshotterArtifactPayload) MarshalTo added in v0.34.0

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

func (*ExtensionSnapshotterArtifactPayload) MarshalToSizedBuffer added in v0.34.0

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

func (*ExtensionSnapshotterArtifactPayload) ProtoMessage added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) ProtoMessage()

func (*ExtensionSnapshotterArtifactPayload) Reset added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) Size added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) String added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) Unmarshal added in v0.34.0

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

func (*ExtensionSnapshotterArtifactPayload) XXX_DiscardUnknown added in v0.34.0

func (m *ExtensionSnapshotterArtifactPayload) XXX_DiscardUnknown()

func (*ExtensionSnapshotterArtifactPayload) XXX_Marshal added in v0.34.0

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

func (*ExtensionSnapshotterArtifactPayload) XXX_Merge added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) XXX_Size added in v0.34.0

func (*ExtensionSnapshotterArtifactPayload) XXX_Unmarshal added in v0.34.0

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

type GenesisState

type GenesisState struct {
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
	State  State  `protobuf:"bytes,3,opt,name=state,proto3" json:"state"`
}

The initial or exported state.

func (*GenesisState) Descriptor

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

func (*GenesisState) GetParams

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetState added in v0.32.0

func (m *GenesisState) GetState() State

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 Messages

type Messages struct {
	Nums     []uint64
	Messages []string
	Ack      uint64
}

func UnmarshalMessagesJSON

func UnmarshalMessagesJSON(jsonString string) (*Messages, error)

type MsgClient

type MsgClient interface {
	// Install a JavaScript sources bundle on the chain's SwingSet controller.
	InstallBundle(ctx context.Context, in *MsgInstallBundle, opts ...grpc.CallOption) (*MsgInstallBundleResponse, error)
	// Send inbound messages.
	DeliverInbound(ctx context.Context, in *MsgDeliverInbound, opts ...grpc.CallOption) (*MsgDeliverInboundResponse, error)
	// Perform a low-privilege wallet action.
	WalletAction(ctx context.Context, in *MsgWalletAction, opts ...grpc.CallOption) (*MsgWalletActionResponse, error)
	// Perform a wallet action that spends assets.
	WalletSpendAction(ctx context.Context, in *MsgWalletSpendAction, opts ...grpc.CallOption) (*MsgWalletSpendActionResponse, error)
	// Provision a new endpoint.
	Provision(ctx context.Context, in *MsgProvision, opts ...grpc.CallOption) (*MsgProvisionResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgDeliverInbound

type MsgDeliverInbound struct {
	Messages  []string                                      `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages" yaml:"messages"`
	Nums      []uint64                                      `protobuf:"varint,2,rep,packed,name=nums,proto3" json:"nums" yaml:"nums"`
	Ack       uint64                                        `protobuf:"varint,3,opt,name=ack,proto3" json:"ack" yaml:"ack"`
	Submitter github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 133-byte string literal not displayed */
}

MsgDeliverInbound defines an SDK message for delivering an eventual send

func NewMsgDeliverInbound

func NewMsgDeliverInbound(msgs *Messages, submitter sdk.AccAddress) *MsgDeliverInbound

func (MsgDeliverInbound) CheckAdmissibility

func (msg MsgDeliverInbound) CheckAdmissibility(ctx sdk.Context, data interface{}) error

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgDeliverInbound) Descriptor

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

func (*MsgDeliverInbound) GetAck

func (m *MsgDeliverInbound) GetAck() uint64

func (MsgDeliverInbound) GetInboundMsgCount added in v0.34.0

func (msg MsgDeliverInbound) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (*MsgDeliverInbound) GetMessages

func (m *MsgDeliverInbound) GetMessages() []string

func (*MsgDeliverInbound) GetNums

func (m *MsgDeliverInbound) GetNums() []uint64

func (MsgDeliverInbound) GetSignBytes

func (msg MsgDeliverInbound) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgDeliverInbound) GetSigners

func (msg MsgDeliverInbound) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgDeliverInbound) GetSubmitter

func (MsgDeliverInbound) IsHighPriority added in v0.34.0

func (msg MsgDeliverInbound) IsHighPriority(ctx sdk.Context, data interface{}) (bool, error)

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgDeliverInbound) Marshal

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

func (*MsgDeliverInbound) MarshalTo

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

func (*MsgDeliverInbound) MarshalToSizedBuffer

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

func (*MsgDeliverInbound) ProtoMessage

func (*MsgDeliverInbound) ProtoMessage()

func (*MsgDeliverInbound) Reset

func (m *MsgDeliverInbound) Reset()

func (MsgDeliverInbound) Route

func (msg MsgDeliverInbound) Route() string

Route should return the name of the module

func (*MsgDeliverInbound) Size

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

func (*MsgDeliverInbound) String

func (m *MsgDeliverInbound) String() string

func (MsgDeliverInbound) Type

func (msg MsgDeliverInbound) Type() string

Type should return the action

func (*MsgDeliverInbound) Unmarshal

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

func (MsgDeliverInbound) ValidateBasic

func (msg MsgDeliverInbound) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgDeliverInbound) XXX_DiscardUnknown

func (m *MsgDeliverInbound) XXX_DiscardUnknown()

func (*MsgDeliverInbound) XXX_Marshal

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

func (*MsgDeliverInbound) XXX_Merge

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

func (*MsgDeliverInbound) XXX_Size

func (m *MsgDeliverInbound) XXX_Size() int

func (*MsgDeliverInbound) XXX_Unmarshal

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

type MsgDeliverInboundResponse

type MsgDeliverInboundResponse struct {
}

MsgDeliverInboundResponse is an empty reply.

func (*MsgDeliverInboundResponse) Descriptor

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

func (*MsgDeliverInboundResponse) Marshal

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

func (*MsgDeliverInboundResponse) MarshalTo

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

func (*MsgDeliverInboundResponse) MarshalToSizedBuffer

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

func (*MsgDeliverInboundResponse) ProtoMessage

func (*MsgDeliverInboundResponse) ProtoMessage()

func (*MsgDeliverInboundResponse) Reset

func (m *MsgDeliverInboundResponse) Reset()

func (*MsgDeliverInboundResponse) Size

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

func (*MsgDeliverInboundResponse) String

func (m *MsgDeliverInboundResponse) String() string

func (*MsgDeliverInboundResponse) Unmarshal

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

func (*MsgDeliverInboundResponse) XXX_DiscardUnknown

func (m *MsgDeliverInboundResponse) XXX_DiscardUnknown()

func (*MsgDeliverInboundResponse) XXX_Marshal

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

func (*MsgDeliverInboundResponse) XXX_Merge

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

func (*MsgDeliverInboundResponse) XXX_Size

func (m *MsgDeliverInboundResponse) XXX_Size() int

func (*MsgDeliverInboundResponse) XXX_Unmarshal

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

type MsgInstallBundle added in v0.30.0

type MsgInstallBundle struct {
	Bundle    string                                        `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle" yaml:"bundle"`
	Submitter github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 133-byte string literal not displayed */
	// Either bundle or compressed_bundle will be set.
	// Default compression algorithm is gzip.
	CompressedBundle []byte `protobuf:"bytes,3,opt,name=compressed_bundle,json=compressedBundle,proto3" json:"compressedBundle" yaml:"bcompressedBndle"`
	// Size in bytes of uncompression of compressed_bundle.
	UncompressedSize int64 `protobuf:"varint,4,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressedSize"`
}

MsgInstallBundle carries a signed bundle to SwingSet.

func NewMsgInstallBundle added in v0.30.0

func NewMsgInstallBundle(bundleJson string, submitter sdk.AccAddress) *MsgInstallBundle

func (MsgInstallBundle) CheckAdmissibility added in v0.31.0

func (msg MsgInstallBundle) CheckAdmissibility(ctx sdk.Context, data interface{}) error

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgInstallBundle) Compress added in v0.34.0

func (msg *MsgInstallBundle) Compress() error

Compress ensures that a validated bundle has been gzip-compressed.

func (*MsgInstallBundle) Descriptor added in v0.30.0

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

func (MsgInstallBundle) ExpectedUncompressedSize added in v0.34.0

func (msg MsgInstallBundle) ExpectedUncompressedSize() uint64

ExpectedUncompressedSize returns the expected uncompressed size of the bundle.

func (*MsgInstallBundle) GetBundle added in v0.30.0

func (m *MsgInstallBundle) GetBundle() string

func (*MsgInstallBundle) GetCompressedBundle added in v0.34.0

func (m *MsgInstallBundle) GetCompressedBundle() []byte

func (MsgInstallBundle) GetInboundMsgCount added in v0.34.0

func (msg MsgInstallBundle) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (MsgInstallBundle) GetSigners added in v0.30.0

func (msg MsgInstallBundle) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgInstallBundle) GetSubmitter added in v0.30.0

func (*MsgInstallBundle) GetUncompressedSize added in v0.34.0

func (m *MsgInstallBundle) GetUncompressedSize() int64

func (MsgInstallBundle) IsHighPriority added in v0.34.0

func (msg MsgInstallBundle) IsHighPriority(ctx sdk.Context, data interface{}) (bool, error)

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgInstallBundle) Marshal added in v0.30.0

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

func (*MsgInstallBundle) MarshalTo added in v0.30.0

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

func (*MsgInstallBundle) MarshalToSizedBuffer added in v0.30.0

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

func (*MsgInstallBundle) ProtoMessage added in v0.30.0

func (*MsgInstallBundle) ProtoMessage()

func (*MsgInstallBundle) Reset added in v0.30.0

func (m *MsgInstallBundle) Reset()

func (MsgInstallBundle) Route added in v0.30.0

func (msg MsgInstallBundle) Route() string

Route should return the name of the module

func (*MsgInstallBundle) Size added in v0.30.0

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

func (*MsgInstallBundle) String added in v0.30.0

func (m *MsgInstallBundle) String() string

func (MsgInstallBundle) Type added in v0.30.0

func (msg MsgInstallBundle) Type() string

Type should return the action

func (*MsgInstallBundle) Uncompress added in v0.34.0

func (msg *MsgInstallBundle) Uncompress() error

Uncompress ensures that a validated bundle is uncompressed, gzip-uncompressing it if necessary. Returns an error (and ends uncompression early) if the uncompressed size does not match the expected uncompressed size. The successor of the uncompressed size must not overflow.

func (*MsgInstallBundle) Unmarshal added in v0.30.0

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

func (MsgInstallBundle) ValidateBasic added in v0.30.0

func (msg MsgInstallBundle) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgInstallBundle) XXX_DiscardUnknown added in v0.30.0

func (m *MsgInstallBundle) XXX_DiscardUnknown()

func (*MsgInstallBundle) XXX_Marshal added in v0.30.0

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

func (*MsgInstallBundle) XXX_Merge added in v0.30.0

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

func (*MsgInstallBundle) XXX_Size added in v0.30.0

func (m *MsgInstallBundle) XXX_Size() int

func (*MsgInstallBundle) XXX_Unmarshal added in v0.30.0

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

type MsgInstallBundleResponse added in v0.30.0

type MsgInstallBundleResponse struct {
}

MsgInstallBundleResponse is an empty acknowledgement that an install bundle message has been queued for the SwingSet kernel's consideration.

func (*MsgInstallBundleResponse) Descriptor added in v0.30.0

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

func (*MsgInstallBundleResponse) Marshal added in v0.30.0

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

func (*MsgInstallBundleResponse) MarshalTo added in v0.30.0

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

func (*MsgInstallBundleResponse) MarshalToSizedBuffer added in v0.30.0

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

func (*MsgInstallBundleResponse) ProtoMessage added in v0.30.0

func (*MsgInstallBundleResponse) ProtoMessage()

func (*MsgInstallBundleResponse) Reset added in v0.30.0

func (m *MsgInstallBundleResponse) Reset()

func (*MsgInstallBundleResponse) Size added in v0.30.0

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

func (*MsgInstallBundleResponse) String added in v0.30.0

func (m *MsgInstallBundleResponse) String() string

func (*MsgInstallBundleResponse) Unmarshal added in v0.30.0

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

func (*MsgInstallBundleResponse) XXX_DiscardUnknown added in v0.30.0

func (m *MsgInstallBundleResponse) XXX_DiscardUnknown()

func (*MsgInstallBundleResponse) XXX_Marshal added in v0.30.0

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

func (*MsgInstallBundleResponse) XXX_Merge added in v0.30.0

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

func (*MsgInstallBundleResponse) XXX_Size added in v0.30.0

func (m *MsgInstallBundleResponse) XXX_Size() int

func (*MsgInstallBundleResponse) XXX_Unmarshal added in v0.30.0

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

type MsgProvision

type MsgProvision struct {
	Nickname   string                                        `protobuf:"bytes,1,opt,name=nickname,proto3" json:"nickname" yaml:"nickname"`
	Address    github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 127-byte string literal not displayed */
	PowerFlags []string                                      `protobuf:"bytes,3,rep,name=power_flags,json=powerFlags,proto3" json:"powerFlags" yaml:"powerFlags"`
	Submitter  github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 133-byte string literal not displayed */
}

MsgProvision defines an SDK message for provisioning a client to the chain

func NewMsgProvision

func NewMsgProvision(nickname string, addr sdk.AccAddress, powerFlags []string, submitter sdk.AccAddress) *MsgProvision

func (MsgProvision) CheckAdmissibility added in v0.34.0

func (msg MsgProvision) CheckAdmissibility(ctx sdk.Context, data interface{}) error

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgProvision) Descriptor

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

func (*MsgProvision) GetAddress

func (MsgProvision) GetInboundMsgCount added in v0.34.0

func (msg MsgProvision) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (*MsgProvision) GetNickname

func (m *MsgProvision) GetNickname() string

func (*MsgProvision) GetPowerFlags

func (m *MsgProvision) GetPowerFlags() []string

func (MsgProvision) GetSignBytes

func (msg MsgProvision) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgProvision) GetSigners

func (msg MsgProvision) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgProvision) GetSubmitter

func (MsgProvision) IsHighPriority added in v0.34.0

func (msg MsgProvision) IsHighPriority(ctx sdk.Context, data interface{}) (bool, error)

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgProvision) Marshal

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

func (*MsgProvision) MarshalTo

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

func (*MsgProvision) MarshalToSizedBuffer

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

func (*MsgProvision) ProtoMessage

func (*MsgProvision) ProtoMessage()

func (*MsgProvision) Reset

func (m *MsgProvision) Reset()

func (MsgProvision) Route

func (msg MsgProvision) Route() string

Route should return the name of the module

func (*MsgProvision) Size

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

func (*MsgProvision) String

func (m *MsgProvision) String() string

func (MsgProvision) Type

func (msg MsgProvision) Type() string

Type should return the action

func (*MsgProvision) Unmarshal

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

func (MsgProvision) ValidateBasic

func (msg MsgProvision) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgProvision) XXX_DiscardUnknown

func (m *MsgProvision) XXX_DiscardUnknown()

func (*MsgProvision) XXX_Marshal

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

func (*MsgProvision) XXX_Merge

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

func (*MsgProvision) XXX_Size

func (m *MsgProvision) XXX_Size() int

func (*MsgProvision) XXX_Unmarshal

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

type MsgProvisionResponse

type MsgProvisionResponse struct {
}

MsgProvisionResponse is an empty reply.

func (*MsgProvisionResponse) Descriptor

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

func (*MsgProvisionResponse) Marshal

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

func (*MsgProvisionResponse) MarshalTo

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

func (*MsgProvisionResponse) MarshalToSizedBuffer

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

func (*MsgProvisionResponse) ProtoMessage

func (*MsgProvisionResponse) ProtoMessage()

func (*MsgProvisionResponse) Reset

func (m *MsgProvisionResponse) Reset()

func (*MsgProvisionResponse) Size

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

func (*MsgProvisionResponse) String

func (m *MsgProvisionResponse) String() string

func (*MsgProvisionResponse) Unmarshal

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

func (*MsgProvisionResponse) XXX_DiscardUnknown

func (m *MsgProvisionResponse) XXX_DiscardUnknown()

func (*MsgProvisionResponse) XXX_Marshal

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

func (*MsgProvisionResponse) XXX_Merge

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

func (*MsgProvisionResponse) XXX_Size

func (m *MsgProvisionResponse) XXX_Size() int

func (*MsgProvisionResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// Install a JavaScript sources bundle on the chain's SwingSet controller.
	InstallBundle(context.Context, *MsgInstallBundle) (*MsgInstallBundleResponse, error)
	// Send inbound messages.
	DeliverInbound(context.Context, *MsgDeliverInbound) (*MsgDeliverInboundResponse, error)
	// Perform a low-privilege wallet action.
	WalletAction(context.Context, *MsgWalletAction) (*MsgWalletActionResponse, error)
	// Perform a wallet action that spends assets.
	WalletSpendAction(context.Context, *MsgWalletSpendAction) (*MsgWalletSpendActionResponse, error)
	// Provision a new endpoint.
	Provision(context.Context, *MsgProvision) (*MsgProvisionResponse, error)
}

MsgServer is the server API for Msg service.

type MsgWalletAction

type MsgWalletAction struct {
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner" yaml:"owner"`
	// The action to perform, as JSON-stringified marshalled data.
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
}

MsgWalletAction defines an SDK message for the on-chain wallet to perform an action that *does not* spend any assets (other than gas fees/stamps). This message type is typically protected by feegrant budgets.

func NewMsgWalletAction added in v0.30.0

func NewMsgWalletAction(owner sdk.AccAddress, action string) *MsgWalletAction

func (MsgWalletAction) CheckAdmissibility added in v0.31.0

func (msg MsgWalletAction) CheckAdmissibility(ctx sdk.Context, data interface{}) error

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgWalletAction) Descriptor

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

func (*MsgWalletAction) GetAction

func (m *MsgWalletAction) GetAction() string

func (MsgWalletAction) GetInboundMsgCount added in v0.34.0

func (msg MsgWalletAction) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (*MsgWalletAction) GetOwner

func (MsgWalletAction) GetSignBytes added in v0.31.0

func (msg MsgWalletAction) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgWalletAction) GetSigners

func (msg MsgWalletAction) GetSigners() []sdk.AccAddress

func (MsgWalletAction) IsHighPriority added in v0.34.0

func (msg MsgWalletAction) IsHighPriority(ctx sdk.Context, data interface{}) (bool, error)

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgWalletAction) Marshal

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

func (*MsgWalletAction) MarshalTo

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

func (*MsgWalletAction) MarshalToSizedBuffer

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

func (*MsgWalletAction) ProtoMessage

func (*MsgWalletAction) ProtoMessage()

func (*MsgWalletAction) Reset

func (m *MsgWalletAction) Reset()

func (MsgWalletAction) Route added in v0.31.0

func (msg MsgWalletAction) Route() string

Route should return the name of the module

func (*MsgWalletAction) Size

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

func (*MsgWalletAction) String

func (m *MsgWalletAction) String() string

func (MsgWalletAction) Type added in v0.31.0

func (msg MsgWalletAction) Type() string

Type should return the action

func (*MsgWalletAction) Unmarshal

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

func (MsgWalletAction) ValidateBasic

func (msg MsgWalletAction) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgWalletAction) XXX_DiscardUnknown

func (m *MsgWalletAction) XXX_DiscardUnknown()

func (*MsgWalletAction) XXX_Marshal

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

func (*MsgWalletAction) XXX_Merge

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

func (*MsgWalletAction) XXX_Size

func (m *MsgWalletAction) XXX_Size() int

func (*MsgWalletAction) XXX_Unmarshal

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

type MsgWalletActionResponse

type MsgWalletActionResponse struct {
}

MsgWalletActionResponse is an empty reply.

func (*MsgWalletActionResponse) Descriptor

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

func (*MsgWalletActionResponse) Marshal

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

func (*MsgWalletActionResponse) MarshalTo

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

func (*MsgWalletActionResponse) MarshalToSizedBuffer

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

func (*MsgWalletActionResponse) ProtoMessage

func (*MsgWalletActionResponse) ProtoMessage()

func (*MsgWalletActionResponse) Reset

func (m *MsgWalletActionResponse) Reset()

func (*MsgWalletActionResponse) Size

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

func (*MsgWalletActionResponse) String

func (m *MsgWalletActionResponse) String() string

func (*MsgWalletActionResponse) Unmarshal

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

func (*MsgWalletActionResponse) XXX_DiscardUnknown

func (m *MsgWalletActionResponse) XXX_DiscardUnknown()

func (*MsgWalletActionResponse) XXX_Marshal

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

func (*MsgWalletActionResponse) XXX_Merge

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

func (*MsgWalletActionResponse) XXX_Size

func (m *MsgWalletActionResponse) XXX_Size() int

func (*MsgWalletActionResponse) XXX_Unmarshal

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

type MsgWalletSpendAction

type MsgWalletSpendAction struct {
	Owner github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner" yaml:"owner"`
	// The action to perform, as JSON-stringified marshalled data.
	SpendAction string `protobuf:"bytes,2,opt,name=spend_action,json=spendAction,proto3" json:"spend_action,omitempty"`
}

MsgWalletSpendAction defines an SDK message for the on-chain wallet to perform an action that *does spend the owner's assets.* This message type is typically protected by explicit confirmation by the user.

func NewMsgWalletSpendAction added in v0.30.0

func NewMsgWalletSpendAction(owner sdk.AccAddress, spendAction string) *MsgWalletSpendAction

func (MsgWalletSpendAction) CheckAdmissibility added in v0.31.0

func (msg MsgWalletSpendAction) CheckAdmissibility(ctx sdk.Context, data interface{}) error

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgWalletSpendAction) Descriptor

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

func (MsgWalletSpendAction) GetInboundMsgCount added in v0.34.0

func (msg MsgWalletSpendAction) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (*MsgWalletSpendAction) GetOwner

func (MsgWalletSpendAction) GetSignBytes added in v0.31.0

func (msg MsgWalletSpendAction) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgWalletSpendAction) GetSigners

func (msg MsgWalletSpendAction) GetSigners() []sdk.AccAddress

func (*MsgWalletSpendAction) GetSpendAction

func (m *MsgWalletSpendAction) GetSpendAction() string

func (MsgWalletSpendAction) IsHighPriority added in v0.34.0

func (msg MsgWalletSpendAction) IsHighPriority(ctx sdk.Context, data interface{}) (bool, error)

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgWalletSpendAction) Marshal

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

func (*MsgWalletSpendAction) MarshalTo

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

func (*MsgWalletSpendAction) MarshalToSizedBuffer

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

func (*MsgWalletSpendAction) ProtoMessage

func (*MsgWalletSpendAction) ProtoMessage()

func (*MsgWalletSpendAction) Reset

func (m *MsgWalletSpendAction) Reset()

func (MsgWalletSpendAction) Route added in v0.31.0

func (msg MsgWalletSpendAction) Route() string

Route should return the name of the module

func (*MsgWalletSpendAction) Size

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

func (*MsgWalletSpendAction) String

func (m *MsgWalletSpendAction) String() string

func (MsgWalletSpendAction) Type added in v0.31.0

func (msg MsgWalletSpendAction) Type() string

Type should return the action

func (*MsgWalletSpendAction) Unmarshal

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

func (MsgWalletSpendAction) ValidateBasic

func (msg MsgWalletSpendAction) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgWalletSpendAction) XXX_DiscardUnknown

func (m *MsgWalletSpendAction) XXX_DiscardUnknown()

func (*MsgWalletSpendAction) XXX_Marshal

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

func (*MsgWalletSpendAction) XXX_Merge

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

func (*MsgWalletSpendAction) XXX_Size

func (m *MsgWalletSpendAction) XXX_Size() int

func (*MsgWalletSpendAction) XXX_Unmarshal

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

type MsgWalletSpendActionResponse

type MsgWalletSpendActionResponse struct {
}

MsgWalletSpendActionResponse is an empty reply.

func (*MsgWalletSpendActionResponse) Descriptor

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

func (*MsgWalletSpendActionResponse) Marshal

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

func (*MsgWalletSpendActionResponse) MarshalTo

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

func (*MsgWalletSpendActionResponse) MarshalToSizedBuffer

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

func (*MsgWalletSpendActionResponse) ProtoMessage

func (*MsgWalletSpendActionResponse) ProtoMessage()

func (*MsgWalletSpendActionResponse) Reset

func (m *MsgWalletSpendActionResponse) Reset()

func (*MsgWalletSpendActionResponse) Size

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

func (*MsgWalletSpendActionResponse) String

func (*MsgWalletSpendActionResponse) Unmarshal

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

func (*MsgWalletSpendActionResponse) XXX_DiscardUnknown

func (m *MsgWalletSpendActionResponse) XXX_DiscardUnknown()

func (*MsgWalletSpendActionResponse) XXX_Marshal

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

func (*MsgWalletSpendActionResponse) XXX_Merge

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

func (*MsgWalletSpendActionResponse) XXX_Size

func (m *MsgWalletSpendActionResponse) XXX_Size() int

func (*MsgWalletSpendActionResponse) XXX_Unmarshal

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

type Params

type Params struct {
	// Map from unit name to a value in SwingSet "beans".
	// Must not be negative.
	//
	// These values are used by SwingSet to normalize named per-resource charges
	// (maybe rent) in a single Nat usage unit, the "bean".
	//
	// There is no required order to this list of entries, but all the chain
	// nodes must all serialize and deserialize the existing order without
	// permuting it.
	BeansPerUnit []StringBeans `protobuf:"bytes,1,rep,name=beans_per_unit,json=beansPerUnit,proto3" json:"beans_per_unit"`
	// The price in Coins per the unit named "fee".  This value is used by
	// cosmic-swingset JS code to decide how many tokens to charge.
	//
	// cost = beans_used * fee_unit_price / beans_per_unit["fee"]
	FeeUnitPrice github_com_cosmos_cosmos_sdk_types.Coins `` /* 143-byte string literal not displayed */
	// The SwingSet bootstrap vat configuration file.  Not usefully modifiable
	// via governance as it is only referenced by the chain's initial
	// construction.
	BootstrapVatConfig string `protobuf:"bytes,3,opt,name=bootstrap_vat_config,json=bootstrapVatConfig,proto3" json:"bootstrap_vat_config,omitempty"`
	// If the provision submitter doesn't hold a provisionpass, their requested
	// power flags are looked up in this fee menu (first match wins) and the sum
	// is charged.  If any power flag is not found in this menu, the request is
	// rejected.
	PowerFlagFees []PowerFlagFee `protobuf:"bytes,4,rep,name=power_flag_fees,json=powerFlagFees,proto3" json:"power_flag_fees"`
	// Maximum sizes for queues.
	// These values are used by SwingSet to compute how many messages should be
	// accepted in a block.
	//
	// There is no required order to this list of entries, but all the chain
	// nodes must all serialize and deserialize the existing order without
	// permuting it.
	QueueMax []QueueSize `protobuf:"bytes,5,rep,name=queue_max,json=queueMax,proto3" json:"queue_max"`
}

Params are the swingset configuration/governance parameters.

func DefaultParams

func DefaultParams() Params

DefaultParams returns default swingset parameters

func (*Params) Descriptor

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

func (*Params) Equal

func (this *Params) Equal(that interface{}) bool

func (*Params) GetBeansPerUnit

func (m *Params) GetBeansPerUnit() []StringBeans

func (*Params) GetBootstrapVatConfig

func (m *Params) GetBootstrapVatConfig() string

func (*Params) GetFeeUnitPrice

func (m *Params) GetFeeUnitPrice() github_com_cosmos_cosmos_sdk_types.Coins

func (*Params) GetPowerFlagFees added in v0.31.0

func (m *Params) GetPowerFlagFees() []PowerFlagFee

func (*Params) GetQueueMax added in v0.32.0

func (m *Params) GetQueueMax() []QueueSize

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 (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs returns the parameter set pairs.

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 (p Params) String() string

func (*Params) Unmarshal

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

func (Params) ValidateBasic

func (p Params) ValidateBasic() error

ValidateBasic performs basic validation on swingset parameters.

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

type PowerFlagFee struct {
	PowerFlag string                                   `protobuf:"bytes,1,opt,name=power_flag,json=powerFlag,proto3" json:"power_flag,omitempty"`
	Fee       github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=fee,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fee"`
}

Map a provisioning power flag to its corresponding fee.

func NewPowerFlagFee added in v0.31.0

func NewPowerFlagFee(powerFlag string, fee sdk.Coins) PowerFlagFee

func (*PowerFlagFee) Descriptor added in v0.31.0

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

func (*PowerFlagFee) Equal added in v0.31.0

func (this *PowerFlagFee) Equal(that interface{}) bool

func (*PowerFlagFee) GetFee added in v0.31.0

func (*PowerFlagFee) GetPowerFlag added in v0.31.0

func (m *PowerFlagFee) GetPowerFlag() string

func (*PowerFlagFee) Marshal added in v0.31.0

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

func (*PowerFlagFee) MarshalTo added in v0.31.0

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

func (*PowerFlagFee) MarshalToSizedBuffer added in v0.31.0

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

func (*PowerFlagFee) ProtoMessage added in v0.31.0

func (*PowerFlagFee) ProtoMessage()

func (*PowerFlagFee) Reset added in v0.31.0

func (m *PowerFlagFee) Reset()

func (*PowerFlagFee) Size added in v0.31.0

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

func (*PowerFlagFee) String added in v0.31.0

func (m *PowerFlagFee) String() string

func (*PowerFlagFee) Unmarshal added in v0.31.0

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

func (*PowerFlagFee) XXX_DiscardUnknown added in v0.31.0

func (m *PowerFlagFee) XXX_DiscardUnknown()

func (*PowerFlagFee) XXX_Marshal added in v0.31.0

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

func (*PowerFlagFee) XXX_Merge added in v0.31.0

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

func (*PowerFlagFee) XXX_Size added in v0.31.0

func (m *PowerFlagFee) XXX_Size() int

func (*PowerFlagFee) XXX_Unmarshal added in v0.31.0

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

type QueryClient

type QueryClient interface {
	// Params queries params of the swingset module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Egress queries a provisioned egress.
	Egress(ctx context.Context, in *QueryEgressRequest, opts ...grpc.CallOption) (*QueryEgressResponse, error)
	// Return the contents of a peer's outbound mailbox.
	Mailbox(ctx context.Context, in *QueryMailboxRequest, opts ...grpc.CallOption) (*QueryMailboxResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryEgressRequest

type QueryEgressRequest struct {
	Peer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=peer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"peer" yaml:"peer"`
}

QueryEgressRequest is the request type for the Query/Egress RPC method

func (*QueryEgressRequest) Descriptor

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

func (*QueryEgressRequest) GetPeer

func (*QueryEgressRequest) Marshal

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

func (*QueryEgressRequest) MarshalTo

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

func (*QueryEgressRequest) MarshalToSizedBuffer

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

func (*QueryEgressRequest) ProtoMessage

func (*QueryEgressRequest) ProtoMessage()

func (*QueryEgressRequest) Reset

func (m *QueryEgressRequest) Reset()

func (*QueryEgressRequest) Size

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

func (*QueryEgressRequest) String

func (m *QueryEgressRequest) String() string

func (*QueryEgressRequest) Unmarshal

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

func (*QueryEgressRequest) XXX_DiscardUnknown

func (m *QueryEgressRequest) XXX_DiscardUnknown()

func (*QueryEgressRequest) XXX_Marshal

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

func (*QueryEgressRequest) XXX_Merge

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

func (*QueryEgressRequest) XXX_Size

func (m *QueryEgressRequest) XXX_Size() int

func (*QueryEgressRequest) XXX_Unmarshal

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

type QueryEgressResponse

type QueryEgressResponse struct {
	Egress *Egress `protobuf:"bytes,1,opt,name=egress,proto3" json:"egress,omitempty"`
}

QueryEgressResponse is the egress response.

func (*QueryEgressResponse) Descriptor

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

func (*QueryEgressResponse) GetEgress

func (m *QueryEgressResponse) GetEgress() *Egress

func (*QueryEgressResponse) Marshal

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

func (*QueryEgressResponse) MarshalTo

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

func (*QueryEgressResponse) MarshalToSizedBuffer

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

func (*QueryEgressResponse) ProtoMessage

func (*QueryEgressResponse) ProtoMessage()

func (*QueryEgressResponse) Reset

func (m *QueryEgressResponse) Reset()

func (*QueryEgressResponse) Size

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

func (*QueryEgressResponse) String

func (m *QueryEgressResponse) String() string

func (*QueryEgressResponse) Unmarshal

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

func (*QueryEgressResponse) XXX_DiscardUnknown

func (m *QueryEgressResponse) XXX_DiscardUnknown()

func (*QueryEgressResponse) XXX_Marshal

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

func (*QueryEgressResponse) XXX_Merge

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

func (*QueryEgressResponse) XXX_Size

func (m *QueryEgressResponse) XXX_Size() int

func (*QueryEgressResponse) XXX_Unmarshal

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

type QueryMailboxRequest

type QueryMailboxRequest struct {
	Peer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,1,opt,name=peer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"peer" yaml:"peer"`
}

QueryMailboxRequest is the mailbox query.

func (*QueryMailboxRequest) Descriptor

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

func (*QueryMailboxRequest) GetPeer

func (*QueryMailboxRequest) Marshal

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

func (*QueryMailboxRequest) MarshalTo

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

func (*QueryMailboxRequest) MarshalToSizedBuffer

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

func (*QueryMailboxRequest) ProtoMessage

func (*QueryMailboxRequest) ProtoMessage()

func (*QueryMailboxRequest) Reset

func (m *QueryMailboxRequest) Reset()

func (*QueryMailboxRequest) Size

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

func (*QueryMailboxRequest) String

func (m *QueryMailboxRequest) String() string

func (*QueryMailboxRequest) Unmarshal

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

func (*QueryMailboxRequest) XXX_DiscardUnknown

func (m *QueryMailboxRequest) XXX_DiscardUnknown()

func (*QueryMailboxRequest) XXX_Marshal

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

func (*QueryMailboxRequest) XXX_Merge

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

func (*QueryMailboxRequest) XXX_Size

func (m *QueryMailboxRequest) XXX_Size() int

func (*QueryMailboxRequest) XXX_Unmarshal

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

type QueryMailboxResponse

type QueryMailboxResponse struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value" yaml:"value"`
}

QueryMailboxResponse is the mailbox response.

func (*QueryMailboxResponse) Descriptor

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

func (*QueryMailboxResponse) GetValue

func (m *QueryMailboxResponse) GetValue() string

func (*QueryMailboxResponse) Marshal

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

func (*QueryMailboxResponse) MarshalTo

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

func (*QueryMailboxResponse) MarshalToSizedBuffer

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

func (*QueryMailboxResponse) ProtoMessage

func (*QueryMailboxResponse) ProtoMessage()

func (*QueryMailboxResponse) Reset

func (m *QueryMailboxResponse) Reset()

func (*QueryMailboxResponse) Size

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

func (*QueryMailboxResponse) String

func (m *QueryMailboxResponse) String() string

func (*QueryMailboxResponse) Unmarshal

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

func (*QueryMailboxResponse) XXX_DiscardUnknown

func (m *QueryMailboxResponse) XXX_DiscardUnknown()

func (*QueryMailboxResponse) XXX_Marshal

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

func (*QueryMailboxResponse) XXX_Merge

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

func (*QueryMailboxResponse) XXX_Size

func (m *QueryMailboxResponse) XXX_Size() int

func (*QueryMailboxResponse) XXX_Unmarshal

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

type QueryParamsRequest

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

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 {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor

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

func (*QueryParamsResponse) GetParams

func (m *QueryParamsResponse) GetParams() Params

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 QueryServer

type QueryServer interface {
	// Params queries params of the swingset module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Egress queries a provisioned egress.
	Egress(context.Context, *QueryEgressRequest) (*QueryEgressResponse, error)
	// Return the contents of a peer's outbound mailbox.
	Mailbox(context.Context, *QueryMailboxRequest) (*QueryMailboxResponse, error)
}

QueryServer is the server API for Query service.

type QueueSize added in v0.32.0

type QueueSize struct {
	// What the size is for.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The actual size value.
	Size_ int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
}

Map element of a string key to a size.

func NewQueueSize added in v0.32.0

func NewQueueSize(key string, sz int32) QueueSize

func (*QueueSize) Descriptor added in v0.32.0

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

func (*QueueSize) Equal added in v0.32.0

func (this *QueueSize) Equal(that interface{}) bool

func (*QueueSize) GetKey added in v0.32.0

func (m *QueueSize) GetKey() string

func (*QueueSize) GetSize_ added in v0.32.0

func (m *QueueSize) GetSize_() int32

func (*QueueSize) Marshal added in v0.32.0

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

func (*QueueSize) MarshalTo added in v0.32.0

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

func (*QueueSize) MarshalToSizedBuffer added in v0.32.0

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

func (*QueueSize) ProtoMessage added in v0.32.0

func (*QueueSize) ProtoMessage()

func (*QueueSize) Reset added in v0.32.0

func (m *QueueSize) Reset()

func (*QueueSize) Size added in v0.32.0

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

func (*QueueSize) String added in v0.32.0

func (m *QueueSize) String() string

func (*QueueSize) Unmarshal added in v0.32.0

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

func (*QueueSize) XXX_DiscardUnknown added in v0.32.0

func (m *QueueSize) XXX_DiscardUnknown()

func (*QueueSize) XXX_Marshal added in v0.32.0

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

func (*QueueSize) XXX_Merge added in v0.32.0

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

func (*QueueSize) XXX_Size added in v0.32.0

func (m *QueueSize) XXX_Size() int

func (*QueueSize) XXX_Unmarshal added in v0.32.0

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

type State added in v0.32.0

type State struct {
	// The allowed number of items to add to queues, as determined by SwingSet.
	// Transactions which attempt to enqueue more should be rejected.
	QueueAllowed []QueueSize `protobuf:"bytes,1,rep,name=queue_allowed,json=queueAllowed,proto3" json:"queue_allowed"`
}

The current state of the module.

func (*State) Descriptor added in v0.32.0

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

func (*State) GetQueueAllowed added in v0.32.0

func (m *State) GetQueueAllowed() []QueueSize

func (*State) Marshal added in v0.32.0

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

func (*State) MarshalTo added in v0.32.0

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

func (*State) MarshalToSizedBuffer added in v0.32.0

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

func (*State) ProtoMessage added in v0.32.0

func (*State) ProtoMessage()

func (*State) Reset added in v0.32.0

func (m *State) Reset()

func (*State) Size added in v0.32.0

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

func (*State) String added in v0.32.0

func (m *State) String() string

func (*State) Unmarshal added in v0.32.0

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

func (*State) XXX_DiscardUnknown added in v0.32.0

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal added in v0.32.0

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

func (*State) XXX_Merge added in v0.32.0

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

func (*State) XXX_Size added in v0.32.0

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal added in v0.32.0

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

type StringBeans

type StringBeans struct {
	// What the beans are for.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The actual bean value.
	Beans github_com_cosmos_cosmos_sdk_types.Uint `protobuf:"bytes,2,opt,name=beans,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Uint" json:"beans"`
}

Map element of a string key to a Nat bean count.

func DefaultBeansPerUnit

func DefaultBeansPerUnit() []StringBeans

move DefaultBeansPerUnit to a function to allow for boot overriding of the Default params

func NewStringBeans

func NewStringBeans(key string, beans sdk.Uint) StringBeans

func (*StringBeans) Descriptor

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

func (*StringBeans) Equal

func (this *StringBeans) Equal(that interface{}) bool

func (*StringBeans) GetKey

func (m *StringBeans) GetKey() string

func (*StringBeans) Marshal

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

func (*StringBeans) MarshalTo

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

func (*StringBeans) MarshalToSizedBuffer

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

func (*StringBeans) ProtoMessage

func (*StringBeans) ProtoMessage()

func (*StringBeans) Reset

func (m *StringBeans) Reset()

func (*StringBeans) Size

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

func (*StringBeans) String

func (m *StringBeans) String() string

func (*StringBeans) Unmarshal

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

func (*StringBeans) XXX_DiscardUnknown

func (m *StringBeans) XXX_DiscardUnknown()

func (*StringBeans) XXX_Marshal

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

func (*StringBeans) XXX_Merge

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

func (*StringBeans) XXX_Size

func (m *StringBeans) XXX_Size() int

func (*StringBeans) XXX_Unmarshal

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

type SwingSetKeeper

type SwingSetKeeper interface {
	GetBeansPerUnit(ctx sdk.Context) map[string]sdk.Uint
	ChargeBeans(ctx sdk.Context, addr sdk.AccAddress, beans sdk.Uint) error
	IsHighPriorityAddress(ctx sdk.Context, addr sdk.AccAddress) (bool, error)
}

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) DeliverInbound

func (*UnimplementedMsgServer) InstallBundle added in v0.30.0

func (*UnimplementedMsgServer) Provision

func (*UnimplementedMsgServer) WalletAction

func (*UnimplementedMsgServer) WalletSpendAction

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Egress

func (*UnimplementedQueryServer) Mailbox

func (*UnimplementedQueryServer) Params

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL