protocol

package
v0.0.11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2023 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

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 DeserializeHeartbeat(data [][]byte) (*Heartbeat, error)

func (*Heartbeat) MarshalLogObject added in v0.0.11 

func (h *Heartbeat) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Heartbeat) Serialize 

func (h *Heartbeat) Serialize() [][]byte

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 

type Socket struct {
	ZmqSocket zmq4.Socket
}

func NewSocket added in v0.0.11 

func NewSocket(zmqSocket zmq4.Socket) *Socket

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 DeserializeTask(data [][]byte) (*Task, error)

func (*Task) MarshalLogObject added in v0.0.11 

func (t *Task) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Task) Serialize 

func (t *Task) Serialize() [][]byte

type TaskCancel 

type TaskCancel struct {
	TaskID uuid.UUID // TODO: task is a binary uuid
}

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 DeserializeTaskEcho(data [][]byte) (*TaskEcho, error)

func (*TaskEcho) MarshalLogObject added in v0.0.11 

func (te *TaskEcho) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*TaskEcho) Serialize 

func (te *TaskEcho) Serialize() [][]byte

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.