api

package

v1.17.1 Latest Latest Go to latest Published: Dec 3, 2024 License: MIT Imports: 25 Imported by: 0

Documentation ¶

Index ¶

func BindRateLimit(msgImp *MessageImp, remoteAuthCli jwtclient.IAuthClient, ...) (messager.IMessager, error)
func RunAPI(lc fx.Lifecycle, localAuthCli *jwtclient.LocalAuthClient, ...) error
type ImplParams
type MessageImp
- func NewMessageImp(implParams ImplParams) *MessageImp

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BindRateLimit ¶

func BindRateLimit(msgImp *MessageImp, remoteAuthCli jwtclient.IAuthClient, rateLimitCfg *config.RateLimitConfig) (messager.IMessager, error)

func RunAPI ¶

func RunAPI(lc fx.Lifecycle, localAuthCli *jwtclient.LocalAuthClient, remoteAuthCli jwtclient.IAuthClient, lst net.Listener, msgImp messager.IMessager) error

RunAPI bind rpc call and start rpc todo

Types ¶

type ImplParams ¶

type ImplParams struct {
	fx.In
	AddressService      *service.AddressService
	MessageService      *service.MessageService
	NodeService         service.INodeService
	SharedParamsService *service.SharedParamsService
	Net                 pubsub.INet
	AuthClient          jwtclient.IAuthClient
	NodeClient          v1.FullNode
}

type MessageImp ¶

type MessageImp struct {
	AddressSrv service.IAddressService
	MessageSrv service.IMessageService
	NodeSrv    service.INodeService
	ParamsSrv  *service.SharedParamsService
	Net        pubsub.INet
	AuthClient jwtclient.IAuthClient
	NodeClient v1.FullNode
}

func NewMessageImp ¶

func NewMessageImp(implParams ImplParams) *MessageImp

func (*MessageImp) ActiveAddress ¶

func (m *MessageImp) ActiveAddress(ctx context.Context, addr address.Address) error

func (*MessageImp) ClearUnFillMessage ¶

func (m *MessageImp) ClearUnFillMessage(ctx context.Context, addr address.Address) (int, error)

func (*MessageImp) DeleteAddress ¶

func (m *MessageImp) DeleteAddress(ctx context.Context, addr address.Address) error

func (*MessageImp) DeleteNode ¶

func (m *MessageImp) DeleteNode(ctx context.Context, name string) error

func (*MessageImp) ForbiddenAddress ¶

func (m *MessageImp) ForbiddenAddress(ctx context.Context, addr address.Address) error

func (*MessageImp) GetActorCfgByID ¶

func (m *MessageImp) GetActorCfgByID(ctx context.Context, id venusTypes.UUID) (*types.ActorCfg, error)

func (*MessageImp) GetAddress ¶

func (m *MessageImp) GetAddress(ctx context.Context, addr address.Address) (*types.Address, error)

func (*MessageImp) GetMessageByFromAndNonce ¶

func (m *MessageImp) GetMessageByFromAndNonce(ctx context.Context, from address.Address, nonce uint64) (*types.Message, error)

func (*MessageImp) GetMessageBySignedCid ¶

func (m *MessageImp) GetMessageBySignedCid(ctx context.Context, cid cid.Cid) (*types.Message, error)

func (*MessageImp) GetMessageByUid ¶

func (m *MessageImp) GetMessageByUid(ctx context.Context, id string) (*types.Message, error)

func (*MessageImp) GetMessageByUnsignedCid ¶

func (m *MessageImp) GetMessageByUnsignedCid(ctx context.Context, cid cid.Cid) (*types.Message, error)

func (*MessageImp) GetNode ¶

func (m *MessageImp) GetNode(ctx context.Context, name string) (*types.Node, error)

func (*MessageImp) GetSharedParams ¶

func (m *MessageImp) GetSharedParams(ctx context.Context) (*types.SharedSpec, error)

func (*MessageImp) HasAddress ¶

func (m *MessageImp) HasAddress(ctx context.Context, addr address.Address) (bool, error)

func (*MessageImp) HasMessageByUid ¶

func (m *MessageImp) HasMessageByUid(ctx context.Context, id string) (bool, error)

func (*MessageImp) HasNode ¶

func (m *MessageImp) HasNode(ctx context.Context, name string) (bool, error)

func (*MessageImp) ListActorCfg ¶

func (m *MessageImp) ListActorCfg(ctx context.Context) ([]*types.ActorCfg, error)

func (*MessageImp) ListAddress ¶

func (m *MessageImp) ListAddress(ctx context.Context) ([]*types.Address, error)

func (*MessageImp) ListBlockedMessage ¶

func (m *MessageImp) ListBlockedMessage(ctx context.Context, addr address.Address, d time.Duration) ([]*types.Message, error)

func (*MessageImp) ListFailedMessage ¶

func (m *MessageImp) ListFailedMessage(ctx context.Context) ([]*types.Message, error)

func (*MessageImp) ListMessage ¶

func (m *MessageImp) ListMessage(ctx context.Context, p *types.MsgQueryParams) ([]*types.Message, error)

func (*MessageImp) ListMessageByAddress ¶

func (m *MessageImp) ListMessageByAddress(ctx context.Context, addr address.Address) ([]*types.Message, error)

func (*MessageImp) ListMessageByFromState ¶

func (m *MessageImp) ListMessageByFromState(ctx context.Context, from address.Address, state types.MessageState, isAsc bool, pageIndex, pageSize int, d time.Duration) ([]*types.Message, error)

func (*MessageImp) ListNode ¶

func (m *MessageImp) ListNode(ctx context.Context) ([]*types.Node, error)

func (*MessageImp) LogList ¶

func (m *MessageImp) LogList(_ context.Context) ([]string, error)

func (*MessageImp) MarkBadMessage ¶

func (m *MessageImp) MarkBadMessage(ctx context.Context, id string) error

func (*MessageImp) NetAddrsListen ¶

func (m *MessageImp) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)

func (*MessageImp) NetConnect ¶

func (m *MessageImp) NetConnect(ctx context.Context, pi peer.AddrInfo) error

func (*MessageImp) NetFindPeer ¶

func (m *MessageImp) NetFindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)

func (*MessageImp) NetPeers ¶

func (m *MessageImp) NetPeers(ctx context.Context) ([]peer.AddrInfo, error)

func (MessageImp) PushMessage ¶

func (m MessageImp) PushMessage(ctx context.Context, msg *venusTypes.Message, meta *types.SendSpec) (string, error)

func (MessageImp) PushMessageWithId ¶

func (m MessageImp) PushMessageWithId(ctx context.Context, id string, msg *venusTypes.Message, meta *types.SendSpec) (string, error)

func (*MessageImp) RecoverFailedMsg ¶

func (m *MessageImp) RecoverFailedMsg(ctx context.Context, addr address.Address) ([]string, error)

func (*MessageImp) ReplaceMessage ¶

func (m *MessageImp) ReplaceMessage(ctx context.Context, params *types.ReplacMessageParams) (cid.Cid, error)

func (*MessageImp) RepublishMessage ¶

func (m *MessageImp) RepublishMessage(ctx context.Context, id string) error

func (*MessageImp) SaveActorCfg ¶

func (m *MessageImp) SaveActorCfg(ctx context.Context, actorCfg *types.ActorCfg) error

func (*MessageImp) SaveNode ¶

func (m *MessageImp) SaveNode(ctx context.Context, node *types.Node) error

func (*MessageImp) Send ¶

func (m *MessageImp) Send(ctx context.Context, params types.QuickSendParams) (string, error)

func (*MessageImp) SetFeeParams ¶

func (m *MessageImp) SetFeeParams(ctx context.Context, params *types.AddressSpec) error

func (*MessageImp) SetLogLevel ¶

func (m *MessageImp) SetLogLevel(_ context.Context, subSystem, level string) error

func (*MessageImp) SetSelectMsgNum ¶

func (m *MessageImp) SetSelectMsgNum(ctx context.Context, addr address.Address, num uint64) error

func (*MessageImp) SetSharedParams ¶

func (m *MessageImp) SetSharedParams(ctx context.Context, params *types.SharedSpec) error

func (*MessageImp) UpdateActorCfg ¶

func (m *MessageImp) UpdateActorCfg(ctx context.Context, id venusTypes.UUID, changeSpecParams *types.ChangeGasSpecParams) error

func (*MessageImp) UpdateAllFilledMessage ¶

func (m *MessageImp) UpdateAllFilledMessage(ctx context.Context) (int, error)

func (*MessageImp) UpdateFilledMessageByID ¶

func (m *MessageImp) UpdateFilledMessageByID(ctx context.Context, id string) (string, error)

func (*MessageImp) UpdateMessageStateByID ¶

func (m *MessageImp) UpdateMessageStateByID(ctx context.Context, id string, state types.MessageState) error

func (*MessageImp) UpdateNonce ¶

func (m *MessageImp) UpdateNonce(ctx context.Context, addr address.Address, nonce uint64) error

func (*MessageImp) Version ¶

func (m *MessageImp) Version(_ context.Context) (venusTypes.Version, error)

func (*MessageImp) WaitMessage ¶

func (m *MessageImp) WaitMessage(ctx context.Context, id string, confidence uint64) (*types.Message, error)

func (*MessageImp) WalletHas ¶

func (m *MessageImp) WalletHas(ctx context.Context, addr address.Address) (bool, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL