dicedb

Index ¶

• func ExecuteVoid(r *Retrier, retryOn []wire.ErrKind, op func() *wire.WireError, ...) *wire.WireError
• func ExecuteWithResult[T any](r *Retrier, retryOn []wire.ErrKind, op func() (*T, *wire.WireError), ...) (*T, *wire.WireError)
• func WithID(id string) option
• type Client
• • func NewClient(host string, port int, opts ...option) (*Client, error)
• • func (c *Client) Close()
  • func (c *Client) Fire(cmd *wire.Command) *wire.Result
  • func (c *Client) FireString(cmdStr string) *wire.Result
  • func (c *Client) WatchCh() (<-chan *wire.Result, error)
• type ClientWire
• • func NewClientWire(maxMsgSize int, host string, port int) (*ClientWire, *wire.WireError)
• • func (cw *ClientWire) Close()
  • func (cw *ClientWire) Receive() (*wire.Result, *wire.WireError)
  • func (cw *ClientWire) Send(cmd *wire.Command) *wire.WireError
• type Retrier
• • func NewRetrier(maxRetries int, retryWindow time.Duration) *Retrier
• • func (r *Retrier) Allow() bool
  • func (r *Retrier) Failure()
  • func (r *Retrier) Success()
• type ServerWire
• • func NewServerWire(maxMsgSize int, keepAlive int32, clientFD int) (*ServerWire, *wire.WireError)
• • func (sw *ServerWire) Close()
  • func (sw *ServerWire) Receive() (*wire.Command, *wire.WireError)
  • func (sw *ServerWire) Send(ctx context.Context, resp *wire.Result) *wire.WireError