redis

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 Transport
  • func (tr *Transport) Endpoint() string
  • func (tr *Transport) Kind() kratosTransport.Kind
  • func (tr *Transport) NodeFilters() []selector.NodeFilter
  • func (tr *Transport) Operation() string
  • func (tr *Transport) ReplyHeader() kratosTransport.Header
  • func (tr *Transport) RequestHeader() kratosTransport.Header

Constants

const (
	KindRedis kratosTransport.Kind = "redis"
)

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 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() 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.