comm

package
v1.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2025 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	io.ReadWriter
	HTTPQwatchResponseChan chan QwatchResponse // Response channel to send back the operation response
	Fd                     int
	Cqueue                 cmd.DiceDBCmds
	IsTxn                  bool
	Session                *auth.Session
	ClientIdentifierID     uint32
}

func NewClient

func NewClient(fd int) *Client

func NewHTTPQwatchClient

func NewHTTPQwatchClient(qwatchResponseChan chan QwatchResponse, clientIdentifierID uint32) *Client

func (*Client) Read

func (c *Client) Read(b []byte) (int, error)

func (*Client) TxnBegin

func (c *Client) TxnBegin()

func (*Client) TxnDiscard

func (c *Client) TxnDiscard()

func (*Client) TxnQueue

func (c *Client) TxnQueue(diceDBCmd *cmd.DiceDBCmd)

func (*Client) Write

func (c *Client) Write(b []byte) (int, error)

type CmdWatchResponse

type CmdWatchResponse struct {
	ClientIdentifierID uint32
	Result             interface{}
	Error              error
}

type QwatchResponse

type QwatchResponse struct {
	ClientIdentifierID uint32
	Result             interface{}
	Error              error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL