nkn

May 29, 2024

Changes in this version

+ var DefaultStunServerAddr = []string

type ClientConfig

+ StunServerAddr *nkngomobile.StringArray

+ WebRTC bool

+ WebRTCConnectTimeout int32

type Node

+ Sdp string

+ func GetPeerAddr(clientAddr string, offer string, config RPCConfigInterface) (*Node, error)

+ func GetPeerAddrContext(ctx context.Context, clientAddr string, offer string, ...) (*Node, error)

Jan 24, 2024

Changes in this version

type OnConnect

+ func (c *OnConnect) MaybeNext() *Node

type OnError

+ func (c *OnError) MaybeNext() error

type OnMessage

+ func (c *OnMessage) MaybeNext() *Message

Aug 2, 2023

Changes in this version

+ var ErrInvalidResolver = errors.New("resolver doesn't implement Resolver interface")

type Client

+ func (c *Client) ResolveDest(dest string) (string, error)

+ func (c *Client) ResolveDestContext(ctx context.Context, dest string) (string, error)

+ func (c *Client) ResolveDests(dests *nkngomobile.StringArray) (*nkngomobile.StringArray, error)

+ func (c *Client) ResolveDestsContext(ctx context.Context, dests *nkngomobile.StringArray) (*nkngomobile.StringArray, error)

type ClientConfig

+ ResolverTimeout int32

type MultiClient

+ func (m *MultiClient) ResolveDest(dest string) (string, error)

+ func (m *MultiClient) ResolveDestContext(ctx context.Context, dest string) (string, error)

+ func (m *MultiClient) ResolveDests(dests *nkngomobile.StringArray) (*nkngomobile.StringArray, error)

+ func (m *MultiClient) ResolveDestsContext(ctx context.Context, dests *nkngomobile.StringArray) (*nkngomobile.StringArray, error)

+ type Resolver interface

+ ResolveContext func(ctx context.Context, address string) (string, error)

Feb 17, 2023

Changes in this version

+ var ErrResolveLimit = errors.New("resolve depth exceeded")

+ func NewReplyPayload(data interface{}, replyToID []byte) (*payloads.Payload, error)

+ func ResolveDest(dest string, resolver []nkngomobile.Resolver) (string, bool, error)

+ func ResolveDestN(dest string, resolver []nkngomobile.Resolver, depth int32) (string, error)

+ func ResolveDests(dests []string, resolver []nkngomobile.Resolver, depth int32) ([]string, error)

type Client

+ func (c *Client) SendPayload(dests *nkngomobile.StringArray, payload *payloads.Payload, ...) (*OnMessage, error)

type ClientConfig

+ HttpDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ ResolverDepth int32

+ Resolvers *nkngomobile.ResolverArray

+ WsDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ func (c *ClientConfig) RPCGetHttpDialContext() func(ctx context.Context, network, addr string) (net.Conn, error)

type MultiClient

+ func (m *MultiClient) SendPayload(dests *nkngomobile.StringArray, payload *payloads.Payload, ...) (*OnMessage, error)

type RPCConfig

+ HttpDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ func (c *RPCConfig) RPCGetHttpDialContext() func(ctx context.Context, network, addr string) (net.Conn, error)

type WalletConfig

+ HttpDialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ func (c *WalletConfig) RPCGetHttpDialContext() func(ctx context.Context, network, addr string) (net.Conn, error)

Apr 1, 2022

Changes in this version

type TransactionConfig

+ FixNonce bool

Mar 2, 2022

Changes in this version

+ var ErrUnencryptedMessage = errors.New("message is unencrypted")

type ClientConfig

+ AllowUnencrypted bool

Nov 24, 2021

Changes in this version

type StringArray

+ func (sa *StringArray) Join(separator string) string

Apr 17, 2021

Changes in this version

type StringArray

+ func MeasureSeedRPCServer(seedRPCList *StringArray, timeout int32) (*StringArray, error)

+ func MeasureSeedRPCServerContext(ctx context.Context, seedRPCList *StringArray, timeout int32) (*StringArray, error)

Feb 9, 2021

Changes in this version

+ func DeleteNameContext(ctx context.Context, s signerRPCClient, name string, config *TransactionConfig) (string, error)

+ func GetHeightContext(ctx context.Context, config RPCConfigInterface) (int32, error)

+ func GetNonceContext(ctx context.Context, address string, txPool bool, config RPCConfigInterface) (int64, error)

+ func GetSubscribersCountContext(ctx context.Context, topic string, config RPCConfigInterface) (int, error)

+ func RegisterNameContext(ctx context.Context, s signerRPCClient, name string, config *TransactionConfig) (string, error)

+ func SendRawTransactionContext(ctx context.Context, txn *transaction.Transaction, config RPCConfigInterface) (string, error)

+ func SubscribeContext(ctx context.Context, s signerRPCClient, identifier, topic string, duration int, ...) (string, error)

+ func TransferContext(ctx context.Context, s signerRPCClient, address, amount string, ...) (string, error)

+ func TransferNameContext(ctx context.Context, s signerRPCClient, name string, recipientPubKey []byte, ...) (string, error)

+ func UnsubscribeContext(ctx context.Context, s signerRPCClient, identifier, topic string, ...) (string, error)

type Amount

+ func GetBalanceContext(ctx context.Context, address string, config RPCConfigInterface) (*Amount, error)

type Client

+ func (c *Client) BalanceByAddressContext(ctx context.Context, address string) (*Amount, error)

+ func (c *Client) BalanceContext(ctx context.Context) (*Amount, error)

+ func (c *Client) DeleteNameContext(ctx context.Context, name string, config *TransactionConfig) (string, error)

+ func (c *Client) GetHeightContext(ctx context.Context) (int32, error)

+ func (c *Client) GetNonceByAddressContext(ctx context.Context, address string, txPool bool) (int64, error)

+ func (c *Client) GetNonceContext(ctx context.Context, txPool bool) (int64, error)

+ func (c *Client) GetRegistrantContext(ctx context.Context, name string) (*Registrant, error)

+ func (c *Client) GetSubscribersContext(ctx context.Context, topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ func (c *Client) GetSubscribersCountContext(ctx context.Context, topic string) (int, error)

+ func (c *Client) GetSubscriptionContext(ctx context.Context, topic string, subscriber string) (*Subscription, error)

+ func (c *Client) RegisterNameContext(ctx context.Context, name string, config *TransactionConfig) (string, error)

+ func (c *Client) SendRawTransactionContext(ctx context.Context, txn *transaction.Transaction) (string, error)

+ func (c *Client) SubscribeContext(ctx context.Context, identifier, topic string, duration int, meta string, ...) (string, error)

+ func (c *Client) TransferContext(ctx context.Context, address, amount string, config *TransactionConfig) (string, error)

+ func (c *Client) TransferNameContext(ctx context.Context, name string, recipientPubKey []byte, ...) (string, error)

+ func (c *Client) UnsubscribeContext(ctx context.Context, identifier, topic string, config *TransactionConfig) (string, error)

type ClientConfig

+ RPCConcurrency int32

+ RPCTimeout int32

+ func (c *ClientConfig) RPCGetConcurrency() int32

+ func (c *ClientConfig) RPCGetRPCTimeout() int32

+ func (c *ClientConfig) RPCGetSeedRPCServerAddr() *StringArray

type MultiClient

+ func (m *MultiClient) BalanceByAddressContext(ctx context.Context, address string) (*Amount, error)

+ func (m *MultiClient) BalanceContext(ctx context.Context) (*Amount, error)

+ func (m *MultiClient) DeleteNameContext(ctx context.Context, name string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) GetHeightContext(ctx context.Context) (int32, error)

+ func (m *MultiClient) GetNonceByAddressContext(ctx context.Context, address string, txPool bool) (int64, error)

+ func (m *MultiClient) GetNonceContext(ctx context.Context, txPool bool) (int64, error)

+ func (m *MultiClient) GetRegistrantContext(ctx context.Context, name string) (*Registrant, error)

+ func (m *MultiClient) GetSubscribersContext(ctx context.Context, topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ func (m *MultiClient) GetSubscribersCountContext(ctx context.Context, topic string) (int, error)

+ func (m *MultiClient) GetSubscriptionContext(ctx context.Context, topic string, subscriber string) (*Subscription, error)

+ func (m *MultiClient) RegisterNameContext(ctx context.Context, name string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) SendRawTransactionContext(ctx context.Context, txn *transaction.Transaction) (string, error)

+ func (m *MultiClient) SubscribeContext(ctx context.Context, identifier, topic string, duration int, meta string, ...) (string, error)

+ func (m *MultiClient) TransferContext(ctx context.Context, address, amount string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) TransferNameContext(ctx context.Context, name string, recipientPubKey []byte, ...) (string, error)

+ func (m *MultiClient) UnsubscribeContext(ctx context.Context, identifier, topic string, config *TransactionConfig) (string, error)

type Node

+ func GetWsAddrContext(ctx context.Context, clientAddr string, config RPCConfigInterface) (*Node, error)

+ func GetWssAddrContext(ctx context.Context, clientAddr string, config RPCConfigInterface) (*Node, error)

+ type NodeState struct

+ Addr string

+ CurrTimeStamp int64

+ Height int32

+ ID string

+ JSONRPCPort int32

+ ProposalSubmitted int32

+ ProtocolVersion int32

+ PublicKey string

+ RelayMessageCount int64

+ SyncState string

+ TLSJSONRpcDomain string

+ TLSJSONRpcPort int32

+ TLSWebsocketDomain string

+ TLSWebsocketPort int32

+ Uptime int64

+ Version string

+ WebsocketPort int32

+ func GetNodeState(config RPCConfigInterface) (*NodeState, error)

+ func GetNodeStateContext(ctx context.Context, config RPCConfigInterface) (*NodeState, error)

type RPCConfig

+ RPCConcurrency int32

+ RPCTimeout int32

+ func (c *RPCConfig) RPCGetConcurrency() int32

+ func (c *RPCConfig) RPCGetRPCTimeout() int32

+ func (c *RPCConfig) RPCGetSeedRPCServerAddr() *StringArray

type RPCConfigInterface

+ RPCGetConcurrency func() int32

+ RPCGetRPCTimeout func() int32

+ RPCGetSeedRPCServerAddr func() *StringArray

type Registrant

+ func GetRegistrantContext(ctx context.Context, name string, config RPCConfigInterface) (*Registrant, error)

type StringArray

+ func (sa *StringArray) RandomElem() string

type Subscribers

+ func GetSubscribersContext(ctx context.Context, topic string, offset, limit int, meta, txPool bool, ...) (*Subscribers, error)

type Subscription

+ func GetSubscriptionContext(ctx context.Context, topic string, subscriber string, ...) (*Subscription, error)

type Wallet

+ func (w *Wallet) BalanceByAddressContext(ctx context.Context, address string) (*Amount, error)

+ func (w *Wallet) BalanceContext(ctx context.Context) (*Amount, error)

+ func (w *Wallet) DeleteNameContext(ctx context.Context, name string, config *TransactionConfig) (string, error)

+ func (w *Wallet) GetHeightContext(ctx context.Context) (int32, error)

+ func (w *Wallet) GetNonceByAddressContext(ctx context.Context, address string, txPool bool) (int64, error)

+ func (w *Wallet) GetNonceContext(ctx context.Context, txPool bool) (int64, error)

+ func (w *Wallet) GetRegistrantContext(ctx context.Context, name string) (*Registrant, error)

+ func (w *Wallet) GetSubscribersContext(ctx context.Context, topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ func (w *Wallet) GetSubscribersCountContext(ctx context.Context, topic string) (int, error)

+ func (w *Wallet) GetSubscriptionContext(ctx context.Context, topic string, subscriber string) (*Subscription, error)

+ func (w *Wallet) RegisterNameContext(ctx context.Context, name string, config *TransactionConfig) (string, error)

+ func (w *Wallet) SendRawTransactionContext(ctx context.Context, txn *transaction.Transaction) (string, error)

+ func (w *Wallet) SubscribeContext(ctx context.Context, identifier, topic string, duration int, meta string, ...) (string, error)

+ func (w *Wallet) TransferContext(ctx context.Context, address, amount string, config *TransactionConfig) (string, error)

+ func (w *Wallet) TransferNameContext(ctx context.Context, name string, recipientPubKey []byte, ...) (string, error)

+ func (w *Wallet) UnsubscribeContext(ctx context.Context, identifier, topic string, config *TransactionConfig) (string, error)

type WalletConfig

+ RPCConcurrency int32

+ RPCTimeout int32

+ func (c *WalletConfig) RPCGetConcurrency() int32

+ func (c *WalletConfig) RPCGetRPCTimeout() int32

+ func (c *WalletConfig) RPCGetSeedRPCServerAddr() *StringArray

Oct 17, 2020

Changes in this version

type OnMessage

+ func (c *OnMessage) NextWithTimeout(timeout int32) *Message

Jun 12, 2020

Changes in this version

type Client

+ func (c *Client) Account() *Account

+ func (c *Client) Reconnect()

type MultiClient

+ func (m *MultiClient) Account() *Account

+ func (m *MultiClient) Reconnect()

type Wallet

+ func (w *Wallet) Account() *Account

May 8, 2020

Changes in this version

+ type ScryptConfig struct

+ N int

+ P int

+ R int

+ Salt []byte

type Wallet

+ func (w *Wallet) MarshalJSON() ([]byte, error)

type WalletConfig

+ ScryptConfig *ScryptConfig

Apr 20, 2020

Changes in this version

+ var DefaultTransactionConfig = TransactionConfig

+ func DeleteName(s SignerRPCClient, name string, config *TransactionConfig) (string, error)

+ func RegisterName(s SignerRPCClient, name string, config *TransactionConfig) (string, error)

+ func Subscribe(s SignerRPCClient, identifier, topic string, duration int, meta string, ...) (string, error)

+ func Transfer(s SignerRPCClient, address, amount string, config *TransactionConfig) (string, error)

+ func TransferName(s SignerRPCClient, name string, recipientPubKey []byte, ...) (string, error)

+ func Unsubscribe(s SignerRPCClient, identifier, topic string, config *TransactionConfig) (string, error)

type Client

+ func (c *Client) Balance() (*Amount, error)

+ func (c *Client) BalanceByAddress(address string) (*Amount, error)

+ func (c *Client) DeleteName(name string, config *TransactionConfig) (string, error)

+ func (c *Client) GetHeight() (int32, error)

+ func (c *Client) GetNonce(txPool bool) (int64, error)

+ func (c *Client) GetNonceByAddress(address string, txPool bool) (int64, error)

+ func (c *Client) GetRegistrant(name string) (*Registrant, error)

+ func (c *Client) NewNanoPay(recipientAddress, fee string, duration int) (*NanoPay, error)

+ func (c *Client) NewNanoPayClaimer(recipientAddress string, claimIntervalMs int32, onError *OnError) (*NanoPayClaimer, error)

+ func (c *Client) ProgramHash() common.Uint160

+ func (c *Client) RegisterName(name string, config *TransactionConfig) (string, error)

+ func (c *Client) SendRawTransaction(txn *transaction.Transaction) (string, error)

+ func (c *Client) SignTransaction(tx *transaction.Transaction) error

+ func (c *Client) Subscribe(identifier, topic string, duration int, meta string, config *TransactionConfig) (string, error)

+ func (c *Client) Transfer(address, amount string, config *TransactionConfig) (string, error)

+ func (c *Client) TransferName(name string, recipientPubKey []byte, config *TransactionConfig) (string, error)

+ func (c *Client) Unsubscribe(identifier, topic string, config *TransactionConfig) (string, error)

type MultiClient

+ func (m *MultiClient) Balance() (*Amount, error)

+ func (m *MultiClient) BalanceByAddress(address string) (*Amount, error)

+ func (m *MultiClient) DeleteName(name string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) GetHeight() (int32, error)

+ func (m *MultiClient) GetNonce(txPool bool) (int64, error)

+ func (m *MultiClient) GetNonceByAddress(address string, txPool bool) (int64, error)

+ func (m *MultiClient) GetRegistrant(name string) (*Registrant, error)

+ func (m *MultiClient) GetSubscribers(topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ func (m *MultiClient) GetSubscribersCount(topic string) (int, error)

+ func (m *MultiClient) GetSubscription(topic string, subscriber string) (*Subscription, error)

+ func (m *MultiClient) NewNanoPay(recipientAddress, fee string, duration int) (*NanoPay, error)

+ func (m *MultiClient) NewNanoPayClaimer(recipientAddress string, claimIntervalMs int32, onError *OnError) (*NanoPayClaimer, error)

+ func (m *MultiClient) ProgramHash() common.Uint160

+ func (m *MultiClient) RegisterName(name string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) SendRawTransaction(txn *transaction.Transaction) (string, error)

+ func (m *MultiClient) SignTransaction(tx *transaction.Transaction) error

+ func (m *MultiClient) Subscribe(identifier, topic string, duration int, meta string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) Transfer(address, amount string, config *TransactionConfig) (string, error)

+ func (m *MultiClient) TransferName(name string, recipientPubKey []byte, config *TransactionConfig) (string, error)

+ func (m *MultiClient) Unsubscribe(identifier, topic string, config *TransactionConfig) (string, error)

type Node

+ Addr string

+ PubKey string

+ RPCAddr string

+ type RPCClient interface

+ Balance func() (*Amount, error)

+ BalanceByAddress func(address string) (*Amount, error)

+ GetHeight func() (int32, error)

+ GetNonce func(txPool bool) (int64, error)

+ GetNonceByAddress func(address string, txPool bool) (int64, error)

+ GetRegistrant func(name string) (*Registrant, error)

+ GetSubscribers func(topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ GetSubscribersCount func(topic string) (int, error)

+ GetSubscription func(topic string, subscriber string) (*Subscription, error)

+ SendRawTransaction func(txn *transaction.Transaction) (string, error)

+ type Signer interface

+ ProgramHash func() common.Uint160

+ PubKey func() []byte

+ SignTransaction func(tx *transaction.Transaction) error

+ type SignerRPCClient interface

+ DeleteName func(name string, config *TransactionConfig) (string, error)

+ RegisterName func(name string, config *TransactionConfig) (string, error)

+ Subscribe func(identifier, topic string, duration int, meta string, config *TransactionConfig) (string, error)

+ Transfer func(address, amount string, config *TransactionConfig) (string, error)

+ TransferName func(name string, recipientPubKey []byte, config *TransactionConfig) (string, error)

+ Unsubscribe func(identifier, topic string, config *TransactionConfig) (string, error)

+ type TransactionConfig struct

+ Attributes []byte

+ Fee string

+ Nonce int64

+ func GetDefaultTransactionConfig() *TransactionConfig

+ func MergeTransactionConfig(conf *TransactionConfig) (*TransactionConfig, error)

type Wallet

+ func (w *Wallet) GetNonceByAddress(address string, txPool bool) (int64, error)

+ func (w *Wallet) GetRegistrant(name string) (*Registrant, error)

+ func (w *Wallet) ProgramHash() common.Uint160

+ func (w *Wallet) SignTransaction(tx *transaction.Transaction) error

Apr 10, 2020

Changes in this version

+ var DefaultRPCConfig = RPCConfig

+ var ErrAddrNotAllowed = errors.New("address not allowed")

+ var ErrConnectFailed = errors.New("connect failed")

+ var ErrCreateClientFailed = errors.New("failed to create client")

+ var ErrDecryptFailed = errors.New("decrypt message failed")

+ var ErrExpiredNanoPay = errors.New("nanopay expired")

+ var ErrExpiredNanoPayTxn = errors.New("nanopay transaction expired")

+ var ErrInsufficientBalance = errors.New("insufficient balance")

+ var ErrInvalidAmount = errors.New("invalid amount")

+ var ErrInvalidDestination = errors.New("invalid destination")

+ var ErrInvalidPubkey = errors.New("invalid public key")

+ var ErrInvalidPubkeyOrName = errors.New("invalid public key or name")

+ var ErrInvalidPubkeySize = errors.New("invalid public key size")

+ var ErrInvalidWalletVersion = fmt.Errorf("invalid wallet version, should be between %v and %v", ...)

+ var ErrMessageOversize = fmt.Errorf("encoded message is greater than %v bytes", maxClientMessageSize)

+ var ErrNanoPayClosed = errors.New("use of closed nano pay claimer")

+ var ErrNilClient = errors.New("client is nil")

+ var ErrNilWebsocketConn = errors.New("nil websocket connection")

+ var ErrNoDestination = errors.New("no destination")

+ var ErrNotNanoPay = errors.New("not nano pay transaction")

+ var ErrWrongPassword = errors.New("wrong password")

+ var ErrWrongRecipient = errors.New("wrong nano pay recipient")

+ func GetDefaultSessionConfig() *ncp.Config

+ func GetHeight(config RPCConfigInterface) (int32, error)

+ func GetNonce(address string, txPool bool, config RPCConfigInterface) (int64, error)

+ func GetSubscribersCount(topic string, config RPCConfigInterface) (int, error)

+ func RPCCall(action string, params map[string]interface{}, result interface{}, ...) error

+ func SendRawTransaction(txn *transaction.Transaction, config RPCConfigInterface) (string, error)

type Amount

+ func GetBalance(address string, config RPCConfigInterface) (*Amount, error)

type Client

+ func (c *Client) GetNode() *Node

+ func (c *Client) GetSubscribers(topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ func (c *Client) GetSubscribersCount(topic string) (int, error)

+ func (c *Client) GetSubscription(topic string, subscriber string) (*Subscription, error)

type ClientConfig

+ func GetDefaultClientConfig() *ClientConfig

type DialConfig

+ func GetDefaultDialConfig(baseSessionConfig *ncp.Config) *DialConfig

+ type ErrorWithCode interface

+ Code func() int32

type Message

+ MessageID []byte

type MessageConfig

+ func GetDefaultMessageConfig() *MessageConfig

type MultiClient

+ func (m *MultiClient) PubKey() []byte

+ func (m *MultiClient) Seed() []byte

type NanoPay

+ func (np *NanoPay) Recipient() string

type NanoPayClaimer

+ func (npc *NanoPayClaimer) Recipient() string

+ type Node struct

+ Address string

+ ID string

+ PublicKey string

+ func GetWsAddr(clientAddr string, config RPCConfigInterface) (*Node, error)

+ func GetWssAddr(clientAddr string, config RPCConfigInterface) (*Node, error)

+ type RPCConfig struct

+ SeedRPCServerAddr *StringArray

+ func GetDefaultRPCConfig() *RPCConfig

+ func (config *RPCConfig) GetRandomSeedRPCServerAddr() string

+ type RPCConfigInterface interface

+ GetRandomSeedRPCServerAddr func() string

+ type Registrant struct

+ ExpiresAt int32

+ Registrant string

+ func GetRegistrant(name string, config RPCConfigInterface) (*Registrant, error)

type Subscribers

+ func GetSubscribers(topic string, offset, limit int, meta, txPool bool, config RPCConfigInterface) (*Subscribers, error)

type Subscription

+ func GetSubscription(topic string, subscriber string, config RPCConfigInterface) (*Subscription, error)

type Wallet

+ func (w *Wallet) GetHeight() (int32, error)

type WalletConfig

+ func GetDefaultWalletConfig() *WalletConfig

Apr 1, 2020

Changes in this version

type ClientConfig

+ WsWriteTimeout int32

type MultiClient

+ func (m *MultiClient) GetClient(i int) *Client

+ func (m *MultiClient) GetClients() map[int]*Client

+ func (m *MultiClient) GetDefaultClient() *Client

Mar 25, 2020

Changes in this version

type Message

+ MessageId []byte

+ NoReply bool

type MessageConfig

+ NoReply bool

Mar 20, 2020

Changes in this version

+ const AckType

+ const AmountUnit

+ const BinaryType

+ const DefaultSessionAllowAddr

+ const MessageIDSize

+ const MultiClientIdentifierRe

+ const SessionIDSize

+ const SessionType

+ const TextType

+ var DefaultSeedRPCServerAddr = []string

+ var ErrClosed = ncp.NewGenericError("use of closed network connection", true, true)

+ var ErrInvalidPayloadType = errors.New("invalid payload type")

+ var ErrKeyNotInMap = errors.New("key not in map")

+ func ClientAddrToPubKey(clientAddr string) ([]byte, error)

+ func ClientAddrToWalletAddr(clientAddr string) (string, error)

+ func DefaultSessionConfig() *ncp.Config

+ func PubKeyToWalletAddr(pk []byte) (string, error)

+ func RandomBytes(numBytes int) ([]byte, error)

+ func VerifyWalletAddress(address string) error

+ type Account struct

+ func NewAccount(seed []byte) (*Account, error)

+ func (account *Account) PubKey() []byte

+ func (account *Account) Seed() []byte

+ func (account *Account) WalletAddress() string

+ type Amount struct

+ func NewAmount(s string) (*Amount, error)

+ func (amount *Amount) ToFixed64() common.Fixed64

+ type BlockInfo struct

+ Hash string

+ Header *HeaderInfo

+ Size int

+ Transactions []TxnInfo

+ func NewBlockInfo() *BlockInfo

+ type Client struct

+ OnBlock *OnBlock

+ OnConnect *OnConnect

+ OnMessage *OnMessage

+ func NewClient(account *Account, identifier string, config *ClientConfig) (*Client, error)

+ func (c *Client) Address() string

+ func (c *Client) Close()

+ func (c *Client) GetConn() *websocket.Conn

+ func (c *Client) GetNodeInfo() *NodeInfo

+ func (c *Client) IsClosed() bool

+ func (c *Client) PubKey() []byte

+ func (c *Client) Publish(topic string, data interface{}, config *MessageConfig) error

+ func (c *Client) PublishBinary(topic string, data []byte, config *MessageConfig) error

+ func (c *Client) PublishText(topic string, data string, config *MessageConfig) error

+ func (c *Client) Seed() []byte

+ func (c *Client) Send(dests *StringArray, data interface{}, config *MessageConfig) (*OnMessage, error)

+ func (c *Client) SendBinary(dests *StringArray, data []byte, config *MessageConfig) (*OnMessage, error)

+ func (c *Client) SendText(dests *StringArray, data string, config *MessageConfig) (*OnMessage, error)

+ func (c *Client) SetWriteDeadline(deadline time.Time) error

+ type ClientAddr struct

+ func NewClientAddr(addr string) *ClientAddr

+ func (addr ClientAddr) Network() string

+ func (addr ClientAddr) String() string

+ type ClientConfig struct

+ BlockChanLen int32

+ ConnectRetries int32

+ MaxHoldingSeconds int32

+ MaxReconnectInterval int32

+ MessageConfig *MessageConfig

+ MinReconnectInterval int32

+ MsgCacheCleanupInterval int32

+ MsgCacheExpiration int32

+ MsgChanLen int32

+ SeedRPCServerAddr *StringArray

+ SessionConfig *ncp.Config

+ WsHandshakeTimeout int32

+ func DefaultClientConfig() *ClientConfig

+ func MergeClientConfig(conf *ClientConfig) (*ClientConfig, error)

+ func (config *ClientConfig) GetRandomSeedRPCServerAddr() string

+ type DialConfig struct

+ DialTimeout int32

+ SessionConfig *ncp.Config

+ func DefaultDialConfig(baseSessionConfig *ncp.Config) *DialConfig

+ func MergeDialConfig(baseSessionConfig *ncp.Config, conf *DialConfig) (*DialConfig, error)

+ type HeaderInfo struct

+ Hash string

+ Height int32

+ PrevBlockHash string

+ RandomBeacon string

+ Signature string

+ SignerId string

+ SignerPk string

+ StateRoot string

+ Timestamp int64

+ TransactionsRoot string

+ Version int32

+ WinnerHash string

+ WinnerType string

+ type Message struct

+ Data []byte

+ Encrypted bool

+ Pid []byte

+ Src string

+ Type int32

+ func (msg *Message) Reply(data interface{}) error

+ func (msg *Message) ReplyBinary(data []byte) error

+ func (msg *Message) ReplyText(data string) error

+ type MessageConfig struct

+ Limit int32

+ MaxHoldingSeconds int32

+ MessageID []byte

+ NoAck bool

+ Offset int32

+ TxPool bool

+ Unencrypted bool

+ func DefaultMessageConfig() *MessageConfig

+ func MergeMessageConfig(base, conf *MessageConfig) (*MessageConfig, error)

+ type MultiClient struct

+ Clients map[int]*Client

+ DefaultClient *Client

+ OnConnect *OnConnect

+ OnMessage *OnMessage

+ func NewMultiClient(account *Account, baseIdentifier string, numSubClients int, ...) (*MultiClient, error)

+ func (m *MultiClient) Accept() (net.Conn, error)

+ func (m *MultiClient) AcceptSession() (*ncp.Session, error)

+ func (m *MultiClient) Addr() net.Addr

+ func (m *MultiClient) Address() string

+ func (m *MultiClient) Close() error

+ func (m *MultiClient) Dial(remoteAddr string) (net.Conn, error)

+ func (m *MultiClient) DialSession(remoteAddr string) (*ncp.Session, error)

+ func (m *MultiClient) DialWithConfig(remoteAddr string, config *DialConfig) (*ncp.Session, error)

+ func (m *MultiClient) IsClosed() bool

+ func (m *MultiClient) Listen(addrsRe *StringArray) error

+ func (m *MultiClient) Publish(topic string, data interface{}, config *MessageConfig) error

+ func (m *MultiClient) PublishBinary(topic string, data []byte, config *MessageConfig) error

+ func (m *MultiClient) PublishText(topic string, data string, config *MessageConfig) error

+ func (m *MultiClient) Send(dests *StringArray, data interface{}, config *MessageConfig) (*OnMessage, error)

+ func (m *MultiClient) SendBinary(dests *StringArray, data []byte, config *MessageConfig) (*OnMessage, error)

+ func (m *MultiClient) SendBinaryWithClient(clientID int, dests *StringArray, data []byte, config *MessageConfig) (*OnMessage, error)

+ func (m *MultiClient) SendText(dests *StringArray, data string, config *MessageConfig) (*OnMessage, error)

+ func (m *MultiClient) SendTextWithClient(clientID int, dests *StringArray, data string, config *MessageConfig) (*OnMessage, error)

+ func (m *MultiClient) SendWithClient(clientID int, dests *StringArray, data interface{}, config *MessageConfig) (*OnMessage, error)

+ type NanoPay struct

+ func NewNanoPay(w *Wallet, address string, fee *Amount, duration int) (*NanoPay, error)

+ func (np *NanoPay) Address() string

+ func (np *NanoPay) IncrementAmount(delta string) (*transaction.Transaction, error)

+ type NanoPayClaimer struct

+ func NewNanoPayClaimer(w *Wallet, address string, claimIntervalMs int32, onError *OnError) (*NanoPayClaimer, error)

+ func (npc *NanoPayClaimer) Address() string

+ func (npc *NanoPayClaimer) Amount() *Amount

+ func (npc *NanoPayClaimer) Claim(tx *transaction.Transaction) (*Amount, error)

+ func (npc *NanoPayClaimer) Close() error

+ func (npc *NanoPayClaimer) Flush() error

+ func (npc *NanoPayClaimer) IsClosed() bool

+ type NodeInfo struct

+ Address string

+ Id string

+ PublicKey string

+ type OnBlock struct

+ C chan *BlockInfo

+ Callback OnBlockFunc

+ func NewOnBlock(size int, cb OnBlockFunc) *OnBlock

+ func (c *OnBlock) Next() *BlockInfo

+ type OnBlockFunc interface

+ OnBlock func(*BlockInfo)

+ type OnConnect struct

+ C chan *NodeInfo

+ Callback OnConnectFunc

+ func NewOnConnect(size int, cb OnConnectFunc) *OnConnect

+ func (c *OnConnect) Next() *NodeInfo

+ type OnConnectFunc interface

+ OnConnect func(*NodeInfo)

+ type OnError struct

+ C chan error

+ Callback OnErrorFunc

+ func NewOnError(size int, cb OnErrorFunc) *OnError

+ func (c *OnError) Next() error

+ type OnErrorFunc interface

+ OnError func(error)

+ type OnMessage struct

+ C chan *Message

+ Callback OnMessageFunc

+ func NewOnMessage(size int, cb OnMessageFunc) *OnMessage

+ func (c *OnMessage) Next() *Message

+ type OnMessageFunc interface

+ OnMessage func(*Message)

+ type ProgramInfo struct

+ Code string

+ Parameter string

+ type RegistrantInfo struct

+ ExpiresAt uint32

+ Registrant string

+ type SetClientResult struct

+ NodeInfo *NodeInfo

+ SigChainBlockHash string

+ type StringArray struct

+ Elems []string

+ func NewStringArray(elems ...string) *StringArray

+ func NewStringArrayFromString(s string) *StringArray

+ func (sa *StringArray) Append(s string)

+ func (sa *StringArray) Len() int

+ type StringMap struct

+ Map map[string]string

+ func NewStringMap(m map[string]string) *StringMap

+ func NewStringMapWithSize(size int) *StringMap

+ func (sm *StringMap) Delete(key string)

+ func (sm *StringMap) Get(key string) (string, error)

+ func (sm *StringMap) Len() int

+ func (sm *StringMap) Range(cb StringMapFunc)

+ func (sm *StringMap) Set(key, value string)

+ type StringMapFunc interface

+ OnVisit func(string, string) bool

+ type Subscribers struct

+ Subscribers *StringMap

+ SubscribersInTxPool *StringMap

+ type Subscription struct

+ ExpiresAt int32

+ Meta string

+ type TxnInfo struct

+ Attributes string

+ Fee int64

+ Hash string

+ Nonce int64

+ PayloadData string

+ Programs []ProgramInfo

+ TxType string

+ type Wallet struct

+ func NewWallet(account *Account, config *WalletConfig) (*Wallet, error)

+ func WalletFromJSON(walletJSON string, config *WalletConfig) (*Wallet, error)

+ func (w *Wallet) Address() string

+ func (w *Wallet) Balance() (*Amount, error)

+ func (w *Wallet) BalanceByAddress(address string) (*Amount, error)

+ func (w *Wallet) DeleteName(name string, fee string) (string, error)

+ func (w *Wallet) GetNonce() (int64, error)

+ func (w *Wallet) GetSubscribers(topic string, offset, limit int, meta, txPool bool) (*Subscribers, error)

+ func (w *Wallet) GetSubscribersCount(topic string) (int, error)

+ func (w *Wallet) GetSubscription(topic string, subscriber string) (*Subscription, error)

+ func (w *Wallet) NewNanoPay(address string, fee string, duration int) (*NanoPay, error)

+ func (w *Wallet) NewNanoPayClaimer(claimIntervalMs int32, onError *OnError, address string) (*NanoPayClaimer, error)

+ func (w *Wallet) PubKey() []byte

+ func (w *Wallet) RegisterName(name string, fee string) (string, error)

+ func (w *Wallet) Seed() []byte

+ func (w *Wallet) SendRawTransaction(tx *transaction.Transaction) (string, error)

+ func (w *Wallet) Subscribe(identifier string, topic string, duration int, meta string, fee string) (string, error)

+ func (w *Wallet) ToJSON() (string, error)

+ func (w *Wallet) Transfer(address string, value string, fee string) (string, error)

+ func (w *Wallet) TransferName(name string, recipient []byte, fee string) (string, error)

+ func (w *Wallet) Unsubscribe(identifier string, topic string, fee string) (string, error)

+ func (w *Wallet) VerifyPassword(password string) bool

+ type WalletConfig struct

+ IV []byte

+ MasterKey []byte

+ Password string

+ SeedRPCServerAddr *StringArray

+ func DefaultWalletConfig() *WalletConfig

+ func MergeWalletConfig(conf *WalletConfig) (*WalletConfig, error)

+ func (config *WalletConfig) GetRandomSeedRPCServerAddr() string