messager

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2025 License: Apache-2.0, MIT Imports: 11 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

View Source 
const APINamespace = "messager.IMessager"
View Source 
const MajorVersion = 0
View Source 
const MethodNamespace = "Message"

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) (*mtypes.Message, error)                                                                                       //perm:read
	PushMessage(ctx context.Context, msg *types.Message, meta *mtypes.SendSpec) (string, error)                                                                                   //perm:write
	PushMessageWithId(ctx context.Context, id string, msg *types.Message, meta *mtypes.SendSpec) (string, error)                                                                  //perm:write
	GetMessageByUid(ctx context.Context, id string) (*mtypes.Message, error)                                                                                                      //perm:read
	GetMessageBySignedCid(ctx context.Context, cid cid.Cid) (*mtypes.Message, error)                                                                                              //perm:read
	GetMessageByUnsignedCid(ctx context.Context, cid cid.Cid) (*mtypes.Message, error)                                                                                            //perm:read
	GetMessageByFromAndNonce(ctx context.Context, from address.Address, nonce uint64) (*mtypes.Message, error)                                                                    //perm:read
	ListMessage(ctx context.Context, p *mtypes.MsgQueryParams) ([]*mtypes.Message, error)                                                                                         //perm:read
	ListMessageByFromState(ctx context.Context, from address.Address, state mtypes.MessageState, isAsc bool, pageIndex, pageSize int, d time.Duration) ([]*mtypes.Message, error) //perm:admin
	ListMessageByAddress(ctx context.Context, addr address.Address) ([]*mtypes.Message, error)                                                                                    //perm:admin
	ListFailedMessage(ctx context.Context) ([]*mtypes.Message, error)                                                                                                             //perm:read
	ListBlockedMessage(ctx context.Context, addr address.Address, d time.Duration) ([]*mtypes.Message, error)                                                                     //perm:read
	UpdateMessageStateByID(ctx context.Context, id string, state mtypes.MessageState) error                                                                                       //perm:write
	UpdateAllFilledMessage(ctx context.Context) (int, error)                                                                                                                      //perm:admin
	UpdateFilledMessageByID(ctx context.Context, id string) (string, error)                                                                                                       //perm:write
	ReplaceMessage(ctx context.Context, params *mtypes.ReplacMessageParams) (cid.Cid, error)                                                                                      //perm:write
	RepublishMessage(ctx context.Context, id string) error                                                                                                                        //perm:admin
	MarkBadMessage(ctx context.Context, id string) error                                                                                                                          //perm:write
	RecoverFailedMsg(ctx context.Context, addr address.Address) ([]string, error)                                                                                                 //perm:write

	SaveActorCfg(ctx context.Context, actorCfg *mtypes.ActorCfg) error                                     //perm:admin
	UpdateActorCfg(ctx context.Context, id types.UUID, changeSpecParams *mtypes.ChangeGasSpecParams) error //perm:admin
	ListActorCfg(ctx context.Context) ([]*mtypes.ActorCfg, error)                                          //perm:read
	GetActorCfgByID(ctx context.Context, id types.UUID) (*mtypes.ActorCfg, error)                          //perm:read

	GetAddress(ctx context.Context, addr address.Address) (*mtypes.Address, error) //perm:read
	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) ([]*mtypes.Address, error)                    //perm:read
	UpdateNonce(ctx context.Context, addr address.Address, nonce uint64) error     //perm:admin
	DeleteAddress(ctx context.Context, addr address.Address) error                 //perm:write
	ForbiddenAddress(ctx context.Context, addr address.Address) error              //perm:write
	ActiveAddress(ctx context.Context, addr address.Address) error                 //perm:write
	SetSelectMsgNum(ctx context.Context, addr address.Address, num uint64) error   //perm:write
	SetFeeParams(ctx context.Context, params *mtypes.AddressSpec) error            //perm:write
	ClearUnFillMessage(ctx context.Context, addr address.Address) (int, error)     //perm:write

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

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

	SetLogLevel(ctx context.Context, subsystem, level string) error //perm:admin
	LogList(context.Context) ([]string, error)                      //perm:admin

	Send(ctx context.Context, params mtypes.QuickSendParams) (string, error) //perm:sign

	NetFindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error) //perm:admin
	NetPeers(ctx context.Context) ([]peer.AddrInfo, error)             //perm:admin
	NetConnect(ctx context.Context, pi peer.AddrInfo) error            //perm:admin
	NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)         //perm:admin

	api.Version
}

func DialIMessagerRPC added in v1.2.2 

func DialIMessagerRPC(ctx context.Context, addr string, token string, requestHeader http.Header, opts ...jsonrpc.Option) (IMessager, jsonrpc.ClientCloser, error)

DialIMessagerRPC is a more convinient way of building client, as it resolves any format (url, multiaddr) of addr string.

func NewIMessagerRPC 

func NewIMessagerRPC(ctx context.Context, addr string, requestHeader http.Header, opts ...jsonrpc.Option) (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:"write"`
		ClearUnFillMessage       func(ctx context.Context, addr address.Address) (int, error)                                                                                                `perm:"write"`
		DeleteAddress            func(ctx context.Context, addr address.Address) error                                                                                                       `perm:"write"`
		DeleteNode               func(ctx context.Context, name string) error                                                                                                                `perm:"admin"`
		ForbiddenAddress         func(ctx context.Context, addr address.Address) error                                                                                                       `perm:"write"`
		GetActorCfgByID          func(ctx context.Context, id types.UUID) (*mtypes.ActorCfg, error)                                                                                          `perm:"read"`
		GetAddress               func(ctx context.Context, addr address.Address) (*mtypes.Address, error)                                                                                    `perm:"read"`
		GetMessageByFromAndNonce func(ctx context.Context, from address.Address, nonce uint64) (*mtypes.Message, error)                                                                      `perm:"read"`
		GetMessageBySignedCid    func(ctx context.Context, cid cid.Cid) (*mtypes.Message, error)                                                                                             `perm:"read"`
		GetMessageByUid          func(ctx context.Context, id string) (*mtypes.Message, error)                                                                                               `perm:"read"`
		GetMessageByUnsignedCid  func(ctx context.Context, cid cid.Cid) (*mtypes.Message, error)                                                                                             `perm:"read"`
		GetNode                  func(ctx context.Context, name string) (*mtypes.Node, error)                                                                                                `perm:"admin"`
		GetSharedParams          func(ctx context.Context) (*mtypes.SharedSpec, error)                                                                                                       `perm:"read"`
		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"`
		ListActorCfg             func(ctx context.Context) ([]*mtypes.ActorCfg, error)                                                                                                       `perm:"read"`
		ListAddress              func(ctx context.Context) ([]*mtypes.Address, error)                                                                                                        `perm:"read"`
		ListBlockedMessage       func(ctx context.Context, addr address.Address, d time.Duration) ([]*mtypes.Message, error)                                                                 `perm:"read"`
		ListFailedMessage        func(ctx context.Context) ([]*mtypes.Message, error)                                                                                                        `perm:"read"`
		ListMessage              func(ctx context.Context, p *mtypes.MsgQueryParams) ([]*mtypes.Message, error)                                                                              `perm:"read"`
		ListMessageByAddress     func(ctx context.Context, addr address.Address) ([]*mtypes.Message, error)                                                                                  `perm:"admin"`
		ListMessageByFromState   func(ctx context.Context, from address.Address, state mtypes.MessageState, isAsc bool, pageIndex, pageSize int, d time.Duration) ([]*mtypes.Message, error) `perm:"admin"`
		ListNode                 func(ctx context.Context) ([]*mtypes.Node, error)                                                                                                           `perm:"admin"`
		LogList                  func(context.Context) ([]string, error)                                                                                                                     `perm:"admin"`
		MarkBadMessage           func(ctx context.Context, id string) error                                                                                                                  `perm:"write"`
		NetAddrsListen           func(ctx context.Context) (peer.AddrInfo, error)                                                                                                            `perm:"admin"`
		NetConnect               func(ctx context.Context, pi peer.AddrInfo) error                                                                                                           `perm:"admin"`
		NetFindPeer              func(ctx context.Context, p peer.ID) (peer.AddrInfo, error)                                                                                                 `perm:"admin"`
		NetPeers                 func(ctx context.Context) ([]peer.AddrInfo, error)                                                                                                          `perm:"admin"`
		PushMessage              func(ctx context.Context, msg *types.Message, meta *mtypes.SendSpec) (string, error)                                                                        `perm:"write"`
		PushMessageWithId        func(ctx context.Context, id string, msg *types.Message, meta *mtypes.SendSpec) (string, error)                                                             `perm:"write"`
		RecoverFailedMsg         func(ctx context.Context, addr address.Address) ([]string, error)                                                                                           `perm:"write"`
		ReplaceMessage           func(ctx context.Context, params *mtypes.ReplacMessageParams) (cid.Cid, error)                                                                              `perm:"write"`
		RepublishMessage         func(ctx context.Context, id string) error                                                                                                                  `perm:"admin"`
		SaveActorCfg             func(ctx context.Context, actorCfg *mtypes.ActorCfg) error                                                                                                  `perm:"admin"`
		SaveNode                 func(ctx context.Context, node *mtypes.Node) error                                                                                                          `perm:"admin"`
		Send                     func(ctx context.Context, params mtypes.QuickSendParams) (string, error)                                                                                    `perm:"sign"`
		SetFeeParams             func(ctx context.Context, params *mtypes.AddressSpec) error                                                                                                 `perm:"write"`
		SetLogLevel              func(ctx context.Context, subsystem, level string) error                                                                                                    `perm:"admin"`
		SetSelectMsgNum          func(ctx context.Context, addr address.Address, num uint64) error                                                                                           `perm:"write"`
		SetSharedParams          func(ctx context.Context, params *mtypes.SharedSpec) error                                                                                                  `perm:"admin"`
		UpdateActorCfg           func(ctx context.Context, id types.UUID, changeSpecParams *mtypes.ChangeGasSpecParams) error                                                                `perm:"admin"`
		UpdateAllFilledMessage   func(ctx context.Context) (int, error)                                                                                                                      `perm:"admin"`
		UpdateFilledMessageByID  func(ctx context.Context, id string) (string, error)                                                                                                        `perm:"write"`
		UpdateMessageStateByID   func(ctx context.Context, id string, state mtypes.MessageState) error                                                                                       `perm:"write"`
		UpdateNonce              func(ctx context.Context, addr address.Address, nonce uint64) error                                                                                         `perm:"admin"`
		Version                  func(ctx context.Context) (types.Version, error)                                                                                                            `perm:"read"`
		WaitMessage              func(ctx context.Context, id string, confidence uint64) (*mtypes.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) GetActorCfgByID added in v1.11.0 

func (s *IMessagerStruct) GetActorCfgByID(p0 context.Context, p1 types.UUID) (*mtypes.ActorCfg, error)

func (*IMessagerStruct) GetAddress 

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

func (*IMessagerStruct) GetMessageByFromAndNonce 

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

func (*IMessagerStruct) GetMessageBySignedCid 

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

func (*IMessagerStruct) GetMessageByUid 

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

func (*IMessagerStruct) GetMessageByUnsignedCid 

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

func (*IMessagerStruct) GetNode 

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

func (*IMessagerStruct) GetSharedParams 

func (s *IMessagerStruct) GetSharedParams(p0 context.Context) (*mtypes.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) ListActorCfg added in v1.11.0 

func (s *IMessagerStruct) ListActorCfg(p0 context.Context) ([]*mtypes.ActorCfg, error)

func (*IMessagerStruct) ListAddress 

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

func (*IMessagerStruct) ListBlockedMessage 

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

func (*IMessagerStruct) ListFailedMessage 

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

func (*IMessagerStruct) ListMessage 

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

func (*IMessagerStruct) ListMessageByAddress 

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

func (*IMessagerStruct) ListMessageByFromState 

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

func (*IMessagerStruct) ListNode 

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

func (*IMessagerStruct) LogList added in v1.9.0 

func (s *IMessagerStruct) LogList(p0 context.Context) ([]string, error)

func (*IMessagerStruct) MarkBadMessage 

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

func (*IMessagerStruct) NetAddrsListen added in v1.7.0 

func (s *IMessagerStruct) NetAddrsListen(p0 context.Context) (peer.AddrInfo, error)

func (*IMessagerStruct) NetConnect added in v1.7.0 

func (s *IMessagerStruct) NetConnect(p0 context.Context, p1 peer.AddrInfo) error

func (*IMessagerStruct) NetFindPeer added in v1.7.0 

func (s *IMessagerStruct) NetFindPeer(p0 context.Context, p1 peer.ID) (peer.AddrInfo, error)

func (*IMessagerStruct) NetPeers added in v1.7.0 

func (s *IMessagerStruct) NetPeers(p0 context.Context) ([]peer.AddrInfo, error)

func (*IMessagerStruct) PushMessage 

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

func (*IMessagerStruct) PushMessageWithId 

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

func (*IMessagerStruct) RecoverFailedMsg 

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

func (*IMessagerStruct) ReplaceMessage 

func (s *IMessagerStruct) ReplaceMessage(p0 context.Context, p1 *mtypes.ReplacMessageParams) (cid.Cid, error)

func (*IMessagerStruct) RepublishMessage 

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

func (*IMessagerStruct) SaveActorCfg added in v1.11.0 

func (s *IMessagerStruct) SaveActorCfg(p0 context.Context, p1 *mtypes.ActorCfg) error

func (*IMessagerStruct) SaveNode 

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

func (*IMessagerStruct) Send 

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

func (*IMessagerStruct) SetFeeParams 

func (s *IMessagerStruct) SetFeeParams(p0 context.Context, p1 *mtypes.AddressSpec) error

func (*IMessagerStruct) SetLogLevel 

func (s *IMessagerStruct) SetLogLevel(p0 context.Context, p1, p2 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 *mtypes.SharedSpec) error

func (*IMessagerStruct) UpdateActorCfg added in v1.11.0 

func (s *IMessagerStruct) UpdateActorCfg(p0 context.Context, p1 types.UUID, p2 *mtypes.ChangeGasSpecParams) 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 mtypes.MessageState) error

func (*IMessagerStruct) UpdateNonce 

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

func (*IMessagerStruct) Version added in v1.7.0 

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

func (*IMessagerStruct) WaitMessage 

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

func (*IMessagerStruct) WalletHas 

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

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.