Documentation ¶
Index ¶
- Constants
- type Sender
- type SenderOption
- func SenderOptionWithCheckTime(checkTime time.Duration) SenderOption
- func SenderOptionWithGP(gp limiter.Pool) SenderOption
- func SenderOptionWithIdleTime(idleTime time.Duration) SenderOption
- func SenderOptionWithLogger(logger system.Logger) SenderOption
- func SenderOptionWithTimeout(timeout time.Duration) SenderOption
Constants ¶
View Source
const SendersType = "GRPC"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sender ¶
type Sender struct {
// contains filtered or unexported fields
}
func NewSender ¶
func NewSender(opts ...SenderOption) *Sender
func (*Sender) Send ¶
func (s *Sender) Send(addr *pb.CallbackInfo, req *pb.CallBackReq) error
type SenderOption ¶
type SenderOption func(*Sender)
func SenderOptionWithCheckTime ¶
func SenderOptionWithCheckTime(checkTime time.Duration) SenderOption
func SenderOptionWithGP ¶
func SenderOptionWithGP(gp limiter.Pool) SenderOption
func SenderOptionWithIdleTime ¶
func SenderOptionWithIdleTime(idleTime time.Duration) SenderOption
func SenderOptionWithLogger ¶
func SenderOptionWithLogger(logger system.Logger) SenderOption
func SenderOptionWithTimeout ¶
func SenderOptionWithTimeout(timeout time.Duration) SenderOption
Click to show internal directories.
Click to hide internal directories.