api

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2023 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BindRateLimit added in v1.4.1 

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 added in v1.1.0 

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 added in v1.1.0 

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 added in v1.1.0 

func NewMessageImp(implParams ImplParams) *MessageImp

func (*MessageImp) ActiveAddress added in v1.4.0 

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

func (*MessageImp) ClearUnFillMessage added in v1.4.0 

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

func (*MessageImp) DeleteAddress added in v1.4.0 

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

func (*MessageImp) DeleteNode added in v1.4.0 

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

func (*MessageImp) ForbiddenAddress added in v1.4.0 

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

func (*MessageImp) GetActorCfgByID added in v1.11.0 

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

func (*MessageImp) GetAddress added in v1.4.0 

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

func (*MessageImp) GetMessageByFromAndNonce added in v1.4.0 

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

func (*MessageImp) GetMessageBySignedCid added in v1.4.0 

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

func (*MessageImp) GetMessageByUid added in v1.4.0 

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

func (*MessageImp) GetMessageByUnsignedCid added in v1.4.0 

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

func (*MessageImp) GetNode added in v1.4.0 

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

func (*MessageImp) GetSharedParams added in v1.4.0 

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

func (*MessageImp) HasAddress added in v1.4.0 

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

func (*MessageImp) HasMessageByUid added in v1.4.0 

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

func (*MessageImp) HasNode added in v1.4.0 

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

func (*MessageImp) ListActorCfg added in v1.11.0 

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

func (*MessageImp) ListAddress added in v1.4.0 

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

func (*MessageImp) ListBlockedMessage added in v1.4.0 

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

func (*MessageImp) ListFailedMessage added in v1.4.0 

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

func (*MessageImp) ListMessage added in v1.4.0 

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

func (*MessageImp) ListMessageByAddress added in v1.4.0 

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

func (*MessageImp) ListMessageByFromState added in v1.4.0 

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

func (*MessageImp) ListNode added in v1.4.0 

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

func (*MessageImp) LogList added in v1.9.0 

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

func (*MessageImp) MarkBadMessage added in v1.4.0 

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

func (*MessageImp) NetAddrsListen added in v1.7.0 

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

func (*MessageImp) NetConnect added in v1.7.0 

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

func (*MessageImp) NetFindPeer added in v1.7.0 

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

func (*MessageImp) NetPeers added in v1.7.0 

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

func (MessageImp) PushMessage added in v1.4.0 

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

func (MessageImp) PushMessageWithId added in v1.4.0 

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

func (*MessageImp) RecoverFailedMsg added in v1.4.0 

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

func (*MessageImp) ReplaceMessage added in v1.4.0 

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

func (*MessageImp) RepublishMessage added in v1.4.0 

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

func (*MessageImp) SaveActorCfg added in v1.11.0 

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

func (*MessageImp) SaveNode added in v1.4.0 

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

func (*MessageImp) Send added in v1.4.0 

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

func (*MessageImp) SetFeeParams added in v1.4.0 

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

func (*MessageImp) SetLogLevel added in v1.4.0 

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

func (*MessageImp) SetSelectMsgNum added in v1.4.0 

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

func (*MessageImp) SetSharedParams added in v1.4.0 

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

func (*MessageImp) UpdateActorCfg added in v1.11.0 

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

func (*MessageImp) UpdateAllFilledMessage added in v1.4.0 

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

func (*MessageImp) UpdateFilledMessageByID added in v1.4.0 

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

func (*MessageImp) UpdateMessageStateByID added in v1.4.0 

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

func (*MessageImp) UpdateNonce added in v1.4.0 

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

func (*MessageImp) Version added in v1.7.0 

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

func (*MessageImp) WaitMessage added in v1.4.0 

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

func (*MessageImp) WalletHas added in v1.4.0 

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.