API reference v103.1.0
Type Aliases
BrandedString<T>
BrandedString<
T>:string&object
Type declaration
__brand
__brand:
T
Type Parameters
• T
DhtAddress
DhtAddress:
BrandedString<"DhtAddress">
EnvironmentId
EnvironmentId: typeof
ENVIRONMENT_IDS[number]
EthereumAddress
EthereumAddress:
BrandedString<"EthereumAddress">
GapFillStrategy
GapFillStrategy:
"light"|"full"
IdentityConfig
IdentityConfig:
KeyPairIdentityConfig|EthereumProviderIdentityConfig|CustomIdentityConfig
KeyType
KeyType: typeof
KEY_TYPES[number]
LogLevel
LogLevel:
"silent"|"fatal"|"error"|"warn"|"info"|"debug"|"trace"
MessageListener()
MessageListener: (
content,metadata) =>unknown|Promise<unknown>
Parameters
content
unknown
metadata
Returns
unknown | Promise<unknown>
MessageMetadata
MessageMetadata:
Omit<Message,"content">
MessageSignatureType
MessageSignatureType:
KeyType|"ECDSA_SECP256K1_LEGACY"|"ERC_1271"
MetricsDefinition
MetricsDefinition:
Record<string,Metric>
MetricsReport
MetricsReport:
object&Record<string,any>
Type declaration
period
period:
object
period.end
end:
number
period.start
start:
number
PermissionAssignment
PermissionAssignment:
UserPermissionAssignment|PublicPermissionAssignment
PermissionQuery
PermissionQuery:
UserPermissionQuery|PublicPermissionQuery
ResendOptions
ResendOptions:
ResendLastOptions|ResendFromOptions|ResendRangeOptions
The supported resend types.
SignerWithProvider
SignerWithProvider:
AbstractSigner<Provider>
The AbstractSigner type is from the ethers library.
StreamDefinition
StreamDefinition:
string| {id:string;partition:number; } | {partition:number;stream:string; } | {partition:number;streamId:string; }
StreamID
StreamID:
BrandedString<"StreamID">
StreamMessageAESEncrypted
StreamMessageAESEncrypted:
StreamMessage&object
Encrypted StreamMessage.
Type declaration
encryptionType
encryptionType:
AES
groupKeyId
groupKeyId:
string
StreamMetadata
StreamMetadata:
Record<string,unknown>
StreamPartID
StreamPartID:
BrandedString<"StreamPartID">
StrictStreamrClientConfig
StrictStreamrClientConfig:
MarkOptional<Required<StreamrClientConfig>,"auth"|"metrics"> &object
Type declaration
cache
cache:
Exclude<Required<StreamrClientConfig["cache"]>,undefined>
contracts
contracts:
Exclude<Required<StreamrClientConfig["contracts"]>,undefined>
encryption
encryption:
Exclude<Required<StreamrClientConfig["encryption"]>,undefined>
network
network:
Exclude<Required<StreamrClientConfig["network"]>,undefined>
SubscribeOptions
SubscribeOptions:
StreamDefinition&ExtraSubscribeOptions
UserID
UserID:
BrandedString<"UserID">
Variables
DEFAULT_ENVIRONMENT_ID
constDEFAULT_ENVIRONMENT_ID:EnvironmentId='polygon'
DEFAULT_KEY_TYPE
constDEFAULT_KEY_TYPE:KeyType='ECDSA_SECP256K1_EVM'
EncryptedGroupKey
EncryptedGroupKey:
EncryptedGroupKey$Type
Generated
MessageType for protobuf message EncryptedGroupKey
ENVIRONMENT_IDS
constENVIRONMENT_IDS: readonly ["polygon","polygonAmoy","peaq","iotex","dev2"]
PeerDescriptor
PeerDescriptor:
PeerDescriptor$Type
Generated
MessageType for protobuf message dht.PeerDescriptor
STREAMR_STORAGE_NODE_ADDRESS
constSTREAMR_STORAGE_NODE_ADDRESS:string
STREAMR_STORAGE_NODE_GERMANY
constSTREAMR_STORAGE_NODE_GERMANY:"0x31546eEA76F2B2b3C5cC06B1c93601dc35c9D916"='0x31546eEA76F2B2b3C5cC06B1c93601dc35c9D916'
Deprecated
use STREAMR_STORAGE_NODE_ADDRESS instead
Functions
convertBytesToStreamMessage()
convertBytesToStreamMessage(
bytes):StreamMessage
Parameters
bytes
Uint8Array
Returns
convertStreamMessageToBytes()
convertStreamMessageToBytes(
oldStreamMessage):Uint8Array
Parameters
oldStreamMessage
Returns
Uint8Array
formStorageNodeAssignmentStreamId()
formStorageNodeAssignmentStreamId(
clusterAddress):StreamID
Parameters
clusterAddress
string
Returns
getStreamPartitionCount()
getStreamPartitionCount(
metadata):number
Parameters
metadata
Returns
number
parseStreamMetadata()
parseStreamMetadata(
metadata):StreamMetadata
Parameters
metadata
string
Returns
peerDescriptorTranslator()
peerDescriptorTranslator(
json):PeerDescriptor
Parameters
json
Returns
Enumerations
- ContentType
- EncryptionType
- NetworkNodeType
- ProxyDirection
- SignatureType
- StreamMessageType
- StreamPermission
Classes
Important
Other
- ECDSAKeyPairIdentity
- EncryptionKey
- EthereumKeyPairIdentity
- EthereumProviderIdentity
- Identity
- KeyPairIdentity
- MessageID
- MessageRef
- MessageStream
- Metric
- MetricsContext
- MLDSAKeyPairIdentity
- RpcProviderSource
- StreamMessage
Interfaces
Important
Other
- ConnectionInfo
- ConnectivityMethod
- ControlLayerConfig
- CustomIdentityConfig
- EncryptedGroupKey
- EntryPointDiscovery
- EthereumNetworkConfig
- EthereumProviderIdentityConfig
- ExtraSubscribeOptions
- IceServer
- KeyPairIdentityConfig
- NetworkConfig
- NetworkNodeConfig
- NetworkPeerDescriptor
- PeerDescriptor
- PortRange
- PublicPermissionAssignment
- PublicPermissionQuery
- PublishMetadata
- ResendFromOptions
- ResendLastOptions
- ResendRangeOptions
- ResendRef
- SearchStreamsPermissionFilter
- SponsorshipCreatedEvent
- StorageNodeAssignmentEvent
- StorageNodeMetadata
- StreamCreationEvent
- StreamMessageOptions
- StreamPartDeliveryOptions
- StreamrClientEvents
- SubscriptionEvents
- UpdateEncryptionKeyOptions
- UserPermissionAssignment
- UserPermissionQuery