Documentation ¶
Index ¶
- Variables
- type FunctionRequest
- type FunctionRequestType
- type FunctionResponse
- type FunctionResponseType
- type Heartbeat
- type MessageType
- type MonitorRequest
- type MonitorResponse
- type Socket
- type Task
- type TaskCancel
- type TaskCancelEcho
- type TaskEcho
- type TaskEchoStatus
- type TaskResult
- type TaskStatus
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidDataLength = errors.New("invalid data length") ErrInvalidEnum = errors.New("invalid enum") )
View Source
var ( ErrFunctionAlreadyExists = errors.New("function already exists") ErrFunctionDoesNotExist = errors.New("function does not exist") ErrFunctionStillHaveTasks = errors.New("function still have tasks") ErrTaskNotFound = errors.New("task not found") ErrWorkerNotFound = errors.New("worker not found") ErrNoWorkerAvailable = errors.New("no worker available") ErrUnknownTaskStatus = errors.New("unknown task status") )
View Source
var FunctionRequestTypeSet = map[FunctionRequestType]struct{}{ FunctionRequestTypeCheck: {}, FunctionRequestTypeAdd: {}, FunctionRequestTypeRequest: {}, FunctionRequestTypeDelete: {}, }
View Source
var FunctionResponseTypeSet = map[FunctionResponseType]struct{}{ FunctionResponseTypeOK: {}, FunctionResponseTypeNotExists: {}, FunctionResponseTypeStillHaveTask: {}, FunctionResponseTypeDuplicated: {}, }
View Source
var MessageTypeSet = map[MessageType]struct{}{ MessageTypeTask: {}, MessageTypeTaskEcho: {}, MessageTypeTaskCancel: {}, MessageTypeTaskCancelEcho: {}, MessageTypeTaskResult: {}, MessageTypeHeartbeat: {}, MessageTypeFunctionRequest: {}, MessageTypeFunctionResponse: {}, MessageTypeMonitoringRequest: {}, MessageTypeMonitoringResponse: {}, }
View Source
var TaskEchoStatusSet = map[TaskEchoStatus]struct{}{ TaskEchoStatusSubmitOK: {}, TaskEchoStatusCancelOK: {}, TaskEchoStatusDuplicated: {}, TaskEchoStatusFunctionNotExists: {}, }
View Source
var TaskStatusSet = map[TaskStatus]struct{}{ TaskStatusSuccess: {}, TaskStatusFailed: {}, TaskStatusCanceled: {}, }
Functions ¶
This section is empty.
Types ¶
type FunctionRequest ¶
type FunctionRequest struct { Type FunctionRequestType FunctionID uuid.UUID FunctionContent []byte }
func DeserializeFunctionRequest ¶
func DeserializeFunctionRequest(data [][]byte) (*FunctionRequest, error)
func (*FunctionRequest) MarshalLogObject ¶ added in v0.0.11
func (fr *FunctionRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*FunctionRequest) Serialize ¶
func (fr *FunctionRequest) Serialize() [][]byte
type FunctionRequestType ¶
type FunctionRequestType string
const ( FunctionRequestTypeCheck FunctionRequestType = "C" FunctionRequestTypeAdd FunctionRequestType = "A" FunctionRequestTypeRequest FunctionRequestType = "R" FunctionRequestTypeDelete FunctionRequestType = "D" )
func (FunctionRequestType) String ¶
func (frt FunctionRequestType) String() string
type FunctionResponse ¶
type FunctionResponse struct { Status FunctionResponseType FunctionID uuid.UUID FunctionContent []byte }
func DeserializeFunctionResponse ¶
func DeserializeFunctionResponse(data [][]byte) (*FunctionResponse, error)
func (*FunctionResponse) MarshalLogObject ¶ added in v0.0.11
func (fr *FunctionResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*FunctionResponse) Serialize ¶
func (fr *FunctionResponse) Serialize() [][]byte
type FunctionResponseType ¶
type FunctionResponseType string
const ( FunctionResponseTypeOK FunctionResponseType = "OK" FunctionResponseTypeNotExists FunctionResponseType = "NE" FunctionResponseTypeStillHaveTask FunctionResponseType = "HT" FunctionResponseTypeDuplicated FunctionResponseType = "DC" )
func (FunctionResponseType) String ¶
func (frt FunctionResponseType) String() string
type Heartbeat ¶
type Heartbeat struct {
// contains filtered or unexported fields
}
func DeserializeHeartbeat ¶
func (*Heartbeat) MarshalLogObject ¶ added in v0.0.11
func (h *Heartbeat) MarshalLogObject(enc zapcore.ObjectEncoder) error
type MessageType ¶
type MessageType string
const ( MessageTypeTask MessageType = "TK" MessageTypeTaskEcho MessageType = "TE" MessageTypeTaskCancel MessageType = "TC" MessageTypeTaskCancelEcho MessageType = "TX" MessageTypeTaskResult MessageType = "TR" MessageTypeHeartbeat MessageType = "HB" MessageTypeFunctionRequest MessageType = "FR" MessageTypeFunctionResponse MessageType = "FA" MessageTypeMonitoringRequest MessageType = "MR" MessageTypeMonitoringResponse MessageType = "MS" )
func (MessageType) String ¶
func (mt MessageType) String() string
type MonitorRequest ¶
type MonitorRequest struct{}
func DeserializeMonitorRequest ¶
func DeserializeMonitorRequest(data [][]byte) (*MonitorRequest, error)
func (*MonitorRequest) MarshalLogObject ¶ added in v0.0.11
func (mr *MonitorRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*MonitorRequest) Serialize ¶
func (mr *MonitorRequest) Serialize() [][]byte
type MonitorResponse ¶
type MonitorResponse struct {
Data []byte
}
func DeserializeMonitorResponse ¶ added in v0.0.6
func DeserializeMonitorResponse(data [][]byte) (*MonitorResponse, error)
func (*MonitorResponse) MarshalLogObject ¶ added in v0.0.11
func (mr *MonitorResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*MonitorResponse) Serialize ¶ added in v0.0.6
func (mr *MonitorResponse) Serialize() [][]byte
type Socket ¶ added in v0.0.11
func (*Socket) Send ¶ added in v0.0.11
func (s *Socket) Send(source string, msgType interfaces.Stringer, payload interfaces.Serializable) error
type Task ¶
type Task struct { TaskID uuid.UUID // TODO: task is a binary uuid FunctionID uuid.UUID FunctionContent []byte FunctionArgs []byte }
func DeserializeTask ¶
func (*Task) MarshalLogObject ¶ added in v0.0.11
func (t *Task) MarshalLogObject(enc zapcore.ObjectEncoder) error
type TaskCancel ¶
func DeserializeTaskCancel ¶
func DeserializeTaskCancel(data [][]byte) (*TaskCancel, error)
func (*TaskCancel) MarshalLogObject ¶ added in v0.0.11
func (tc *TaskCancel) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TaskCancel) Serialize ¶
func (tc *TaskCancel) Serialize() [][]byte
type TaskCancelEcho ¶
type TaskCancelEcho struct { TaskID uuid.UUID // TODO: task is a binary uuid Status TaskEchoStatus }
func DeserializeTaskCancelEcho ¶
func DeserializeTaskCancelEcho(data [][]byte) (*TaskCancelEcho, error)
func (*TaskCancelEcho) MarshalLogObject ¶ added in v0.0.11
func (tce *TaskCancelEcho) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TaskCancelEcho) Serialize ¶
func (tce *TaskCancelEcho) Serialize() [][]byte
type TaskEcho ¶
type TaskEcho struct { TaskID uuid.UUID // TODO: task is a binary uuid Status TaskEchoStatus }
func DeserializeTaskEcho ¶
func (*TaskEcho) MarshalLogObject ¶ added in v0.0.11
func (te *TaskEcho) MarshalLogObject(enc zapcore.ObjectEncoder) error
type TaskEchoStatus ¶
type TaskEchoStatus string
const ( TaskEchoStatusSubmitOK TaskEchoStatus = "SK" TaskEchoStatusCancelOK TaskEchoStatus = "CK" TaskEchoStatusDuplicated TaskEchoStatus = "DC" TaskEchoStatusFunctionNotExists TaskEchoStatus = "FN" )
func (TaskEchoStatus) String ¶
func (tes TaskEchoStatus) String() string
type TaskResult ¶
type TaskResult struct { TaskID uuid.UUID // TODO: task is a binary uuid Status TaskStatus Result []byte Duration float32 }
func DeserializeTaskResult ¶
func DeserializeTaskResult(data [][]byte) (*TaskResult, error)
func (*TaskResult) MarshalLogObject ¶ added in v0.0.11
func (tr *TaskResult) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TaskResult) Serialize ¶
func (tr *TaskResult) Serialize() [][]byte
type TaskStatus ¶
type TaskStatus string
const ( TaskStatusSuccess TaskStatus = "S" TaskStatusFailed TaskStatus = "F" TaskStatusCanceled TaskStatus = "C" )
func (TaskStatus) String ¶
func (ts TaskStatus) String() string
Click to show internal directories.
Click to hide internal directories.