stress

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2026 License: MIT Imports: 30 Imported by: 0

Documentation

Overview

Package stress implements the stress test for the identity updates.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StressIdentityUpdates 

func StressIdentityUpdates(
	ctx context.Context,
	logger *zap.Logger,
	n int,
	contractAddress common.Address,
	rpc string,
	privateKey string,
	async bool,
) error

Types

type CastSendCommand 

type CastSendCommand struct {
	ContractAddress string
	Function        string
	FunctionArgs    []string
	RPC             string
	PrivateKey      string
	Nonce           *uint64
	Async           bool
}

func (*CastSendCommand) Run 

func (c *CastSendCommand) Run(ctx context.Context) error

type EnvelopesGenerator added in v0.5.1 

type EnvelopesGenerator struct {
	// contains filtered or unexported fields
}

func NewEnvelopesGenerator added in v0.5.1 

func NewEnvelopesGenerator(
	nodeHTTPAddress string,
	privateKeyString string,
	originatorID uint32,
	protocol Protocol,
) (*EnvelopesGenerator, error)

func (*EnvelopesGenerator) Close added in v0.5.1 

func (e *EnvelopesGenerator) Close() error

func (*EnvelopesGenerator) PublishGroupMessageEnvelopes added in v0.5.1 

func (e *EnvelopesGenerator) PublishGroupMessageEnvelopes(
	ctx context.Context,
	numEnvelopes uint,
	size string,
) ([]*envelopesProto.OriginatorEnvelope, error)

PublishGroupMessageEnvelopes publishes group message envelopes to the XMTPD node. The data size can be specified.

func (*EnvelopesGenerator) PublishKeyPackageEnvelopes added in v0.5.1 

func (e *EnvelopesGenerator) PublishKeyPackageEnvelopes(
	ctx context.Context,
	numEnvelopes uint,
) ([]*envelopesProto.OriginatorEnvelope, error)

PublishKeyPackageEnvelopes publishes key package envelopes to the XMTPD node. The data size is hardcoded to 1651 bytes, as expected by the protocol.

func (*EnvelopesGenerator) PublishWelcomeMessageEnvelopes added in v0.5.1 

func (e *EnvelopesGenerator) PublishWelcomeMessageEnvelopes(
	ctx context.Context,
	numEnvelopes uint,
	dataSize uint,
) ([]*envelopesProto.OriginatorEnvelope, error)

PublishWelcomeMessageEnvelopes publishes welcome message envelopes to the XMTPD node. The data size can be specified.

type Protocol added in v1.0.0 

type Protocol int
const (
	ProtocolConnect Protocol = iota
	ProtocolConnectGRPC
	ProtocolConnectGRPCWeb
	ProtocolNativeGRPC
)

type Watcher 

type Watcher struct {
	// contains filtered or unexported fields
}

func NewWatcher 

func NewWatcher(
	ctx context.Context,
	logger *zap.Logger,
	wsURL string,
	watchedContract common.Address,
) (*Watcher, error)

func (*Watcher) Listen 

func (w *Watcher) Listen(ctx context.Context) 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.