drpc

package module

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

Details

Package drpc provides a drpc transport for client/orb.

View Source

const Name = "drpc"

Name is the transports name.

This section is empty.

func NewTransport(network string) func(logger log.Logger, cfg *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 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 creates a bidirectional DRPC stream to the service endpoint.

Path	Synopsis
pool Package pool provides a pool of grpc clients This is a modified version of: https://github.com/processout/grpc-go-pool/blob/master/pool.go	Package pool provides a pool of grpc clients This is a modified version of: https://github.com/processout/grpc-go-pool/blob/master/pool.go