redis

package module

v1.2.10 Latest Latest Go to latest Published: May 22, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tx7do/kratos-transport

Links

Open Source Insights

README ¶

Redis

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
- func (s *Server) Endpoint() (*url.URL, error)
- func (s *Server) Name() string
- func (s *Server) RegisterSubscriber(topic string, handler broker.Handler, binder broker.Binder, ...) error
- func (s *Server) Start(ctx context.Context) error
- func (s *Server) Stop(_ context.Context) error
type ServerOption
- func WithAddress(addr string) ServerOption
- func WithBrokerOptions(opts ...broker.Option) ServerOption
- func WithCodec(c string) ServerOption
- func WithConnectTimeout(timeout time.Duration) ServerOption
- func WithEnableKeepAlive(enable bool) ServerOption
- func WithIdleTimeout(timeout time.Duration) ServerOption
- func WithMaxActive(n int) ServerOption
- func WithMaxIdle(n int) ServerOption
- func WithReadTimeout(timeout time.Duration) ServerOption
- func WithTLSConfig(c *tls.Config) ServerOption
- func WithWriteTimeout(timeout time.Duration) ServerOption
type SubscribeOption
type SubscribeOptionMap
type SubscriberMap
type Transport
- func (tr *Transport) Endpoint() string
- func (tr *Transport) Kind() transport.Kind
- func (tr *Transport) NodeFilters() []selector.NodeFilter
- func (tr *Transport) Operation() string
- func (tr *Transport) ReplyHeader() transport.Header
- func (tr *Transport) RequestHeader() transport.Header

Constants ¶

View Source

const (
	KindRedis transport.Kind = "redis"
)

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(_ context.Context) error

type ServerOption ¶

type ServerOption func(o *Server)

func WithAddress ¶

func WithAddress(addr string) ServerOption

WithAddress Redis服务器地址

func WithBrokerOptions ¶

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

WithBrokerOptions MQ代理配置

func WithCodec ¶

func WithCodec(c string) ServerOption

WithCodec 编解码器

func WithConnectTimeout ¶

func WithConnectTimeout(timeout time.Duration) ServerOption

WithConnectTimeout 连接Redis超时时间

func WithEnableKeepAlive ¶

func WithEnableKeepAlive(enable bool) ServerOption

WithEnableKeepAlive enable keep alive

func WithIdleTimeout ¶

func WithIdleTimeout(timeout time.Duration) ServerOption

WithIdleTimeout 最大的空闲连接等待时间，超过此时间后，空闲连接将被关闭。如果设置成0，空闲连接将不会被关闭。应该设置一个比redis服务端超时时间更短的时间。

func WithMaxActive ¶

func WithMaxActive(n int) ServerOption

WithMaxActive 最大的连接数，表示同时最多有N个连接。0表示不限制。

func WithMaxIdle ¶

func WithMaxIdle(n int) ServerOption

WithMaxIdle 最大的空闲连接数，表示即使没有redis连接时依然可以保持N个空闲的连接，而不被清除，随时处于待命状态。

func WithReadTimeout ¶

func WithReadTimeout(timeout time.Duration) ServerOption

WithReadTimeout 从Redis读取数据超时时间

func WithTLSConfig ¶

func WithTLSConfig(c *tls.Config) ServerOption

WithTLSConfig TLS配置

func WithWriteTimeout ¶

func WithWriteTimeout(timeout time.Duration) ServerOption

WithWriteTimeout 向Redis写入数据超时时间

type SubscribeOption ¶

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

type SubscribeOptionMap ¶

type SubscribeOptionMap map[string]*SubscribeOption

type SubscriberMap ¶

type SubscriberMap map[string]broker.Subscriber

type Transport ¶

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

Transport is a redis transport.

func (*Transport) Endpoint ¶

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind ¶

func (tr *Transport) Kind() transport.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() transport.Header

ReplyHeader returns the reply header.

func (*Transport) RequestHeader ¶

func (tr *Transport) RequestHeader() transport.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