Documentation
¶
Index ¶
- Variables
- type NewClientFunc
- type StubExt
- func (d *StubExt) Application() *gobay.Application
- func (d *StubExt) Close() error
- func (d *StubExt) GetConn(userOpts ...grpc.DialOption) (*grpc.ClientConn, error)
- func (d *StubExt) GetCtx(ctx context.Context) context.Context
- func (d *StubExt) Init(app *gobay.Application) error
- func (d *StubExt) Object() interface{}
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrUnHealthyUpStream = errors.New("grpc response body is no healthy upstream")
)
Functions ¶
This section is empty.
Types ¶
type NewClientFunc ¶
type NewClientFunc (func(*grpc.ClientConn) interface{})
type StubExt ¶
type StubExt struct {
NS string
DialOptions []grpc.DialOption
NewClientFuncs map[string]NewClientFunc
RetryCodes []codes.Code
Host string
Port uint16
ConnTimeout time.Duration
CallTimeout time.Duration
RetryBackoff time.Duration
RetryTimes uint
Authority string
Metadata map[string]string
Mocked bool
Clients map[string]interface{}
// contains filtered or unexported fields
}
func (*StubExt) Application ¶
func (d *StubExt) Application() *gobay.Application
func (*StubExt) GetConn ¶
func (d *StubExt) GetConn(userOpts ...grpc.DialOption) (*grpc.ClientConn, error)
Source Files
Click to show internal directories.
Click to hide internal directories.