processManager

type AppLogFunction func(id string, msg string)

type Command uint8

type MessageDeliver interface {
	// ReceiveMessage is when msg is received from the c++ side
	ReceiveMessage(msg *ResponseMessage)

	// ApplicationLog will write the message to the application log
	ApplicationLog(msg string)
}

type OnDeployAckMsg struct {
	Status checkpointManager.OnDeployState `json:"on_deploy_status"`
}

type OnDeployActionObject struct {
	Reason string `json:"reason""`
	Delay  int64  `json:"delay""`
}

type ProcessConfig struct {
	Username string
	Password string
	Address  string

	NsServerPort string

	// ipv4/ipv6
	IPMode          common.IpMode
	BreakpadOn      bool
	DebuggerPort    string
	DiagDir         string
	EventingDir     string
	EventingPort    string
	EventingSSLPort string
	ExecPath        string
	CertPath        string
	ClientCertPath  string
	ClientKeyPath   string

	// Id used to create tcp socket
	ID string

	InstanceID         string
	SingleFunctionMode bool

	AppLogCallback AppLogFunction
}

type ProcessDetails struct {
	Version uint32 `json:"version"`
	PID     int    `json:"pid"`
}

type ProcessManager interface {
	// Start will start the process. response channel should be used
	// to get response
	// CHECK: if this should return error or not
	// or process manager should takecare of the errors internally
	Start() (<-chan *ResponseMessage, error)
	StartWithContext(ctx context.Context) (<-chan *ResponseMessage, error)

	InitEvent(version uint32, opcode uint8, handlerID []byte, value interface{})

	VbSettings(version uint32, opcode uint8, handlerID []byte, key interface{}, value interface{})

	LifeCycleOp(version uint32, opcode uint8, handlerID []byte)

	SendControlMessage(version uint32, cmd Command, opcode uint8, handlerID []byte, key, value interface{})

	GetStats(version uint32, opcode uint8, handlerID []byte)

	WriteDcpMessage(version uint32, buffer *bytes.Buffer, opcode uint8, workerID uint8,
		instanceID []byte, msg *dcpMessage.DcpEvent, internalInfo *checkpointManager.ParsedInternalDetails) int32

	FlushMessage(version uint32, buffer *bytes.Buffer)

	GetProcessDetails() ProcessDetails

	GetRuntimeStats() common.StatsInterface

	StopProcess()
}

type ResponseMessage struct {
	Event     Command
	Opcode    uint8
	HandlerID string

	Extras []byte
	Meta   []byte
	Value  []byte
}