types

package
v2.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeAggTask   = "aggregate_task"
	EventTypeAggTxTask = "aggregate_tx_task"

	AttributeValueCategory = ModuleName
)
View Source 
const (
	// ModuleName is the name of this module
	ModuleName = "oracle"

	// RouterKey is used to route messages.
	RouterKey = ModuleName

	// StoreKey is the prefix under which we store this module's data.
	StoreKey = ModuleName

	// QuerierRoute is used to handle abci_query requests.
	QuerierRoute = ModuleName
)
View Source 
const (
	TypeMsgCreateOperator   = "create_operator"
	TypeMsgRemoveOperator   = "remove_operator"
	TypeMsgAddCollateral    = "add_collateral"
	TypeMsgReduceCollateral = "reduce_collateral"
	TypeMsgWithdrawReward   = "withdraw_reward"
	TypeMsgCreateTask       = "create_task"
	TypeMsgRespondToTask    = "respond_to_task"
	TypeMsgDeleteTask       = "delete_task"
	TypeMsgCreateTxTask     = "create_tx_task"
	TypeMsgRespondToTxTask  = "respond_to_tx_task"
	TypeMsgDeleteTxTask     = "delete_tx_task"
)
View Source 
const (
	QueryOperator    = "operator"
	QueryOperators   = "operators"
	QueryWithdrawals = "withdrawals"
	QueryTask        = "task"
	QueryResponse    = "response"
)

Querier routes for the oracle module

Variables

View Source 
var (
	ErrNoOperatorFound         = sdkerrors.Register(ModuleName, errNoOperatorFound, "no operator was found")
	ErrOperatorAlreadyExists   = sdkerrors.Register(ModuleName, errOperatorAlreadyExists, "operator already exists")
	ErrInvalidDueBlock         = sdkerrors.Register(ModuleName, errInvalidDueBlock, "invalid due block")
	ErrNoTotalCollateralFound  = sdkerrors.Register(ModuleName, errNoTotalCollateralFound, "total collateral not found")
	ErrNoEnoughTotalCollateral = sdkerrors.Register(ModuleName, errNoEnoughTotalCollateral, "total collateral not enough")
	ErrTotalCollateralNotEqual = sdkerrors.Register(ModuleName, errTotalCollateralNotEqual, "total collateral not equal")
	ErrNoEnoughCollateral      = sdkerrors.Register(ModuleName, errNoEnoughCollateral, "collateral not enough")
	ErrInvalidPoolParams       = sdkerrors.Register(ModuleName, errInvalidPoolParams, "invalid pool params")
	ErrInvalidTaskParams       = sdkerrors.Register(ModuleName, errInvalidTaskParams, "invalid task params")
	ErrUnqualifiedRemover      = sdkerrors.Register(ModuleName, errUnqualifiedRemover, "unauthorized to remove this operator - not the operator itself nor a certifier")

	ErrTaskNotExists       = sdkerrors.Register(ModuleName, errTaskNotExists, "task does not exist")
	ErrUnqualifiedOperator = sdkerrors.Register(ModuleName, errUnqualifiedOperator, "operator is not qualified")
	ErrDuplicateResponse   = sdkerrors.Register(ModuleName, errDuplicateResponse, "already receive response from this operator")
	ErrTaskClosed          = sdkerrors.Register(ModuleName, errTaskClosed, "task is already closed")
	ErrTaskNotClosed       = sdkerrors.Register(ModuleName, errTaskNotClosed, "task has not been closed")
	ErrNotExpired          = sdkerrors.Register(ModuleName, errNotExpired, "task is not expired")
	ErrNotCreator          = sdkerrors.Register(ModuleName, errNotCreated, "only creator is allowed to perform this action")
	ErrNotFinished         = sdkerrors.Register(ModuleName, errNotFinished, "the task is on going")
	ErrTaskFailed          = sdkerrors.Register(ModuleName, errTaskFailed, "task failed")
	ErrInvalidScore        = sdkerrors.Register(ModuleName, errInvalidScore, "invalid score")
	ErrInvalidTask         = sdkerrors.Register(ModuleName, errInvalidTask, "invalid task")
	ErrOverdueValidTime    = sdkerrors.Register(ModuleName, errOverdueValidTime, "the valid time is overdue")
	ErrUnexpectedTask      = sdkerrors.Register(ModuleName, errUnexpectedTask, "a different typed task already exists")
	ErrTooLateValidTime    = sdkerrors.Register(ModuleName, errTooLateValidTime, "the valid time is later than expiration time")

	ErrInconsistentOperators = sdkerrors.Register(ModuleName, errInconsistentOperators, "two operators not consistent")

	ErrFailedToCastTask = sdkerrors.Register(ModuleName, errFailedToCastTask, "failed to cast to concrete task")
)
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 (
	OperatorStoreKeyPrefix         = []byte{0x01}
	WithdrawStoreKeyPrefix         = []byte{0x02}
	TotalCollateralKeyPrefix       = []byte{0x03}
	TaskStoreKeyPrefix             = []byte{0x04}
	ClosingTaskStoreKeyPrefix      = []byte{0x05}
	ClosingTaskStoreKeyTimedPrefix = []byte{0x06}
	ExpireTaskStoreKeyPrefix       = []byte{0x07}
	ShortcutTasksKeyPrefix         = []byte{0x08}
)
View Source 
var (
	ErrInvalidLengthOracle        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOracle          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ParamsStoreKeyTaskParams = []byte("taskparams")
	ParamsStoreKeyPoolParams = []byte("poolparams")
)
View Source 
var (
	MinScore                 = sdk.NewInt(0)
	MaxScore                 = sdk.NewInt(100)
	DefaultThresholdScore    = sdk.NewInt(50)
	DefaultAggregationResult = sdk.NewInt(50)

	DefaultExpirationDuration = time.Duration(24) * time.Hour
	DefaultAggregationWindow  = int64(20)
	DefaultEpsilon1           = sdk.NewInt(1)
	DefaultEpsilon2           = sdk.NewInt(100)
	DefaultShortcutQuorum     = sdk.NewDecWithPrec(50, 2)

	DefaultLockedInBlocks    = int64(30)
	DefaultMinimumCollateral = int64(50000)
)

Default parameters

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 (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (

	// ModuleCdc references the global x/oracle 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/oracle and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var TaskStatus_name = map[int32]string{
	0: "TASK_STATUS_UNSPECIFIED",
	1: "TASK_STATUS_PENDING",
	2: "TASK_STATUS_SUCCEEDED",
	3: "TASK_STATUS_FAILED",
}
View Source 
var TaskStatus_value = map[string]int32{
	"TASK_STATUS_UNSPECIFIED": 0,
	"TASK_STATUS_PENDING":     1,
	"TASK_STATUS_SUCCEEDED":   2,
	"TASK_STATUS_FAILED":      3,
}

Functions

func ClosingTaskIDsStoreKey 

func ClosingTaskIDsStoreKey(blockHeight int64) []byte

func NewTaskID added in v2.7.0 

func NewTaskID(contract, function string) []byte

func NewTxTaskID added in v2.7.0 

func NewTxTaskID(txHash string) ([]byte, error)

func OperatorStoreKey 

func OperatorStoreKey(operator sdk.AccAddress) []byte

func ParamKeyTable 

func ParamKeyTable() params.KeyTable

ParamKeyTable is the key declaration for parameters.

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

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

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on the LegacyAmino codec

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)

func TaskStoreKey 

func TaskStoreKey(taskID []byte) []byte

func TimeStoreKey added in v2.7.0 

func TimeStoreKey(prefix []byte, theTime time.Time) []byte

func TotalCollateralKey 

func TotalCollateralKey() []byte

func ValidateGenesis 

func ValidateGenesis(genesisState GenesisState) error

ValidateGenesis validates oracle genesis data.

func WithdrawStoreKey 

func WithdrawStoreKey(address sdk.AccAddress, dueBlock int64) []byte

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(moduleName string) sdk.AccAddress
}

type BankKeeper 

type BankKeeper interface {
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

type CertKeeper 

type CertKeeper interface {
	IsCertifier(ctx sdk.Context, addr sdk.AccAddress) bool
}

type CoinsProto 

type CoinsProto struct {
	Coins github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=coins,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"coins" yaml:"amount"`
}

func (*CoinsProto) Descriptor 

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

func (*CoinsProto) GetCoins 

func (m *CoinsProto) GetCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*CoinsProto) Marshal 

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

func (*CoinsProto) MarshalTo 

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

func (*CoinsProto) MarshalToSizedBuffer 

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

func (*CoinsProto) ProtoMessage 

func (*CoinsProto) ProtoMessage()

func (*CoinsProto) Reset 

func (m *CoinsProto) Reset()

func (*CoinsProto) Size 

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

func (*CoinsProto) String 

func (m *CoinsProto) String() string

func (*CoinsProto) Unmarshal 

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

func (*CoinsProto) XXX_DiscardUnknown 

func (m *CoinsProto) XXX_DiscardUnknown()

func (*CoinsProto) XXX_Marshal 

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

func (*CoinsProto) XXX_Merge 

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

func (*CoinsProto) XXX_Size 

func (m *CoinsProto) XXX_Size() int

func (*CoinsProto) XXX_Unmarshal 

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

type DistrKeeper 

type DistrKeeper interface {
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

type GenesisState 

type GenesisState struct {
	Operators       []Operator                               `protobuf:"bytes,1,rep,name=operators,proto3" json:"operators" yaml:"operators"`
	TotalCollateral github_com_cosmos_cosmos_sdk_types.Coins `` /* 174-byte string literal not displayed */
	PoolParams      *LockedPoolParams                        `protobuf:"bytes,3,opt,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty" yaml:"pool_params"`
	TaskParams      *TaskParams                              `protobuf:"bytes,4,opt,name=task_params,json=taskParams,proto3" json:"task_params,omitempty" yaml:"task_params"`
	Withdraws       []Withdraw                               `protobuf:"bytes,5,rep,name=withdraws,proto3" json:"withdraws" yaml:"withdraws"`
	Tasks           []Task                                   `protobuf:"bytes,6,rep,name=tasks,proto3" json:"tasks" yaml:"tasks"`
	TxTasks         []TxTask                                 `protobuf:"bytes,7,rep,name=tx_tasks,json=txTasks,proto3" json:"tx_tasks" yaml:"tx_tasks"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState creates a default GenesisState object.

func NewGenesisState 

func NewGenesisState(operators []Operator, totalCollateral sdk.Coins, poolParams LockedPoolParams, taskParams TaskParams,
	withdraws []Withdraw, tasks []Task, txTasks []TxTask) GenesisState

NewGenesisState constructs a GenesisState object.

func (*GenesisState) Descriptor 

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

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 LockedPoolParams 

type LockedPoolParams struct {
	LockedInBlocks    int64 `` /* 130-byte string literal not displayed */
	MinimumCollateral int64 `` /* 139-byte string literal not displayed */
}

func DefaultLockedPoolParams 

func DefaultLockedPoolParams() LockedPoolParams

DefaultLockedPoolParams generates default set for LockedPoolParams

func NewLockedPoolParams 

func NewLockedPoolParams(lockedInBlocks, minimumCollateral int64) LockedPoolParams

NewLockedPoolParams returns a LockedPoolParams object.

func (*LockedPoolParams) Descriptor 

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

func (*LockedPoolParams) Marshal 

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

func (*LockedPoolParams) MarshalTo 

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

func (*LockedPoolParams) MarshalToSizedBuffer 

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

func (*LockedPoolParams) ProtoMessage 

func (*LockedPoolParams) ProtoMessage()

func (*LockedPoolParams) Reset 

func (m *LockedPoolParams) Reset()

func (*LockedPoolParams) Size 

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

func (*LockedPoolParams) String 

func (m *LockedPoolParams) String() string

func (*LockedPoolParams) Unmarshal 

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

func (*LockedPoolParams) XXX_DiscardUnknown 

func (m *LockedPoolParams) XXX_DiscardUnknown()

func (*LockedPoolParams) XXX_Marshal 

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

func (*LockedPoolParams) XXX_Merge 

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

func (*LockedPoolParams) XXX_Size 

func (m *LockedPoolParams) XXX_Size() int

func (*LockedPoolParams) XXX_Unmarshal 

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

type MsgAddCollateral 

type MsgAddCollateral struct {
	Address             string                                   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	CollateralIncrement github_com_cosmos_cosmos_sdk_types.Coins `` /* 190-byte string literal not displayed */
}

func NewMsgAddCollateral 

func NewMsgAddCollateral(address sdk.AccAddress, increment sdk.Coins) *MsgAddCollateral

NewMsgAddCollateral returns the message for adding collateral.

func (*MsgAddCollateral) Descriptor 

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

func (MsgAddCollateral) GetSignBytes 

func (m MsgAddCollateral) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgAddCollateral) GetSigners 

func (m MsgAddCollateral) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgAddCollateral) Marshal 

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

func (*MsgAddCollateral) MarshalTo 

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

func (*MsgAddCollateral) MarshalToSizedBuffer 

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

func (*MsgAddCollateral) ProtoMessage 

func (*MsgAddCollateral) ProtoMessage()

func (*MsgAddCollateral) Reset 

func (m *MsgAddCollateral) Reset()

func (MsgAddCollateral) Route 

func (MsgAddCollateral) Route() string

Route returns the module name.

func (*MsgAddCollateral) Size 

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

func (*MsgAddCollateral) String 

func (m *MsgAddCollateral) String() string

func (MsgAddCollateral) Type 

func (MsgAddCollateral) Type() string

Type returns the action name.

func (*MsgAddCollateral) Unmarshal 

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

func (MsgAddCollateral) ValidateBasic 

func (m MsgAddCollateral) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgAddCollateral) XXX_DiscardUnknown 

func (m *MsgAddCollateral) XXX_DiscardUnknown()

func (*MsgAddCollateral) XXX_Marshal 

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

func (*MsgAddCollateral) XXX_Merge 

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

func (*MsgAddCollateral) XXX_Size 

func (m *MsgAddCollateral) XXX_Size() int

func (*MsgAddCollateral) XXX_Unmarshal 

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

type MsgAddCollateralResponse 

type MsgAddCollateralResponse struct {
}

func (*MsgAddCollateralResponse) Descriptor 

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

func (*MsgAddCollateralResponse) Marshal 

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

func (*MsgAddCollateralResponse) MarshalTo 

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

func (*MsgAddCollateralResponse) MarshalToSizedBuffer 

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

func (*MsgAddCollateralResponse) ProtoMessage 

func (*MsgAddCollateralResponse) ProtoMessage()

func (*MsgAddCollateralResponse) Reset 

func (m *MsgAddCollateralResponse) Reset()

func (*MsgAddCollateralResponse) Size 

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

func (*MsgAddCollateralResponse) String 

func (m *MsgAddCollateralResponse) String() string

func (*MsgAddCollateralResponse) Unmarshal 

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

func (*MsgAddCollateralResponse) XXX_DiscardUnknown 

func (m *MsgAddCollateralResponse) XXX_DiscardUnknown()

func (*MsgAddCollateralResponse) XXX_Marshal 

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

func (*MsgAddCollateralResponse) XXX_Merge 

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

func (*MsgAddCollateralResponse) XXX_Size 

func (m *MsgAddCollateralResponse) XXX_Size() int

func (*MsgAddCollateralResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	CreateOperator(ctx context.Context, in *MsgCreateOperator, opts ...grpc.CallOption) (*MsgCreateOperatorResponse, error)
	RemoveOperator(ctx context.Context, in *MsgRemoveOperator, opts ...grpc.CallOption) (*MsgRemoveOperatorResponse, error)
	AddCollateral(ctx context.Context, in *MsgAddCollateral, opts ...grpc.CallOption) (*MsgAddCollateralResponse, error)
	ReduceCollateral(ctx context.Context, in *MsgReduceCollateral, opts ...grpc.CallOption) (*MsgReduceCollateralResponse, error)
	WithdrawReward(ctx context.Context, in *MsgWithdrawReward, opts ...grpc.CallOption) (*MsgWithdrawRewardResponse, error)
	CreateTask(ctx context.Context, in *MsgCreateTask, opts ...grpc.CallOption) (*MsgCreateTaskResponse, error)
	TaskResponse(ctx context.Context, in *MsgTaskResponse, opts ...grpc.CallOption) (*MsgTaskResponseResponse, error)
	DeleteTask(ctx context.Context, in *MsgDeleteTask, opts ...grpc.CallOption) (*MsgDeleteTaskResponse, error)
	CreateTxTask(ctx context.Context, in *MsgCreateTxTask, opts ...grpc.CallOption) (*MsgCreateTxTaskResponse, error)
	TxTaskResponse(ctx context.Context, in *MsgTxTaskResponse, opts ...grpc.CallOption) (*MsgTxTaskResponseResponse, error)
	DeleteTxTask(ctx context.Context, in *MsgDeleteTxTask, opts ...grpc.CallOption) (*MsgDeleteTxTaskResponse, 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 MsgCreateOperator 

type MsgCreateOperator struct {
	Address    string                                   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	Collateral github_com_cosmos_cosmos_sdk_types.Coins `` /* 135-byte string literal not displayed */
	Proposer   string                                   `protobuf:"bytes,3,opt,name=proposer,proto3" json:"proposer,omitempty" yaml:"proposer"`
	Name       string                                   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty" yaml:"name"`
}

func NewMsgCreateOperator 

func NewMsgCreateOperator(address sdk.AccAddress, collateral sdk.Coins, proposer sdk.AccAddress, name string) *MsgCreateOperator

NewMsgCreateOperator returns the message for creating an operator.

func (*MsgCreateOperator) Descriptor 

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

func (MsgCreateOperator) GetSignBytes 

func (m MsgCreateOperator) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgCreateOperator) GetSigners 

func (m MsgCreateOperator) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgCreateOperator) Marshal 

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

func (*MsgCreateOperator) MarshalTo 

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

func (*MsgCreateOperator) MarshalToSizedBuffer 

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

func (*MsgCreateOperator) ProtoMessage 

func (*MsgCreateOperator) ProtoMessage()

func (*MsgCreateOperator) Reset 

func (m *MsgCreateOperator) Reset()

func (MsgCreateOperator) Route 

func (MsgCreateOperator) Route() string

Route returns the module name.

func (*MsgCreateOperator) Size 

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

func (*MsgCreateOperator) String 

func (m *MsgCreateOperator) String() string

func (MsgCreateOperator) Type 

func (MsgCreateOperator) Type() string

Type returns the action name.

func (*MsgCreateOperator) Unmarshal 

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

func (MsgCreateOperator) ValidateBasic 

func (m MsgCreateOperator) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgCreateOperator) XXX_DiscardUnknown 

func (m *MsgCreateOperator) XXX_DiscardUnknown()

func (*MsgCreateOperator) XXX_Marshal 

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

func (*MsgCreateOperator) XXX_Merge 

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

func (*MsgCreateOperator) XXX_Size 

func (m *MsgCreateOperator) XXX_Size() int

func (*MsgCreateOperator) XXX_Unmarshal 

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

type MsgCreateOperatorResponse 

type MsgCreateOperatorResponse struct {
}

func (*MsgCreateOperatorResponse) Descriptor 

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

func (*MsgCreateOperatorResponse) Marshal 

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

func (*MsgCreateOperatorResponse) MarshalTo 

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

func (*MsgCreateOperatorResponse) MarshalToSizedBuffer 

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

func (*MsgCreateOperatorResponse) ProtoMessage 

func (*MsgCreateOperatorResponse) ProtoMessage()

func (*MsgCreateOperatorResponse) Reset 

func (m *MsgCreateOperatorResponse) Reset()

func (*MsgCreateOperatorResponse) Size 

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

func (*MsgCreateOperatorResponse) String 

func (m *MsgCreateOperatorResponse) String() string

func (*MsgCreateOperatorResponse) Unmarshal 

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

func (*MsgCreateOperatorResponse) XXX_DiscardUnknown 

func (m *MsgCreateOperatorResponse) XXX_DiscardUnknown()

func (*MsgCreateOperatorResponse) XXX_Marshal 

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

func (*MsgCreateOperatorResponse) XXX_Merge 

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

func (*MsgCreateOperatorResponse) XXX_Size 

func (m *MsgCreateOperatorResponse) XXX_Size() int

func (*MsgCreateOperatorResponse) XXX_Unmarshal 

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

type MsgCreateTask 

type MsgCreateTask struct {
	Contract      string                                   `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty" yaml:"contract"`
	Function      string                                   `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty" yaml:"function"`
	Bounty        github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=bounty,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"bounty" yaml:"bounty"`
	Description   string                                   `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty" yaml:"description"`
	Creator       string                                   `protobuf:"bytes,5,opt,name=creator,proto3" json:"creator,omitempty" yaml:"creator"`
	Wait          int64                                    `protobuf:"varint,6,opt,name=wait,proto3" json:"wait,omitempty" yaml:"wait"`
	ValidDuration time.Duration                            `protobuf:"bytes,7,opt,name=valid_duration,json=validDuration,proto3,stdduration" json:"valid_duration" yaml:"valid_duration"`
}

func NewMsgCreateTask 

func NewMsgCreateTask(contract, function string, bounty sdk.Coins, description string,
	creator sdk.AccAddress, wait int64, validDuration time.Duration) *MsgCreateTask

NewMsgCreateTask returns a new message for creating a task.

func (*MsgCreateTask) Descriptor 

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

func (MsgCreateTask) GetSignBytes 

func (m MsgCreateTask) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgCreateTask) GetSigners 

func (m MsgCreateTask) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgCreateTask) Marshal 

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

func (*MsgCreateTask) MarshalTo 

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

func (*MsgCreateTask) MarshalToSizedBuffer 

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

func (*MsgCreateTask) ProtoMessage 

func (*MsgCreateTask) ProtoMessage()

func (*MsgCreateTask) Reset 

func (m *MsgCreateTask) Reset()

func (MsgCreateTask) Route 

func (MsgCreateTask) Route() string

Route returns the module name.

func (*MsgCreateTask) Size 

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

func (*MsgCreateTask) String 

func (m *MsgCreateTask) String() string

func (MsgCreateTask) Type 

func (MsgCreateTask) Type() string

Type returns the action name.

func (*MsgCreateTask) Unmarshal 

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

func (MsgCreateTask) ValidateBasic 

func (m MsgCreateTask) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgCreateTask) XXX_DiscardUnknown 

func (m *MsgCreateTask) XXX_DiscardUnknown()

func (*MsgCreateTask) XXX_Marshal 

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

func (*MsgCreateTask) XXX_Merge 

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

func (*MsgCreateTask) XXX_Size 

func (m *MsgCreateTask) XXX_Size() int

func (*MsgCreateTask) XXX_Unmarshal 

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

type MsgCreateTaskResponse 

type MsgCreateTaskResponse struct {
}

func (*MsgCreateTaskResponse) Descriptor 

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

func (*MsgCreateTaskResponse) Marshal 

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

func (*MsgCreateTaskResponse) MarshalTo 

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

func (*MsgCreateTaskResponse) MarshalToSizedBuffer 

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

func (*MsgCreateTaskResponse) ProtoMessage 

func (*MsgCreateTaskResponse) ProtoMessage()

func (*MsgCreateTaskResponse) Reset 

func (m *MsgCreateTaskResponse) Reset()

func (*MsgCreateTaskResponse) Size 

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

func (*MsgCreateTaskResponse) String 

func (m *MsgCreateTaskResponse) String() string

func (*MsgCreateTaskResponse) Unmarshal 

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

func (*MsgCreateTaskResponse) XXX_DiscardUnknown 

func (m *MsgCreateTaskResponse) XXX_DiscardUnknown()

func (*MsgCreateTaskResponse) XXX_Marshal 

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

func (*MsgCreateTaskResponse) XXX_Merge 

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

func (*MsgCreateTaskResponse) XXX_Size 

func (m *MsgCreateTaskResponse) XXX_Size() int

func (*MsgCreateTaskResponse) XXX_Unmarshal 

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

type MsgCreateTxTask added in v2.7.0 

type MsgCreateTxTask struct {
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty" yaml:"creator"`
	ChainId string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty" yaml:"chain_id"`
	// the bytes of application chain transaction that is going to be evaluated
	AtxBytes  []byte                                   `protobuf:"bytes,3,opt,name=atx_bytes,json=atxBytes,proto3" json:"atx_bytes,omitempty" yaml:"atx_bytes"`
	Bounty    github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=bounty,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"bounty" yaml:"bounty"`
	ValidTime time.Time                                `protobuf:"bytes,5,opt,name=valid_time,json=validTime,proto3,stdtime" json:"valid_time" yaml:"valid_time"`
}

func NewMsgCreateTxTask added in v2.7.0 

func NewMsgCreateTxTask(creator sdk.AccAddress, chainID string, txBytes []byte,
	bounty sdk.Coins, validTime time.Time) *MsgCreateTxTask

NewMsgCreateTxTask returns a new MsgCreateTxTask instance.

func (*MsgCreateTxTask) Descriptor added in v2.7.0 

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

func (MsgCreateTxTask) GetSignBytes added in v2.7.0 

func (m MsgCreateTxTask) GetSignBytes() []byte

GetSignBytes encodes the message for signing. LegacyMsg interface for Amino

func (MsgCreateTxTask) GetSigners added in v2.7.0 

func (m MsgCreateTxTask) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgCreateTxTask) Marshal added in v2.7.0 

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

func (*MsgCreateTxTask) MarshalTo added in v2.7.0 

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

func (*MsgCreateTxTask) MarshalToSizedBuffer added in v2.7.0 

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

func (*MsgCreateTxTask) ProtoMessage added in v2.7.0 

func (*MsgCreateTxTask) ProtoMessage()

func (*MsgCreateTxTask) Reset added in v2.7.0 

func (m *MsgCreateTxTask) Reset()

func (MsgCreateTxTask) Route added in v2.7.0 

func (MsgCreateTxTask) Route() string

Route returns the module name.

func (*MsgCreateTxTask) Size added in v2.7.0 

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

func (*MsgCreateTxTask) String added in v2.7.0 

func (m *MsgCreateTxTask) String() string

func (MsgCreateTxTask) Type added in v2.7.0 

func (MsgCreateTxTask) Type() string

Type returns the action name.

func (*MsgCreateTxTask) Unmarshal added in v2.7.0 

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

func (MsgCreateTxTask) ValidateBasic added in v2.7.0 

func (m MsgCreateTxTask) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgCreateTxTask) XXX_DiscardUnknown added in v2.7.0 

func (m *MsgCreateTxTask) XXX_DiscardUnknown()

func (*MsgCreateTxTask) XXX_Marshal added in v2.7.0 

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

func (*MsgCreateTxTask) XXX_Merge added in v2.7.0 

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

func (*MsgCreateTxTask) XXX_Size added in v2.7.0 

func (m *MsgCreateTxTask) XXX_Size() int

func (*MsgCreateTxTask) XXX_Unmarshal added in v2.7.0 

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

type MsgCreateTxTaskResponse added in v2.7.0 

type MsgCreateTxTaskResponse struct {
	// sha256 hash of the application chain transaction
	AtxHash []byte `protobuf:"bytes,1,opt,name=atx_hash,json=atxHash,proto3" json:"atx_hash,omitempty"`
}

func (*MsgCreateTxTaskResponse) Descriptor added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) Marshal added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) MarshalTo added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) MarshalToSizedBuffer added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) ProtoMessage added in v2.7.0 

func (*MsgCreateTxTaskResponse) ProtoMessage()

func (*MsgCreateTxTaskResponse) Reset added in v2.7.0 

func (m *MsgCreateTxTaskResponse) Reset()

func (*MsgCreateTxTaskResponse) Size added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) String added in v2.7.0 

func (m *MsgCreateTxTaskResponse) String() string

func (*MsgCreateTxTaskResponse) Unmarshal added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) XXX_DiscardUnknown added in v2.7.0 

func (m *MsgCreateTxTaskResponse) XXX_DiscardUnknown()

func (*MsgCreateTxTaskResponse) XXX_Marshal added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) XXX_Merge added in v2.7.0 

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

func (*MsgCreateTxTaskResponse) XXX_Size added in v2.7.0 

func (m *MsgCreateTxTaskResponse) XXX_Size() int

func (*MsgCreateTxTaskResponse) XXX_Unmarshal added in v2.7.0 

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

type MsgDeleteTask 

type MsgDeleteTask struct {
	Contract string `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty" yaml:"contract"`
	Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty" yaml:"function"`
	Force    bool   `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty" yaml:"force"`
	From     string `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
}

func NewMsgDeleteTask 

func NewMsgDeleteTask(contract, function string, force bool, deleter sdk.AccAddress) *MsgDeleteTask

NewMsgDeleteTask returns a new MsgDeleteTask instance.

func (*MsgDeleteTask) Descriptor 

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

func (MsgDeleteTask) GetSignBytes 

func (m MsgDeleteTask) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgDeleteTask) GetSigners 

func (m MsgDeleteTask) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgDeleteTask) Marshal 

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

func (*MsgDeleteTask) MarshalTo 

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

func (*MsgDeleteTask) MarshalToSizedBuffer 

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

func (*MsgDeleteTask) ProtoMessage 

func (*MsgDeleteTask) ProtoMessage()

func (*MsgDeleteTask) Reset 

func (m *MsgDeleteTask) Reset()

func (MsgDeleteTask) Route 

func (MsgDeleteTask) Route() string

Route returns the module name.

func (*MsgDeleteTask) Size 

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

func (*MsgDeleteTask) String 

func (m *MsgDeleteTask) String() string

func (MsgDeleteTask) Type 

func (MsgDeleteTask) Type() string

Type returns the action name.

func (*MsgDeleteTask) Unmarshal 

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

func (MsgDeleteTask) ValidateBasic 

func (m MsgDeleteTask) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgDeleteTask) XXX_DiscardUnknown 

func (m *MsgDeleteTask) XXX_DiscardUnknown()

func (*MsgDeleteTask) XXX_Marshal 

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

func (*MsgDeleteTask) XXX_Merge 

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

func (*MsgDeleteTask) XXX_Size 

func (m *MsgDeleteTask) XXX_Size() int

func (*MsgDeleteTask) XXX_Unmarshal 

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

type MsgDeleteTaskResponse 

type MsgDeleteTaskResponse struct {
}

func (*MsgDeleteTaskResponse) Descriptor 

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

func (*MsgDeleteTaskResponse) Marshal 

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

func (*MsgDeleteTaskResponse) MarshalTo 

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

func (*MsgDeleteTaskResponse) MarshalToSizedBuffer 

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

func (*MsgDeleteTaskResponse) ProtoMessage 

func (*MsgDeleteTaskResponse) ProtoMessage()

func (*MsgDeleteTaskResponse) Reset 

func (m *MsgDeleteTaskResponse) Reset()

func (*MsgDeleteTaskResponse) Size 

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

func (*MsgDeleteTaskResponse) String 

func (m *MsgDeleteTaskResponse) String() string

func (*MsgDeleteTaskResponse) Unmarshal 

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

func (*MsgDeleteTaskResponse) XXX_DiscardUnknown 

func (m *MsgDeleteTaskResponse) XXX_DiscardUnknown()

func (*MsgDeleteTaskResponse) XXX_Marshal 

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

func (*MsgDeleteTaskResponse) XXX_Merge 

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

func (*MsgDeleteTaskResponse) XXX_Size 

func (m *MsgDeleteTaskResponse) XXX_Size() int

func (*MsgDeleteTaskResponse) XXX_Unmarshal 

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

type MsgDeleteTxTask added in v2.7.0 

type MsgDeleteTxTask struct {
	// sha256 hash of the application chain transaction
	AtxHash []byte `protobuf:"bytes,1,opt,name=atx_hash,json=atxHash,proto3" json:"atx_hash,omitempty" yaml:"atx_hash"`
	From    string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
}

func NewMsgDeleteTxTask added in v2.7.0 

func NewMsgDeleteTxTask(txHash []byte, deleter sdk.AccAddress) *MsgDeleteTxTask

func (*MsgDeleteTxTask) Descriptor added in v2.7.0 

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

func (MsgDeleteTxTask) GetSignBytes added in v2.7.0 

func (m MsgDeleteTxTask) GetSignBytes() []byte

LegacyMsg interface for Amino

func (MsgDeleteTxTask) GetSigners added in v2.7.0 

func (m MsgDeleteTxTask) GetSigners() []sdk.AccAddress

Msg interface, return the account that should sign the tx

func (*MsgDeleteTxTask) Marshal added in v2.7.0 

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

func (*MsgDeleteTxTask) MarshalTo added in v2.7.0 

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

func (*MsgDeleteTxTask) MarshalToSizedBuffer added in v2.7.0 

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

func (*MsgDeleteTxTask) ProtoMessage added in v2.7.0 

func (*MsgDeleteTxTask) ProtoMessage()

func (*MsgDeleteTxTask) Reset added in v2.7.0 

func (m *MsgDeleteTxTask) Reset()

func (MsgDeleteTxTask) Route added in v2.7.0 

func (MsgDeleteTxTask) Route() string

LegacyMsg interface for Amino

func (*MsgDeleteTxTask) Size added in v2.7.0 

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

func (*MsgDeleteTxTask) String added in v2.7.0 

func (m *MsgDeleteTxTask) String() string

func (MsgDeleteTxTask) Type added in v2.7.0 

func (MsgDeleteTxTask) Type() string

LegacyMsg interface for Amino

func (*MsgDeleteTxTask) Unmarshal added in v2.7.0 

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

func (MsgDeleteTxTask) ValidateBasic added in v2.7.0 

func (m MsgDeleteTxTask) ValidateBasic() error

Msg interface

func (*MsgDeleteTxTask) XXX_DiscardUnknown added in v2.7.0 

func (m *MsgDeleteTxTask) XXX_DiscardUnknown()

func (*MsgDeleteTxTask) XXX_Marshal added in v2.7.0 

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

func (*MsgDeleteTxTask) XXX_Merge added in v2.7.0 

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

func (*MsgDeleteTxTask) XXX_Size added in v2.7.0 

func (m *MsgDeleteTxTask) XXX_Size() int

func (*MsgDeleteTxTask) XXX_Unmarshal added in v2.7.0 

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

type MsgDeleteTxTaskResponse added in v2.7.0 

type MsgDeleteTxTaskResponse struct {
}

func (*MsgDeleteTxTaskResponse) Descriptor added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) Marshal added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) MarshalTo added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) MarshalToSizedBuffer added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) ProtoMessage added in v2.7.0 

func (*MsgDeleteTxTaskResponse) ProtoMessage()

func (*MsgDeleteTxTaskResponse) Reset added in v2.7.0 

func (m *MsgDeleteTxTaskResponse) Reset()

func (*MsgDeleteTxTaskResponse) Size added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) String added in v2.7.0 

func (m *MsgDeleteTxTaskResponse) String() string

func (*MsgDeleteTxTaskResponse) Unmarshal added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) XXX_DiscardUnknown added in v2.7.0 

func (m *MsgDeleteTxTaskResponse) XXX_DiscardUnknown()

func (*MsgDeleteTxTaskResponse) XXX_Marshal added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) XXX_Merge added in v2.7.0 

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

func (*MsgDeleteTxTaskResponse) XXX_Size added in v2.7.0 

func (m *MsgDeleteTxTaskResponse) XXX_Size() int

func (*MsgDeleteTxTaskResponse) XXX_Unmarshal added in v2.7.0 

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

type MsgReduceCollateral 

type MsgReduceCollateral struct {
	Address             string                                   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	CollateralDecrement github_com_cosmos_cosmos_sdk_types.Coins `` /* 190-byte string literal not displayed */
}

func NewMsgReduceCollateral 

func NewMsgReduceCollateral(address sdk.AccAddress, decrement sdk.Coins) *MsgReduceCollateral

NewMsgReduceCollateral returns the message for reducing collateral.

func (*MsgReduceCollateral) Descriptor 

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

func (MsgReduceCollateral) GetSignBytes 

func (m MsgReduceCollateral) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgReduceCollateral) GetSigners 

func (m MsgReduceCollateral) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgReduceCollateral) Marshal 

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

func (*MsgReduceCollateral) MarshalTo 

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

func (*MsgReduceCollateral) MarshalToSizedBuffer 

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

func (*MsgReduceCollateral) ProtoMessage 

func (*MsgReduceCollateral) ProtoMessage()

func (*MsgReduceCollateral) Reset 

func (m *MsgReduceCollateral) Reset()

func (MsgReduceCollateral) Route 

func (MsgReduceCollateral) Route() string

Route returns the module name.

func (*MsgReduceCollateral) Size 

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

func (*MsgReduceCollateral) String 

func (m *MsgReduceCollateral) String() string

func (MsgReduceCollateral) Type 

func (MsgReduceCollateral) Type() string

Type returns the action name.

func (*MsgReduceCollateral) Unmarshal 

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

func (MsgReduceCollateral) ValidateBasic 

func (m MsgReduceCollateral) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgReduceCollateral) XXX_DiscardUnknown 

func (m *MsgReduceCollateral) XXX_DiscardUnknown()

func (*MsgReduceCollateral) XXX_Marshal 

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

func (*MsgReduceCollateral) XXX_Merge 

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

func (*MsgReduceCollateral) XXX_Size 

func (m *MsgReduceCollateral) XXX_Size() int

func (*MsgReduceCollateral) XXX_Unmarshal 

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

type MsgReduceCollateralResponse 

type MsgReduceCollateralResponse struct {
}

func (*MsgReduceCollateralResponse) Descriptor 

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

func (*MsgReduceCollateralResponse) Marshal 

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

func (*MsgReduceCollateralResponse) MarshalTo 

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

func (*MsgReduceCollateralResponse) MarshalToSizedBuffer 

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

func (*MsgReduceCollateralResponse) ProtoMessage 

func (*MsgReduceCollateralResponse) ProtoMessage()

func (*MsgReduceCollateralResponse) Reset 

func (m *MsgReduceCollateralResponse) Reset()

func (*MsgReduceCollateralResponse) Size 

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

func (*MsgReduceCollateralResponse) String 

func (m *MsgReduceCollateralResponse) String() string

func (*MsgReduceCollateralResponse) Unmarshal 

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

func (*MsgReduceCollateralResponse) XXX_DiscardUnknown 

func (m *MsgReduceCollateralResponse) XXX_DiscardUnknown()

func (*MsgReduceCollateralResponse) XXX_Marshal 

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

func (*MsgReduceCollateralResponse) XXX_Merge 

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

func (*MsgReduceCollateralResponse) XXX_Size 

func (m *MsgReduceCollateralResponse) XXX_Size() int

func (*MsgReduceCollateralResponse) XXX_Unmarshal 

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

type MsgRemoveOperator 

type MsgRemoveOperator struct {
	Address  string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	Proposer string `protobuf:"bytes,2,opt,name=proposer,proto3" json:"proposer,omitempty" yaml:"proposer"`
}

func NewMsgRemoveOperator 

func NewMsgRemoveOperator(address sdk.AccAddress, proposer sdk.AccAddress) *MsgRemoveOperator

NewMsgRemoveOperator returns the message for removing an operator.

func (*MsgRemoveOperator) Descriptor 

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

func (MsgRemoveOperator) GetSignBytes 

func (m MsgRemoveOperator) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgRemoveOperator) GetSigners 

func (m MsgRemoveOperator) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgRemoveOperator) Marshal 

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

func (*MsgRemoveOperator) MarshalTo 

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

func (*MsgRemoveOperator) MarshalToSizedBuffer 

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

func (*MsgRemoveOperator) ProtoMessage 

func (*MsgRemoveOperator) ProtoMessage()

func (*MsgRemoveOperator) Reset 

func (m *MsgRemoveOperator) Reset()

func (MsgRemoveOperator) Route 

func (MsgRemoveOperator) Route() string

Route returns the module name.

func (*MsgRemoveOperator) Size 

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

func (*MsgRemoveOperator) String 

func (m *MsgRemoveOperator) String() string

func (MsgRemoveOperator) Type 

func (MsgRemoveOperator) Type() string

Type returns the action name.

func (*MsgRemoveOperator) Unmarshal 

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

func (MsgRemoveOperator) ValidateBasic 

func (m MsgRemoveOperator) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgRemoveOperator) XXX_DiscardUnknown 

func (m *MsgRemoveOperator) XXX_DiscardUnknown()

func (*MsgRemoveOperator) XXX_Marshal 

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

func (*MsgRemoveOperator) XXX_Merge 

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

func (*MsgRemoveOperator) XXX_Size 

func (m *MsgRemoveOperator) XXX_Size() int

func (*MsgRemoveOperator) XXX_Unmarshal 

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

type MsgRemoveOperatorResponse 

type MsgRemoveOperatorResponse struct {
}

func (*MsgRemoveOperatorResponse) Descriptor 

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

func (*MsgRemoveOperatorResponse) Marshal 

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

func (*MsgRemoveOperatorResponse) MarshalTo 

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

func (*MsgRemoveOperatorResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveOperatorResponse) ProtoMessage 

func (*MsgRemoveOperatorResponse) ProtoMessage()

func (*MsgRemoveOperatorResponse) Reset 

func (m *MsgRemoveOperatorResponse) Reset()

func (*MsgRemoveOperatorResponse) Size 

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

func (*MsgRemoveOperatorResponse) String 

func (m *MsgRemoveOperatorResponse) String() string

func (*MsgRemoveOperatorResponse) Unmarshal 

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

func (*MsgRemoveOperatorResponse) XXX_DiscardUnknown 

func (m *MsgRemoveOperatorResponse) XXX_DiscardUnknown()

func (*MsgRemoveOperatorResponse) XXX_Marshal 

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

func (*MsgRemoveOperatorResponse) XXX_Merge 

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

func (*MsgRemoveOperatorResponse) XXX_Size 

func (m *MsgRemoveOperatorResponse) XXX_Size() int

func (*MsgRemoveOperatorResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	CreateOperator(context.Context, *MsgCreateOperator) (*MsgCreateOperatorResponse, error)
	RemoveOperator(context.Context, *MsgRemoveOperator) (*MsgRemoveOperatorResponse, error)
	AddCollateral(context.Context, *MsgAddCollateral) (*MsgAddCollateralResponse, error)
	ReduceCollateral(context.Context, *MsgReduceCollateral) (*MsgReduceCollateralResponse, error)
	WithdrawReward(context.Context, *MsgWithdrawReward) (*MsgWithdrawRewardResponse, error)
	CreateTask(context.Context, *MsgCreateTask) (*MsgCreateTaskResponse, error)
	TaskResponse(context.Context, *MsgTaskResponse) (*MsgTaskResponseResponse, error)
	DeleteTask(context.Context, *MsgDeleteTask) (*MsgDeleteTaskResponse, error)
	CreateTxTask(context.Context, *MsgCreateTxTask) (*MsgCreateTxTaskResponse, error)
	TxTaskResponse(context.Context, *MsgTxTaskResponse) (*MsgTxTaskResponseResponse, error)
	DeleteTxTask(context.Context, *MsgDeleteTxTask) (*MsgDeleteTxTaskResponse, error)
}

MsgServer is the server API for Msg service.

type MsgTaskResponse 

type MsgTaskResponse struct {
	Contract string `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty" yaml:"contract"`
	Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty" yaml:"function"`
	Score    int64  `protobuf:"varint,3,opt,name=score,proto3" json:"score,omitempty" yaml:"score"`
	Operator string `protobuf:"bytes,4,opt,name=operator,proto3" json:"operator,omitempty" yaml:"operator"`
}

func NewMsgTaskResponse 

func NewMsgTaskResponse(contract, function string, score int64, operator sdk.AccAddress) *MsgTaskResponse

NewMsgTaskResponse returns a new message for responding to a task.

func (*MsgTaskResponse) Descriptor 

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

func (MsgTaskResponse) GetSignBytes 

func (m MsgTaskResponse) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgTaskResponse) GetSigners 

func (m MsgTaskResponse) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgTaskResponse) Marshal 

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

func (*MsgTaskResponse) MarshalTo 

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

func (*MsgTaskResponse) MarshalToSizedBuffer 

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

func (*MsgTaskResponse) ProtoMessage 

func (*MsgTaskResponse) ProtoMessage()

func (*MsgTaskResponse) Reset 

func (m *MsgTaskResponse) Reset()

func (MsgTaskResponse) Route 

func (MsgTaskResponse) Route() string

Route returns the module name.

func (*MsgTaskResponse) Size 

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

func (*MsgTaskResponse) String 

func (m *MsgTaskResponse) String() string

func (MsgTaskResponse) Type 

func (MsgTaskResponse) Type() string

Type returns the action name.

func (*MsgTaskResponse) Unmarshal 

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

func (MsgTaskResponse) ValidateBasic 

func (m MsgTaskResponse) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgTaskResponse) XXX_DiscardUnknown 

func (m *MsgTaskResponse) XXX_DiscardUnknown()

func (*MsgTaskResponse) XXX_Marshal 

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

func (*MsgTaskResponse) XXX_Merge 

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

func (*MsgTaskResponse) XXX_Size 

func (m *MsgTaskResponse) XXX_Size() int

func (*MsgTaskResponse) XXX_Unmarshal 

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

type MsgTaskResponseResponse 

type MsgTaskResponseResponse struct {
}

func (*MsgTaskResponseResponse) Descriptor 

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

func (*MsgTaskResponseResponse) Marshal 

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

func (*MsgTaskResponseResponse) MarshalTo 

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

func (*MsgTaskResponseResponse) MarshalToSizedBuffer 

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

func (*MsgTaskResponseResponse) ProtoMessage 

func (*MsgTaskResponseResponse) ProtoMessage()

func (*MsgTaskResponseResponse) Reset 

func (m *MsgTaskResponseResponse) Reset()

func (*MsgTaskResponseResponse) Size 

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

func (*MsgTaskResponseResponse) String 

func (m *MsgTaskResponseResponse) String() string

func (*MsgTaskResponseResponse) Unmarshal 

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

func (*MsgTaskResponseResponse) XXX_DiscardUnknown 

func (m *MsgTaskResponseResponse) XXX_DiscardUnknown()

func (*MsgTaskResponseResponse) XXX_Marshal 

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

func (*MsgTaskResponseResponse) XXX_Merge 

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

func (*MsgTaskResponseResponse) XXX_Size 

func (m *MsgTaskResponseResponse) XXX_Size() int

func (*MsgTaskResponseResponse) XXX_Unmarshal 

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

type MsgTxTaskResponse added in v2.7.0 

type MsgTxTaskResponse struct {
	// sha256 hash of the application chain transaction
	AtxHash  []byte `protobuf:"bytes,1,opt,name=atx_hash,json=atxHash,proto3" json:"atx_hash,omitempty" yaml:"atx_hash"`
	Score    int64  `protobuf:"varint,2,opt,name=score,proto3" json:"score,omitempty" yaml:"score"`
	Operator string `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty" yaml:"operator"`
}

func NewMsgTxTaskResponse added in v2.7.0 

func NewMsgTxTaskResponse(txHash []byte, score int64, operator sdk.AccAddress) *MsgTxTaskResponse

func (*MsgTxTaskResponse) Descriptor added in v2.7.0 

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

func (MsgTxTaskResponse) GetSignBytes added in v2.7.0 

func (m MsgTxTaskResponse) GetSignBytes() []byte

LegacyMsg interface for Amino

func (MsgTxTaskResponse) GetSigners added in v2.7.0 

func (m MsgTxTaskResponse) GetSigners() []sdk.AccAddress

Msg interface, return the account that should sign the tx

func (*MsgTxTaskResponse) Marshal added in v2.7.0 

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

func (*MsgTxTaskResponse) MarshalTo added in v2.7.0 

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

func (*MsgTxTaskResponse) MarshalToSizedBuffer added in v2.7.0 

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

func (*MsgTxTaskResponse) ProtoMessage added in v2.7.0 

func (*MsgTxTaskResponse) ProtoMessage()

func (*MsgTxTaskResponse) Reset added in v2.7.0 

func (m *MsgTxTaskResponse) Reset()

func (MsgTxTaskResponse) Route added in v2.7.0 

func (MsgTxTaskResponse) Route() string

LegacyMsg interface for Amino

func (*MsgTxTaskResponse) Size added in v2.7.0 

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

func (*MsgTxTaskResponse) String added in v2.7.0 

func (m *MsgTxTaskResponse) String() string

func (MsgTxTaskResponse) Type added in v2.7.0 

func (MsgTxTaskResponse) Type() string

LegacyMsg interface for Amino

func (*MsgTxTaskResponse) Unmarshal added in v2.7.0 

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

func (MsgTxTaskResponse) ValidateBasic added in v2.7.0 

func (m MsgTxTaskResponse) ValidateBasic() error

Msg interface

func (*MsgTxTaskResponse) XXX_DiscardUnknown added in v2.7.0 

func (m *MsgTxTaskResponse) XXX_DiscardUnknown()

func (*MsgTxTaskResponse) XXX_Marshal added in v2.7.0 

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

func (*MsgTxTaskResponse) XXX_Merge added in v2.7.0 

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

func (*MsgTxTaskResponse) XXX_Size added in v2.7.0 

func (m *MsgTxTaskResponse) XXX_Size() int

func (*MsgTxTaskResponse) XXX_Unmarshal added in v2.7.0 

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

type MsgTxTaskResponseResponse added in v2.7.0 

type MsgTxTaskResponseResponse struct {
}

func (*MsgTxTaskResponseResponse) Descriptor added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) Marshal added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) MarshalTo added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) MarshalToSizedBuffer added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) ProtoMessage added in v2.7.0 

func (*MsgTxTaskResponseResponse) ProtoMessage()

func (*MsgTxTaskResponseResponse) Reset added in v2.7.0 

func (m *MsgTxTaskResponseResponse) Reset()

func (*MsgTxTaskResponseResponse) Size added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) String added in v2.7.0 

func (m *MsgTxTaskResponseResponse) String() string

func (*MsgTxTaskResponseResponse) Unmarshal added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) XXX_DiscardUnknown added in v2.7.0 

func (m *MsgTxTaskResponseResponse) XXX_DiscardUnknown()

func (*MsgTxTaskResponseResponse) XXX_Marshal added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) XXX_Merge added in v2.7.0 

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

func (*MsgTxTaskResponseResponse) XXX_Size added in v2.7.0 

func (m *MsgTxTaskResponseResponse) XXX_Size() int

func (*MsgTxTaskResponseResponse) XXX_Unmarshal added in v2.7.0 

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

type MsgWithdrawReward 

type MsgWithdrawReward struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
}

func NewMsgWithdrawReward 

func NewMsgWithdrawReward(address sdk.AccAddress) *MsgWithdrawReward

NewMsgWithdrawReward returns the message for withdrawing reward.

func (*MsgWithdrawReward) Descriptor 

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

func (MsgWithdrawReward) GetSignBytes 

func (m MsgWithdrawReward) GetSignBytes() []byte

GetSignBytes encodes the message for signing.

func (MsgWithdrawReward) GetSigners 

func (m MsgWithdrawReward) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required.

func (*MsgWithdrawReward) Marshal 

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

func (*MsgWithdrawReward) MarshalTo 

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

func (*MsgWithdrawReward) MarshalToSizedBuffer 

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

func (*MsgWithdrawReward) ProtoMessage 

func (*MsgWithdrawReward) ProtoMessage()

func (*MsgWithdrawReward) Reset 

func (m *MsgWithdrawReward) Reset()

func (MsgWithdrawReward) Route 

func (MsgWithdrawReward) Route() string

Route returns the module name.

func (*MsgWithdrawReward) Size 

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

func (*MsgWithdrawReward) String 

func (m *MsgWithdrawReward) String() string

func (MsgWithdrawReward) Type 

func (MsgWithdrawReward) Type() string

Type returns the action name.

func (*MsgWithdrawReward) Unmarshal 

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

func (MsgWithdrawReward) ValidateBasic 

func (m MsgWithdrawReward) ValidateBasic() error

ValidateBasic runs stateless checks on the message.

func (*MsgWithdrawReward) XXX_DiscardUnknown 

func (m *MsgWithdrawReward) XXX_DiscardUnknown()

func (*MsgWithdrawReward) XXX_Marshal 

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

func (*MsgWithdrawReward) XXX_Merge 

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

func (*MsgWithdrawReward) XXX_Size 

func (m *MsgWithdrawReward) XXX_Size() int

func (*MsgWithdrawReward) XXX_Unmarshal 

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

type MsgWithdrawRewardResponse 

type MsgWithdrawRewardResponse struct {
}

func (*MsgWithdrawRewardResponse) Descriptor 

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

func (*MsgWithdrawRewardResponse) Marshal 

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

func (*MsgWithdrawRewardResponse) MarshalTo 

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

func (*MsgWithdrawRewardResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawRewardResponse) ProtoMessage 

func (*MsgWithdrawRewardResponse) ProtoMessage()

func (*MsgWithdrawRewardResponse) Reset 

func (m *MsgWithdrawRewardResponse) Reset()

func (*MsgWithdrawRewardResponse) Size 

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

func (*MsgWithdrawRewardResponse) String 

func (m *MsgWithdrawRewardResponse) String() string

func (*MsgWithdrawRewardResponse) Unmarshal 

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

func (*MsgWithdrawRewardResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawRewardResponse) XXX_DiscardUnknown()

func (*MsgWithdrawRewardResponse) XXX_Marshal 

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

func (*MsgWithdrawRewardResponse) XXX_Merge 

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

func (*MsgWithdrawRewardResponse) XXX_Size 

func (m *MsgWithdrawRewardResponse) XXX_Size() int

func (*MsgWithdrawRewardResponse) XXX_Unmarshal 

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

type Operator 

type Operator struct {
	Address            string                                   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	Proposer           string                                   `protobuf:"bytes,2,opt,name=proposer,proto3" json:"proposer,omitempty" yaml:"proposer"`
	Collateral         github_com_cosmos_cosmos_sdk_types.Coins `` /* 135-byte string literal not displayed */
	AccumulatedRewards github_com_cosmos_cosmos_sdk_types.Coins `` /* 186-byte string literal not displayed */
	Name               string                                   `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty" yaml:"name"`
}

func NewOperator 

func NewOperator(address sdk.AccAddress, proposer sdk.AccAddress, collateral sdk.Coins,
	accumulatedRewards sdk.Coins, name string) Operator

NewOperator returns an Operator object.

func (*Operator) Descriptor 

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

func (*Operator) Marshal 

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

func (*Operator) MarshalTo 

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

func (*Operator) MarshalToSizedBuffer 

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

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) Reset 

func (m *Operator) Reset()

func (*Operator) Size 

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

func (*Operator) String 

func (m *Operator) String() string

func (*Operator) Unmarshal 

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

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

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

func (*Operator) XXX_Merge 

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

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

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

type Operators 

type Operators []Operator

func (Operators) String 

func (operators Operators) String() (out string)

type ParamSubspace 

type ParamSubspace interface {
	Get(ctx sdk.Context, key []byte, ptr interface{})
	Set(ctx sdk.Context, key []byte, param interface{})
}

type QueryClient 

type QueryClient interface {
	Operator(ctx context.Context, in *QueryOperatorRequest, opts ...grpc.CallOption) (*QueryOperatorResponse, error)
	Operators(ctx context.Context, in *QueryOperatorsRequest, opts ...grpc.CallOption) (*QueryOperatorsResponse, error)
	Withdraws(ctx context.Context, in *QueryWithdrawsRequest, opts ...grpc.CallOption) (*QueryWithdrawsResponse, error)
	Task(ctx context.Context, in *QueryTaskRequest, opts ...grpc.CallOption) (*QueryTaskResponse, error)
	TxTask(ctx context.Context, in *QueryTxTaskRequest, opts ...grpc.CallOption) (*QueryTxTaskResponse, error)
	Response(ctx context.Context, in *QueryResponseRequest, opts ...grpc.CallOption) (*QueryResponseResponse, error)
	TxResponse(ctx context.Context, in *QueryTxResponseRequest, opts ...grpc.CallOption) (*QueryTxResponseResponse, error)
	// Params queries all parameters of the oracle module.
	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 QueryOperatorRequest 

type QueryOperatorRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func (*QueryOperatorRequest) Descriptor 

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

func (*QueryOperatorRequest) GetAddress 

func (m *QueryOperatorRequest) GetAddress() string

func (*QueryOperatorRequest) Marshal 

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

func (*QueryOperatorRequest) MarshalTo 

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

func (*QueryOperatorRequest) MarshalToSizedBuffer 

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

func (*QueryOperatorRequest) ProtoMessage 

func (*QueryOperatorRequest) ProtoMessage()

func (*QueryOperatorRequest) Reset 

func (m *QueryOperatorRequest) Reset()

func (*QueryOperatorRequest) Size 

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

func (*QueryOperatorRequest) String 

func (m *QueryOperatorRequest) String() string

func (*QueryOperatorRequest) Unmarshal 

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

func (*QueryOperatorRequest) XXX_DiscardUnknown 

func (m *QueryOperatorRequest) XXX_DiscardUnknown()

func (*QueryOperatorRequest) XXX_Marshal 

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

func (*QueryOperatorRequest) XXX_Merge 

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

func (*QueryOperatorRequest) XXX_Size 

func (m *QueryOperatorRequest) XXX_Size() int

func (*QueryOperatorRequest) XXX_Unmarshal 

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

type QueryOperatorResponse 

type QueryOperatorResponse struct {
	Operator Operator `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator"`
}

func (*QueryOperatorResponse) Descriptor 

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

func (*QueryOperatorResponse) GetOperator 

func (m *QueryOperatorResponse) GetOperator() Operator

func (*QueryOperatorResponse) Marshal 

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

func (*QueryOperatorResponse) MarshalTo 

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

func (*QueryOperatorResponse) MarshalToSizedBuffer 

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

func (*QueryOperatorResponse) ProtoMessage 

func (*QueryOperatorResponse) ProtoMessage()

func (*QueryOperatorResponse) Reset 

func (m *QueryOperatorResponse) Reset()

func (*QueryOperatorResponse) Size 

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

func (*QueryOperatorResponse) String 

func (m *QueryOperatorResponse) String() string

func (*QueryOperatorResponse) Unmarshal 

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

func (*QueryOperatorResponse) XXX_DiscardUnknown 

func (m *QueryOperatorResponse) XXX_DiscardUnknown()

func (*QueryOperatorResponse) XXX_Marshal 

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

func (*QueryOperatorResponse) XXX_Merge 

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

func (*QueryOperatorResponse) XXX_Size 

func (m *QueryOperatorResponse) XXX_Size() int

func (*QueryOperatorResponse) XXX_Unmarshal 

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

type QueryOperatorsRequest 

type QueryOperatorsRequest struct {
}

func (*QueryOperatorsRequest) Descriptor 

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

func (*QueryOperatorsRequest) Marshal 

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

func (*QueryOperatorsRequest) MarshalTo 

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

func (*QueryOperatorsRequest) MarshalToSizedBuffer 

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

func (*QueryOperatorsRequest) ProtoMessage 

func (*QueryOperatorsRequest) ProtoMessage()

func (*QueryOperatorsRequest) Reset 

func (m *QueryOperatorsRequest) Reset()

func (*QueryOperatorsRequest) Size 

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

func (*QueryOperatorsRequest) String 

func (m *QueryOperatorsRequest) String() string

func (*QueryOperatorsRequest) Unmarshal 

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

func (*QueryOperatorsRequest) XXX_DiscardUnknown 

func (m *QueryOperatorsRequest) XXX_DiscardUnknown()

func (*QueryOperatorsRequest) XXX_Marshal 

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

func (*QueryOperatorsRequest) XXX_Merge 

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

func (*QueryOperatorsRequest) XXX_Size 

func (m *QueryOperatorsRequest) XXX_Size() int

func (*QueryOperatorsRequest) XXX_Unmarshal 

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

type QueryOperatorsResponse 

type QueryOperatorsResponse struct {
	Operators []Operator `protobuf:"bytes,1,rep,name=operators,proto3" json:"operators"`
}

func (*QueryOperatorsResponse) Descriptor 

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

func (*QueryOperatorsResponse) GetOperators 

func (m *QueryOperatorsResponse) GetOperators() []Operator

func (*QueryOperatorsResponse) Marshal 

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

func (*QueryOperatorsResponse) MarshalTo 

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

func (*QueryOperatorsResponse) MarshalToSizedBuffer 

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

func (*QueryOperatorsResponse) ProtoMessage 

func (*QueryOperatorsResponse) ProtoMessage()

func (*QueryOperatorsResponse) Reset 

func (m *QueryOperatorsResponse) Reset()

func (*QueryOperatorsResponse) Size 

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

func (*QueryOperatorsResponse) String 

func (m *QueryOperatorsResponse) String() string

func (*QueryOperatorsResponse) Unmarshal 

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

func (*QueryOperatorsResponse) XXX_DiscardUnknown 

func (m *QueryOperatorsResponse) XXX_DiscardUnknown()

func (*QueryOperatorsResponse) XXX_Marshal 

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

func (*QueryOperatorsResponse) XXX_Merge 

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

func (*QueryOperatorsResponse) XXX_Size 

func (m *QueryOperatorsResponse) XXX_Size() int

func (*QueryOperatorsResponse) XXX_Unmarshal 

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

type QueryParamsRequest added in v2.7.1 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor added in v2.7.1 

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

func (*QueryParamsRequest) Marshal added in v2.7.1 

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

func (*QueryParamsRequest) MarshalTo added in v2.7.1 

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

func (*QueryParamsRequest) MarshalToSizedBuffer added in v2.7.1 

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

func (*QueryParamsRequest) ProtoMessage added in v2.7.1 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v2.7.1 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v2.7.1 

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

func (*QueryParamsRequest) String added in v2.7.1 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v2.7.1 

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

func (*QueryParamsRequest) XXX_DiscardUnknown added in v2.7.1 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v2.7.1 

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

func (*QueryParamsRequest) XXX_Merge added in v2.7.1 

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

func (*QueryParamsRequest) XXX_Size added in v2.7.1 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v2.7.1 

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

type QueryParamsResponse added in v2.7.1 

type QueryParamsResponse struct {
	TaskParams TaskParams       `protobuf:"bytes,2,opt,name=task_params,json=taskParams,proto3" json:"task_params"`
	PoolParams LockedPoolParams `protobuf:"bytes,1,opt,name=pool_params,json=poolParams,proto3" json:"pool_params"`
}

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

func (*QueryParamsResponse) Descriptor added in v2.7.1 

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

func (*QueryParamsResponse) GetPoolParams added in v2.7.1 

func (m *QueryParamsResponse) GetPoolParams() LockedPoolParams

func (*QueryParamsResponse) GetTaskParams added in v2.7.1 

func (m *QueryParamsResponse) GetTaskParams() TaskParams

func (*QueryParamsResponse) Marshal added in v2.7.1 

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

func (*QueryParamsResponse) MarshalTo added in v2.7.1 

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

func (*QueryParamsResponse) MarshalToSizedBuffer added in v2.7.1 

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

func (*QueryParamsResponse) ProtoMessage added in v2.7.1 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v2.7.1 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v2.7.1 

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

func (*QueryParamsResponse) String added in v2.7.1 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v2.7.1 

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

func (*QueryParamsResponse) XXX_DiscardUnknown added in v2.7.1 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v2.7.1 

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

func (*QueryParamsResponse) XXX_Merge added in v2.7.1 

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

func (*QueryParamsResponse) XXX_Size added in v2.7.1 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v2.7.1 

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

type QueryResponseParams 

type QueryResponseParams struct {
	Contract string
	Function string
	Operator sdk.AccAddress
}

func NewQueryResponseParams 

func NewQueryResponseParams(contract string, function string, operator sdk.AccAddress) QueryResponseParams

NewQueryResponseParams returns a QueryResponseParams.

type QueryResponseRequest 

type QueryResponseRequest struct {
	Contract        string `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty"`
	Function        string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	OperatorAddress string `protobuf:"bytes,3,opt,name=operator_address,json=operatorAddress,proto3" json:"operator_address,omitempty"`
}

func (*QueryResponseRequest) Descriptor 

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

func (*QueryResponseRequest) GetContract 

func (m *QueryResponseRequest) GetContract() string

func (*QueryResponseRequest) GetFunction 

func (m *QueryResponseRequest) GetFunction() string

func (*QueryResponseRequest) GetOperatorAddress 

func (m *QueryResponseRequest) GetOperatorAddress() string

func (*QueryResponseRequest) Marshal 

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

func (*QueryResponseRequest) MarshalTo 

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

func (*QueryResponseRequest) MarshalToSizedBuffer 

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

func (*QueryResponseRequest) ProtoMessage 

func (*QueryResponseRequest) ProtoMessage()

func (*QueryResponseRequest) Reset 

func (m *QueryResponseRequest) Reset()

func (*QueryResponseRequest) Size 

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

func (*QueryResponseRequest) String 

func (m *QueryResponseRequest) String() string

func (*QueryResponseRequest) Unmarshal 

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

func (*QueryResponseRequest) XXX_DiscardUnknown 

func (m *QueryResponseRequest) XXX_DiscardUnknown()

func (*QueryResponseRequest) XXX_Marshal 

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

func (*QueryResponseRequest) XXX_Merge 

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

func (*QueryResponseRequest) XXX_Size 

func (m *QueryResponseRequest) XXX_Size() int

func (*QueryResponseRequest) XXX_Unmarshal 

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

type QueryResponseResponse 

type QueryResponseResponse struct {
	Response Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response"`
}

func (*QueryResponseResponse) Descriptor 

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

func (*QueryResponseResponse) GetResponse 

func (m *QueryResponseResponse) GetResponse() Response

func (*QueryResponseResponse) Marshal 

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

func (*QueryResponseResponse) MarshalTo 

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

func (*QueryResponseResponse) MarshalToSizedBuffer 

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

func (*QueryResponseResponse) ProtoMessage 

func (*QueryResponseResponse) ProtoMessage()

func (*QueryResponseResponse) Reset 

func (m *QueryResponseResponse) Reset()

func (*QueryResponseResponse) Size 

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

func (*QueryResponseResponse) String 

func (m *QueryResponseResponse) String() string

func (*QueryResponseResponse) Unmarshal 

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

func (*QueryResponseResponse) XXX_DiscardUnknown 

func (m *QueryResponseResponse) XXX_DiscardUnknown()

func (*QueryResponseResponse) XXX_Marshal 

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

func (*QueryResponseResponse) XXX_Merge 

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

func (*QueryResponseResponse) XXX_Size 

func (m *QueryResponseResponse) XXX_Size() int

func (*QueryResponseResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	Operator(context.Context, *QueryOperatorRequest) (*QueryOperatorResponse, error)
	Operators(context.Context, *QueryOperatorsRequest) (*QueryOperatorsResponse, error)
	Withdraws(context.Context, *QueryWithdrawsRequest) (*QueryWithdrawsResponse, error)
	Task(context.Context, *QueryTaskRequest) (*QueryTaskResponse, error)
	TxTask(context.Context, *QueryTxTaskRequest) (*QueryTxTaskResponse, error)
	Response(context.Context, *QueryResponseRequest) (*QueryResponseResponse, error)
	TxResponse(context.Context, *QueryTxResponseRequest) (*QueryTxResponseResponse, error)
	// Params queries all parameters of the oracle module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type QueryTaskParams 

type QueryTaskParams struct {
	Contract string
	Function string
}

func NewQueryTaskParams 

func NewQueryTaskParams(contract string, function string) QueryTaskParams

NewQueryTaskParams returns a QueryTaskParams object.

type QueryTaskRequest 

type QueryTaskRequest struct {
	Contract string `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty"`
	Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
}

func (*QueryTaskRequest) Descriptor 

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

func (*QueryTaskRequest) GetContract 

func (m *QueryTaskRequest) GetContract() string

func (*QueryTaskRequest) GetFunction 

func (m *QueryTaskRequest) GetFunction() string

func (*QueryTaskRequest) Marshal 

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

func (*QueryTaskRequest) MarshalTo 

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

func (*QueryTaskRequest) MarshalToSizedBuffer 

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

func (*QueryTaskRequest) ProtoMessage 

func (*QueryTaskRequest) ProtoMessage()

func (*QueryTaskRequest) Reset 

func (m *QueryTaskRequest) Reset()

func (*QueryTaskRequest) Size 

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

func (*QueryTaskRequest) String 

func (m *QueryTaskRequest) String() string

func (*QueryTaskRequest) Unmarshal 

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

func (*QueryTaskRequest) XXX_DiscardUnknown 

func (m *QueryTaskRequest) XXX_DiscardUnknown()

func (*QueryTaskRequest) XXX_Marshal 

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

func (*QueryTaskRequest) XXX_Merge 

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

func (*QueryTaskRequest) XXX_Size 

func (m *QueryTaskRequest) XXX_Size() int

func (*QueryTaskRequest) XXX_Unmarshal 

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

type QueryTaskResponse 

type QueryTaskResponse struct {
	Task Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task"`
}

func (*QueryTaskResponse) Descriptor 

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

func (*QueryTaskResponse) GetTask 

func (m *QueryTaskResponse) GetTask() Task

func (*QueryTaskResponse) Marshal 

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

func (*QueryTaskResponse) MarshalTo 

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

func (*QueryTaskResponse) MarshalToSizedBuffer 

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

func (*QueryTaskResponse) ProtoMessage 

func (*QueryTaskResponse) ProtoMessage()

func (*QueryTaskResponse) Reset 

func (m *QueryTaskResponse) Reset()

func (*QueryTaskResponse) Size 

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

func (*QueryTaskResponse) String 

func (m *QueryTaskResponse) String() string

func (*QueryTaskResponse) Unmarshal 

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

func (*QueryTaskResponse) XXX_DiscardUnknown 

func (m *QueryTaskResponse) XXX_DiscardUnknown()

func (*QueryTaskResponse) XXX_Marshal 

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

func (*QueryTaskResponse) XXX_Merge 

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

func (*QueryTaskResponse) XXX_Size 

func (m *QueryTaskResponse) XXX_Size() int

func (*QueryTaskResponse) XXX_Unmarshal 

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

type QueryTxResponseRequest added in v2.7.0 

type QueryTxResponseRequest struct {
	AtxHash         string `protobuf:"bytes,1,opt,name=atx_hash,json=atxHash,proto3" json:"atx_hash,omitempty"`
	OperatorAddress string `protobuf:"bytes,2,opt,name=operator_address,json=operatorAddress,proto3" json:"operator_address,omitempty"`
}

func (*QueryTxResponseRequest) Descriptor added in v2.7.0 

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

func (*QueryTxResponseRequest) GetAtxHash added in v2.7.0 

func (m *QueryTxResponseRequest) GetAtxHash() string

func (*QueryTxResponseRequest) GetOperatorAddress added in v2.7.0 

func (m *QueryTxResponseRequest) GetOperatorAddress() string

func (*QueryTxResponseRequest) Marshal added in v2.7.0 

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

func (*QueryTxResponseRequest) MarshalTo added in v2.7.0 

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

func (*QueryTxResponseRequest) MarshalToSizedBuffer added in v2.7.0 

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

func (*QueryTxResponseRequest) ProtoMessage added in v2.7.0 

func (*QueryTxResponseRequest) ProtoMessage()

func (*QueryTxResponseRequest) Reset added in v2.7.0 

func (m *QueryTxResponseRequest) Reset()

func (*QueryTxResponseRequest) Size added in v2.7.0 

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

func (*QueryTxResponseRequest) String added in v2.7.0 

func (m *QueryTxResponseRequest) String() string

func (*QueryTxResponseRequest) Unmarshal added in v2.7.0 

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

func (*QueryTxResponseRequest) XXX_DiscardUnknown added in v2.7.0 

func (m *QueryTxResponseRequest) XXX_DiscardUnknown()

func (*QueryTxResponseRequest) XXX_Marshal added in v2.7.0 

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

func (*QueryTxResponseRequest) XXX_Merge added in v2.7.0 

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

func (*QueryTxResponseRequest) XXX_Size added in v2.7.0 

func (m *QueryTxResponseRequest) XXX_Size() int

func (*QueryTxResponseRequest) XXX_Unmarshal added in v2.7.0 

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

type QueryTxResponseResponse added in v2.7.0 

type QueryTxResponseResponse struct {
	Response Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response"`
}

func (*QueryTxResponseResponse) Descriptor added in v2.7.0 

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

func (*QueryTxResponseResponse) GetResponse added in v2.7.0 

func (m *QueryTxResponseResponse) GetResponse() Response

func (*QueryTxResponseResponse) Marshal added in v2.7.0 

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

func (*QueryTxResponseResponse) MarshalTo added in v2.7.0 

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

func (*QueryTxResponseResponse) MarshalToSizedBuffer added in v2.7.0 

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

func (*QueryTxResponseResponse) ProtoMessage added in v2.7.0 

func (*QueryTxResponseResponse) ProtoMessage()

func (*QueryTxResponseResponse) Reset added in v2.7.0 

func (m *QueryTxResponseResponse) Reset()

func (*QueryTxResponseResponse) Size added in v2.7.0 

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

func (*QueryTxResponseResponse) String added in v2.7.0 

func (m *QueryTxResponseResponse) String() string

func (*QueryTxResponseResponse) Unmarshal added in v2.7.0 

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

func (*QueryTxResponseResponse) XXX_DiscardUnknown added in v2.7.0 

func (m *QueryTxResponseResponse) XXX_DiscardUnknown()

func (*QueryTxResponseResponse) XXX_Marshal added in v2.7.0 

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

func (*QueryTxResponseResponse) XXX_Merge added in v2.7.0 

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

func (*QueryTxResponseResponse) XXX_Size added in v2.7.0 

func (m *QueryTxResponseResponse) XXX_Size() int

func (*QueryTxResponseResponse) XXX_Unmarshal added in v2.7.0 

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

type QueryTxTaskRequest added in v2.7.0 

type QueryTxTaskRequest struct {
	AtxHash string `protobuf:"bytes,1,opt,name=atx_hash,json=atxHash,proto3" json:"atx_hash,omitempty"`
}

func (*QueryTxTaskRequest) Descriptor added in v2.7.0 

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

func (*QueryTxTaskRequest) GetAtxHash added in v2.7.0 

func (m *QueryTxTaskRequest) GetAtxHash() string

func (*QueryTxTaskRequest) Marshal added in v2.7.0 

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

func (*QueryTxTaskRequest) MarshalTo added in v2.7.0 

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

func (*QueryTxTaskRequest) MarshalToSizedBuffer added in v2.7.0 

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

func (*QueryTxTaskRequest) ProtoMessage added in v2.7.0 

func (*QueryTxTaskRequest) ProtoMessage()

func (*QueryTxTaskRequest) Reset added in v2.7.0 

func (m *QueryTxTaskRequest) Reset()

func (*QueryTxTaskRequest) Size added in v2.7.0 

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

func (*QueryTxTaskRequest) String added in v2.7.0 

func (m *QueryTxTaskRequest) String() string

func (*QueryTxTaskRequest) Unmarshal added in v2.7.0 

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

func (*QueryTxTaskRequest) XXX_DiscardUnknown added in v2.7.0 

func (m *QueryTxTaskRequest) XXX_DiscardUnknown()

func (*QueryTxTaskRequest) XXX_Marshal added in v2.7.0 

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

func (*QueryTxTaskRequest) XXX_Merge added in v2.7.0 

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

func (*QueryTxTaskRequest) XXX_Size added in v2.7.0 

func (m *QueryTxTaskRequest) XXX_Size() int

func (*QueryTxTaskRequest) XXX_Unmarshal added in v2.7.0 

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

type QueryTxTaskResponse added in v2.7.0 

type QueryTxTaskResponse struct {
	Task TxTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task"`
}

func (*QueryTxTaskResponse) Descriptor added in v2.7.0 

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

func (*QueryTxTaskResponse) GetTask added in v2.7.0 

func (m *QueryTxTaskResponse) GetTask() TxTask

func (*QueryTxTaskResponse) Marshal added in v2.7.0 

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

func (*QueryTxTaskResponse) MarshalTo added in v2.7.0 

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

func (*QueryTxTaskResponse) MarshalToSizedBuffer added in v2.7.0 

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

func (*QueryTxTaskResponse) ProtoMessage added in v2.7.0 

func (*QueryTxTaskResponse) ProtoMessage()

func (*QueryTxTaskResponse) Reset added in v2.7.0 

func (m *QueryTxTaskResponse) Reset()

func (*QueryTxTaskResponse) Size added in v2.7.0 

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

func (*QueryTxTaskResponse) String added in v2.7.0 

func (m *QueryTxTaskResponse) String() string

func (*QueryTxTaskResponse) Unmarshal added in v2.7.0 

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

func (*QueryTxTaskResponse) XXX_DiscardUnknown added in v2.7.0 

func (m *QueryTxTaskResponse) XXX_DiscardUnknown()

func (*QueryTxTaskResponse) XXX_Marshal added in v2.7.0 

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

func (*QueryTxTaskResponse) XXX_Merge added in v2.7.0 

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

func (*QueryTxTaskResponse) XXX_Size added in v2.7.0 

func (m *QueryTxTaskResponse) XXX_Size() int

func (*QueryTxTaskResponse) XXX_Unmarshal added in v2.7.0 

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

type QueryWithdrawsRequest 

type QueryWithdrawsRequest struct {
}

func (*QueryWithdrawsRequest) Descriptor 

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

func (*QueryWithdrawsRequest) Marshal 

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

func (*QueryWithdrawsRequest) MarshalTo 

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

func (*QueryWithdrawsRequest) MarshalToSizedBuffer 

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

func (*QueryWithdrawsRequest) ProtoMessage 

func (*QueryWithdrawsRequest) ProtoMessage()

func (*QueryWithdrawsRequest) Reset 

func (m *QueryWithdrawsRequest) Reset()

func (*QueryWithdrawsRequest) Size 

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

func (*QueryWithdrawsRequest) String 

func (m *QueryWithdrawsRequest) String() string

func (*QueryWithdrawsRequest) Unmarshal 

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

func (*QueryWithdrawsRequest) XXX_DiscardUnknown 

func (m *QueryWithdrawsRequest) XXX_DiscardUnknown()

func (*QueryWithdrawsRequest) XXX_Marshal 

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

func (*QueryWithdrawsRequest) XXX_Merge 

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

func (*QueryWithdrawsRequest) XXX_Size 

func (m *QueryWithdrawsRequest) XXX_Size() int

func (*QueryWithdrawsRequest) XXX_Unmarshal 

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

type QueryWithdrawsResponse 

type QueryWithdrawsResponse struct {
	Withdraws []Withdraw `protobuf:"bytes,1,rep,name=withdraws,proto3" json:"withdraws"`
}

func (*QueryWithdrawsResponse) Descriptor 

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

func (*QueryWithdrawsResponse) GetWithdraws 

func (m *QueryWithdrawsResponse) GetWithdraws() []Withdraw

func (*QueryWithdrawsResponse) Marshal 

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

func (*QueryWithdrawsResponse) MarshalTo 

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

func (*QueryWithdrawsResponse) MarshalToSizedBuffer 

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

func (*QueryWithdrawsResponse) ProtoMessage 

func (*QueryWithdrawsResponse) ProtoMessage()

func (*QueryWithdrawsResponse) Reset 

func (m *QueryWithdrawsResponse) Reset()

func (*QueryWithdrawsResponse) Size 

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

func (*QueryWithdrawsResponse) String 

func (m *QueryWithdrawsResponse) String() string

func (*QueryWithdrawsResponse) Unmarshal 

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

func (*QueryWithdrawsResponse) XXX_DiscardUnknown 

func (m *QueryWithdrawsResponse) XXX_DiscardUnknown()

func (*QueryWithdrawsResponse) XXX_Marshal 

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

func (*QueryWithdrawsResponse) XXX_Merge 

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

func (*QueryWithdrawsResponse) XXX_Size 

func (m *QueryWithdrawsResponse) XXX_Size() int

func (*QueryWithdrawsResponse) XXX_Unmarshal 

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

type Response 

type Response struct {
	Operator string                                   `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty" yaml:"operator"`
	Score    github_com_cosmos_cosmos_sdk_types.Int   `protobuf:"bytes,2,opt,name=score,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"score" yaml:"score"`
	Weight   github_com_cosmos_cosmos_sdk_types.Int   `protobuf:"bytes,3,opt,name=weight,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"weight" yaml:"weight"`
	Reward   github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=reward,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"reward" yaml:"reward"`
}

func NewResponse 

func NewResponse(score sdk.Int, operator sdk.AccAddress) Response

NewResponse returns a new response.

func (*Response) Descriptor 

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

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type Responses 

type Responses []Response

func (Responses) String 

func (r Responses) String() string

String implements the Stringer interface.

type StakingKeeper 

type StakingKeeper interface {
	BondDenom(ctx sdk.Context) (res string)
}

type Task 

type Task struct {
	Contract      string                                   `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty" yaml:"contract"`
	Function      string                                   `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty" yaml:"function"`
	BeginBlock    int64                                    `protobuf:"varint,3,opt,name=begin_block,json=beginBlock,proto3" json:"begin_block,omitempty" yaml:"begin_block"`
	Bounty        github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,4,rep,name=bounty,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"bounty" yaml:"bounty"`
	Description   string                                   `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty" yaml:"description"`
	Expiration    time.Time                                `protobuf:"bytes,6,opt,name=expiration,proto3,stdtime" json:"expiration" yaml:"expiration"`
	Creator       string                                   `protobuf:"bytes,7,opt,name=creator,proto3" json:"creator,omitempty" yaml:"creator"`
	Responses     Responses                                `protobuf:"bytes,8,rep,name=responses,proto3,castrepeated=Responses" json:"responses" yaml:"responses"`
	Result        github_com_cosmos_cosmos_sdk_types.Int   `protobuf:"bytes,9,opt,name=result,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"result" yaml:"result"`
	ExpireHeight  int64                                    `protobuf:"varint,10,opt,name=expire_height,json=expireHeight,proto3" json:"expire_height,omitempty" yaml:"expire_height"`
	WaitingBlocks int64                                    `protobuf:"varint,11,opt,name=waiting_blocks,json=waitingBlocks,proto3" json:"waiting_blocks,omitempty" yaml:"waiting_blocks"`
	Status        TaskStatus                               `protobuf:"varint,12,opt,name=status,proto3,enum=shentu.oracle.v1alpha1.TaskStatus" json:"status,omitempty" yaml:"status"`
}

func NewTask 

func NewTask(
	contract string,
	function string,
	beginBlock int64,
	bounty sdk.Coins,
	description string,
	expiration time.Time,
	creator sdk.AccAddress,
	expireHeight int64,
	waitingBlocks int64,
) Task

NewTask returns a new task.

func (*Task) AddResponse added in v2.7.0 

func (t *Task) AddResponse(response Response)

func (*Task) Descriptor 

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

func (*Task) GetBounty added in v2.7.0 

func (t *Task) GetBounty() sdk.Coins

func (*Task) GetCreator added in v2.7.0 

func (t *Task) GetCreator() string

func (*Task) GetID added in v2.7.0 

func (t *Task) GetID() []byte

func (*Task) GetResponses added in v2.7.0 

func (t *Task) GetResponses() Responses

func (*Task) GetScore added in v2.7.0 

func (t *Task) GetScore() int64

func (*Task) GetStatus added in v2.7.0 

func (t *Task) GetStatus() TaskStatus

func (*Task) GetValidTime added in v2.7.0 

func (t *Task) GetValidTime() (int64, time.Time)

func (*Task) IsExpired added in v2.7.0 

func (t *Task) IsExpired(ctx sdk.Context) bool

func (*Task) Marshal 

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

func (*Task) MarshalTo 

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

func (*Task) MarshalToSizedBuffer 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) SetScore added in v2.7.0 

func (t *Task) SetScore(score int64)

func (*Task) SetStatus added in v2.7.0 

func (t *Task) SetStatus(status TaskStatus)

func (*Task) ShouldAgg added in v2.7.0 

func (t *Task) ShouldAgg(ctx sdk.Context) bool

func (*Task) Size 

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

func (*Task) String 

func (m *Task) String() string

func (*Task) Unmarshal 

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

func (*Task) XXX_DiscardUnknown 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal 

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

func (*Task) XXX_Merge 

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

func (*Task) XXX_Size 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal 

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

type TaskI added in v2.7.0 

type TaskI interface {
	proto.Message

	GetID() []byte
	GetCreator() string
	GetResponses() Responses
	IsExpired(ctx sdk.Context) bool
	GetValidTime() (int64, time.Time)
	GetBounty() sdk.Coins
	GetStatus() TaskStatus
	GetScore() int64
	AddResponse(response Response)
	SetStatus(status TaskStatus)
	SetScore(score int64)
	ShouldAgg(ctx sdk.Context) bool
}

type TaskID 

type TaskID struct {
	Tid []byte `protobuf:"bytes,1,opt,name=tid,proto3" json:"tid,omitempty" yaml:"tid"`
}

func (*TaskID) Descriptor 

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

func (*TaskID) Marshal 

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

func (*TaskID) MarshalTo 

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

func (*TaskID) MarshalToSizedBuffer 

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

func (*TaskID) ProtoMessage 

func (*TaskID) ProtoMessage()

func (*TaskID) Reset 

func (m *TaskID) Reset()

func (*TaskID) Size 

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

func (*TaskID) String 

func (m *TaskID) String() string

func (*TaskID) Unmarshal 

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

func (*TaskID) XXX_DiscardUnknown 

func (m *TaskID) XXX_DiscardUnknown()

func (*TaskID) XXX_Marshal 

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

func (*TaskID) XXX_Merge 

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

func (*TaskID) XXX_Size 

func (m *TaskID) XXX_Size() int

func (*TaskID) XXX_Unmarshal 

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

type TaskIDs 

type TaskIDs struct {
	TaskIds []TaskID `protobuf:"bytes,1,rep,name=task_ids,json=taskIds,proto3" json:"task_ids"`
}

func (*TaskIDs) Descriptor 

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

func (*TaskIDs) GetTaskIds 

func (m *TaskIDs) GetTaskIds() []TaskID

func (*TaskIDs) Marshal 

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

func (*TaskIDs) MarshalTo 

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

func (*TaskIDs) MarshalToSizedBuffer 

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

func (*TaskIDs) ProtoMessage 

func (*TaskIDs) ProtoMessage()

func (*TaskIDs) Reset 

func (m *TaskIDs) Reset()

func (*TaskIDs) Size 

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

func (*TaskIDs) String 

func (m *TaskIDs) String() string

func (*TaskIDs) Unmarshal 

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

func (*TaskIDs) XXX_DiscardUnknown 

func (m *TaskIDs) XXX_DiscardUnknown()

func (*TaskIDs) XXX_Marshal 

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

func (*TaskIDs) XXX_Merge 

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

func (*TaskIDs) XXX_Size 

func (m *TaskIDs) XXX_Size() int

func (*TaskIDs) XXX_Unmarshal 

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

type TaskParams 

type TaskParams struct {
	ExpirationDuration time.Duration                          `` /* 144-byte string literal not displayed */
	AggregationWindow  int64                                  `` /* 139-byte string literal not displayed */
	AggregationResult  github_com_cosmos_cosmos_sdk_types.Int `` /* 178-byte string literal not displayed */
	ThresholdScore     github_com_cosmos_cosmos_sdk_types.Int `` /* 166-byte string literal not displayed */
	Epsilon1           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,5,opt,name=epsilon1,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"epsilon1" yaml:"epsilon1"`
	Epsilon2           github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,6,opt,name=epsilon2,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"epsilon2" yaml:"epsilon2"`
	ShortcutQuorum     github_com_cosmos_cosmos_sdk_types.Dec `` /* 166-byte string literal not displayed */
}

func DefaultTaskParams 

func DefaultTaskParams() TaskParams

DefaultTaskParams generates default set for TaskParams.

func NewTaskParams 

func NewTaskParams(expirationDuration time.Duration, aggregationWindow int64, aggregationResult,
	thresholdScore, epsilon1, epsilon2 sdk.Int, shortcutQuorum sdk.Dec) TaskParams

NewTaskParams returns a TaskParams object.

func (*TaskParams) Descriptor 

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

func (*TaskParams) Marshal 

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

func (*TaskParams) MarshalTo 

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

func (*TaskParams) MarshalToSizedBuffer 

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

func (*TaskParams) ProtoMessage 

func (*TaskParams) ProtoMessage()

func (*TaskParams) Reset 

func (m *TaskParams) Reset()

func (*TaskParams) Size 

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

func (*TaskParams) String 

func (m *TaskParams) String() string

func (*TaskParams) Unmarshal 

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

func (*TaskParams) XXX_DiscardUnknown 

func (m *TaskParams) XXX_DiscardUnknown()

func (*TaskParams) XXX_Marshal 

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

func (*TaskParams) XXX_Merge 

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

func (*TaskParams) XXX_Size 

func (m *TaskParams) XXX_Size() int

func (*TaskParams) XXX_Unmarshal 

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

type TaskStatus 

type TaskStatus int32

TaskStatus enumerates the valid statuses of a task. 

const (
	TaskStatusNil       TaskStatus = 0
	TaskStatusPending   TaskStatus = 1
	TaskStatusSucceeded TaskStatus = 2
	TaskStatusFailed    TaskStatus = 3
)

func (TaskStatus) EnumDescriptor 

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

func (TaskStatus) String 

func (x TaskStatus) String() string

type TxTask added in v2.7.0 

type TxTask struct {
	AtxHash    []byte                                   `protobuf:"bytes,1,opt,name=atx_hash,json=atxHash,proto3" json:"atx_hash,omitempty" yaml:"atx_hash"`
	Creator    string                                   `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty" yaml:"creator"`
	Bounty     github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=bounty,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"bounty" yaml:"bounty"`
	ValidTime  time.Time                                `protobuf:"bytes,4,opt,name=valid_time,json=validTime,proto3,stdtime" json:"valid_time" yaml:"valid_time"`
	Expiration time.Time                                `protobuf:"bytes,5,opt,name=expiration,proto3,stdtime" json:"expiration" yaml:"expiration"`
	Responses  Responses                                `protobuf:"bytes,6,rep,name=responses,proto3,castrepeated=Responses" json:"responses" yaml:"responses"`
	Score      int64                                    `protobuf:"varint,7,opt,name=score,proto3" json:"score,omitempty" yaml:"score"`
	Status     TaskStatus                               `protobuf:"varint,8,opt,name=status,proto3,enum=shentu.oracle.v1alpha1.TaskStatus" json:"status,omitempty" yaml:"status"`
}

func NewTxTask added in v2.7.0 

func NewTxTask(
	txHash []byte,
	creator string,
	bounty sdk.Coins,
	validTime time.Time,
	status TaskStatus,
) *TxTask

func (*TxTask) AddResponse added in v2.7.0 

func (t *TxTask) AddResponse(response Response)

func (*TxTask) Descriptor added in v2.7.0 

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

func (*TxTask) GetBounty added in v2.7.0 

func (t *TxTask) GetBounty() sdk.Coins

func (*TxTask) GetCreator added in v2.7.0 

func (t *TxTask) GetCreator() string

func (*TxTask) GetID added in v2.7.0 

func (t *TxTask) GetID() []byte

func (*TxTask) GetResponses added in v2.7.0 

func (t *TxTask) GetResponses() Responses

func (*TxTask) GetScore added in v2.7.0 

func (t *TxTask) GetScore() int64

func (*TxTask) GetStatus added in v2.7.0 

func (t *TxTask) GetStatus() TaskStatus

func (*TxTask) GetValidTime added in v2.7.0 

func (t *TxTask) GetValidTime() (int64, time.Time)

func (*TxTask) IsExpired added in v2.7.0 

func (t *TxTask) IsExpired(ctx sdk.Context) bool

func (*TxTask) Marshal added in v2.7.0 

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

func (*TxTask) MarshalTo added in v2.7.0 

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

func (*TxTask) MarshalToSizedBuffer added in v2.7.0 

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

func (*TxTask) ProtoMessage added in v2.7.0 

func (*TxTask) ProtoMessage()

func (*TxTask) Reset added in v2.7.0 

func (m *TxTask) Reset()

func (*TxTask) SetScore added in v2.7.0 

func (t *TxTask) SetScore(score int64)

func (*TxTask) SetStatus added in v2.7.0 

func (t *TxTask) SetStatus(status TaskStatus)

func (*TxTask) ShouldAgg added in v2.7.0 

func (t *TxTask) ShouldAgg(ctx sdk.Context) bool

func (*TxTask) Size added in v2.7.0 

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

func (*TxTask) String added in v2.7.0 

func (m *TxTask) String() string

func (*TxTask) Unmarshal added in v2.7.0 

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

func (*TxTask) XXX_DiscardUnknown added in v2.7.0 

func (m *TxTask) XXX_DiscardUnknown()

func (*TxTask) XXX_Marshal added in v2.7.0 

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

func (*TxTask) XXX_Merge added in v2.7.0 

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

func (*TxTask) XXX_Size added in v2.7.0 

func (m *TxTask) XXX_Size() int

func (*TxTask) XXX_Unmarshal added in v2.7.0 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddCollateral 

func (*UnimplementedMsgServer) AddCollateral(ctx context.Context, req *MsgAddCollateral) (*MsgAddCollateralResponse, error)

func (*UnimplementedMsgServer) CreateOperator 

func (*UnimplementedMsgServer) CreateOperator(ctx context.Context, req *MsgCreateOperator) (*MsgCreateOperatorResponse, error)

func (*UnimplementedMsgServer) CreateTask 

func (*UnimplementedMsgServer) CreateTask(ctx context.Context, req *MsgCreateTask) (*MsgCreateTaskResponse, error)

func (*UnimplementedMsgServer) CreateTxTask added in v2.7.0 

func (*UnimplementedMsgServer) CreateTxTask(ctx context.Context, req *MsgCreateTxTask) (*MsgCreateTxTaskResponse, error)

func (*UnimplementedMsgServer) DeleteTask 

func (*UnimplementedMsgServer) DeleteTask(ctx context.Context, req *MsgDeleteTask) (*MsgDeleteTaskResponse, error)

func (*UnimplementedMsgServer) DeleteTxTask added in v2.7.0 

func (*UnimplementedMsgServer) DeleteTxTask(ctx context.Context, req *MsgDeleteTxTask) (*MsgDeleteTxTaskResponse, error)

func (*UnimplementedMsgServer) ReduceCollateral 

func (*UnimplementedMsgServer) ReduceCollateral(ctx context.Context, req *MsgReduceCollateral) (*MsgReduceCollateralResponse, error)

func (*UnimplementedMsgServer) RemoveOperator 

func (*UnimplementedMsgServer) RemoveOperator(ctx context.Context, req *MsgRemoveOperator) (*MsgRemoveOperatorResponse, error)

func (*UnimplementedMsgServer) TaskResponse 

func (*UnimplementedMsgServer) TaskResponse(ctx context.Context, req *MsgTaskResponse) (*MsgTaskResponseResponse, error)

func (*UnimplementedMsgServer) TxTaskResponse added in v2.7.0 

func (*UnimplementedMsgServer) TxTaskResponse(ctx context.Context, req *MsgTxTaskResponse) (*MsgTxTaskResponseResponse, error)

func (*UnimplementedMsgServer) WithdrawReward 

func (*UnimplementedMsgServer) WithdrawReward(ctx context.Context, req *MsgWithdrawReward) (*MsgWithdrawRewardResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Operator 

func (*UnimplementedQueryServer) Operator(ctx context.Context, req *QueryOperatorRequest) (*QueryOperatorResponse, error)

func (*UnimplementedQueryServer) Operators 

func (*UnimplementedQueryServer) Operators(ctx context.Context, req *QueryOperatorsRequest) (*QueryOperatorsResponse, error)

func (*UnimplementedQueryServer) Params added in v2.7.1 

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

func (*UnimplementedQueryServer) Response 

func (*UnimplementedQueryServer) Response(ctx context.Context, req *QueryResponseRequest) (*QueryResponseResponse, error)

func (*UnimplementedQueryServer) Task 

func (*UnimplementedQueryServer) Task(ctx context.Context, req *QueryTaskRequest) (*QueryTaskResponse, error)

func (*UnimplementedQueryServer) TxResponse added in v2.7.0 

func (*UnimplementedQueryServer) TxResponse(ctx context.Context, req *QueryTxResponseRequest) (*QueryTxResponseResponse, error)

func (*UnimplementedQueryServer) TxTask added in v2.7.0 

func (*UnimplementedQueryServer) TxTask(ctx context.Context, req *QueryTxTaskRequest) (*QueryTxTaskResponse, error)

func (*UnimplementedQueryServer) Withdraws 

func (*UnimplementedQueryServer) Withdraws(ctx context.Context, req *QueryWithdrawsRequest) (*QueryWithdrawsResponse, error)

type Withdraw 

type Withdraw struct {
	Address  string                                   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	Amount   github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount" yaml:"amount"`
	DueBlock int64                                    `protobuf:"varint,3,opt,name=due_block,json=dueBlock,proto3" json:"due_block,omitempty" yaml:"due_block"`
}

Withdraw stores a withdraw of "Amount" scheduled for a given "DueBlock."

func NewWithdraw 

func NewWithdraw(address sdk.AccAddress, amount sdk.Coins, dueBlock int64) Withdraw

NewWithdraw returns a Withdraw object.

func (*Withdraw) Descriptor 

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

func (*Withdraw) Marshal 

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

func (*Withdraw) MarshalTo 

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

func (*Withdraw) MarshalToSizedBuffer 

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

func (*Withdraw) ProtoMessage 

func (*Withdraw) ProtoMessage()

func (*Withdraw) Reset 

func (m *Withdraw) Reset()

func (*Withdraw) Size 

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

func (*Withdraw) String 

func (m *Withdraw) String() string

func (*Withdraw) Unmarshal 

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

func (*Withdraw) XXX_DiscardUnknown 

func (m *Withdraw) XXX_DiscardUnknown()

func (*Withdraw) XXX_Marshal 

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

func (*Withdraw) XXX_Merge 

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

func (*Withdraw) XXX_Size 

func (m *Withdraw) XXX_Size() int

func (*Withdraw) XXX_Unmarshal 

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

type Withdraws 

type Withdraws []Withdraw

func (Withdraws) String 

func (withdraws Withdraws) String() (out string)

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.