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) 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)
Source Files
Click to show internal directories.
Click to hide internal directories.