Documentation
      ¶
    
    
  
    
  
    Index ¶
- type Conn
 - func (c *Conn) Endpoint() endpoint.Endpoint
 - func (c *Conn) GetState() conn.State
 - func (c *Conn) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
 - func (c *Conn) IsState(states ...conn.State) bool
 - func (c *Conn) LastUsage() time.Time
 - func (c *Conn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
 - func (c *Conn) Park(ctx context.Context) (err error)
 - func (c *Conn) Ping(ctx context.Context) error
 - func (c *Conn) SetState(state conn.State) conn.State
 - func (c *Conn) Unban() conn.State
 
- type Endpoint
 - func (e *Endpoint) Address() string
 - func (e *Endpoint) Choose(bool)
 - func (e *Endpoint) Copy() endpoint.Endpoint
 - func (e *Endpoint) LastUpdated() time.Time
 - func (e *Endpoint) LoadFactor() float32
 - func (e *Endpoint) LocalDC() bool
 - func (e *Endpoint) Location() string
 - func (e *Endpoint) NodeID() uint32
 - func (e *Endpoint) String() string
 - func (e *Endpoint) Touch(opts ...endpoint.Option)
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conn ¶
type Conn struct {
	PingErr       error
	AddrField     string
	LocationField string
	NodeIDField   uint32
	State         conn.State
	LocalDCField  bool
}
    func (*Conn) NewStream ¶
func (c *Conn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption, ) (grpc.ClientStream, error)
 Click to show internal directories. 
   Click to hide internal directories.