messager

package
v1.15.0 Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2024 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 (*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)

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