transport

package
v1.1.17 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 5, 2025 License: MIT Imports: 5 Imported by: 27

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AdjustAddress added in v1.1.16

func AdjustAddress(hostPort string, lis net.Listener) (string, error)

func AdjustScheme added in v1.1.16

func AdjustScheme(scheme string, isSecure bool) string

func ExtractHostPort added in v1.1.16

func ExtractHostPort(addr string) (host string, port uint64, err error)

ExtractHostPort from address

func ExtractPort added in v1.1.16

func ExtractPort(lis net.Listener) (int, bool)

func GetIPAddressByInterfaceName added in v1.1.16

func GetIPAddressByInterfaceName(ifName string) (string, error)

func GetLocalIP added in v1.1.16

func GetLocalIP() (string, error)

func GetPublicIP added in v1.1.16

func GetPublicIP() (string, error)

func IsValidIP added in v1.1.16

func IsValidIP(addr string) bool

func NewRegistryEndpoint added in v1.1.17

func NewRegistryEndpoint(serviceKindName string, host string) *url.URL

NewRegistryEndpoint creates a new registry endpoint URL.

Types

type SubscribeOption

type SubscribeOption struct {
	Handler          broker.Handler
	Binder           broker.Binder
	SubscribeOptions []broker.SubscribeOption
}

type SubscribeOptionMap

type SubscribeOptionMap map[string]*SubscribeOption

Directories

Path Synopsis
activemq module
asynq module
fasthttp module
gin module
gozero module
graphql module
hertz module
http3 module
iris module
kafka module
keepalive module
machinery module
mqtt module
nats module
nsq module
pulsar module
rabbitmq module
redis module
rocketmq module
signalr module
socketio module
sse module
tcp module
thrift module
trpc module
websocket module
webtransport module

Jump to

Keyboard shortcuts

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