 Documentation
      ¶
      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(ctx context.Context, state conn.State) conn.State
- func (c *Conn) Unban(ctx context.Context) 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() booldeprecated
- func (e *Endpoint) Location() string
- func (e *Endpoint) NodeID() uint32
- func (e *Endpoint) OverrideHost() string
- 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)
type Endpoint ¶
func (*Endpoint) LastUpdated ¶
func (*Endpoint) LoadFactor ¶
        
          
            func (*Endpoint) LocalDC
            deprecated
            
          
  
    
  
      
      Deprecated: LocalDC check "local" by compare endpoint location with discovery "selflocation" field. It work good only if connection url always point to local dc. Will be removed after Oct 2024. Read about versioning policy: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#deprecated
func (*Endpoint) OverrideHost ¶ added in v3.81.1
 Click to show internal directories. 
   Click to hide internal directories.