Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + const HeaderSize + const MagicNumber + const ProtocolVersion + func IsValidMessageType(t MessageType) bool + type Flag uint16 + const FLAG_BINARY_BODY + const FLAG_CHUNKED + const FLAG_COMPRESSED + const FLAG_ERROR + const FLAG_IS_ACK + const FLAG_JSON_BODY + const FLAG_LAST_CHUNK + const FLAG_NEED_ACK + type Message struct + Body []byte + Header *MessageHeader + Headers json.RawMessage + func DecodeMessage(data []byte) (*Message, error) + func NewAgentMetricMessage(agentID string, metrics any) (*Message, error) + func NewHTTPRequestMessage(method, url string, headers map[string]string, body []byte) (*Message, error) + func NewHTTPResponseMessage(messageID string, statusCode int, headers map[string]string, body []byte) (*Message, error) + func NewHeartbeatMessage() *Message + func NewMessage(msgType MessageType) *Message + func NewTaskConfirmMessage(requestID, taskID string, confirm any) (*Message, error) + func NewTaskLogMessage(requestID, taskID string, logMsg any) (*Message, error) + func NewTaskResultMessage(requestID, taskID string, result any) (*Message, error) + func NewTaskRunMessage(requestID, taskID, action string, taskData any) (*Message, error) + func (m *Message) Encode() ([]byte, error) + func (m *Message) GetHeaders(v interface{}) error + func (m *Message) GetJSONBody(v interface{}) error + func (m *Message) SetBinaryBody(data []byte) + func (m *Message) SetHeaders(v interface{}) error + func (m *Message) SetJSONBody(v interface{}) error + type MessageHeader struct + BodyLen uint32 + Flags uint16 + HeadersLen uint32 + Magic [4]byte + MessageID [16]byte + MessageType uint8 + Reserved1 uint16 + Reserved2 uint32 + StatusCode uint16 + Version uint8 + func DecodeHeader(data []byte) (*MessageHeader, error) + func NewMessageHeader(msgType MessageType) *MessageHeader + func (h *MessageHeader) ClearFlag(flag Flag) + func (h *MessageHeader) Encode() []byte + func (h *MessageHeader) GetMessageID() string + func (h *MessageHeader) HasFlag(flag Flag) bool + func (h *MessageHeader) SetFlag(flag Flag) + func (h *MessageHeader) SetMessageID(id uuid.UUID) + func (h *MessageHeader) TotalSize() uint32 + func (h *MessageHeader) Validate() error + type MessageType uint8 + const MSG_TYPE_AGENT_INFO + const MSG_TYPE_AGENT_METRIC + const MSG_TYPE_AUTH + const MSG_TYPE_CONFIG_UPDATE + const MSG_TYPE_FILE_DOWNLOAD + const MSG_TYPE_FILE_UPLOAD + const MSG_TYPE_HANDSHAKE + const MSG_TYPE_HEARTBEAT + const MSG_TYPE_HTTP_REQUEST + const MSG_TYPE_HTTP_RESPONSE + const MSG_TYPE_TASK_CANCEL + const MSG_TYPE_TASK_CONFIRM + const MSG_TYPE_TASK_LOG + const MSG_TYPE_TASK_RESULT + const MSG_TYPE_TASK_RUN + const MSG_TYPE_TASK_STATUS + const MSG_TYPE_TASK_STDERR + const MSG_TYPE_TASK_STDOUT
Go to main page