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
- type IMessager
- type IMessagerStruct
- func (s *IMessagerStruct) ActiveAddress(p0 context.Context, p1 address.Address) error
- func (s *IMessagerStruct) ClearUnFillMessage(p0 context.Context, p1 address.Address) (int, error)
- func (s *IMessagerStruct) DeleteAddress(p0 context.Context, p1 address.Address) error
- func (s *IMessagerStruct) DeleteNode(p0 context.Context, p1 string) error
- func (s *IMessagerStruct) ForbiddenAddress(p0 context.Context, p1 address.Address) error
- func (s *IMessagerStruct) GetAddress(p0 context.Context, p1 address.Address) (*mtypes.Address, error)
- func (s *IMessagerStruct) GetMessageByFromAndNonce(p0 context.Context, p1 address.Address, p2 uint64) (*mtypes.Message, error)
- func (s *IMessagerStruct) GetMessageBySignedCid(p0 context.Context, p1 cid.Cid) (*mtypes.Message, error)
- func (s *IMessagerStruct) GetMessageByUid(p0 context.Context, p1 string) (*mtypes.Message, error)
- func (s *IMessagerStruct) GetMessageByUnsignedCid(p0 context.Context, p1 cid.Cid) (*mtypes.Message, error)
- func (s *IMessagerStruct) GetNode(p0 context.Context, p1 string) (*mtypes.Node, error)
- func (s *IMessagerStruct) GetSharedParams(p0 context.Context) (*mtypes.SharedSpec, error)
- func (s *IMessagerStruct) HasAddress(p0 context.Context, p1 address.Address) (bool, error)
- func (s *IMessagerStruct) HasMessageByUid(p0 context.Context, p1 string) (bool, error)
- func (s *IMessagerStruct) HasNode(p0 context.Context, p1 string) (bool, error)
- func (s *IMessagerStruct) ListAddress(p0 context.Context) ([]*mtypes.Address, error)
- func (s *IMessagerStruct) ListBlockedMessage(p0 context.Context, p1 address.Address, p2 time.Duration) ([]*mtypes.Message, error)
- func (s *IMessagerStruct) ListFailedMessage(p0 context.Context) ([]*mtypes.Message, error)
- func (s *IMessagerStruct) ListMessage(p0 context.Context, p1 *mtypes.MsgQueryParams) ([]*mtypes.Message, error)
- func (s *IMessagerStruct) ListMessageByAddress(p0 context.Context, p1 address.Address) ([]*mtypes.Message, error)
- func (s *IMessagerStruct) ListMessageByFromState(p0 context.Context, p1 address.Address, p2 mtypes.MessageState, p3 bool, ...) ([]*mtypes.Message, error)
- func (s *IMessagerStruct) ListNode(p0 context.Context) ([]*mtypes.Node, error)
- func (s *IMessagerStruct) LogList(p0 context.Context) ([]string, error)
- func (s *IMessagerStruct) MarkBadMessage(p0 context.Context, p1 string) error
- func (s *IMessagerStruct) NetAddrsListen(p0 context.Context) (peer.AddrInfo, error)
- func (s *IMessagerStruct) NetConnect(p0 context.Context, p1 peer.AddrInfo) error
- func (s *IMessagerStruct) NetFindPeer(p0 context.Context, p1 peer.ID) (peer.AddrInfo, error)
- func (s *IMessagerStruct) NetPeers(p0 context.Context) ([]peer.AddrInfo, error)
- func (s *IMessagerStruct) PushMessage(p0 context.Context, p1 *types.Message, p2 *mtypes.SendSpec) (string, error)
- func (s *IMessagerStruct) PushMessageWithId(p0 context.Context, p1 string, p2 *types.Message, p3 *mtypes.SendSpec) (string, error)
- func (s *IMessagerStruct) RecoverFailedMsg(p0 context.Context, p1 address.Address) ([]string, error)
- func (s *IMessagerStruct) ReplaceMessage(p0 context.Context, p1 *mtypes.ReplacMessageParams) (cid.Cid, error)
- func (s *IMessagerStruct) RepublishMessage(p0 context.Context, p1 string) error
- func (s *IMessagerStruct) SaveNode(p0 context.Context, p1 *mtypes.Node) error
- func (s *IMessagerStruct) Send(p0 context.Context, p1 mtypes.QuickSendParams) (string, error)
- func (s *IMessagerStruct) SetFeeParams(p0 context.Context, p1 *mtypes.AddressSpec) error
- func (s *IMessagerStruct) SetLogLevel(p0 context.Context, p1, p2 string) error
- func (s *IMessagerStruct) SetSelectMsgNum(p0 context.Context, p1 address.Address, p2 uint64) error
- func (s *IMessagerStruct) SetSharedParams(p0 context.Context, p1 *mtypes.SharedSpec) error
- func (s *IMessagerStruct) UpdateAllFilledMessage(p0 context.Context) (int, error)
- func (s *IMessagerStruct) UpdateFilledMessageByID(p0 context.Context, p1 string) (string, error)
- func (s *IMessagerStruct) UpdateMessageStateByID(p0 context.Context, p1 string, p2 mtypes.MessageState) error
- func (s *IMessagerStruct) UpdateNonce(p0 context.Context, p1 address.Address, p2 uint64) error
- func (s *IMessagerStruct) Version(p0 context.Context) (types.Version, error)
- func (s *IMessagerStruct) WaitMessage(p0 context.Context, p1 string, p2 uint64) (*mtypes.Message, error)
- func (s *IMessagerStruct) WalletHas(p0 context.Context, p1 address.Address) (bool, error)
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) ([]*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 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 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.
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"` 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"` 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) ([]*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"` 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"` 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 (*IMessagerStruct) ClearUnFillMessage ¶
func (*IMessagerStruct) DeleteAddress ¶
func (*IMessagerStruct) DeleteNode ¶
func (s *IMessagerStruct) DeleteNode(p0 context.Context, p1 string) error
func (*IMessagerStruct) ForbiddenAddress ¶
func (*IMessagerStruct) GetAddress ¶
func (*IMessagerStruct) GetMessageByFromAndNonce ¶
func (*IMessagerStruct) GetMessageBySignedCid ¶
func (*IMessagerStruct) GetMessageByUid ¶
func (*IMessagerStruct) GetMessageByUnsignedCid ¶
func (*IMessagerStruct) GetSharedParams ¶
func (s *IMessagerStruct) GetSharedParams(p0 context.Context) (*mtypes.SharedSpec, error)
func (*IMessagerStruct) HasAddress ¶
func (*IMessagerStruct) HasMessageByUid ¶
func (*IMessagerStruct) ListAddress ¶
func (*IMessagerStruct) ListBlockedMessage ¶
func (*IMessagerStruct) ListFailedMessage ¶
func (*IMessagerStruct) ListMessage ¶
func (s *IMessagerStruct) ListMessage(p0 context.Context, p1 *mtypes.MsgQueryParams) ([]*mtypes.Message, error)
func (*IMessagerStruct) ListMessageByAddress ¶
func (*IMessagerStruct) ListMessageByFromState ¶
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 (*IMessagerStruct) NetConnect ¶ added in v1.7.0
func (*IMessagerStruct) NetFindPeer ¶ added in v1.7.0
func (*IMessagerStruct) PushMessage ¶
func (*IMessagerStruct) PushMessageWithId ¶
func (*IMessagerStruct) RecoverFailedMsg ¶
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) 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 (*IMessagerStruct) SetSharedParams ¶
func (s *IMessagerStruct) SetSharedParams(p0 context.Context, p1 *mtypes.SharedSpec) error
func (*IMessagerStruct) UpdateAllFilledMessage ¶
func (s *IMessagerStruct) UpdateAllFilledMessage(p0 context.Context) (int, error)
func (*IMessagerStruct) UpdateFilledMessageByID ¶
func (*IMessagerStruct) UpdateMessageStateByID ¶
func (s *IMessagerStruct) UpdateMessageStateByID(p0 context.Context, p1 string, p2 mtypes.MessageState) error
func (*IMessagerStruct) UpdateNonce ¶
func (*IMessagerStruct) WaitMessage ¶
Click to show internal directories.
Click to hide internal directories.