memory

package module

v0.1.0 Latest Latest Go to latest Published: Mar 26, 2025 License: Apache-2.0 Imports: 7 Imported by: 1

Details

Package memory implements a go-orb/plugins/client/orb compatible memory transport.

View Source

const Name = "memory"

Name is the name of this transport.

This section is empty.

func NewTransport(logger log.Logger, _ *orb.Config) (orb.TransportType, error)

NewTransport creates a Transport.

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

Transport is a go-orb/plugins/client/orb compatible memory transport.

func (t *Transport) Name() string

Name returns the name of this transport.

func (t *Transport) Request(ctx context.Context, infos client.RequestInfos, req any, result any, opts *client.CallOptions) error

Request does the actual rpc request to the server.

func (t *Transport) Start() error

Start starts the transport.

func (t *Transport) Stop(_ context.Context) error

Stop stop the transport.

func (t *Transport) Stream(
	ctx context.Context, infos client.RequestInfos,
	opts *client.CallOptions,
) (client.StreamIface[any, any], error)

Stream opens a bidirectional stream to the memory server.