cfored

Documentation

Index

• Variables
• func ParseCmdArgs()
• func StartCfored()
• type CranedChannelKeeper
  • func NewCranedChannelKeeper() *CranedChannelKeeper
  • func (keeper *CranedChannelKeeper) CranedCrashAndRemoveAllChannel(cranedId string)
• type CrunRequestCranedChannel
• type GlobalVariables
• type GrpcCforedServer
  • func (cforedServer *GrpcCforedServer) CallocStream(toCallocStream protos.CraneForeD_CallocStreamServer) error
  • func (cforedServer *GrpcCforedServer) CrunStream(toCrunStream protos.CraneForeD_CrunStreamServer) error
  • func (cforedServer *GrpcCforedServer) QueryTaskIdFromPort(ctx context.Context, request *protos.QueryTaskIdFromPortRequest) (*protos.QueryTaskIdFromPortReply, error)
  • func (cforedServer *GrpcCforedServer) TaskIOStream(toCranedStream protos.CraneForeD_TaskIOStreamServer) error
• type GrpcCtldClient
  • func (client *GrpcCtldClient) CtldReplyReceiveRoutine(stream protos.CraneCtld_CforedStreamClient)
  • func (client *GrpcCtldClient) StartCtldClientStream(wg *sync.WaitGroup)
• type StateOfCallocServer
• type StateOfCranedServer
• type StateOfCrunServer
• type StateOfCtldClient

Variables

var (
	FlagConfigFilePath string
	FlagDebugLevel     string
)

Functions

func ParseCmdArgs

func ParseCmdArgs()

func StartCfored

func StartCfored()

Types

type CranedChannelKeeper

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

func NewCranedChannelKeeper

func NewCranedChannelKeeper() *CranedChannelKeeper

func (*CranedChannelKeeper) CranedCrashAndRemoveAllChannel

func (keeper *CranedChannelKeeper) CranedCrashAndRemoveAllChannel(cranedId string)

type CrunRequestCranedChannel

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

type GlobalVariables

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

type GrpcCforedServer

type GrpcCforedServer struct {
	protos.CraneForeDServer
}

func (*GrpcCforedServer) CallocStream

func (cforedServer *GrpcCforedServer) CallocStream(toCallocStream protos.CraneForeD_CallocStreamServer) error

func (*GrpcCforedServer) CrunStream

func (cforedServer *GrpcCforedServer) CrunStream(toCrunStream protos.CraneForeD_CrunStreamServer) error

func (*GrpcCforedServer) QueryTaskIdFromPort

func (cforedServer *GrpcCforedServer) QueryTaskIdFromPort(ctx context.Context,
	request *protos.QueryTaskIdFromPortRequest) (*protos.QueryTaskIdFromPortReply, error)

func (*GrpcCforedServer) TaskIOStream

func (cforedServer *GrpcCforedServer) TaskIOStream(toCranedStream protos.CraneForeD_TaskIOStreamServer) error

type GrpcCtldClient

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

func (*GrpcCtldClient) CtldReplyReceiveRoutine

func (client *GrpcCtldClient) CtldReplyReceiveRoutine(stream protos.CraneCtld_CforedStreamClient)

func (*GrpcCtldClient) StartCtldClientStream

func (client *GrpcCtldClient) StartCtldClientStream(wg *sync.WaitGroup)

type StateOfCallocServer

type StateOfCallocServer int

const (
	WaitTaskIdAllocReq     StateOfCallocServer = 0
	WaitCtldAllocTaskId    StateOfCallocServer = 1
	WaitCtldAllocRes       StateOfCallocServer = 2
	WaitCallocComplete     StateOfCallocServer = 3
	WaitCallocCancel       StateOfCallocServer = 4
	WaitCtldAck            StateOfCallocServer = 5
	CancelTaskOfDeadCalloc StateOfCallocServer = 6
)

type StateOfCranedServer

type StateOfCranedServer int

const (
	CranedReg    StateOfCranedServer = 0
	IOForwarding StateOfCranedServer = 1
	CranedUnReg  StateOfCranedServer = 2
)

type StateOfCrunServer

type StateOfCrunServer int

const (
	CrunWaitTaskIdAllocReq  StateOfCrunServer = 0
	CrunWaitCtldAllocTaskId StateOfCrunServer = 1
	CrunWaitCtldAllocRes    StateOfCrunServer = 2
	CrunWaitIOForward       StateOfCrunServer = 3
	CrunWaitTaskComplete    StateOfCrunServer = 4
	CrunWaitTaskCancel      StateOfCrunServer = 5
	CrunWaitCtldAck         StateOfCrunServer = 6
	CancelTaskOfDeadCrun    StateOfCrunServer = 7
)

type StateOfCtldClient

type StateOfCtldClient int

const (
	StartReg        StateOfCtldClient = 0
	WaitReg         StateOfCtldClient = 1
	WaitChannelReq  StateOfCtldClient = 2
	WaitAllFrontEnd StateOfCtldClient = 3
	GracefulExit    StateOfCtldClient = 4
)