types

package
v2.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2022 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 (
	// 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"
	TypeMsgInquireTask      = "inquire_task"
	TypeMsgDeleteTask       = "delete_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")

	ErrInconsistentOperators = sdkerrors.Register(ModuleName, errInconsistentOperators, "two operators not consistent")
)
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}
)
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)

	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 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(contract, function string) []byte

func TotalCollateralKey 

func TotalCollateralKey() []byte

func ValidateGenesis 

func ValidateGenesis(gs 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 added in v2.3.0 

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

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

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 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"`
	Deleter  string `protobuf:"bytes,4,opt,name=deleter,proto3" json:"deleter,omitempty" yaml:"deleter"`
}

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

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 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)
	Response(ctx context.Context, in *QueryResponseRequest, opts ...grpc.CallOption) (*QueryResponseResponse, 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 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)
	Response(context.Context, *QueryResponseRequest) (*QueryResponseResponse, 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 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"`
	ClosingBlock  int64                                    `protobuf:"varint,10,opt,name=closing_block,json=closingBlock,proto3" json:"closing_block,omitempty" yaml:"closing_block"`
	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,
	closingBlock int64,
	waitingBlocks int64,
) Task

NewTask returns a new task.

func (*Task) Descriptor 

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

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

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

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                          `` /* 149-byte string literal not displayed */
	AggregationWindow  int64                                  `` /* 144-byte string literal not displayed */
	AggregationResult  github_com_cosmos_cosmos_sdk_types.Int `` /* 183-byte string literal not displayed */
	ThresholdScore     github_com_cosmos_cosmos_sdk_types.Int `` /* 171-byte string literal not displayed */
	Epsilon1           github_com_cosmos_cosmos_sdk_types.Int `` /* 130-byte string literal not displayed */
	Epsilon2           github_com_cosmos_cosmos_sdk_types.Int `` /* 130-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) 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 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) DeleteTask 

func (*UnimplementedMsgServer) DeleteTask(ctx context.Context, req *MsgDeleteTask) (*MsgDeleteTaskResponse, 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) 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) 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) 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.