repl

package

v0.0.0-...-d1c0873 Latest Latest Go to latest Published: Mar 7, 2022 License: Apache-2.0 Imports: 15 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/jjhpeopl/jdchubaofs

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type FollowerPacket
- func NewFollowerPacket() (fp *FollowerPacket)
- func (p *FollowerPacket) IsErrPacket() bool
- func (p *FollowerPacket) PackErrorBody(action, msg string)
type FollowerTransport
- func NewFollowersTransport(addr string) (ft *FollowerTransport, err error)
- func (ft *FollowerTransport) Destory()
- func (ft *FollowerTransport) Write(p *FollowerPacket)
type Packet
type ReplProtocol
- func NewReplProtocol(inConn net.Conn, prepareFunc func(p *Packet) error, ...) *ReplProtocol

Constants ¶

View Source

const (
	ActionSendToFollowers     = "ActionSendToFollowers"
	ActionReceiveFromFollower = "ActionReceiveFromFollower"
	ActionWriteToClient       = "ActionWriteToClient"
	ActionCheckReply          = "ActionCheckReply"

	ActionPreparePkt = "ActionPreparePkt"
)

View Source

const (
	ReplRuning    = 2
	ReplExiting   = 1
	ReplHasExited = -3

	FollowerTransportRuning  = 2
	FollowerTransportExiting = 1
	FollowerTransportExited  = -1
)

View Source

const (
	ConnIsNullErr = "ConnIsNullErr"
)

View Source

const (
	ReplProtocolError = 1
)

View Source

const (
	RequestChanSize = 10240
)

Variables ¶

View Source

var (
	ErrBadNodes       = errors.New("BadNodesErr")
	ErrArgLenMismatch = errors.New("ArgLenMismatchErr")
)

View Source

var (
	ErrorUnknownOp = errors.New("unknown opcode")
)

Functions ¶

This section is empty.

Types ¶

type FollowerPacket ¶

type FollowerPacket struct {
	proto.Packet
	// contains filtered or unexported fields
}

func NewFollowerPacket ¶

func NewFollowerPacket() (fp *FollowerPacket)

func (*FollowerPacket) IsErrPacket ¶

func (p *FollowerPacket) IsErrPacket() bool

func (*FollowerPacket) PackErrorBody ¶

func (p *FollowerPacket) PackErrorBody(action, msg string)

type FollowerTransport ¶

type FollowerTransport struct {
	// contains filtered or unexported fields
}

func NewFollowersTransport ¶

func NewFollowersTransport(addr string) (ft *FollowerTransport, err error)

func (*FollowerTransport) Destory ¶

func (ft *FollowerTransport) Destory()

func (*FollowerTransport) Write ¶

func (ft *FollowerTransport) Write(p *FollowerPacket)

type Packet ¶

type Packet struct {
	proto.Packet

	IsReleased int32 // TODO what is released?
	Object     interface{}
	TpObject   *exporter.TimePointCount
	NeedReply  bool
	OrgBuffer  []byte
	// contains filtered or unexported fields
}

func NewExtentRepairReadPacket ¶

func NewExtentRepairReadPacket(partitionID uint64, extentID uint64, offset, size int) (p *Packet)

func NewPacket ¶

func NewPacket() (p *Packet)

func NewPacketToGetAllWatermarks ¶

func NewPacketToGetAllWatermarks(partitionID uint64, extentType uint8) (p *Packet)

func NewPacketToNotifyExtentRepair ¶

func NewPacketToNotifyExtentRepair(partitionID uint64) (p *Packet)

func NewPacketToReadTinyDeleteRecord ¶

func NewPacketToReadTinyDeleteRecord(partitionID uint64, offset int64) (p *Packet)

func NewReadTinyDeleteRecordResponsePacket ¶

func NewReadTinyDeleteRecordResponsePacket(requestID int64, partitionID uint64) (p *Packet)

func NewStreamReadResponsePacket ¶

func NewStreamReadResponsePacket(requestID int64, partitionID uint64, extentID uint64) (p *Packet)

func NewTinyExtentRepairReadPacket ¶

func NewTinyExtentRepairReadPacket(partitionID uint64, extentID uint64, offset, size int) (p *Packet)

func NewTinyExtentStreamReadResponsePacket ¶

func NewTinyExtentStreamReadResponsePacket(requestID int64, partitionID uint64, extentID uint64) (p *Packet)

func (*Packet) AfterTp ¶

func (p *Packet) AfterTp() (ok bool)

func (*Packet) BeforeTp ¶

func (p *Packet) BeforeTp(clusterID string) (ok bool)

func (*Packet) IsBatchDeleteExtents ¶

func (p *Packet) IsBatchDeleteExtents() bool

func (*Packet) IsBroadcastMinAppliedID ¶

func (p *Packet) IsBroadcastMinAppliedID() bool

func (*Packet) IsCreateExtentOperation ¶

func (p *Packet) IsCreateExtentOperation() bool

func (*Packet) IsErrPacket ¶

func (p *Packet) IsErrPacket() bool

func (*Packet) IsForwardPacket ¶

func (p *Packet) IsForwardPacket() bool

func (*Packet) IsLeaderPacket ¶

func (p *Packet) IsLeaderPacket() (ok bool)

A leader packet is the packet send to the leader and does not require packet forwarding.

func (*Packet) IsMarkDeleteExtentOperation ¶

func (p *Packet) IsMarkDeleteExtentOperation() bool

func (*Packet) IsMasterCommand ¶

func (p *Packet) IsMasterCommand() bool

func (*Packet) IsRandomWrite ¶

func (p *Packet) IsRandomWrite() bool

func (*Packet) IsReadOperation ¶

func (p *Packet) IsReadOperation() bool

func (*Packet) IsSyncWrite ¶

func (p *Packet) IsSyncWrite() bool

func (*Packet) IsTinyExtentType ¶

func (p *Packet) IsTinyExtentType() bool

func (*Packet) IsWriteOperation ¶

func (p *Packet) IsWriteOperation() bool

func (*Packet) PackErrorBody ¶

func (p *Packet) PackErrorBody(action, msg string)

func (*Packet) ReadFromConnFromCli ¶

func (p *Packet) ReadFromConnFromCli(c net.Conn, deadlineTime time.Duration) (err error)

func (*Packet) ReadFull ¶

func (p *Packet) ReadFull(c net.Conn, opcode uint8, readSize int) (err error)

func (*Packet) SetDegrade ¶

func (p *Packet) SetDegrade()

func (*Packet) ShallDegrade ¶

func (p *Packet) ShallDegrade() bool

func (*Packet) UnsetDegrade ¶

func (p *Packet) UnsetDegrade()

type ReplProtocol ¶

type ReplProtocol struct {
	// contains filtered or unexported fields
}

ReplProtocol defines the struct of the replication protocol. 1. ServerConn reads a packet from the client socket, and analyzes the addresses of the followers. 2. After the preparation, the packet is send to toBeProcessedCh. If failure happens, send it to the response channel. 3. OperatorAndForwardPktGoRoutine fetches a packet from toBeProcessedCh, and determine if it needs to be forwarded to the followers. 4. receiveResponse fetches a reply from responseCh, executes postFunc, and writes a response to the client if necessary.

func NewReplProtocol ¶

func NewReplProtocol(inConn net.Conn, prepareFunc func(p *Packet) error,
	operatorFunc func(p *Packet, c net.Conn) error, postFunc func(p *Packet) error) *ReplProtocol

func (*ReplProtocol) OperatorAndForwardPktGoRoutine ¶

func (rp *ReplProtocol) OperatorAndForwardPktGoRoutine()

OperatorAndForwardPktGoRoutine reads packets from the to-be-processed channel and writes responses to the client.

Read a packet from toBeProcessCh, and determine if it needs to be forwarded or not. If the answer is no, then process the packet locally and put it into responseCh.
If the packet needs to be forwarded, the first send it to the followers, and execute the operator function. Then notify receiveResponse to read the followers' responses.
Read a reply from responseCh, and write to the client.

func (*ReplProtocol) ReceiveResponseFromFollowersGoRoutine ¶

func (rp *ReplProtocol) ReceiveResponseFromFollowersGoRoutine()

Receive response from all followers.

func (*ReplProtocol) ServerConn ¶

func (rp *ReplProtocol) ServerConn()

ServerConn keeps reading data from the socket to analyze the follower address, execute the prepare function, and throw the packets to the to-be-processed channel.

func (*ReplProtocol) Stop ¶

func (rp *ReplProtocol) Stop()

Stop stops the replication protocol.

Source Files ¶

View all Source files

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