wrpc

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

type Client struct {
	Options
	// contains filtered or unexported fields
}

type Frame struct {
	Status        uint16
	Seq           int64
	ServiceMethod string
	Metadata      *utils.MetaDict
	Payload       any
}

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

type Option func(*Options)

type Options struct {
	ProtocolMagicNumber uint32

	//编码器
	Marshal func(any, io.Writer) error
	//解码器
	Unmarshal func([]byte, any) error
	//劫持者
	Hijacker func([]byte, WriterFunc) error
	//入口拦截器
	IntletHook []func([]byte, WriterFunc) ([]byte, error)
	//出口拦截器
	OutletHook []func([]byte, WriterFunc) ([]byte, error)
	//熔断器
	AllowRequest func() error
	MarkSuccess  func()
	MarkFailed   func()
	//平衡器
	//Balancer func([]int) int
	//Registry  IRegistry
	//日志
	Logger utils.ILogger
	// contains filtered or unexported fields
}

type Service struct {
	Options
	// contains filtered or unexported fields
}

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

type TCPServer struct {
	ProtocolMagicNumber uint32

	Hijacker func([]byte, WriterFunc) error
	Handler  func([]byte, WriterFunc, func()) error

	Logger utils.ILogger
	// contains filtered or unexported fields
}

type TCPSession struct {
	Hijacker func([]byte, WriterFunc) error
	Handler  func([]byte, WriterFunc, func()) error

	Logger utils.ILogger
	// contains filtered or unexported fields
}

type TokenBucketLimiter struct {
	//限流器速率，每秒处理的令牌数
	LimitRate int64
	//限流器大小，存放令牌的最大值
	LimitSize int64
	//加入的时间间隔
	Snippet time.Duration
	// contains filtered or unexported fields
}

type Topic struct {
	*Service
	Name string
	// contains filtered or unexported fields
}

type WriterFunc func([]byte) error