test

package

Go to main page

Versions in this module

v0

v0.1.7

Nov 11, 2025

Changes in this version

+ const CACertificateKey

+ const PrivateKey

+ const PublicKey

+ var InsecureTLSConfig connection.TLSConfig

+ var ServerModes = []string

+ func CreateClientWithTLS[T any](t *testing.T, endpoint *connection.Endpoint, tlsCfg connection.TLSConfig, ...) T

+ func CreateDockerNetwork(t *testing.T, name string) *docker.Network

+ func CreateServerAndClientTLSConfig(t *testing.T, tlsMode string) (serverTLSConfig, clientTLSConfig connection.TLSConfig)

+ func GetDockerClient(t *testing.T) *docker.Client

+ func MustCreateEndpoint(value string) *connection.Endpoint

+ func NewInsecureClientConfig(ep *connection.Endpoint) *connection.ClientConfig

+ func NewInsecureConnection(t *testing.T, endpoint connection.WithAddress) *grpc.ClientConn

+ func NewInsecureConnectionWithRetry(t *testing.T, endpoint connection.WithAddress, retry connection.RetryProfile) *grpc.ClientConn

+ func NewInsecureLoadBalancedConnection(t *testing.T, endpoints []*connection.Endpoint) *grpc.ClientConn

+ func NewSecuredConnection(t *testing.T, endpoint connection.WithAddress, tlsConfig connection.TLSConfig) *grpc.ClientConn

+ func NewSecuredConnectionWithRetry(t *testing.T, endpoint connection.WithAddress, tlsConfig connection.TLSConfig, ...) *grpc.ClientConn

+ func NewTLSClientConfig(tlsConfig connection.TLSConfig, ep *connection.Endpoint) *connection.ClientConfig

+ func NewTLSMultiClientConfig(tlsConfig connection.TLSConfig, ep ...*connection.Endpoint) *connection.MultiClientConfig

+ func RemoveDockerNetwork(t *testing.T, name string)

+ func RunSecureConnectionTest(t *testing.T, starter ServerStarter)

+ func ServerToMultiClientConfig(servers ...*connection.ServerConfig) *connection.MultiClientConfig

type BroadcastStream

+ func (s *BroadcastStream) CloseConnections()

+ type CredentialsFactory struct

+ CertificateAuthority tlsgen.CA

+ func NewCredentialsFactory(t *testing.T) *CredentialsFactory

+ func (scm *CredentialsFactory) CreateClientCredentials(t *testing.T, tlsMode string) (connection.TLSConfig, string)

+ func (scm *CredentialsFactory) CreateServerCredentials(t *testing.T, tlsMode string, san ...string) (connection.TLSConfig, string)

+ type RPCAttempt func(ctx context.Context, t *testing.T, cfg connection.TLSConfig) error

+ type ServerStarter func(t *testing.T, serverTLS connection.TLSConfig) RPCAttempt

v0.1.6

Sep 10, 2025

Changes in this version

+ func LogStruct(t *testing.T, name string, v any)

+ func WaitUntilGrpcServerIsDown(ctx context.Context, t *testing.T, conn grpc.ClientConnInterface)

+ type BroadcastStream struct

+ ConnectionManager *ordererconn.ConnectionManager

+ func NewBroadcastStream(ctx context.Context, config *ordererconn.Config) (*BroadcastStream, error)

+ func (s *BroadcastStream) Close()

+ func (s *BroadcastStream) SendBatch(envelopes []*common.Envelope) error

+ type Broadcaster interface

+ Send func(*common.Envelope) error

v0.1.5

Aug 6, 2025

v0.1.4

Jul 23, 2025

v0.1.3

Jul 8, 2025

Changes in this version

+ func CheckMetrics(t *testing.T, url string, expectedMetrics ...string)

+ func CheckServerStopped(t *testing.T, addr string) bool

+ func EnsurePersistedTxStatus(ctx context.Context, t *testing.T, r StatusRetriever, txIDs []string, ...)

+ func EventuallyIntMetric(t *testing.T, expected int, m prometheus.Metric, waitFor, tick time.Duration, ...)

+ func FailHandler(t *testing.T)

+ func GetIntMetricValue(t *testing.T, m prometheus.Metric) int

+ func GetMetricValue(t *testing.T, m prometheus.Metric) float64

+ func GetMetricValueFromURL(t *testing.T, url, metricName string) int

+ func RequireIntMetricValue(t *testing.T, expected int, m prometheus.Metric)

+ func RequireProtoElementsMatch[T proto.Message](t *testing.T, expected, actual []T, msgAndArgs ...any)

+ func RequireProtoEqual(t *testing.T, expected, actual proto.Message)

+ func RunGrpcServerForTest(ctx context.Context, t *testing.T, serverConfig *connection.ServerConfig, ...) *grpc.Server

+ func RunServiceAndGrpcForTest(ctx context.Context, t *testing.T, service connection.Service, ...) *channel.Ready

+ func RunServiceForTest(ctx context.Context, tb testing.TB, service func(ctx context.Context) error, ...) *channel.Ready

+ func ServerToClientConfig(servers ...*connection.ServerConfig) *connection.ClientConfig

+ func SetupDebugging()

+ func WaitUntilGrpcServerIsReady(ctx context.Context, t *testing.T, conn grpc.ClientConnInterface)

+ type GrpcServers struct

+ Configs []*connection.ServerConfig

+ Servers []*grpc.Server

+ func StartGrpcServersForTest(ctx context.Context, t *testing.T, numService int, ...) *GrpcServers

+ func StartGrpcServersWithConfigForTest(ctx context.Context, t *testing.T, sc []*connection.ServerConfig, ...) *GrpcServers

+ type StatusRetriever interface

+ GetTransactionsStatus func(context.Context, *protoblocktx.QueryStatus, ...grpc.CallOption) (*protoblocktx.TransactionsStatus, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL