messager

package
v1.2.0-rc5 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2022 License: Apache-2.0, MIT Imports: 9 Imported by: 17

Documentation

Overview

Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.

Code generated by github.com/filecoin-project/venus/venus-devtool/api-gen. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IMessager 

type IMessager interface {
	HasMessageByUid(ctx context.Context, id string) (bool, error)                                                                                              //perm:read
	WaitMessage(ctx context.Context, id string, confidence uint64) (*types.Message, error)                                                                     //perm:read
	ForcePushMessage(ctx context.Context, account string, msg *shared.Message, meta *types.SendSpec) (string, error)                                           //perm:admin
	ForcePushMessageWithId(ctx context.Context, id string, account string, msg *shared.Message, meta *types.SendSpec) (string, error)                          //perm:write
	PushMessage(ctx context.Context, msg *shared.Message, meta *types.SendSpec) (string, error)                                                                //perm:write
	PushMessageWithId(ctx context.Context, id string, msg *shared.Message, meta *types.SendSpec) (string, error)                                               //perm:write
	GetMessageByUid(ctx context.Context, id string) (*types.Message, error)                                                                                    //perm:read
	GetMessageBySignedCid(ctx context.Context, cid cid.Cid) (*types.Message, error)                                                                            //perm:read
	GetMessageByUnsignedCid(ctx context.Context, cid cid.Cid) (*types.Message, error)                                                                          //perm:read
	GetMessageByFromAndNonce(ctx context.Context, from address.Address, nonce uint64) (*types.Message, error)                                                  //perm:read
	ListMessage(ctx context.Context) ([]*types.Message, error)                                                                                                 //perm:admin
	ListMessageByFromState(ctx context.Context, from address.Address, state types.MessageState, isAsc bool, pageIndex, pageSize int) ([]*types.Message, error) //perm:admin
	ListMessageByAddress(ctx context.Context, addr address.Address) ([]*types.Message, error)                                                                  //perm:admin
	ListFailedMessage(ctx context.Context) ([]*types.Message, error)                                                                                           //perm:admin
	ListBlockedMessage(ctx context.Context, addr address.Address, d time.Duration) ([]*types.Message, error)                                                   //perm:admin
	UpdateMessageStateByID(ctx context.Context, id string, state types.MessageState) error                                                                     //perm:admin
	UpdateAllFilledMessage(ctx context.Context) (int, error)                                                                                                   //perm:admin
	UpdateFilledMessageByID(ctx context.Context, id string) (string, error)                                                                                    //perm:admin
	ReplaceMessage(ctx context.Context, id string, auto bool, maxFee string, gasLimit int64, gasPremium string, gasFeecap string) (cid.Cid, error)             //perm:admin
	RepublishMessage(ctx context.Context, id string) error                                                                                                     //perm:admin
	MarkBadMessage(ctx context.Context, id string) error                                                                                                       //perm:admin
	RecoverFailedMsg(ctx context.Context, addr address.Address) ([]string, error)                                                                              //perm:admin

	GetAddress(ctx context.Context, addr address.Address) (*types.Address, error)                                      //perm:admin
	HasAddress(ctx context.Context, addr address.Address) (bool, error)                                                //perm:read
	WalletHas(ctx context.Context, addr address.Address) (bool, error)                                                 //perm:read
	ListAddress(ctx context.Context) ([]*types.Address, error)                                                         //perm:admin
	UpdateNonce(ctx context.Context, addr address.Address, nonce uint64) error                                         //perm:admin
	DeleteAddress(ctx context.Context, addr address.Address) error                                                     //perm:admin
	ForbiddenAddress(ctx context.Context, addr address.Address) error                                                  //perm:admin
	ActiveAddress(ctx context.Context, addr address.Address) error                                                     //perm:admin
	SetSelectMsgNum(ctx context.Context, addr address.Address, num uint64) error                                       //perm:admin
	SetFeeParams(ctx context.Context, addr address.Address, gasOverEstimation float64, maxFee, maxFeeCap string) error //perm:admin
	ClearUnFillMessage(ctx context.Context, addr address.Address) (int, error)                                         //perm:admin

	GetSharedParams(ctx context.Context) (*types.SharedSpec, error)      //perm:admin
	SetSharedParams(ctx context.Context, params *types.SharedSpec) error //perm:admin
	RefreshSharedParams(ctx context.Context) error                       //perm:admin

	SaveNode(ctx context.Context, node *types.Node) error          //perm:admin
	GetNode(ctx context.Context, name string) (*types.Node, error) //perm:admin
	HasNode(ctx context.Context, name string) (bool, error)        //perm:admin
	ListNode(ctx context.Context) ([]*types.Node, error)           //perm:admin
	DeleteNode(ctx context.Context, name string) error             //perm:admin

	SetLogLevel(ctx context.Context, level string) error //perm:admin

	Send(ctx context.Context, params types.QuickSendParams) (string, error) //perm:admin
}

func NewIMessagerRPC 

func NewIMessagerRPC(ctx context.Context, addr string, requestHeader http.Header) (IMessager, jsonrpc.ClientCloser, error)

NewIMessagerRPC creates a new httpparse jsonrpc remotecli.

type IMessagerStruct 

type IMessagerStruct struct {
	Internal struct {
		ActiveAddress            func(ctx context.Context, addr address.Address) error                                                                                    `perm:"admin"`
		ClearUnFillMessage       func(ctx context.Context, addr address.Address) (int, error)                                                                             `perm:"admin"`
		DeleteAddress            func(ctx context.Context, addr address.Address) error                                                                                    `perm:"admin"`
		DeleteNode               func(ctx context.Context, name string) error                                                                                             `perm:"admin"`
		ForbiddenAddress         func(ctx context.Context, addr address.Address) error                                                                                    `perm:"admin"`
		ForcePushMessage         func(ctx context.Context, account string, msg *shared.Message, meta *types.SendSpec) (string, error)                                     `perm:"admin"`
		ForcePushMessageWithId   func(ctx context.Context, id string, account string, msg *shared.Message, meta *types.SendSpec) (string, error)                          `perm:"write"`
		GetAddress               func(ctx context.Context, addr address.Address) (*types.Address, error)                                                                  `perm:"admin"`
		GetMessageByFromAndNonce func(ctx context.Context, from address.Address, nonce uint64) (*types.Message, error)                                                    `perm:"read"`
		GetMessageBySignedCid    func(ctx context.Context, cid cid.Cid) (*types.Message, error)                                                                           `perm:"read"`
		GetMessageByUid          func(ctx context.Context, id string) (*types.Message, error)                                                                             `perm:"read"`
		GetMessageByUnsignedCid  func(ctx context.Context, cid cid.Cid) (*types.Message, error)                                                                           `perm:"read"`
		GetNode                  func(ctx context.Context, name string) (*types.Node, error)                                                                              `perm:"admin"`
		GetSharedParams          func(ctx context.Context) (*types.SharedSpec, error)                                                                                     `perm:"admin"`
		HasAddress               func(ctx context.Context, addr address.Address) (bool, error)                                                                            `perm:"read"`
		HasMessageByUid          func(ctx context.Context, id string) (bool, error)                                                                                       `perm:"read"`
		HasNode                  func(ctx context.Context, name string) (bool, error)                                                                                     `perm:"admin"`
		ListAddress              func(ctx context.Context) ([]*types.Address, error)                                                                                      `perm:"admin"`
		ListBlockedMessage       func(ctx context.Context, addr address.Address, d time.Duration) ([]*types.Message, error)                                               `perm:"admin"`
		ListFailedMessage        func(ctx context.Context) ([]*types.Message, error)                                                                                      `perm:"admin"`
		ListMessage              func(ctx context.Context) ([]*types.Message, error)                                                                                      `perm:"admin"`
		ListMessageByAddress     func(ctx context.Context, addr address.Address) ([]*types.Message, error)                                                                `perm:"admin"`
		ListMessageByFromState   func(ctx context.Context, from address.Address, state types.MessageState, isAsc bool, pageIndex, pageSize int) ([]*types.Message, error) `perm:"admin"`
		ListNode                 func(ctx context.Context) ([]*types.Node, error)                                                                                         `perm:"admin"`
		MarkBadMessage           func(ctx context.Context, id string) error                                                                                               `perm:"admin"`
		PushMessage              func(ctx context.Context, msg *shared.Message, meta *types.SendSpec) (string, error)                                                     `perm:"write"`
		PushMessageWithId        func(ctx context.Context, id string, msg *shared.Message, meta *types.SendSpec) (string, error)                                          `perm:"write"`
		RecoverFailedMsg         func(ctx context.Context, addr address.Address) ([]string, error)                                                                        `perm:"admin"`
		RefreshSharedParams      func(ctx context.Context) error                                                                                                          `perm:"admin"`
		ReplaceMessage           func(ctx context.Context, id string, auto bool, maxFee string, gasLimit int64, gasPremium string, gasFeecap string) (cid.Cid, error)     `perm:"admin"`
		RepublishMessage         func(ctx context.Context, id string) error                                                                                               `perm:"admin"`
		SaveNode                 func(ctx context.Context, node *types.Node) error                                                                                        `perm:"admin"`
		Send                     func(ctx context.Context, params types.QuickSendParams) (string, error)                                                                  `perm:"admin"`
		SetFeeParams             func(ctx context.Context, addr address.Address, gasOverEstimation float64, maxFee, maxFeeCap string) error                               `perm:"admin"`
		SetLogLevel              func(ctx context.Context, level string) error                                                                                            `perm:"admin"`
		SetSelectMsgNum          func(ctx context.Context, addr address.Address, num uint64) error                                                                        `perm:"admin"`
		SetSharedParams          func(ctx context.Context, params *types.SharedSpec) error                                                                                `perm:"admin"`
		UpdateAllFilledMessage   func(ctx context.Context) (int, error)                                                                                                   `perm:"admin"`
		UpdateFilledMessageByID  func(ctx context.Context, id string) (string, error)                                                                                     `perm:"admin"`
		UpdateMessageStateByID   func(ctx context.Context, id string, state types.MessageState) error                                                                     `perm:"admin"`
		UpdateNonce              func(ctx context.Context, addr address.Address, nonce uint64) error                                                                      `perm:"admin"`
		WaitMessage              func(ctx context.Context, id string, confidence uint64) (*types.Message, error)                                                          `perm:"read"`
		WalletHas                func(ctx context.Context, addr address.Address) (bool, error)                                                                            `perm:"read"`
	}
}

func (*IMessagerStruct) ActiveAddress 

func (s *IMessagerStruct) ActiveAddress(p0 context.Context, p1 address.Address) error

func (*IMessagerStruct) ClearUnFillMessage 

func (s *IMessagerStruct) ClearUnFillMessage(p0 context.Context, p1 address.Address) (int, error)

func (*IMessagerStruct) DeleteAddress 

func (s *IMessagerStruct) DeleteAddress(p0 context.Context, p1 address.Address) error

func (*IMessagerStruct) DeleteNode 

func (s *IMessagerStruct) DeleteNode(p0 context.Context, p1 string) error

func (*IMessagerStruct) ForbiddenAddress 

func (s *IMessagerStruct) ForbiddenAddress(p0 context.Context, p1 address.Address) error

func (*IMessagerStruct) ForcePushMessage 

func (s *IMessagerStruct) ForcePushMessage(p0 context.Context, p1 string, p2 *shared.Message, p3 *types.SendSpec) (string, error)

func (*IMessagerStruct) ForcePushMessageWithId 

func (s *IMessagerStruct) ForcePushMessageWithId(p0 context.Context, p1 string, p2 string, p3 *shared.Message, p4 *types.SendSpec) (string, error)

func (*IMessagerStruct) GetAddress 

func (s *IMessagerStruct) GetAddress(p0 context.Context, p1 address.Address) (*types.Address, error)

func (*IMessagerStruct) GetMessageByFromAndNonce 

func (s *IMessagerStruct) GetMessageByFromAndNonce(p0 context.Context, p1 address.Address, p2 uint64) (*types.Message, error)

func (*IMessagerStruct) GetMessageBySignedCid 

func (s *IMessagerStruct) GetMessageBySignedCid(p0 context.Context, p1 cid.Cid) (*types.Message, error)

func (*IMessagerStruct) GetMessageByUid 

func (s *IMessagerStruct) GetMessageByUid(p0 context.Context, p1 string) (*types.Message, error)

func (*IMessagerStruct) GetMessageByUnsignedCid 

func (s *IMessagerStruct) GetMessageByUnsignedCid(p0 context.Context, p1 cid.Cid) (*types.Message, error)

func (*IMessagerStruct) GetNode 

func (s *IMessagerStruct) GetNode(p0 context.Context, p1 string) (*types.Node, error)

func (*IMessagerStruct) GetSharedParams 

func (s *IMessagerStruct) GetSharedParams(p0 context.Context) (*types.SharedSpec, error)

func (*IMessagerStruct) HasAddress 

func (s *IMessagerStruct) HasAddress(p0 context.Context, p1 address.Address) (bool, error)

func (*IMessagerStruct) HasMessageByUid 

func (s *IMessagerStruct) HasMessageByUid(p0 context.Context, p1 string) (bool, error)

func (*IMessagerStruct) HasNode 

func (s *IMessagerStruct) HasNode(p0 context.Context, p1 string) (bool, error)

func (*IMessagerStruct) ListAddress 

func (s *IMessagerStruct) ListAddress(p0 context.Context) ([]*types.Address, error)

func (*IMessagerStruct) ListBlockedMessage 

func (s *IMessagerStruct) ListBlockedMessage(p0 context.Context, p1 address.Address, p2 time.Duration) ([]*types.Message, error)

func (*IMessagerStruct) ListFailedMessage 

func (s *IMessagerStruct) ListFailedMessage(p0 context.Context) ([]*types.Message, error)

func (*IMessagerStruct) ListMessage 

func (s *IMessagerStruct) ListMessage(p0 context.Context) ([]*types.Message, error)

func (*IMessagerStruct) ListMessageByAddress 

func (s *IMessagerStruct) ListMessageByAddress(p0 context.Context, p1 address.Address) ([]*types.Message, error)

func (*IMessagerStruct) ListMessageByFromState 

func (s *IMessagerStruct) ListMessageByFromState(p0 context.Context, p1 address.Address, p2 types.MessageState, p3 bool, p4, p5 int) ([]*types.Message, error)

func (*IMessagerStruct) ListNode 

func (s *IMessagerStruct) ListNode(p0 context.Context) ([]*types.Node, error)

func (*IMessagerStruct) MarkBadMessage 

func (s *IMessagerStruct) MarkBadMessage(p0 context.Context, p1 string) error

func (*IMessagerStruct) PushMessage 

func (s *IMessagerStruct) PushMessage(p0 context.Context, p1 *shared.Message, p2 *types.SendSpec) (string, error)

func (*IMessagerStruct) PushMessageWithId 

func (s *IMessagerStruct) PushMessageWithId(p0 context.Context, p1 string, p2 *shared.Message, p3 *types.SendSpec) (string, error)

func (*IMessagerStruct) RecoverFailedMsg 

func (s *IMessagerStruct) RecoverFailedMsg(p0 context.Context, p1 address.Address) ([]string, error)

func (*IMessagerStruct) RefreshSharedParams 

func (s *IMessagerStruct) RefreshSharedParams(p0 context.Context) error

func (*IMessagerStruct) ReplaceMessage 

func (s *IMessagerStruct) ReplaceMessage(p0 context.Context, p1 string, p2 bool, p3 string, p4 int64, p5 string, p6 string) (cid.Cid, error)

func (*IMessagerStruct) RepublishMessage 

func (s *IMessagerStruct) RepublishMessage(p0 context.Context, p1 string) error

func (*IMessagerStruct) SaveNode 

func (s *IMessagerStruct) SaveNode(p0 context.Context, p1 *types.Node) error

func (*IMessagerStruct) Send 

func (s *IMessagerStruct) Send(p0 context.Context, p1 types.QuickSendParams) (string, error)

func (*IMessagerStruct) SetFeeParams 

func (s *IMessagerStruct) SetFeeParams(p0 context.Context, p1 address.Address, p2 float64, p3, p4 string) error

func (*IMessagerStruct) SetLogLevel 

func (s *IMessagerStruct) SetLogLevel(p0 context.Context, p1 string) error

func (*IMessagerStruct) SetSelectMsgNum 

func (s *IMessagerStruct) SetSelectMsgNum(p0 context.Context, p1 address.Address, p2 uint64) error

func (*IMessagerStruct) SetSharedParams 

func (s *IMessagerStruct) SetSharedParams(p0 context.Context, p1 *types.SharedSpec) error

func (*IMessagerStruct) UpdateAllFilledMessage 

func (s *IMessagerStruct) UpdateAllFilledMessage(p0 context.Context) (int, error)

func (*IMessagerStruct) UpdateFilledMessageByID 

func (s *IMessagerStruct) UpdateFilledMessageByID(p0 context.Context, p1 string) (string, error)

func (*IMessagerStruct) UpdateMessageStateByID 

func (s *IMessagerStruct) UpdateMessageStateByID(p0 context.Context, p1 string, p2 types.MessageState) error

func (*IMessagerStruct) UpdateNonce 

func (s *IMessagerStruct) UpdateNonce(p0 context.Context, p1 address.Address, p2 uint64) error

func (*IMessagerStruct) WaitMessage 

func (s *IMessagerStruct) WaitMessage(p0 context.Context, p1 string, p2 uint64) (*types.Message, error)

func (*IMessagerStruct) WalletHas 

func (s *IMessagerStruct) WalletHas(p0 context.Context, p1 address.Address) (bool, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.