grpc

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 28, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

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

func (*Sender) Valid

func (s *Sender) Valid(_ *pb.CallbackInfo) 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

Jump to

Keyboard shortcuts

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