v1

package
v0.2.11-rc Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2026 License: Apache-2.0 Imports: 28 Imported by: 5

Documentation ¶

Overview ¶

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index ¶

Constants ¶

View Source 
const (
	// ModuleName is the module name constant used in many places
	ModuleName = "awasm"

	// StoreKey is the store key string for deployment
	StoreKey = ModuleName

	// RouterKey is the message route for deployment
	RouterKey = ModuleName
)

Variables ¶

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthParamsmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParamsmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParamsmsg = fmt.Errorf("proto: unexpected end of group")
)
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 (
	// ModuleCdc references the global x/deployment 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/deployment and
	// defined at the application level.
	//
	// Deprecated: ModuleCdc use is deprecated
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions ¶

func ParamKeyTable ¶ 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for wasm module Deprecated: now params can be accessed on key `0x01` on the wasm store.

func ParamsPrefix ¶ 

func ParamsPrefix() []byte

func RegisterInterfaces ¶ 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

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

func RegisterLegacyAminoCodec deprecated 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec register concrete types on codec

Deprecated: RegisterLegacyAminoCodec is deprecated

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 EventMsgBlocked ¶ 

type EventMsgBlocked struct {
	ContractAddress string `protobuf:"bytes,1,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address" yaml:"contract_address"`
	MsgType         string `protobuf:"bytes,2,opt,name=msg_type,json=msgType,proto3" json:"msg_type" yaml:"msg_type"`
	Reason          string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason" yaml:"reason"`
}

EventMsgBlocked is triggered when smart contract does not pass message filter

func (*EventMsgBlocked) Descriptor ¶ 

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

func (*EventMsgBlocked) Equal ¶ 

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

func (*EventMsgBlocked) GetContractAddress ¶ 

func (m *EventMsgBlocked) GetContractAddress() string

func (*EventMsgBlocked) GetMsgType ¶ 

func (m *EventMsgBlocked) GetMsgType() string

func (*EventMsgBlocked) GetReason ¶ 

func (m *EventMsgBlocked) GetReason() string

func (*EventMsgBlocked) Marshal ¶ 

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

func (*EventMsgBlocked) MarshalTo ¶ 

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

func (*EventMsgBlocked) MarshalToSizedBuffer ¶ 

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

func (*EventMsgBlocked) ProtoMessage ¶ 

func (*EventMsgBlocked) ProtoMessage()

func (*EventMsgBlocked) Reset ¶ 

func (m *EventMsgBlocked) Reset()

func (*EventMsgBlocked) Size ¶ 

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

func (*EventMsgBlocked) String ¶ 

func (m *EventMsgBlocked) String() string

func (*EventMsgBlocked) Unmarshal ¶ 

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

func (*EventMsgBlocked) XXX_DiscardUnknown ¶ 

func (m *EventMsgBlocked) XXX_DiscardUnknown()

func (*EventMsgBlocked) XXX_Marshal ¶ 

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

func (*EventMsgBlocked) XXX_Merge ¶ 

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

func (*EventMsgBlocked) XXX_Size ¶ 

func (m *EventMsgBlocked) XXX_Size() int

func (*EventMsgBlocked) XXX_Unmarshal ¶ 

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

type GenesisState ¶ 

type GenesisState struct {
	// Params holds parameters of the genesis of akash wasm.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"params"`
}

GenesisState stores slice of genesis wasm parameters.

func (*GenesisState) Descriptor ¶ 

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

func (*GenesisState) GetParams ¶ 

func (m *GenesisState) GetParams() Params

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 MsgClient ¶ 

type MsgClient interface {
	// UpdateParams defines a governance operation for updating the x/wasm module
	// parameters. The authority is hard-coded to the x/gov module account.
	//
	// Since: akash v2.0.0
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgServer ¶ 

type MsgServer interface {
	// UpdateParams defines a governance operation for updating the x/wasm module
	// parameters. The authority is hard-coded to the x/gov module account.
	//
	// Since: akash v2.0.0
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams ¶ 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/wasm parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type.

Since: akash v1.0.0

func (*MsgUpdateParams) Descriptor ¶ 

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

func (*MsgUpdateParams) GetAuthority ¶ 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams ¶ 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) GetSignBytes deprecated 

func (m *MsgUpdateParams) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgUpdateParams) GetSigners ¶ 

func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress

GetSigners returns the expected signers for a MsgUpdateParams message.

func (*MsgUpdateParams) Marshal ¶ 

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

func (*MsgUpdateParams) MarshalTo ¶ 

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

func (*MsgUpdateParams) MarshalToSizedBuffer ¶ 

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

func (*MsgUpdateParams) ProtoMessage ¶ 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset ¶ 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Route deprecated 

func (m *MsgUpdateParams) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgUpdateParams) Size ¶ 

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

func (*MsgUpdateParams) String ¶ 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Type ¶ 

func (m *MsgUpdateParams) Type() string

Type implements the sdk.Msg interface

func (*MsgUpdateParams) Unmarshal ¶ 

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

func (*MsgUpdateParams) ValidateBasic ¶ 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown ¶ 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal ¶ 

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

func (*MsgUpdateParams) XXX_Merge ¶ 

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

func (*MsgUpdateParams) XXX_Size ¶ 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal ¶ 

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

type MsgUpdateParamsResponse ¶ 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

Since: akash v1.0.0

func (*MsgUpdateParamsResponse) Descriptor ¶ 

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

func (*MsgUpdateParamsResponse) Marshal ¶ 

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

func (*MsgUpdateParamsResponse) MarshalTo ¶ 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer ¶ 

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

func (*MsgUpdateParamsResponse) ProtoMessage ¶ 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset ¶ 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size ¶ 

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

func (*MsgUpdateParamsResponse) String ¶ 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal ¶ 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown ¶ 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal ¶ 

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

func (*MsgUpdateParamsResponse) XXX_Merge ¶ 

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

func (*MsgUpdateParamsResponse) XXX_Size ¶ 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal ¶ 

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

type Params ¶ 

type Params struct {
	BlockedAddresses []string `protobuf:"bytes,1,rep,name=blocked_addresses,json=blockedAddresses,proto3" json:"blocked_addresses" yaml:"blocked_addresses"`
}

Params defines the parameters for the x/wasm package.

func DefaultParams ¶ 

func DefaultParams() Params

func (*Params) Descriptor ¶ 

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

func (*Params) GetBlockedAddresses ¶ 

func (m *Params) GetBlockedAddresses() []string

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

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

func (*Params) Unmarshal ¶ 

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

func (Params) Validate ¶ 

func (p Params) Validate() error

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 QueryClient ¶ 

type QueryClient interface {
	// Params returns the total set of wasm parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 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 returns the total set of wasm parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer ¶ 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) UpdateParams ¶ 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer ¶ 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Params ¶ 

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

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.