server

Documentation

Index

• func ListenAndServeRepositoryRpc(ip string, port uint, raft *raft.Raft)
• type RepositoryRpc
  • func (r *RepositoryRpc) RaftApplyCommandHandler(data []byte, ack *bool) error

Functions

func ListenAndServeRepositoryRpc

func ListenAndServeRepositoryRpc(ip string, port uint, raft *raft.Raft)

Types

type RepositoryRpc

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

func (*RepositoryRpc) RaftApplyCommandHandler

func (r *RepositoryRpc) RaftApplyCommandHandler(data []byte, ack *bool) error