lmstfy

package

v0.0.0-...-40a656a Latest Latest Go to latest Published: Apr 23, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

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

Repository

github.com/hxx258456/kratos-transport-lmstfy

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func LogDebug(args ...interface{})
func LogDebugf(format string, args ...interface{})
func LogError(args ...interface{})
func LogErrorf(format string, args ...interface{})
func LogFatal(args ...interface{})
func LogFatalf(format string, args ...interface{})
func LogInfo(args ...interface{})
func LogInfof(format string, args ...interface{})
func LogWarn(args ...interface{})
func LogWarnf(format string, args ...interface{})
func RegisterSubscriber[T any](srv *Server, topic string, ...) error
type Server
- func NewServer(opts ...ServerOption) *Server
type ServerOption
type Transport

Constants ¶

View Source

const (
	KindLmstfy kratosTransport.Kind = "lmstfy"
)

Variables ¶

This section is empty.

Functions ¶

func LogDebug ¶

func LogDebug(args ...interface{})

func LogDebugf ¶

func LogDebugf(format string, args ...interface{})

func LogError ¶

func LogError(args ...interface{})

func LogErrorf ¶

func LogErrorf(format string, args ...interface{})

func LogFatal ¶

func LogFatal(args ...interface{})

func LogFatalf ¶

func LogFatalf(format string, args ...interface{})

func LogInfo ¶

func LogInfo(args ...interface{})

func LogInfof ¶

func LogInfof(format string, args ...interface{})

func LogWarn ¶

func LogWarn(args ...interface{})

func LogWarnf ¶

func LogWarnf(format string, args ...interface{})

func RegisterSubscriber ¶

func RegisterSubscriber[T any](srv *Server, topic string, handler func(context.Context, string, broker.Headers, *T) error, opts ...broker.SubscribeOption) error

Types ¶

type Server ¶

type Server struct {
	broker.Broker

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(opts ...ServerOption) *Server

func (*Server) Endpoint ¶

func (s *Server) Endpoint() (*url.URL, error)

func (*Server) Name ¶

func (s *Server) Name() string

func (*Server) RegisterSubscriber ¶

func (s *Server) RegisterSubscriber(topic string, handler broker.Handler, binder broker.Binder, opts ...broker.SubscribeOption) error

func (*Server) Start ¶

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop ¶

func (s *Server) Stop(ctx context.Context) error

type ServerOption ¶

type ServerOption func(o *Server)

func WithAddress ¶

func WithAddress(addr string) ServerOption

WithAddress lmstfy服务地址

func WithBrokerOptions ¶

func WithBrokerOptions(opts ...broker.Option) ServerOption

WithBrokerOptions broker配置

func WithCodec ¶

func WithCodec(c string) ServerOption

WithCodec 编解码器

func WithEnableKeepAlive ¶

func WithEnableKeepAlive(enable bool) ServerOption

WithEnableKeepAlive enable keep alive

func WithNamespace ¶

func WithNamespace(ns string) ServerOption

func WithToken ¶

func WithToken(token string) ServerOption

type Transport ¶

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

Transport is a lmstfy transport.

func (*Transport) Endpoint ¶

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind ¶

func (tr *Transport) Kind() kratosTransport.Kind

Kind returns the transport kind.

func (*Transport) NodeFilters ¶

func (tr *Transport) NodeFilters() []selector.NodeFilter

NodeFilters returns the client select filters.

func (*Transport) Operation ¶

func (tr *Transport) Operation() string

Operation returns the transport operation.

func (*Transport) ReplyHeader ¶

func (tr *Transport) ReplyHeader() kratosTransport.Header

ReplyHeader returns the reply header.

func (*Transport) RequestHeader ¶

func (tr *Transport) RequestHeader() kratosTransport.Header

RequestHeader returns the request header.

Source Files ¶

View all Source files

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