api

package
v1.15.0 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2024 License: MIT Imports: 25 Imported by: 0

Documentation

Index

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(ctx 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(ctx 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

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.