types

package
v0.0.0-...-4833f45 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2026 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	BeansPerBlockComputeLimit = "blockComputeLimit"
	BeansPerVatCreation       = "vatCreation"
	BeansPerXsnapComputron    = "xsnapComputron"

	BeansPerFeeUnit              = "feeUnit"
	BeansPerInboundTx            = "inboundTx"
	BeansPerMessage              = "message"
	BeansPerMessageByte          = "messageByte"
	BeansPerMinFeeDebit          = "minFeeDebit"
	BeansPerStorageByte          = "storageByte"
	BeansPerSmartWalletProvision = "smartWalletProvision"

	// PowerFlags.
	PowerFlagSmartWallet = "SMART_WALLET"

	// QueueSize keys.
	// Keep up-to-date with updateQueueAllowed() in packages/cosmic-swingset/src/launch-chain.js
	QueueInbound        = "inbound"
	QueueInboundMempool = "inbound_mempool"

	// Vat cleanup budget keys.
	// Keep up-to-date with CleanupBudget in packages/cosmic-swingset/src/launch-chain.js
	VatCleanupDefault     = "default"
	VatCleanupExports     = "exports"
	VatCleanupImports     = "imports"
	VatCleanupPromises    = "promises"
	VatCleanupKv          = "kv"
	VatCleanupSnapshots   = "snapshots"
	VatCleanupTranscripts = "transcripts"
)
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 = sdkmath.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 = sdkmath.NewUint(8000000).Mul(DefaultBeansPerXsnapComputron)
	// observed: 0.385 sec
	DefaultBeansPerVatCreation = sdkmath.NewUint(300000).Mul(DefaultBeansPerXsnapComputron)

	// Fees are represented as integer "beans", where each bean is a uniform
	// fraction of this `fee_unit_price` as controlled by the below
	// `beans_per_unit` "feeUnit".
	// TODO: create the cost model we want, and update these to be more principled.
	DefaultFeeUnitPrice = sdk.NewCoins(sdk.NewInt64Coin("ubld", 1_000_000)) // 1 BLD

	// The count of "beans" into which `fee_unit_price` is divided.
	// Larger numbers make for smaller beans, and we expect values to be rather
	// large for representing fees precisely in beans that each approximate
	// a "picoUSD"--one trillionth of a USD.
	DefaultBeansPerFeeUnit = sdkmath.NewUint(1_000_000_000_000) // 1e12 (assumes $1 per BLD)

	DefaultBeansPerInboundTx            = DefaultBeansPerFeeUnit.Quo(sdkmath.NewUint(100))    //  10e09, ~$0.01
	DefaultBeansPerMessage              = DefaultBeansPerFeeUnit.Quo(sdkmath.NewUint(1_000))  //   1e09, ~$0.001
	DefaultBeansPerMessageByte          = DefaultBeansPerFeeUnit.Quo(sdkmath.NewUint(50_000)) //  20e06, ~$0.00002
	DefaultBeansPerMinFeeDebit          = DefaultBeansPerFeeUnit.Quo(sdkmath.NewUint(5))      // 200e09, ~$0.2
	DefaultBeansPerStorageByte          = DefaultBeansPerFeeUnit.Quo(sdkmath.NewUint(500))    //   2e09, ~$0.002
	DefaultBeansPerSmartWalletProvision = DefaultBeansPerFeeUnit                              //   1e12, ~$1

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

	DefaultInstallationDeadlineBlocks  int64 = -1           // unlimited
	DefaultInstallationDeadlineSeconds int64 = 24 * 60 * 60 // 24 hours

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

	DefaultInboundQueueMax = int32(1_000)
	DefaultQueueMax        = []QueueSize{
		NewQueueSize(QueueInbound, DefaultInboundQueueMax),
	}

	DefaultVatCleanupDefault = sdkmath.NewUint(5)
	// DefaultVatCleanupExports     = DefaultVatCleanupDefault
	// DefaultVatCleanupImports     = DefaultVatCleanupDefault
	// DefaultVatCleanupPromises    = DefaultVatCleanupDefault
	DefaultVatCleanupKv = sdkmath.NewUint(50)
	// DefaultVatCleanupSnapshots   = DefaultVatCleanupDefault
	// DefaultVatCleanupTranscripts = DefaultVatCleanupDefault
	DefaultVatCleanupBudget = []UintMapEntry{
		UintMapEntry{VatCleanupDefault, DefaultVatCleanupDefault},

		UintMapEntry{VatCleanupKv, DefaultVatCleanupKv},
	}

	// DefaultBundleUncompressedSizeLimitBytes is the (exclusive) limit on uncompressed bundle size.
	// We must ensure there is an exclusive int64 limit in order to detect an underflow.
	// Bundles must be strictly less than this size.
	DefaultBundleUncompressedSizeLimitBytes int64 = 10_000_000
	DefaultChunkSizeLimitBytes              int64 = 490_000
)
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")
	ParamStoreKeyVatCleanupBudget                 = []byte("vat_cleanup_budget")
	ParamStoreKeyBundleUncompressedSizeLimitBytes = []byte("bundle_uncompressed_size_limit_bytes")
	ParamStoreKeyChunkSizeLimitBytes              = []byte("chunk_size_limit_bytes")
	ParamStoreKeyInstallationDeadlineSeconds      = []byte("installation_deadline_seconds")
	ParamStoreKeyInstallationDeadlineBlocks       = []byte("installation_deadline_blocks")
)

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 ChunkState_name = map[int32]string{
	0: "CHUNK_STATE_UNSPECIFIED",
	1: "CHUNK_STATE_IN_FLIGHT",
	2: "CHUNK_STATE_RECEIVED",
	3: "CHUNK_STATE_PROCESSED",
}
View Source 
var ChunkState_value = map[string]int32{
	"CHUNK_STATE_UNSPECIFIED": 0,
	"CHUNK_STATE_IN_FLIGHT":   1,
	"CHUNK_STATE_RECEIVED":    2,
	"CHUNK_STATE_PROCESSED":   3,
}
View Source 
var IsHexBytes = regexp.MustCompile(`^([0-9a-fA-F]{2})+$`).MatchString

IsHexBytes defines a regular expression to check if the string represents only hexadecimal bytes.

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)
)
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func DefineCustomGetSigners 

func DefineCustomGetSigners(options *signing.Options)

func MaxArtifactChunksCount 

func MaxArtifactChunksCount(bundleUncompressedSizeLimitBytes int64, chunkSizeLimitBytes int64) int64

MaxArtifactChunkCount derives the maximum number of entries in an artifact manifest

func Nat 

func Nat(num float64) (uint64, error)

Nat is analogous to @endo/nat https://github.com/endojs/endo/blob/master/packages/nat

func NewCoreEvalProposal 

func NewCoreEvalProposal(title, description string, evals []CoreEval) govv1beta1.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 

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 context.Context, addr sdk.AccAddress) sdk.AccountI
	NewAccountWithAddress(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	SetAccount(ctx context.Context, acc sdk.AccountI)
}

AccountKeeper defines the expected interface for the auth module keeper

type ActionContext 

type ActionContext struct {
	// The block height in which the corresponding action was enqueued
	BlockHeight int64 `json:"blockHeight"`
	// The hash of the cosmos transaction that included the message
	// If the action didn't result from a transaction message, a substitute value
	// may be used. For example the VBANK_BALANCE_UPDATE actions use `x/vbank`.
	TxHash string `json:"txHash"`
	// The index of the message within the transaction. If the action didn't
	// result from a cosmos transaction, a number should be chosen to make the
	// actionContext unique. (for example a counter per block and source module).
	MsgIdx int `json:"msgIdx"`
}

Contextual information about the message source of an action on an inbound queue. This context should be unique per inboundQueueRecord.

type BankKeeper 

type BankKeeper interface {
	GetAllBalances(ctx context.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromAccountToModule(ctx context.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected interface for the bank module keeper

type ChunkInfo 

type ChunkInfo struct {
	// The SHA-512 hash of the chunk contents.
	Sha512 string `protobuf:"bytes,1,opt,name=sha512,proto3" json:"sha512" yaml:"sha512"`
	// The chunk size in bytes.
	SizeBytes uint64 `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes" yaml:"size_bytes"`
	// The current state of the chunk.
	State ChunkState `protobuf:"varint,3,opt,name=state,proto3,enum=agoric.swingset.ChunkState" json:"state" yaml:"state"`
}

Information about a chunk of an artifact.

func (*ChunkInfo) Descriptor 

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

func (*ChunkInfo) GetSha512 

func (m *ChunkInfo) GetSha512() string

func (*ChunkInfo) GetSizeBytes 

func (m *ChunkInfo) GetSizeBytes() uint64

func (*ChunkInfo) GetState 

func (m *ChunkInfo) GetState() ChunkState

func (*ChunkInfo) Marshal 

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

func (*ChunkInfo) MarshalTo 

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

func (*ChunkInfo) MarshalToSizedBuffer 

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

func (*ChunkInfo) ProtoMessage 

func (*ChunkInfo) ProtoMessage()

func (*ChunkInfo) Reset 

func (m *ChunkInfo) Reset()

func (*ChunkInfo) Size 

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

func (*ChunkInfo) String 

func (m *ChunkInfo) String() string

func (*ChunkInfo) Unmarshal 

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

func (*ChunkInfo) XXX_DiscardUnknown 

func (m *ChunkInfo) XXX_DiscardUnknown()

func (*ChunkInfo) XXX_Marshal 

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

func (*ChunkInfo) XXX_Merge 

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

func (*ChunkInfo) XXX_Size 

func (m *ChunkInfo) XXX_Size() int

func (*ChunkInfo) XXX_Unmarshal 

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

type ChunkState 

type ChunkState int32

Current state of this chunk. 

const (
	// Unknown state.
	ChunkState_CHUNK_STATE_UNSPECIFIED ChunkState = 0
	// The chunk is still in-flight.
	ChunkState_CHUNK_STATE_IN_FLIGHT ChunkState = 1
	// The chunk has been received.
	ChunkState_CHUNK_STATE_RECEIVED ChunkState = 2
	// The chunk has been processed.
	ChunkState_CHUNK_STATE_PROCESSED ChunkState = 3
)

func (ChunkState) EnumDescriptor 

func (ChunkState) EnumDescriptor() ([]byte, []int)

func (ChunkState) String 

func (x ChunkState) String() string

type ChunkedArtifact 

type ChunkedArtifact struct {
	// The SHA-512 hash of the entire artifact's contents.
	Sha512 string `protobuf:"bytes,1,opt,name=sha512,proto3" json:"sha512" yaml:"sha512"`
	// The size of the final artifact in bytes.
	SizeBytes uint64 `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes" yaml:"size_bytes"`
	// Information about the chunks that will be concatenated to form this
	// artifact.
	Chunks []*ChunkInfo `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks" yaml:"chunks"`
}

ChunkedArtifact is the manifest for an artifact that is submitted across multiple transactions, in chunks, as when using InstallBundle to submit chunks.

func (*ChunkedArtifact) Descriptor 

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

func (*ChunkedArtifact) GetChunks 

func (m *ChunkedArtifact) GetChunks() []*ChunkInfo

func (*ChunkedArtifact) GetSha512 

func (m *ChunkedArtifact) GetSha512() string

func (*ChunkedArtifact) GetSizeBytes 

func (m *ChunkedArtifact) GetSizeBytes() uint64

func (*ChunkedArtifact) Marshal 

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

func (*ChunkedArtifact) MarshalTo 

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

func (*ChunkedArtifact) MarshalToSizedBuffer 

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

func (*ChunkedArtifact) ProtoMessage 

func (*ChunkedArtifact) ProtoMessage()

func (*ChunkedArtifact) Reset 

func (m *ChunkedArtifact) Reset()

func (*ChunkedArtifact) Size 

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

func (*ChunkedArtifact) String 

func (m *ChunkedArtifact) String() string

func (*ChunkedArtifact) Unmarshal 

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

func (ChunkedArtifact) ValidateBasic 

func (bc ChunkedArtifact) ValidateBasic() error

func (*ChunkedArtifact) XXX_DiscardUnknown 

func (m *ChunkedArtifact) XXX_DiscardUnknown()

func (*ChunkedArtifact) XXX_Marshal 

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

func (*ChunkedArtifact) XXX_Merge 

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

func (*ChunkedArtifact) XXX_Size 

func (m *ChunkedArtifact) XXX_Size() int

func (*ChunkedArtifact) XXX_Unmarshal 

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

type ChunkedArtifactNode 

type ChunkedArtifactNode struct {
	// The id of the pending bundle installation.
	ChunkedArtifactId uint64 `` /* 128-byte string literal not displayed */
	// The ID of the next chunked artifact in the list.
	// A value of 0 indicates the end of the list.
	NextId uint64 `protobuf:"varint,2,opt,name=next_id,json=nextId,proto3" json:"nextId" yaml:"nextId"`
	// The ID of the previous chunked artifact in the list.
	// A value of 0 indicates the start of the list.
	PrevId uint64 `protobuf:"varint,3,opt,name=prev_id,json=prevId,proto3" json:"prevId" yaml:"prevId"`
	// The time at which the pending installation began, in UNIX epoch seconds.
	StartTimeUnix int64 `protobuf:"varint,4,opt,name=start_time_unix,json=startTimeUnix,proto3" json:"startTimeUnix" yaml:"startTimeUnix"`
	// The block at which the pending installation began.
	StartBlockHeight int64 `protobuf:"varint,5,opt,name=start_block_height,json=startBlockHeight,proto3" json:"startBlockHeight" yaml:"startBlockHeight"`
}

A node in a doubly-linked-list of chunked artifacts, as used for chunked bundle installation, in order of ascending block time. This list is not circular and has no sentinel head node; the start and end are indicated by prev_id/next_id being 0. The keeper uses this to expediently expire stale incomplete artifacts.

func (*ChunkedArtifactNode) Descriptor 

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

func (*ChunkedArtifactNode) GetChunkedArtifactId 

func (m *ChunkedArtifactNode) GetChunkedArtifactId() uint64

func (*ChunkedArtifactNode) GetNextId 

func (m *ChunkedArtifactNode) GetNextId() uint64

func (*ChunkedArtifactNode) GetPrevId 

func (m *ChunkedArtifactNode) GetPrevId() uint64

func (*ChunkedArtifactNode) GetStartBlockHeight 

func (m *ChunkedArtifactNode) GetStartBlockHeight() int64

func (*ChunkedArtifactNode) GetStartTimeUnix 

func (m *ChunkedArtifactNode) GetStartTimeUnix() int64

func (*ChunkedArtifactNode) Marshal 

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

func (*ChunkedArtifactNode) MarshalTo 

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

func (*ChunkedArtifactNode) MarshalToSizedBuffer 

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

func (*ChunkedArtifactNode) ProtoMessage 

func (*ChunkedArtifactNode) ProtoMessage()

func (*ChunkedArtifactNode) Reset 

func (m *ChunkedArtifactNode) Reset()

func (*ChunkedArtifactNode) Size 

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

func (*ChunkedArtifactNode) String 

func (m *ChunkedArtifactNode) String() string

func (*ChunkedArtifactNode) Unmarshal 

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

func (*ChunkedArtifactNode) XXX_DiscardUnknown 

func (m *ChunkedArtifactNode) XXX_DiscardUnknown()

func (*ChunkedArtifactNode) XXX_Marshal 

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

func (*ChunkedArtifactNode) XXX_Merge 

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

func (*ChunkedArtifactNode) XXX_Size 

func (m *ChunkedArtifactNode) XXX_Size() int

func (*ChunkedArtifactNode) XXX_Unmarshal 

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

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 `bridgeCoreEval` in agoric-sdk packages/vats/src/core/chain-behaviors.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 (m *Egress) GetPeer() github_com_cosmos_cosmos_sdk_types.AccAddress

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 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"`
	SwingStoreExportData     []*SwingStoreExportDataEntry `protobuf:"bytes,4,rep,name=swing_store_export_data,json=swingStoreExportData,proto3" json:"swingStoreExportData"`
	SwingStoreExportDataHash string                       `protobuf:"bytes,5,opt,name=swing_store_export_data_hash,json=swingStoreExportDataHash,proto3" json:"swingStoreExportDataHash"`
}

The initial or exported state.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetState 

func (m *GenesisState) GetState() State

func (*GenesisState) GetSwingStoreExportData 

func (m *GenesisState) GetSwingStoreExportData() []*SwingStoreExportDataEntry

func (*GenesisState) GetSwingStoreExportDataHash 

func (m *GenesisState) GetSwingStoreExportDataHash() string

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 InboundQueueRecord 

type InboundQueueRecord struct {
	Action  vm.Jsonable   `json:"action"`
	Context ActionContext `json:"context"`
}

type ListKey 

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

type ListTools 

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

func NewListTools 

func NewListTools(ctx sdk.Context, nodeStore storetypes.KVStore, cdc codec.Codec) *ListTools

func (ListTools) Delete 

func (lt ListTools) Delete(key ListKey)

func (ListTools) Fetch 

func (lt ListTools) Fetch(key ListKey) *ChunkedArtifactNode

func (ListTools) Key 

func (ListTools) Key(id uint64) ListKey

func (ListTools) Store 

func (lt ListTools) Store(key ListKey, node *ChunkedArtifactNode)
func (lt ListTools) Unlink(victim *ChunkedArtifactNode, updateEnds func(first, last *uint64)) error

Unlink removes a node from a non-circular list where PrevId == 0 indicates the head and NextId == 0 indicates the tail.

type Messages 

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

func UnmarshalMessagesJSON 

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

UnmarshalMessagesJSON decodes Messages from JSON text. Input must represent an array in which the first element is an array of [messageNum: integer, messageBody: string] pairs and the second element is an "Ack" integer.

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 a chunk of a bundle (or other artifact) to tolerate RPC message size limits.
	SendChunk(ctx context.Context, in *MsgSendChunk, opts ...grpc.CallOption) (*MsgSendChunkResponse, 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)
	// Execute a core evaluation.
	CoreEval(ctx context.Context, in *MsgCoreEval, opts ...grpc.CallOption) (*MsgCoreEvalResponse, 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 MsgCoreEval 

type MsgCoreEval struct {
	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// The JSON-stringified core bootstrap permits to grant to the jsCode, as the
	// `powers` endowment.
	JsonPermits string `protobuf:"bytes,2,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,3,opt,name=js_code,json=jsCode,proto3" json:"js_code,omitempty" yaml:"js_code"`
}

MsgCoreEval defines an SDK message for a core eval.

func (*MsgCoreEval) Descriptor 

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

func (*MsgCoreEval) GetAuthority 

func (m *MsgCoreEval) GetAuthority() string

func (*MsgCoreEval) GetJsCode 

func (m *MsgCoreEval) GetJsCode() string

func (*MsgCoreEval) GetJsonPermits 

func (m *MsgCoreEval) GetJsonPermits() string

func (*MsgCoreEval) Marshal 

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

func (*MsgCoreEval) MarshalTo 

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

func (*MsgCoreEval) MarshalToSizedBuffer 

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

func (*MsgCoreEval) ProtoMessage 

func (*MsgCoreEval) ProtoMessage()

func (*MsgCoreEval) Reset 

func (m *MsgCoreEval) Reset()

func (*MsgCoreEval) Size 

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

func (*MsgCoreEval) String 

func (m *MsgCoreEval) String() string

func (*MsgCoreEval) Unmarshal 

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

func (*MsgCoreEval) XXX_DiscardUnknown 

func (m *MsgCoreEval) XXX_DiscardUnknown()

func (*MsgCoreEval) XXX_Marshal 

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

func (*MsgCoreEval) XXX_Merge 

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

func (*MsgCoreEval) XXX_Size 

func (m *MsgCoreEval) XXX_Size() int

func (*MsgCoreEval) XXX_Unmarshal 

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

type MsgCoreEvalResponse 

type MsgCoreEvalResponse struct {
	// The result of the core eval.
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty" yaml:"result"`
}

MsgCoreEvalResponse is an empty reply.

func (*MsgCoreEvalResponse) Descriptor 

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

func (*MsgCoreEvalResponse) GetResult 

func (m *MsgCoreEvalResponse) GetResult() string

func (*MsgCoreEvalResponse) Marshal 

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

func (*MsgCoreEvalResponse) MarshalTo 

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

func (*MsgCoreEvalResponse) MarshalToSizedBuffer 

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

func (*MsgCoreEvalResponse) ProtoMessage 

func (*MsgCoreEvalResponse) ProtoMessage()

func (*MsgCoreEvalResponse) Reset 

func (m *MsgCoreEvalResponse) Reset()

func (*MsgCoreEvalResponse) Size 

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

func (*MsgCoreEvalResponse) String 

func (m *MsgCoreEvalResponse) String() string

func (*MsgCoreEvalResponse) Unmarshal 

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

func (*MsgCoreEvalResponse) XXX_DiscardUnknown 

func (m *MsgCoreEvalResponse) XXX_DiscardUnknown()

func (*MsgCoreEvalResponse) XXX_Marshal 

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

func (*MsgCoreEvalResponse) XXX_Merge 

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

func (*MsgCoreEvalResponse) XXX_Size 

func (m *MsgCoreEvalResponse) XXX_Size() int

func (*MsgCoreEvalResponse) XXX_Unmarshal 

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

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 

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) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgDeliverInbound) GetSubmitter 

func (m *MsgDeliverInbound) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgDeliverInbound) IsHighPriority 

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 

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 */
	// Default compression algorithm is gzip.
	CompressedBundle []byte `protobuf:"bytes,3,opt,name=compressed_bundle,json=compressedBundle,proto3" json:"compressedBundle" yaml:"compressedBundle"`
	// Total size in bytes of the bundle artifact, before compression and after
	// decompression.
	UncompressedSize int64 `protobuf:"varint,4,opt,name=uncompressed_size,json=uncompressedSize,proto3" json:"uncompressedSize"`
	// Declaration of a chunked bundle.
	ChunkedArtifact *ChunkedArtifact `` /* 128-byte string literal not displayed */
}

MsgInstallBundle carries a signed bundle to SwingSet. The fields `bundle`, `compressed_bundle`, and `chunked_artifact` are mutually exclusive, and exactly one must be present based on what is being submitted:

  • `bundle` for a complete and uncompressed bundle
  • `compressed_bundle` for a complete and compressed bundle
  • `chunked_artifact` for a manifest of chunks to be submitted in subsequent messages.

func NewMsgInstallBundle 

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

func (MsgInstallBundle) CheckAdmissibility 

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

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgInstallBundle) Compress 

func (msg *MsgInstallBundle) Compress() error

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

func (*MsgInstallBundle) Descriptor 

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

func (MsgInstallBundle) ExpectedUncompressedSize 

func (msg MsgInstallBundle) ExpectedUncompressedSize() uint64

ExpectedUncompressedSize returns the expected uncompressed size of the bundle.

func (*MsgInstallBundle) GetBundle 

func (m *MsgInstallBundle) GetBundle() string

func (*MsgInstallBundle) GetChunkedArtifact 

func (m *MsgInstallBundle) GetChunkedArtifact() *ChunkedArtifact

func (*MsgInstallBundle) GetCompressedBundle 

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

func (MsgInstallBundle) GetInboundMsgCount 

func (msg MsgInstallBundle) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (MsgInstallBundle) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgInstallBundle) GetSubmitter 

func (m *MsgInstallBundle) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*MsgInstallBundle) GetUncompressedSize 

func (m *MsgInstallBundle) GetUncompressedSize() int64

func (MsgInstallBundle) IsHighPriority 

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

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgInstallBundle) Marshal 

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

func (*MsgInstallBundle) MarshalTo 

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

func (*MsgInstallBundle) MarshalToSizedBuffer 

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

func (*MsgInstallBundle) ProtoMessage 

func (*MsgInstallBundle) ProtoMessage()

func (*MsgInstallBundle) Reset 

func (m *MsgInstallBundle) Reset()

func (MsgInstallBundle) Route 

func (msg MsgInstallBundle) Route() string

Route should return the name of the module

func (*MsgInstallBundle) Size 

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

func (*MsgInstallBundle) String 

func (m *MsgInstallBundle) String() string

func (MsgInstallBundle) Type 

func (msg MsgInstallBundle) Type() string

Type should return the action

func (*MsgInstallBundle) Uncompress 

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 

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

func (MsgInstallBundle) ValidateBasic 

func (msg MsgInstallBundle) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgInstallBundle) XXX_DiscardUnknown 

func (m *MsgInstallBundle) XXX_DiscardUnknown()

func (*MsgInstallBundle) XXX_Marshal 

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

func (*MsgInstallBundle) XXX_Merge 

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

func (*MsgInstallBundle) XXX_Size 

func (m *MsgInstallBundle) XXX_Size() int

func (*MsgInstallBundle) XXX_Unmarshal 

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

type MsgInstallBundleResponse 

type MsgInstallBundleResponse struct {
	// The assigned identifier for a chunked artifact, if the caller is expected
	// to call back with MsgSendChunk messages.
	ChunkedArtifactId uint64 `` /* 128-byte string literal not displayed */
}

MsgInstallBundleResponse is either an empty acknowledgement that a bundle installation message has been queued for the SwingSet kernel's consideration, or (for MsgInstallBundle requests that have a chunked artifact manifest instead of a compressed or uncompressed bundle) a container for the chunked artifact identifier to be included in subsequent MsgSendChunk messages.

func (*MsgInstallBundleResponse) Descriptor 

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

func (*MsgInstallBundleResponse) GetChunkedArtifactId 

func (m *MsgInstallBundleResponse) GetChunkedArtifactId() uint64

func (*MsgInstallBundleResponse) Marshal 

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

func (*MsgInstallBundleResponse) MarshalTo 

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

func (*MsgInstallBundleResponse) MarshalToSizedBuffer 

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

func (*MsgInstallBundleResponse) ProtoMessage 

func (*MsgInstallBundleResponse) ProtoMessage()

func (*MsgInstallBundleResponse) Reset 

func (m *MsgInstallBundleResponse) Reset()

func (*MsgInstallBundleResponse) Size 

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

func (*MsgInstallBundleResponse) String 

func (m *MsgInstallBundleResponse) String() string

func (*MsgInstallBundleResponse) Unmarshal 

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

func (*MsgInstallBundleResponse) XXX_DiscardUnknown 

func (m *MsgInstallBundleResponse) XXX_DiscardUnknown()

func (*MsgInstallBundleResponse) XXX_Marshal 

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

func (*MsgInstallBundleResponse) XXX_Merge 

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

func (*MsgInstallBundleResponse) XXX_Size 

func (m *MsgInstallBundleResponse) XXX_Size() int

func (*MsgInstallBundleResponse) XXX_Unmarshal 

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 

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 (m *MsgProvision) GetAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgProvision) GetInboundMsgCount 

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) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgProvision) GetSubmitter 

func (m *MsgProvision) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgProvision) IsHighPriority 

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 MsgSendChunk 

type MsgSendChunk struct {
	ChunkedArtifactId uint64                                        `` /* 128-byte string literal not displayed */
	Submitter         github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 133-byte string literal not displayed */
	ChunkIndex        uint64                                        `protobuf:"varint,3,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunkIndex" yaml:"chunkIndex"`
	ChunkData         []byte                                        `protobuf:"bytes,4,opt,name=chunk_data,json=chunkData,proto3" json:"chunkData" yaml:"chunkData"`
}

MsgSendChunk carries a chunk of an artifact through RPC to the chain. Individual chunks are addressed by the chunked artifact identifier and the zero-based index of the chunk among all chunks as mentioned in the manifest provided to MsgInstallBundle.

func NewMsgSendChunk 

func NewMsgSendChunk(chunkedArtifactId uint64, submitter sdk.AccAddress, chunkIndex uint64, chunkData []byte) *MsgSendChunk

func (MsgSendChunk) CheckAdmissibility 

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

CheckAdmissibility implements the vm.ControllerAdmissionMsg interface.

func (*MsgSendChunk) Descriptor 

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

func (*MsgSendChunk) GetChunkData 

func (m *MsgSendChunk) GetChunkData() []byte

func (*MsgSendChunk) GetChunkIndex 

func (m *MsgSendChunk) GetChunkIndex() uint64

func (*MsgSendChunk) GetChunkedArtifactId 

func (m *MsgSendChunk) GetChunkedArtifactId() uint64

func (MsgSendChunk) GetInboundMsgCount 

func (msg MsgSendChunk) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (MsgSendChunk) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgSendChunk) GetSubmitter 

func (m *MsgSendChunk) GetSubmitter() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgSendChunk) IsHighPriority 

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

IsHighPriority implements the vm.ControllerAdmissionMsg interface.

func (*MsgSendChunk) Marshal 

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

func (*MsgSendChunk) MarshalTo 

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

func (*MsgSendChunk) MarshalToSizedBuffer 

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

func (*MsgSendChunk) ProtoMessage 

func (*MsgSendChunk) ProtoMessage()

func (*MsgSendChunk) Reset 

func (m *MsgSendChunk) Reset()

func (MsgSendChunk) Route 

func (msg MsgSendChunk) Route() string

Route should return the name of the module

func (*MsgSendChunk) Size 

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

func (*MsgSendChunk) String 

func (m *MsgSendChunk) String() string

func (MsgSendChunk) Type 

func (msg MsgSendChunk) Type() string

Type should return the action

func (*MsgSendChunk) Unmarshal 

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

func (MsgSendChunk) ValidateBasic 

func (msg MsgSendChunk) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgSendChunk) XXX_DiscardUnknown 

func (m *MsgSendChunk) XXX_DiscardUnknown()

func (*MsgSendChunk) XXX_Marshal 

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

func (*MsgSendChunk) XXX_Merge 

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

func (*MsgSendChunk) XXX_Size 

func (m *MsgSendChunk) XXX_Size() int

func (*MsgSendChunk) XXX_Unmarshal 

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

type MsgSendChunkResponse 

type MsgSendChunkResponse struct {
	ChunkedArtifactId uint64 `` /* 128-byte string literal not displayed */
	// The current state of the chunk.
	Chunk *ChunkInfo `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk" yaml:"chunk"`
}

MsgSendChunkResponse is an acknowledgement that a chunk has been received by the chain.

func (*MsgSendChunkResponse) Descriptor 

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

func (*MsgSendChunkResponse) GetChunk 

func (m *MsgSendChunkResponse) GetChunk() *ChunkInfo

func (*MsgSendChunkResponse) GetChunkedArtifactId 

func (m *MsgSendChunkResponse) GetChunkedArtifactId() uint64

func (*MsgSendChunkResponse) Marshal 

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

func (*MsgSendChunkResponse) MarshalTo 

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

func (*MsgSendChunkResponse) MarshalToSizedBuffer 

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

func (*MsgSendChunkResponse) ProtoMessage 

func (*MsgSendChunkResponse) ProtoMessage()

func (*MsgSendChunkResponse) Reset 

func (m *MsgSendChunkResponse) Reset()

func (*MsgSendChunkResponse) Size 

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

func (*MsgSendChunkResponse) String 

func (m *MsgSendChunkResponse) String() string

func (*MsgSendChunkResponse) Unmarshal 

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

func (*MsgSendChunkResponse) XXX_DiscardUnknown 

func (m *MsgSendChunkResponse) XXX_DiscardUnknown()

func (*MsgSendChunkResponse) XXX_Marshal 

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

func (*MsgSendChunkResponse) XXX_Merge 

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

func (*MsgSendChunkResponse) XXX_Size 

func (m *MsgSendChunkResponse) XXX_Size() int

func (*MsgSendChunkResponse) XXX_Unmarshal 

func (m *MsgSendChunkResponse) 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 a chunk of a bundle (or other artifact) to tolerate RPC message size limits.
	SendChunk(context.Context, *MsgSendChunk) (*MsgSendChunkResponse, 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)
	// Execute a core evaluation.
	CoreEval(context.Context, *MsgCoreEval) (*MsgCoreEvalResponse, 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 

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

func (MsgWalletAction) CheckAdmissibility 

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 

func (msg MsgWalletAction) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (*MsgWalletAction) GetOwner 

func (m *MsgWalletAction) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgWalletAction) GetSigners 

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

GetSigners defines whose signature is required

func (MsgWalletAction) IsHighPriority 

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 

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 

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 

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

func (MsgWalletSpendAction) CheckAdmissibility 

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 

func (msg MsgWalletSpendAction) GetInboundMsgCount() int32

GetInboundMsgCount implements InboundMsgCarrier.

func (*MsgWalletSpendAction) GetOwner 

func (m *MsgWalletSpendAction) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgWalletSpendAction) GetSigners 

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

GetSigners defines whose signature is required

func (*MsgWalletSpendAction) GetSpendAction 

func (m *MsgWalletSpendAction) GetSpendAction() string

func (MsgWalletSpendAction) IsHighPriority 

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 

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 

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 (m *MsgWalletSpendActionResponse) String() 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"`
	// Vat cleanup budget values.
	// These values are used by SwingSet to control the pace of removing data
	// associated with a terminated vat as described at
	// https://github.com/Agoric/agoric-sdk/blob/master/packages/SwingSet/docs/run-policy.md#terminated-vat-cleanup
	//
	// 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.
	VatCleanupBudget []UintMapEntry `protobuf:"bytes,6,rep,name=vat_cleanup_budget,json=vatCleanupBudget,proto3" json:"vat_cleanup_budget"`
	// The maximum number of blocks that an async installation can use.  -1 is
	// unlimited.
	InstallationDeadlineBlocks int64 `` /* 142-byte string literal not displayed */
	// The maximum number of seconds that an async installation can use.  -1 is
	// unlimited.
	InstallationDeadlineSeconds int64 `` /* 145-byte string literal not displayed */
	// The maximum size of a bundle (0 implies default 10000000 bytes). This
	// limit is exclusive.
	BundleUncompressedSizeLimitBytes int64 `` /* 164-byte string literal not displayed */
	// The maximum size of a bundle or artifact chunk (0 implies default 490000 bytes)
	ChunkSizeLimitBytes int64 `protobuf:"varint,10,opt,name=chunk_size_limit_bytes,json=chunkSizeLimitBytes,proto3" json:"chunk_size_limit_bytes,omitempty"`
}

Params are the swingset configuration/governance parameters.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default swingset parameters

func UpdateParams 

func UpdateParams(params Params) (Params, error)

UpdateParams appends any missing params, configuring them to their defaults, then returning the updated params or an error. Existing params are not modified, regardless of their value, and they are not removed if they no longer appear in the defaults. UpdateParams appends missing entries and fills defaults. Note that InstallationDeadlineBlocks and InstallationDeadlineSeconds treat 0 as "unset" and will be replaced with DefaultInstallationDeadlineBlocks and DefaultInstallationDeadlineSeconds, respectively.

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) GetBundleUncompressedSizeLimitBytes 

func (m *Params) GetBundleUncompressedSizeLimitBytes() int64

func (*Params) GetChunkSizeLimitBytes 

func (m *Params) GetChunkSizeLimitBytes() int64

func (*Params) GetFeeUnitPrice 

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

func (*Params) GetInstallationDeadlineBlocks 

func (m *Params) GetInstallationDeadlineBlocks() int64

func (*Params) GetInstallationDeadlineSeconds 

func (m *Params) GetInstallationDeadlineSeconds() int64

func (*Params) GetPowerFlagFees 

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

func (*Params) GetQueueMax 

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

func (*Params) GetVatCleanupBudget 

func (m *Params) GetVatCleanupBudget() []UintMapEntry

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 

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 

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

func (*PowerFlagFee) Descriptor 

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

func (*PowerFlagFee) Equal 

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

func (*PowerFlagFee) GetFee 

func (m *PowerFlagFee) GetFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*PowerFlagFee) GetPowerFlag 

func (m *PowerFlagFee) GetPowerFlag() string

func (*PowerFlagFee) Marshal 

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

func (*PowerFlagFee) MarshalTo 

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

func (*PowerFlagFee) MarshalToSizedBuffer 

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

func (*PowerFlagFee) ProtoMessage 

func (*PowerFlagFee) ProtoMessage()

func (*PowerFlagFee) Reset 

func (m *PowerFlagFee) Reset()

func (*PowerFlagFee) Size 

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

func (*PowerFlagFee) String 

func (m *PowerFlagFee) String() string

func (*PowerFlagFee) Unmarshal 

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

func (*PowerFlagFee) XXX_DiscardUnknown 

func (m *PowerFlagFee) XXX_DiscardUnknown()

func (*PowerFlagFee) XXX_Marshal 

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

func (*PowerFlagFee) XXX_Merge 

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

func (*PowerFlagFee) XXX_Size 

func (m *PowerFlagFee) XXX_Size() int

func (*PowerFlagFee) XXX_Unmarshal 

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

type QueryChunkedArtifactStatusRequest 

type QueryChunkedArtifactStatusRequest struct {
	ChunkedArtifactId uint64 `` /* 128-byte string literal not displayed */
}

QueryChunkedArtifactStatusRequest is the request type for the Query/ChunkedArtifact RPC method.

func (*QueryChunkedArtifactStatusRequest) Descriptor 

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

func (*QueryChunkedArtifactStatusRequest) GetChunkedArtifactId 

func (m *QueryChunkedArtifactStatusRequest) GetChunkedArtifactId() uint64

func (*QueryChunkedArtifactStatusRequest) Marshal 

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

func (*QueryChunkedArtifactStatusRequest) MarshalTo 

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

func (*QueryChunkedArtifactStatusRequest) MarshalToSizedBuffer 

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

func (*QueryChunkedArtifactStatusRequest) ProtoMessage 

func (*QueryChunkedArtifactStatusRequest) ProtoMessage()

func (*QueryChunkedArtifactStatusRequest) Reset 

func (m *QueryChunkedArtifactStatusRequest) Reset()

func (*QueryChunkedArtifactStatusRequest) Size 

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

func (*QueryChunkedArtifactStatusRequest) String 

func (m *QueryChunkedArtifactStatusRequest) String() string

func (*QueryChunkedArtifactStatusRequest) Unmarshal 

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

func (*QueryChunkedArtifactStatusRequest) XXX_DiscardUnknown 

func (m *QueryChunkedArtifactStatusRequest) XXX_DiscardUnknown()

func (*QueryChunkedArtifactStatusRequest) XXX_Marshal 

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

func (*QueryChunkedArtifactStatusRequest) XXX_Merge 

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

func (*QueryChunkedArtifactStatusRequest) XXX_Size 

func (m *QueryChunkedArtifactStatusRequest) XXX_Size() int

func (*QueryChunkedArtifactStatusRequest) XXX_Unmarshal 

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

type QueryChunkedArtifactStatusResponse 

type QueryChunkedArtifactStatusResponse struct {
	ChunkedArtifactId uint64           `` /* 128-byte string literal not displayed */
	ChunkedArtifact   *ChunkedArtifact `protobuf:"bytes,2,opt,name=chunked_artifact,json=chunkedArtifact,proto3" json:"chunkedArtifact" yaml:"chunkedArtifact"`
	// Start time in UNIX epoch seconds.
	StartTimeUnix    int64 `protobuf:"varint,3,opt,name=start_time_unix,json=startTimeUnix,proto3" json:"startTimeUnix" yaml:"startTimeUnix"`
	StartBlockHeight int64 `protobuf:"varint,4,opt,name=start_block_height,json=startBlockHeight,proto3" json:"startBlockHeight" yaml:"startBlockHeight"`
}

QueryChunkedArtifactStatusResponse is the response type for the Query/ChunkedArtifact RPC method.

func (*QueryChunkedArtifactStatusResponse) Descriptor 

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

func (*QueryChunkedArtifactStatusResponse) GetChunkedArtifact 

func (m *QueryChunkedArtifactStatusResponse) GetChunkedArtifact() *ChunkedArtifact

func (*QueryChunkedArtifactStatusResponse) GetChunkedArtifactId 

func (m *QueryChunkedArtifactStatusResponse) GetChunkedArtifactId() uint64

func (*QueryChunkedArtifactStatusResponse) GetStartBlockHeight 

func (m *QueryChunkedArtifactStatusResponse) GetStartBlockHeight() int64

func (*QueryChunkedArtifactStatusResponse) GetStartTimeUnix 

func (m *QueryChunkedArtifactStatusResponse) GetStartTimeUnix() int64

func (*QueryChunkedArtifactStatusResponse) Marshal 

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

func (*QueryChunkedArtifactStatusResponse) MarshalTo 

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

func (*QueryChunkedArtifactStatusResponse) MarshalToSizedBuffer 

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

func (*QueryChunkedArtifactStatusResponse) ProtoMessage 

func (*QueryChunkedArtifactStatusResponse) ProtoMessage()

func (*QueryChunkedArtifactStatusResponse) Reset 

func (m *QueryChunkedArtifactStatusResponse) Reset()

func (*QueryChunkedArtifactStatusResponse) Size 

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

func (*QueryChunkedArtifactStatusResponse) String 

func (m *QueryChunkedArtifactStatusResponse) String() string

func (*QueryChunkedArtifactStatusResponse) Unmarshal 

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

func (*QueryChunkedArtifactStatusResponse) XXX_DiscardUnknown 

func (m *QueryChunkedArtifactStatusResponse) XXX_DiscardUnknown()

func (*QueryChunkedArtifactStatusResponse) XXX_Marshal 

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

func (*QueryChunkedArtifactStatusResponse) XXX_Merge 

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

func (*QueryChunkedArtifactStatusResponse) XXX_Size 

func (m *QueryChunkedArtifactStatusResponse) XXX_Size() int

func (*QueryChunkedArtifactStatusResponse) XXX_Unmarshal 

func (m *QueryChunkedArtifactStatusResponse) 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)
	// Return the state of a pending installation.
	ChunkedArtifactStatus(ctx context.Context, in *QueryChunkedArtifactStatusRequest, opts ...grpc.CallOption) (*QueryChunkedArtifactStatusResponse, 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 (m *QueryEgressRequest) GetPeer() github_com_cosmos_cosmos_sdk_types.AccAddress

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 (m *QueryMailboxRequest) GetPeer() github_com_cosmos_cosmos_sdk_types.AccAddress

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)
	// Return the state of a pending installation.
	ChunkedArtifactStatus(context.Context, *QueryChunkedArtifactStatusRequest) (*QueryChunkedArtifactStatusResponse, error)
}

QueryServer is the server API for Query service.

type QueueSize 

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. TODO: Replace with UintMapEntry?

func NewQueueSize 

func NewQueueSize(key string, sz int32) QueueSize

func (*QueueSize) Descriptor 

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

func (*QueueSize) Equal 

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

func (*QueueSize) GetKey 

func (m *QueueSize) GetKey() string

func (*QueueSize) GetSize_ 

func (m *QueueSize) GetSize_() int32

func (*QueueSize) Marshal 

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

func (*QueueSize) MarshalTo 

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

func (*QueueSize) MarshalToSizedBuffer 

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

func (*QueueSize) ProtoMessage 

func (*QueueSize) ProtoMessage()

func (*QueueSize) Reset 

func (m *QueueSize) Reset()

func (*QueueSize) Size 

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

func (*QueueSize) String 

func (m *QueueSize) String() string

func (*QueueSize) Unmarshal 

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

func (*QueueSize) XXX_DiscardUnknown 

func (m *QueueSize) XXX_DiscardUnknown()

func (*QueueSize) XXX_Marshal 

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

func (*QueueSize) XXX_Merge 

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

func (*QueueSize) XXX_Size 

func (m *QueueSize) XXX_Size() int

func (*QueueSize) XXX_Unmarshal 

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

type SmartWalletState 

type SmartWalletState uint8
const (
	SmartWalletStateUnspecified SmartWalletState = iota
	SmartWalletStateNone
	SmartWalletStatePending
	SmartWalletStateProvisioned
)

type State 

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"`
	// Doubly-linked list in order of ascending start block and time.
	FirstChunkedArtifactId uint64 `` /* 155-byte string literal not displayed */
	// The last chunked artifact id that has not expired nor completed.
	LastChunkedArtifactId uint64 `` /* 151-byte string literal not displayed */
	// The next monotonically increasing chunked artifact id to allocate.
	NextChunkedArtifactId uint64 `` /* 151-byte string literal not displayed */
}

The current state of the module.

func (*State) Descriptor 

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

func (*State) GetFirstChunkedArtifactId 

func (m *State) GetFirstChunkedArtifactId() uint64

func (*State) GetLastChunkedArtifactId 

func (m *State) GetLastChunkedArtifactId() uint64

func (*State) GetNextChunkedArtifactId 

func (m *State) GetNextChunkedArtifactId() uint64

func (*State) GetQueueAllowed 

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

func (*State) Marshal 

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

func (*State) MarshalTo 

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

func (*State) MarshalToSizedBuffer 

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

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) Size 

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

func (*State) String 

func (m *State) String() string

func (*State) Unmarshal 

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

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

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

func (*State) XXX_Merge 

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

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

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 cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=beans,proto3,customtype=cosmossdk.io/math.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 sdkmath.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]sdkmath.Uint
	ChargeBeans(ctx sdk.Context, beansPerUnit map[string]sdkmath.Uint, addr sdk.AccAddress, beans sdkmath.Uint) error
	IsHighPriorityAddress(ctx sdk.Context, addr sdk.AccAddress) (bool, error)
	GetSmartWalletState(ctx sdk.Context, addr sdk.AccAddress) SmartWalletState
	ChargeForSmartWallet(ctx sdk.Context, beansPerUnit map[string]sdkmath.Uint, addr sdk.AccAddress) error
}

type SwingStoreArtifact 

type SwingStoreArtifact 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"`
}

SwingStoreArtifact encodes an artifact of a swing-store export. Artifacts may be stored or transmitted in any order. Most handlers do maintain the artifact order from their original source as an effect of how they handle the artifacts.

func (*SwingStoreArtifact) Descriptor 

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

func (*SwingStoreArtifact) GetData 

func (m *SwingStoreArtifact) GetData() []byte

func (*SwingStoreArtifact) GetName 

func (m *SwingStoreArtifact) GetName() string

func (*SwingStoreArtifact) Marshal 

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

func (*SwingStoreArtifact) MarshalTo 

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

func (*SwingStoreArtifact) MarshalToSizedBuffer 

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

func (*SwingStoreArtifact) ProtoMessage 

func (*SwingStoreArtifact) ProtoMessage()

func (*SwingStoreArtifact) Reset 

func (m *SwingStoreArtifact) Reset()

func (*SwingStoreArtifact) Size 

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

func (*SwingStoreArtifact) String 

func (m *SwingStoreArtifact) String() string

func (*SwingStoreArtifact) Unmarshal 

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

func (*SwingStoreArtifact) XXX_DiscardUnknown 

func (m *SwingStoreArtifact) XXX_DiscardUnknown()

func (*SwingStoreArtifact) XXX_Marshal 

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

func (*SwingStoreArtifact) XXX_Merge 

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

func (*SwingStoreArtifact) XXX_Size 

func (m *SwingStoreArtifact) XXX_Size() int

func (*SwingStoreArtifact) XXX_Unmarshal 

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

type SwingStoreExportDataEntry 

type SwingStoreExportDataEntry struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

A SwingStore "export data" entry.

func (*SwingStoreExportDataEntry) Descriptor 

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

func (*SwingStoreExportDataEntry) GetKey 

func (m *SwingStoreExportDataEntry) GetKey() string

func (*SwingStoreExportDataEntry) GetValue 

func (m *SwingStoreExportDataEntry) GetValue() string

func (*SwingStoreExportDataEntry) Marshal 

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

func (*SwingStoreExportDataEntry) MarshalTo 

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

func (*SwingStoreExportDataEntry) MarshalToSizedBuffer 

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

func (*SwingStoreExportDataEntry) ProtoMessage 

func (*SwingStoreExportDataEntry) ProtoMessage()

func (*SwingStoreExportDataEntry) Reset 

func (m *SwingStoreExportDataEntry) Reset()

func (*SwingStoreExportDataEntry) Size 

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

func (*SwingStoreExportDataEntry) String 

func (m *SwingStoreExportDataEntry) String() string

func (*SwingStoreExportDataEntry) Unmarshal 

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

func (*SwingStoreExportDataEntry) XXX_DiscardUnknown 

func (m *SwingStoreExportDataEntry) XXX_DiscardUnknown()

func (*SwingStoreExportDataEntry) XXX_Marshal 

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

func (*SwingStoreExportDataEntry) XXX_Merge 

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

func (*SwingStoreExportDataEntry) XXX_Size 

func (m *SwingStoreExportDataEntry) XXX_Size() int

func (*SwingStoreExportDataEntry) XXX_Unmarshal 

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

type UintMapEntry 

type UintMapEntry struct {
	Key   string                 `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=value,proto3,customtype=cosmossdk.io/math.Uint" json:"value"`
}

Map element of a string key to an unsigned integer. The value uses cosmos-sdk Uint rather than a native Go type to ensure that zeroes survive "omitempty" JSON serialization.

func (*UintMapEntry) Descriptor 

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

func (*UintMapEntry) Equal 

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

func (*UintMapEntry) GetKey 

func (m *UintMapEntry) GetKey() string

func (*UintMapEntry) Marshal 

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

func (*UintMapEntry) MarshalTo 

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

func (*UintMapEntry) MarshalToSizedBuffer 

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

func (*UintMapEntry) ProtoMessage 

func (*UintMapEntry) ProtoMessage()

func (*UintMapEntry) Reset 

func (m *UintMapEntry) Reset()

func (*UintMapEntry) Size 

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

func (*UintMapEntry) String 

func (m *UintMapEntry) String() string

func (*UintMapEntry) Unmarshal 

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

func (*UintMapEntry) XXX_DiscardUnknown 

func (m *UintMapEntry) XXX_DiscardUnknown()

func (*UintMapEntry) XXX_Marshal 

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

func (*UintMapEntry) XXX_Merge 

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

func (*UintMapEntry) XXX_Size 

func (m *UintMapEntry) XXX_Size() int

func (*UintMapEntry) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CoreEval 

func (*UnimplementedMsgServer) CoreEval(ctx context.Context, req *MsgCoreEval) (*MsgCoreEvalResponse, error)

func (*UnimplementedMsgServer) DeliverInbound 

func (*UnimplementedMsgServer) DeliverInbound(ctx context.Context, req *MsgDeliverInbound) (*MsgDeliverInboundResponse, error)

func (*UnimplementedMsgServer) InstallBundle 

func (*UnimplementedMsgServer) InstallBundle(ctx context.Context, req *MsgInstallBundle) (*MsgInstallBundleResponse, error)

func (*UnimplementedMsgServer) Provision 

func (*UnimplementedMsgServer) Provision(ctx context.Context, req *MsgProvision) (*MsgProvisionResponse, error)

func (*UnimplementedMsgServer) SendChunk 

func (*UnimplementedMsgServer) SendChunk(ctx context.Context, req *MsgSendChunk) (*MsgSendChunkResponse, error)

func (*UnimplementedMsgServer) WalletAction 

func (*UnimplementedMsgServer) WalletAction(ctx context.Context, req *MsgWalletAction) (*MsgWalletActionResponse, error)

func (*UnimplementedMsgServer) WalletSpendAction 

func (*UnimplementedMsgServer) WalletSpendAction(ctx context.Context, req *MsgWalletSpendAction) (*MsgWalletSpendActionResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ChunkedArtifactStatus 

func (*UnimplementedQueryServer) ChunkedArtifactStatus(ctx context.Context, req *QueryChunkedArtifactStatusRequest) (*QueryChunkedArtifactStatusResponse, error)

func (*UnimplementedQueryServer) Egress 

func (*UnimplementedQueryServer) Egress(ctx context.Context, req *QueryEgressRequest) (*QueryEgressResponse, error)

func (*UnimplementedQueryServer) Mailbox 

func (*UnimplementedQueryServer) Mailbox(ctx context.Context, req *QueryMailboxRequest) (*QueryMailboxResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

type VstorageKeeper 

type VstorageKeeper interface {
	PushQueueItem(ctx sdk.Context, path string, value string) error
	HasEntry(ctx sdk.Context, path string) bool
	GetQueueLength(ctx sdk.Context, path string) (sdkmath.Int, error)
	GetEntry(ctx sdk.Context, path string) agoric.KVEntry
	SetStorage(ctx sdk.Context, entry agoric.KVEntry)
	LegacySetStorageAndNotify(ctx sdk.Context, entry agoric.KVEntry)
	PathToEncodedKey(path string) []byte
	GetStoreName() string
	GetChildren(ctx sdk.Context, path string) []string
}

VstorageKeeper defines the expected interface for the vstorage module keeper

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.