sync

Documentation

Index

• Constants
• func AddPromNodeEvent(typ string, evt *model.Event, node *model.Node)
• func EventOperateProxy(evt model.Event) error
• func Rollback(operate model.Operate) error
• func Update(operates ...model.Operate) error
• func Watch()
• type Client
• type GSyncServer
  • func (server *GSyncServer) Sync(syncServer pb.Sync_SyncServer) error
• type Server
  • func (srv *Server) GetNode(nodeInfoReq *model.NodeInfo, nodeResp *model.Node) error
  • func (srv *Server) Sync(evtReq *model.Event, evtResp *model.Event) error

Constants

const (
	ConnectTimeout = time.Duration(10) * time.Second
	ReadTimeout    = time.Duration(30) * time.Second
	WriteTimeout   = time.Duration(30) * time.Second
)

Functions

func AddPromNodeEvent

func AddPromNodeEvent(typ string, evt *model.Event, node *model.Node)

func EventOperateProxy

func EventOperateProxy(evt model.Event) error

func Rollback

func Rollback(operate model.Operate) error

func Update

func Update(operates ...model.Operate) error

check operates and commit data

func Watch

func Watch()

Types

type Client

type Client struct {
	*gorpc.Client
}

type GSyncServer

type GSyncServer struct{}

func (*GSyncServer) Sync

func (server *GSyncServer) Sync(syncServer pb.Sync_SyncServer) error

grpc协议同步配置 目前只要报错，就直接把当前stream连接断开，后续需要修改 @todo 规范grpc error code

type Server

type Server struct{}

为兼容先前gorpc，仍命名为Server

func (*Server) GetNode

func (srv *Server) GetNode(nodeInfoReq *model.NodeInfo, nodeResp *model.Node) error

func (*Server) Sync

func (srv *Server) Sync(evtReq *model.Event, evtResp *model.Event) error