registrant

Documentation

Index

• type C2SPINGer
  • func (p C2SPINGer) PING(ctx context.Context, info protocol.RegistryInfo) (ok bool)
• type C2SRequestProtocol
  • func (p C2SRequestProtocol) Request(ctx context.Context, requestChan <-chan protocol.TobeSendRequest, ...)
• type ConnectionPool
  • func NewConnectionPool(DialOption []grpc.DialOption, MaxDialHoldDuration time.Duration) *ConnectionPool
  • func (c *ConnectionPool) GetClientConn(addr string) (connection *grpc.ClientConn, err error)
• type GRPCRegistrantOption
  • func DefaultOption() GRPCRegistrantOption
• type S2CRegistrant
  • func NewS2CRegistrant(option GRPCRegistrantOption) *S2CRegistrant
  • func (c *S2CRegistrant) NewC2SPINGer() *C2SPINGer
  • func (c *S2CRegistrant) NewRequestProtocol() C2SRequestProtocol
• type S2SPINGer
  • func (p S2SPINGer) PING(ctx context.Context, info protocol.RegistryInfo) (ok bool)
• type S2SRegistrant
  • func NewS2SRegistrant(option GRPCRegistrantOption) *S2SRegistrant
  • func (c *S2SRegistrant) NewRequestProtocol() S2SRequestProtocol
  • func (c *S2SRegistrant) NewS2SPINGer() *S2SPINGer
• type S2SRequestProtocol
  • func (p S2SRequestProtocol) Request(ctx context.Context, requestChan <-chan protocol.TobeSendRequest, ...)

Types

type C2SPINGer

type C2SPINGer struct {
	CallOption []grpc.CallOption
	// contains filtered or unexported fields
}

func (C2SPINGer) PING

func (p C2SPINGer) PING(ctx context.Context, info protocol.RegistryInfo) (ok bool)

type C2SRequestProtocol

type C2SRequestProtocol struct {
	CallOption []grpc.CallOption
	// contains filtered or unexported fields
}

func (C2SRequestProtocol) Request

func (p C2SRequestProtocol) Request(ctx context.Context, requestChan <-chan protocol.TobeSendRequest, responseChan chan<- protocol.ReceivedResponse)

type ConnectionPool

type ConnectionPool struct {
	DialOption          []grpc.DialOption
	MaxDialHoldDuration time.Duration
	// contains filtered or unexported fields
}

func NewConnectionPool

func NewConnectionPool(DialOption []grpc.DialOption, MaxDialHoldDuration time.Duration) *ConnectionPool

func (*ConnectionPool) GetClientConn

func (c *ConnectionPool) GetClientConn(addr string) (connection *grpc.ClientConn, err error)

type GRPCRegistrantOption

type GRPCRegistrantOption struct {
	DialOption          []grpc.DialOption
	CallOption          []grpc.CallOption
	MaxDialHoldDuration time.Duration //保持连接的最大时长
}

func DefaultOption

func DefaultOption() GRPCRegistrantOption

type S2CRegistrant

type S2CRegistrant struct {
	CallOption []grpc.CallOption
	// contains filtered or unexported fields
}

func NewS2CRegistrant

func NewS2CRegistrant(option GRPCRegistrantOption) *S2CRegistrant

func (*S2CRegistrant) NewC2SPINGer

func (c *S2CRegistrant) NewC2SPINGer() *C2SPINGer

func (*S2CRegistrant) NewRequestProtocol

func (c *S2CRegistrant) NewRequestProtocol() C2SRequestProtocol

type S2SPINGer

type S2SPINGer struct {
	CallOption []grpc.CallOption
	// contains filtered or unexported fields
}

func (S2SPINGer) PING

func (p S2SPINGer) PING(ctx context.Context, info protocol.RegistryInfo) (ok bool)

type S2SRegistrant

type S2SRegistrant struct {
	CallOption []grpc.CallOption
	// contains filtered or unexported fields
}

func NewS2SRegistrant

func NewS2SRegistrant(option GRPCRegistrantOption) *S2SRegistrant

func (*S2SRegistrant) NewRequestProtocol

func (c *S2SRegistrant) NewRequestProtocol() S2SRequestProtocol

func (*S2SRegistrant) NewS2SPINGer

func (c *S2SRegistrant) NewS2SPINGer() *S2SPINGer

type S2SRequestProtocol

type S2SRequestProtocol struct {
	CallOption []grpc.CallOption
	// contains filtered or unexported fields
}

func (S2SRequestProtocol) Request

func (p S2SRequestProtocol) Request(ctx context.Context, requestChan <-chan protocol.TobeSendRequest, responseChan chan<- protocol.ReceivedResponse)