client

package

v0.0.0-...-3e9ff4f Latest Latest Go to latest Published: Apr 19, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/imdea-software/swiftpaxos

Links

Open Source Insights

Documentation ¶

Index ¶

type BufferClient
- func NewBufferClient(c *Client, reqNum, psize, conflict, writes int, conflictKey int64) *BufferClient
type Client
- func NewClient(server, maddr string, mport int, fast, leaderless, verbose bool) *Client
- func NewClientLog(server, maddr string, mport int, fast, leaderless, verbose bool, ...) *Client
type ReqReply

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BufferClient ¶

type BufferClient struct {
	*Client

	Reply        chan *ReqReply
	GetClientKey func() int64
	// contains filtered or unexported fields
}

func NewBufferClient ¶

func NewBufferClient(c *Client, reqNum, psize, conflict, writes int, conflictKey int64) *BufferClient

func (*BufferClient) Loop ¶

func (c *BufferClient) Loop()

Assumed to be connected

func (*BufferClient) Pipeline ¶

func (c *BufferClient) Pipeline(syncFreq int, window int32)

func (*BufferClient) Read ¶

func (c *BufferClient) Read(key int64) []byte

func (*BufferClient) RegisterReply ¶

func (c *BufferClient) RegisterReply(val state.Value, seqnum int32)

func (*BufferClient) Scan ¶

func (c *BufferClient) Scan(key, count int64) []byte

func (*BufferClient) WaitReplies ¶

func (c *BufferClient) WaitReplies(waitFrom int)

func (*BufferClient) Write ¶

func (c *BufferClient) Write(key int64, val []byte)

type Client ¶

type Client struct {
	*dlog.Logger

	ClientId  int32
	LeaderId  int
	ClosestId int // also co-located

	Ping []float64

	Fast       bool
	Verbose    bool
	Leaderless bool
	// contains filtered or unexported fields
}

func NewClient ¶

func NewClient(server, maddr string, mport int, fast, leaderless, verbose bool) *Client

func NewClientLog ¶

func NewClientLog(server, maddr string, mport int, fast, leaderless, verbose bool, logger *dlog.Logger) *Client

func (*Client) Connect ¶

func (c *Client) Connect() error

func (*Client) Disconnect ¶

func (c *Client) Disconnect()

func (*Client) GetReplyFrom ¶

func (c *Client) GetReplyFrom(rid int) (*defs.ProposeReplyTS, error)

func (*Client) Reconnect ¶

func (c *Client) Reconnect() error

func (*Client) RegisterRPCTable ¶

func (c *Client) RegisterRPCTable(t *fastrpc.Table)

func (*Client) SendMsg ¶

func (c *Client) SendMsg(rid int32, code uint8, msg fastrpc.Serializable)

For custom client messages

func (*Client) SendProposal ¶

func (c *Client) SendProposal(cmd defs.Propose)

func (*Client) SendRead ¶

func (c *Client) SendRead(key int64) int32

func (*Client) SendScan ¶

func (c *Client) SendScan(key, count int64) int32

func (*Client) SendWrite ¶

func (c *Client) SendWrite(key int64, value []byte) int32

type ReqReply ¶

type ReqReply struct {
	Val    state.Value
	Seqnum int
	Time   time.Time
}

Source Files ¶

View all Source files

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