The highest tagged major version is v0.

conn

package

v83.0.0-...-38e0eed Latest Latest Go to latest Published: Oct 12, 2017 License: AGPL-3.0, Apache-2.0 Imports: 16 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/adibiarsotp/dgraph

Documentation ¶

Index ¶

Variables
type Node
- func NewNode(rc *protos.RaftContext) *Node
type Pool
- func NewPool(addr string) (*Pool, error)
type Pools
- func Get() *Pools
- func (p *Pools) Connect(addr string) *Pool
- func (p *Pools) Get(addr string) (*Pool, error)
type RaftServer

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNoConnection        = fmt.Errorf("No connection exists")
	ErrUnhealthyConnection = fmt.Errorf("Unhealthy connection")
)

View Source

var (
	ErrDuplicateRaftId = x.Errorf("Node is already part of group")
)

Functions ¶

This section is empty.

Types ¶

type Node ¶

type Node struct {
	x.SafeMutex

	// Changed after init but not protected by SafeMutex
	RequestCh chan linReadReq

	// Fields which are never changed after init.
	Cfg    *raft.Config
	MyAddr string
	Id     uint64

	RaftContext *protos.RaftContext
	Store       *raft.MemoryStorage
	Wal         *raftwal.Wal

	// applied is used to keep track of the applied RAFT proposals.
	// The stages are proposed -> committed (accepted by cluster) ->
	// applied (to PL) -> synced (to RocksDB).
	Applied x.WaterMark
	// contains filtered or unexported fields
}

func NewNode ¶

func NewNode(rc *protos.RaftContext) *Node

func (*Node) AddToCluster ¶

func (n *Node) AddToCluster(ctx context.Context, pid uint64) error

func (*Node) BatchAndSendMessages ¶

func (n *Node) BatchAndSendMessages()

func (*Node) ConfState ¶

func (n *Node) ConfState() *raftpb.ConfState

ConfState would return the latest ConfState stored in node.

func (*Node) Connect ¶

func (n *Node) Connect(pid uint64, addr string)

Connects the node and makes its peerPool refer to the constructed pool and address (possibly updating ourselves from the old address.) (Unless pid is ourselves, in which case this does nothing.)

func (*Node) InitFromWal ¶

func (n *Node) InitFromWal(wal *raftwal.Wal) (idx uint64, restart bool, rerr error)

func (*Node) Peer ¶

func (n *Node) Peer(pid uint64) (string, bool)

func (*Node) Raft ¶

func (n *Node) Raft() raft.Node

Raft would return back the raft.Node stored in the node.

func (*Node) ReadIndex ¶

func (n *Node) ReadIndex(ctx context.Context) (chan uint64, error)

func (*Node) RunReadIndexLoop ¶

func (n *Node) RunReadIndexLoop(closer *y.Closer, readStateCh <-chan raft.ReadState)

func (*Node) SaveToStorage ¶

func (n *Node) SaveToStorage(s raftpb.Snapshot, h raftpb.HardState,
	es []raftpb.Entry)

func (*Node) Send ¶

func (n *Node) Send(m raftpb.Message)

func (*Node) SetConfState ¶

func (n *Node) SetConfState(cs *raftpb.ConfState)

SetConfState would store the latest ConfState generated by ApplyConfChange.

func (*Node) SetPeer ¶

func (n *Node) SetPeer(pid uint64, addr string)

addr must not be empty.

func (*Node) SetRaft ¶

func (n *Node) SetRaft(r raft.Node)

SetRaft would set the provided raft.Node to this node. It would check fail if the node is already set.

func (*Node) WaitLinearizableRead ¶

func (n *Node) WaitLinearizableRead(ctx context.Context) error

type Pool ¶

type Pool struct {
	sync.RWMutex

	Addr string
	// contains filtered or unexported fields
}

"Pool" is used to manage the grpc client connection(s) for communicating with other worker instances. Right now it just holds one of them.

func NewPool ¶

func NewPool(addr string) (*Pool, error)

NewPool creates a new "pool" with one gRPC connection, refcount 0.

func (*Pool) Get ¶

func (p *Pool) Get() *grpc.ClientConn

Get returns the connection to use from the pool of connections.

func (*Pool) IsHealthy ¶

func (p *Pool) IsHealthy() bool

func (*Pool) MonitorHealth ¶

func (p *Pool) MonitorHealth()

MonitorHealth monitors the health of the connection via Echo. This function blocks forever.

type Pools ¶

type Pools struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func Get ¶

func Get() *Pools

func (*Pools) Connect ¶

func (p *Pools) Connect(addr string) *Pool

func (*Pools) Get ¶

func (p *Pools) Get(addr string) (*Pool, error)

type RaftServer ¶

type RaftServer struct {
	Node *Node
	// contains filtered or unexported fields
}

func (*RaftServer) Echo ¶

func (w *RaftServer) Echo(ctx context.Context, in *protos.Payload) (*protos.Payload, error)

Hello rpc call is used to check connection with other workers after worker tcp server for this instance starts.

func (*RaftServer) GetNode ¶

func (w *RaftServer) GetNode() *Node

func (*RaftServer) JoinCluster ¶

func (w *RaftServer) JoinCluster(ctx context.Context,
	rc *protos.RaftContext) (*protos.Payload, error)

func (*RaftServer) RaftMessage ¶

func (w *RaftServer) RaftMessage(ctx context.Context,
	query *protos.Payload) (*protos.Payload, error)

Source Files ¶

View all Source files

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