http

package module

v0.3.0 Latest Latest Go to latest Published: Apr 7, 2025 License: Apache-2.0 Imports: 20 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-orb/plugins

Links

Open Source Insights

Documentation ¶

Overview ¶

Package http contains the http transport for the orb client,

Index ¶

func NewHTTP3Transport(logger log.Logger, cfg *orb.Config) (orb.TransportType, error)
func NewHTTPSTransport(logger log.Logger, cfg *orb.Config) (orb.TransportType, error)
func NewHTTPTransport(network string) func(logger log.Logger, cfg *orb.Config) (orb.TransportType, error)
func NewTransport(name string, logger log.Logger, scheme string, network string, cfg *orb.Config, ...) (orb.TransportType, error)
type Transport

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewHTTP3Transport ¶

func NewHTTP3Transport(logger log.Logger, cfg *orb.Config) (orb.TransportType, error)

NewHTTP3Transport creates a new https transport for the orb client. This transport is used for HTTP/3.

func NewHTTPSTransport ¶

func NewHTTPSTransport(logger log.Logger, cfg *orb.Config) (orb.TransportType, error)

NewHTTPSTransport creates a new https transport for the orb client. This transport is used for HTTPS/1.1.

func NewHTTPTransport ¶

func NewHTTPTransport(network string) func(logger log.Logger, cfg *orb.Config) (orb.TransportType, error)

NewHTTPTransport creates a new https transport for the orb client.

func NewTransport ¶

func NewTransport(
	name string,
	logger log.Logger,
	scheme string,
	network string,
	cfg *orb.Config,
	hclient *http.Client,
) (orb.TransportType, error)

NewTransport creates a Transport with a custom http.Client.

Types ¶

type Transport ¶

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

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

func (*Transport) Name ¶

func (t *Transport) Name() string

Name returns the name of this transport.

func (*Transport) Request ¶

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

Request does the actual rpc call to the server.

func (*Transport) Start ¶

func (t *Transport) Start() error

Start starts the transport.

func (*Transport) Stop ¶

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

Stop stop the transport.

func (*Transport) Stream ¶

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

Stream creates a bidirectional stream to the service endpoint. HTTP transport does not support streaming operations by default.

Source Files ¶

View all Source files

http.go

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