process_master

Documentation

Index

• Variables
• func Process()
• type IAdmin
• type IWorkerProcess
• type Master
  • func NewMasterHandle(pid *pidfile.PidFile) *Master
  • func (m *Master) Close()
  • func (m *Master) Fork() error
  • func (m *Master) Hello(ctx context.Context, request *service.HelloRequest) (*service.HelloResponse, error)
  • func (m *Master) Info(ctx context.Context, request *service.InfoRequest) (*service.InfoResponse, error)
  • func (m *Master) Join(ctx context.Context, request *service.JoinRequest) (*service.JoinResponse, error)
  • func (m *Master) Leave(ctx context.Context, request *service.LeaveRequest) (*service.LeaveResponse, error)
  • func (m *Master) List(ctx context.Context, request *service.ListRequest) (*service.ListResponse, error)
  • func (m *Master) Start(handler *MasterHandler) error
  • func (m *Master) Wait() error
• type MasterHandler
• type ProfessionRaft
  • func NewProfessionRaft(IProfessionsData eosc.IProfessionsData) *ProfessionRaft
  • func (p *ProfessionRaft) CommitHandler(cmd string, data []byte) error
  • func (p *ProfessionRaft) Delete(name string) error
  • func (p *ProfessionRaft) Encode(startIndex int) ([]byte, []*os.File, error)
  • func (p *ProfessionRaft) ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)
  • func (p *ProfessionRaft) ResetHandler(data []byte) error
  • func (p *ProfessionRaft) Set(name string, profession *eosc.ProfessionConfig) error
  • func (p *ProfessionRaft) Snapshot() []byte
• type WorkerController
  • func NewWorkerController(trafficController traffic.IController, dms ...eosc.IDataMarshaller) *WorkerController
  • func (wc *WorkerController) Delete(ctx context.Context, in *service.WorkerDeleteRequest, opts ...grpc.CallOption) (*service.WorkerDeleteResponse, error)
  • func (wc *WorkerController) DeleteCheck(ctx context.Context, in *service.WorkerDeleteRequest, opts ...grpc.CallOption) (*service.WorkerDeleteResponse, error)
  • func (wc *WorkerController) NewWorker() error
  • func (wc *WorkerController) Ping(ctx context.Context, in *service.WorkerHelloRequest, opts ...grpc.CallOption) (*service.WorkerHelloResponse, error)
  • func (wc *WorkerController) Refresh(ctx context.Context, in *service.WorkerRefreshRequest, opts ...grpc.CallOption) (*service.WorkerRefreshResponse, error)
  • func (wc *WorkerController) Restart()
  • func (wc *WorkerController) Set(ctx context.Context, in *service.WorkerSetRequest, opts ...grpc.CallOption) (*service.WorkerSetResponse, error)
  • func (wc *WorkerController) SetCheck(ctx context.Context, in *service.WorkerSetRequest, opts ...grpc.CallOption) (*service.WorkerSetResponse, error)
  • func (wc *WorkerController) Start()
  • func (wc *WorkerController) Stop()
• type WorkerProcess
  • func (w *WorkerProcess) Close() error
• type WorkerProcessController
• type WorkersData
  • func NewWorkersData(ITypedWorkers workers.ITypedWorkers) *WorkersData
  • func (w *WorkersData) Encode(startIndex int) ([]byte, []*os.File, error)
• type WorkersRaft
  • func NewWorkersRaft(workerData *WorkersData, professions eosc.IProfessionsData, ...) *WorkersRaft
  • func (w *WorkersRaft) CommitHandler(cmd string, data []byte) error
  • func (w *WorkersRaft) Delete(id string) (eosc.TWorker, error)
  • func (w *WorkersRaft) GetList(profession string) ([]eosc.TWorker, error)
  • func (w *WorkersRaft) GetWork(id string) (eosc.TWorker, error)
  • func (w *WorkersRaft) ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)
  • func (w *WorkersRaft) ResetHandler(data []byte) error
  • func (w *WorkersRaft) Set(profession, name, driver string, data []byte) (eosc.TWorker, error)
  • func (w *WorkersRaft) Snapshot() []byte

Variables

var (
	ErrClientNotInit = errors.New("no client")
)

Functions

func Process

func Process()

Types

type IAdmin

type IAdmin interface {
}

type IWorkerProcess

type IWorkerProcess interface {
	TrafficStatus() ([]int, []int, error)
}

type Master

type Master struct {
	service.UnimplementedMasterServer
	service.UnimplementedCtiServiceServer

	PID *pidfile.PidFile
	// contains filtered or unexported fields
}

func NewMasterHandle

func NewMasterHandle(pid *pidfile.PidFile) *Master

func (*Master) Close

func (m *Master) Close()

func (*Master) Fork

func (m *Master) Fork() error

Fork Master fork 子进程，入参为子进程需要的内容

func (*Master) Hello

func (m *Master) Hello(ctx context.Context, request *service.HelloRequest) (*service.HelloResponse, error)

func (*Master) Info

func (m *Master) Info(ctx context.Context, request *service.InfoRequest) (*service.InfoResponse, error)

Info 获取节点信息

func (*Master) Join

func (m *Master) Join(ctx context.Context, request *service.JoinRequest) (*service.JoinResponse, error)

Join 加入集群操作

func (*Master) Leave

func (m *Master) Leave(ctx context.Context, request *service.LeaveRequest) (*service.LeaveResponse, error)

Leave 将节点移除

func (*Master) List

func (m *Master) List(ctx context.Context, request *service.ListRequest) (*service.ListResponse, error)

List 获取节点列表

func (*Master) Start

func (m *Master) Start(handler *MasterHandler) error

func (*Master) Wait

func (m *Master) Wait() error

type MasterHandler

type MasterHandler struct {
	Professions eosc.IProfessionsData
}

type ProfessionRaft

type ProfessionRaft struct {
	eosc.IProfessionsData
}

func NewProfessionRaft

func NewProfessionRaft(IProfessionsData eosc.IProfessionsData) *ProfessionRaft

func (*ProfessionRaft) CommitHandler

func (p *ProfessionRaft) CommitHandler(cmd string, data []byte) error

func (*ProfessionRaft) Delete

func (p *ProfessionRaft) Delete(name string) error

func (*ProfessionRaft) Encode

func (p *ProfessionRaft) Encode(startIndex int) ([]byte, []*os.File, error)

func (*ProfessionRaft) ProcessHandler

func (p *ProfessionRaft) ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)

func (*ProfessionRaft) ResetHandler

func (p *ProfessionRaft) ResetHandler(data []byte) error

func (*ProfessionRaft) Set

func (p *ProfessionRaft) Set(name string, profession *eosc.ProfessionConfig) error

func (*ProfessionRaft) Snapshot

func (p *ProfessionRaft) Snapshot() []byte

type WorkerController

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

func NewWorkerController

func NewWorkerController(trafficController traffic.IController, dms ...eosc.IDataMarshaller) *WorkerController

func (*WorkerController) Delete

func (wc *WorkerController) Delete(ctx context.Context, in *service.WorkerDeleteRequest, opts ...grpc.CallOption) (*service.WorkerDeleteResponse, error)

func (*WorkerController) DeleteCheck

func (wc *WorkerController) DeleteCheck(ctx context.Context, in *service.WorkerDeleteRequest, opts ...grpc.CallOption) (*service.WorkerDeleteResponse, error)

func (*WorkerController) NewWorker

func (wc *WorkerController) NewWorker() error

func (*WorkerController) Ping

func (wc *WorkerController) Ping(ctx context.Context, in *service.WorkerHelloRequest, opts ...grpc.CallOption) (*service.WorkerHelloResponse, error)

func (*WorkerController) Refresh

func (wc *WorkerController) Refresh(ctx context.Context, in *service.WorkerRefreshRequest, opts ...grpc.CallOption) (*service.WorkerRefreshResponse, error)

func (*WorkerController) Restart

func (wc *WorkerController) Restart()

func (*WorkerController) Set

func (wc *WorkerController) Set(ctx context.Context, in *service.WorkerSetRequest, opts ...grpc.CallOption) (*service.WorkerSetResponse, error)

func (*WorkerController) SetCheck

func (wc *WorkerController) SetCheck(ctx context.Context, in *service.WorkerSetRequest, opts ...grpc.CallOption) (*service.WorkerSetResponse, error)

func (*WorkerController) Start

func (wc *WorkerController) Start()

func (*WorkerController) Stop

func (wc *WorkerController) Stop()

type WorkerProcess

type WorkerProcess struct {
	service.WorkerServiceClient
	// contains filtered or unexported fields
}

func (*WorkerProcess) Close

func (w *WorkerProcess) Close() error

type WorkerProcessController

type WorkerProcessController interface {
	Stop()
	NewWorker() error
	Start()
	Restart()
}

type WorkersData

type WorkersData struct {
	workers.ITypedWorkers
}

func NewWorkersData

func NewWorkersData(ITypedWorkers workers.ITypedWorkers) *WorkersData

func (*WorkersData) Encode

func (w *WorkersData) Encode(startIndex int) ([]byte, []*os.File, error)

type WorkersRaft

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

func NewWorkersRaft

func NewWorkersRaft(workerData *WorkersData, professions eosc.IProfessionsData, workerServiceClient service.WorkerServiceClient, service raft_service.IService, workerController WorkerProcessController) *WorkersRaft

func (*WorkersRaft) CommitHandler

func (w *WorkersRaft) CommitHandler(cmd string, data []byte) error

func (*WorkersRaft) Delete

func (w *WorkersRaft) Delete(id string) (eosc.TWorker, error)

func (*WorkersRaft) GetList

func (w *WorkersRaft) GetList(profession string) ([]eosc.TWorker, error)

func (*WorkersRaft) GetWork

func (w *WorkersRaft) GetWork(id string) (eosc.TWorker, error)

func (*WorkersRaft) ProcessHandler

func (w *WorkersRaft) ProcessHandler(cmd string, body []byte) ([]byte, interface{}, error)

func (*WorkersRaft) ResetHandler

func (w *WorkersRaft) ResetHandler(data []byte) error

func (*WorkersRaft) Set

func (w *WorkersRaft) Set(profession, name, driver string, data []byte) (eosc.TWorker, error)

func (*WorkersRaft) Snapshot

func (w *WorkersRaft) Snapshot() []byte