grpctest

package

v0.0.0-...-c9f981a Latest Latest Go to latest Published: Mar 7, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

Client wraps a gRPC client connection

func NewClient(_ testing.TB, url string) *Client

NewClient connects to a gRPC server and creates the reflex client

func (cl *Client) Close() error

Close ends the stream

func (cl *Client) StreamEvents(ctx context.Context, after string,
	opts ...reflex.StreamOption,
) (reflex.StreamClient, error)

StreamEvents wraps a gRPC stream, feeding the events to reflex

type Server struct {
	reflexpb.UnimplementedReflexServer
	// contains filtered or unexported fields
}

Server is an gRPC streaming server for testing

func NewServer(_ testing.TB, stream reflex.StreamFunc,
	cStore reflex.CursorStore,
) (*Server, string)

NewServer starts and returns a reflex server and its address.

func (srv *Server) SentCount() float64

SentCount is the number of events sent

func (srv *Server) Stop()

Stop ends any streams and stops the gRPC server

func (srv *Server) Stream(req *reflexpb.StreamRequest,
	ss reflexpb.Reflex_StreamServer,
) error

Stream creates a new stream