nmp

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 3, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	NMP_OP_READ      = 0
	NMP_OP_READ_RSP  = 1
	NMP_OP_WRITE     = 2
	NMP_OP_WRITE_RSP = 3
)
View Source 
const (
	NMP_ERR_OK       = 0
	NMP_ERR_EUNKNOWN = 1
	NMP_ERR_ENOMEM   = 2
	NMP_ERR_EINVAL   = 3
	NMP_ERR_ETIMEOUT = 4
	NMP_ERR_ENOENT   = 5
)
View Source 
const (
	NMP_GROUP_DEFAULT = 0
	NMP_GROUP_IMAGE   = 1
	NMP_GROUP_STAT    = 2
	NMP_GROUP_CONFIG  = 3
	NMP_GROUP_LOG     = 4
	NMP_GROUP_CRASH   = 5
	NMP_GROUP_SPLIT   = 6
	NMP_GROUP_RUN     = 7
	NMP_GROUP_FS      = 8
	NMP_GROUP_SHELL   = 9
	NMP_GROUP_PERUSER = 64
)
View Source 
const (
	NMP_ID_DEF_ECHO           = 0
	NMP_ID_DEF_CONS_ECHO_CTRL = 1
	NMP_ID_DEF_TASKSTAT       = 2
	NMP_ID_DEF_MPSTAT         = 3
	NMP_ID_DEF_DATETIME_STR   = 4
	NMP_ID_DEF_RESET          = 5
)

Default group (0).

View Source 
const (
	NMP_ID_IMAGE_STATE    = 0
	NMP_ID_IMAGE_UPLOAD   = 1
	NMP_ID_IMAGE_CORELIST = 3
	NMP_ID_IMAGE_CORELOAD = 4
	NMP_ID_IMAGE_ERASE    = 5
)

Image group (1).

View Source 
const (
	NMP_ID_STAT_READ = 0
	NMP_ID_STAT_LIST = 1
)

Stat group (2).

View Source 
const (
	NMP_ID_LOG_SHOW        = 0
	NMP_ID_LOG_CLEAR       = 1
	NMP_ID_LOG_APPEND      = 2
	NMP_ID_LOG_MODULE_LIST = 3
	NMP_ID_LOG_LEVEL_LIST  = 4
	NMP_ID_LOG_LIST        = 5
)

Log group (4).

View Source 
const (
	NMP_ID_RUN_TEST = 0
	NMP_ID_RUN_LIST = 1
)

Run group (7).

View Source 
const (
	LEVEL_DEBUG    int = 0
	LEVEL_INFO         = 1
	LEVEL_WARN         = 2
	LEVEL_ERROR        = 3
	LEVEL_CRITICAL     = 4
	/* Upto 7 custom loglevels */
	LEVEL_MAX = 255
)
View Source 
const (
	STREAM_LOG  int = 0
	MEMORY_LOG      = 1
	STORAGE_LOG     = 2
)
View Source 
const (
	MODULE_DEFAULT     int = 0
	MODULE_OS              = 1
	MODULE_NEWTMGR         = 2
	MODULE_NIMBLE_CTLR     = 3
	MODULE_NIMBLE_HOST     = 4
	MODULE_NFFS            = 5
	MODULE_REBOOT          = 6
	MODULE_TEST            = 8
	MODULE_MAX             = 255
)
View Source 
const (
	LOG_ENTRY_TYPE_STRING LogEntryType = 0
	LOG_ENTRY_TYPE_CBOR                = 1
	LOG_ENTRY_TYPE_BINARY              = 2
)
View Source 
const NMP_HDR_SIZE = 8
View Source 
const (
	NMP_ID_CONFIG_VAL = 0
)

Config group (3).

View Source 
const (
	NMP_ID_CRASH_TRIGGER = 0
)

Crash group (5).

View Source 
const (
	NMP_ID_FS_FILE = 0
)

File system group (8).

View Source 
const (
	NMP_ID_SHELL_EXEC = 0
)

Shell group (8).

Variables

View Source 
var LogEntryTypeStringMap = map[LogEntryType]string{
	LOG_ENTRY_TYPE_STRING: "str",
	LOG_ENTRY_TYPE_CBOR:   "cbor",
	LOG_ENTRY_TYPE_BINARY: "bin",
}
View Source 
var LogLevelNameMap = map[int]string{
	LEVEL_DEBUG:    "DEBUG",
	LEVEL_INFO:     "INFO",
	LEVEL_WARN:     "WARN",
	LEVEL_ERROR:    "ERROR",
	LEVEL_CRITICAL: "CRITICAL",
}
View Source 
var LogModuleNameMap = map[int]string{
	MODULE_DEFAULT:     "DEFAULT",
	MODULE_OS:          "OS",
	MODULE_NEWTMGR:     "NEWTMGR",
	MODULE_NIMBLE_CTLR: "NIMBLE_CTLR",
	MODULE_NIMBLE_HOST: "NIMBLE_HOST",
	MODULE_NFFS:        "NFFS",
	MODULE_REBOOT:      "REBOOT",
	MODULE_TEST:        "TEST",
}
View Source 
var LogTypeNameMap = map[int]string{
	STREAM_LOG:  "STREAM",
	MEMORY_LOG:  "MEMORY",
	STORAGE_LOG: "STORAGE",
}

Functions

func BodyBytes 

func BodyBytes(body interface{}) ([]byte, error)

func EncodeNmpPlain 

func EncodeNmpPlain(nmr *NmpMsg) ([]byte, error)

func LogEntryTypeToString 

func LogEntryTypeToString(LogType LogEntryType) string

func LogLevelToString 

func LogLevelToString(lm int) string

func LogModuleToString 

func LogModuleToString(lm int) string

func LogTypeToString 

func LogTypeToString(lm int) string

func RegisterResponseHandler 

func RegisterResponseHandler(ogi Ogi, f rspCtor)

Types

type ConfigReadReq 

type ConfigReadReq struct {
	NmpBase `codec:"-"`
	Name    string `codec:"name"`
}

func NewConfigReadReq 

func NewConfigReadReq() *ConfigReadReq

func (*ConfigReadReq) Msg 

func (r *ConfigReadReq) Msg() *NmpMsg

type ConfigReadRsp 

type ConfigReadRsp struct {
	NmpBase
	Rc  int    `codec:"rc"`
	Val string `codec:"val"`
}

func NewConfigReadRsp 

func NewConfigReadRsp() *ConfigReadRsp

func (*ConfigReadRsp) Msg 

func (r *ConfigReadRsp) Msg() *NmpMsg

type ConfigWriteReq 

type ConfigWriteReq struct {
	NmpBase `codec:"-"`
	Name    string `codec:"name,omitempty"`
	Val     string `codec:"val,omitempty"`
	Save    bool   `codec:"save,omitempty"`
}

func NewConfigWriteReq 

func NewConfigWriteReq() *ConfigWriteReq

func (*ConfigWriteReq) Msg 

func (r *ConfigWriteReq) Msg() *NmpMsg

type ConfigWriteRsp 

type ConfigWriteRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewConfigWriteRsp 

func NewConfigWriteRsp() *ConfigWriteRsp

func (*ConfigWriteRsp) Msg 

func (r *ConfigWriteRsp) Msg() *NmpMsg

type CoreEraseReq 

type CoreEraseReq struct {
	NmpBase `codec:"-"`
}

func NewCoreEraseReq 

func NewCoreEraseReq() *CoreEraseReq

func (*CoreEraseReq) Msg 

func (r *CoreEraseReq) Msg() *NmpMsg

type CoreEraseRsp 

type CoreEraseRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewCoreEraseRsp 

func NewCoreEraseRsp() *CoreEraseRsp

func (*CoreEraseRsp) Msg 

func (r *CoreEraseRsp) Msg() *NmpMsg

type CoreListReq 

type CoreListReq struct {
	NmpBase `codec:"-"`
}

func NewCoreListReq 

func NewCoreListReq() *CoreListReq

func (*CoreListReq) Msg 

func (r *CoreListReq) Msg() *NmpMsg

type CoreListRsp 

type CoreListRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewCoreListRsp 

func NewCoreListRsp() *CoreListRsp

func (*CoreListRsp) Msg 

func (r *CoreListRsp) Msg() *NmpMsg

type CoreLoadReq 

type CoreLoadReq struct {
	NmpBase `codec:"-"`
	Off     uint32 `codec:"off"`
}

func NewCoreLoadReq 

func NewCoreLoadReq() *CoreLoadReq

func (*CoreLoadReq) Msg 

func (r *CoreLoadReq) Msg() *NmpMsg

type CoreLoadRsp 

type CoreLoadRsp struct {
	NmpBase
	Rc   int    `codec:"rc"`
	Off  uint32 `codec:"off"`
	Len  uint32 `codec:"len"`
	Data []byte `codec:"data"`
}

func NewCoreLoadRsp 

func NewCoreLoadRsp() *CoreLoadRsp

func (*CoreLoadRsp) Msg 

func (r *CoreLoadRsp) Msg() *NmpMsg

type CrashReq 

type CrashReq struct {
	NmpBase   `codec:"-"`
	CrashType string `codec:"t"`
}

func NewCrashReq 

func NewCrashReq() *CrashReq

func (*CrashReq) Msg 

func (r *CrashReq) Msg() *NmpMsg

type CrashRsp 

type CrashRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewCrashRsp 

func NewCrashRsp() *CrashRsp

func (*CrashRsp) Msg 

func (r *CrashRsp) Msg() *NmpMsg

type DateTimeReadReq 

type DateTimeReadReq struct {
	NmpBase `codec:"-"`
}

func NewDateTimeReadReq 

func NewDateTimeReadReq() *DateTimeReadReq

func (*DateTimeReadReq) Msg 

func (r *DateTimeReadReq) Msg() *NmpMsg

type DateTimeReadRsp 

type DateTimeReadRsp struct {
	NmpBase
	DateTime string `codec:"datetime"`
	Rc       int    `codec:"rc"`
}

func NewDateTimeReadRsp 

func NewDateTimeReadRsp() *DateTimeReadRsp

func (*DateTimeReadRsp) Msg 

func (r *DateTimeReadRsp) Msg() *NmpMsg

type DateTimeWriteReq 

type DateTimeWriteReq struct {
	NmpBase  `codec:"-"`
	DateTime string `codec:"datetime"`
}

func NewDateTimeWriteReq 

func NewDateTimeWriteReq() *DateTimeWriteReq

func (*DateTimeWriteReq) Msg 

func (r *DateTimeWriteReq) Msg() *NmpMsg

type DateTimeWriteRsp 

type DateTimeWriteRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewDateTimeWriteRsp 

func NewDateTimeWriteRsp() *DateTimeWriteRsp

func (*DateTimeWriteRsp) Msg 

func (r *DateTimeWriteRsp) Msg() *NmpMsg

type Dispatcher 

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

The dispatcher is the owner of the listeners it points to. Only the dispatcher writes to these listeners.

func NewDispatcher 

func NewDispatcher(logDepth int) *Dispatcher

func (*Dispatcher) AddListener 

func (d *Dispatcher) AddListener(seq uint8) (*Listener, error)

func (*Dispatcher) Dispatch 

func (d *Dispatcher) Dispatch(data []byte) bool

Returns true if the response was dispatched.

func (*Dispatcher) DispatchRsp 

func (d *Dispatcher) DispatchRsp(r NmpRsp) bool

Returns true if the response was dispatched.

func (*Dispatcher) ErrorAll 

func (d *Dispatcher) ErrorAll(err error)

func (*Dispatcher) ErrorOne 

func (d *Dispatcher) ErrorOne(seq uint8, err error) error

func (*Dispatcher) RemoveListener 

func (d *Dispatcher) RemoveListener(seq uint8) *Listener

type EchoReq 

type EchoReq struct {
	NmpBase `codec:"-"`
	Payload string `codec:"d"`
}

func NewEchoReq 

func NewEchoReq() *EchoReq

func (*EchoReq) Msg 

func (r *EchoReq) Msg() *NmpMsg

type EchoRsp 

type EchoRsp struct {
	NmpBase
	Payload string `codec:"r"`
	Rc      int    `codec:"rc"`
}

func NewEchoRsp 

func NewEchoRsp() *EchoRsp

func (*EchoRsp) Msg 

func (r *EchoRsp) Msg() *NmpMsg

type FsDownloadReq 

type FsDownloadReq struct {
	NmpBase `codec:"-"`
	Name    string `codec:"name"`
	Off     uint32 `codec:"off"`
}

func NewFsDownloadReq 

func NewFsDownloadReq() *FsDownloadReq

func (*FsDownloadReq) Msg 

func (r *FsDownloadReq) Msg() *NmpMsg

type FsDownloadRsp 

type FsDownloadRsp struct {
	NmpBase
	Rc   int    `codec:"rc"`
	Off  uint32 `codec:"off"`
	Len  uint32 `codec:"len"`
	Data []byte `codec:"data"`
}

func NewFsDownloadRsp 

func NewFsDownloadRsp() *FsDownloadRsp

func (*FsDownloadRsp) Msg 

func (r *FsDownloadRsp) Msg() *NmpMsg

type FsUploadReq 

type FsUploadReq struct {
	NmpBase `codec:"-"`
	Name    string `codec:"name"`
	Len     uint32 `codec:"len"`
	Off     uint32 `codec:"off"`
	Data    []byte `codec:"data"`
}

func NewFsUploadReq 

func NewFsUploadReq() *FsUploadReq

func (*FsUploadReq) Msg 

func (r *FsUploadReq) Msg() *NmpMsg

type FsUploadRsp 

type FsUploadRsp struct {
	NmpBase
	Rc  int    `codec:"rc"`
	Off uint32 `codec:"off"`
}

func NewFsUploadRsp 

func NewFsUploadRsp() *FsUploadRsp

func (*FsUploadRsp) Msg 

func (r *FsUploadRsp) Msg() *NmpMsg

type ImageEraseReq 

type ImageEraseReq struct {
	NmpBase `codec:"-"`
}

func NewImageEraseReq 

func NewImageEraseReq() *ImageEraseReq

func (*ImageEraseReq) Msg 

func (r *ImageEraseReq) Msg() *NmpMsg

type ImageEraseRsp 

type ImageEraseRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewImageEraseRsp 

func NewImageEraseRsp() *ImageEraseRsp

func (*ImageEraseRsp) Msg 

func (r *ImageEraseRsp) Msg() *NmpMsg

type ImageStateEntry 

type ImageStateEntry struct {
	NmpBase
	Image     int    `codec:"image"`
	Slot      int    `codec:"slot"`
	Version   string `codec:"version"`
	Hash      []byte `codec:"hash"`
	Bootable  bool   `codec:"bootable"`
	Pending   bool   `codec:"pending"`
	Confirmed bool   `codec:"confirmed"`
	Active    bool   `codec:"active"`
	Permanent bool   `codec:"permanent"`
}

type ImageStateReadReq 

type ImageStateReadReq struct {
	NmpBase `codec:"-"`
}

func NewImageStateReadReq 

func NewImageStateReadReq() *ImageStateReadReq

func (*ImageStateReadReq) Msg 

func (r *ImageStateReadReq) Msg() *NmpMsg

type ImageStateRsp 

type ImageStateRsp struct {
	NmpBase
	Rc          int               `codec:"rc"`
	Images      []ImageStateEntry `codec:"images"`
	SplitStatus SplitStatus       `codec:"splitStatus"`
}

func NewImageStateRsp 

func NewImageStateRsp() *ImageStateRsp

func (*ImageStateRsp) Msg 

func (r *ImageStateRsp) Msg() *NmpMsg

type ImageStateWriteReq 

type ImageStateWriteReq struct {
	NmpBase `codec:"-"`
	Hash    []byte `codec:"hash"`
	Confirm bool   `codec:"confirm"`
}

func NewImageStateWriteReq 

func NewImageStateWriteReq() *ImageStateWriteReq

func (*ImageStateWriteReq) Msg 

func (r *ImageStateWriteReq) Msg() *NmpMsg

type ImageUploadReq 

type ImageUploadReq struct {
	NmpBase  `codec:"-"`
	ImageNum uint8  `codec:"image"`
	Off      uint32 `codec:"off"`
	Len      uint32 `codec:"len,omitempty"`
	DataSha  []byte `codec:"sha,omitempty"`
	Upgrade  bool   `codec:"upgrade,omitempty"`
	Data     []byte `codec:"data"`
}

func NewImageUploadReq 

func NewImageUploadReq() *ImageUploadReq

func NewImageUploadReqWithSeq 

func NewImageUploadReqWithSeq(seq uint8) *ImageUploadReq

func (*ImageUploadReq) Msg 

func (r *ImageUploadReq) Msg() *NmpMsg

type ImageUploadRsp 

type ImageUploadRsp struct {
	NmpBase
	Rc  int    `codec:"rc"`
	Off uint32 `codec:"off"`
}

func NewImageUploadRsp 

func NewImageUploadRsp() *ImageUploadRsp

func (*ImageUploadRsp) Msg 

func (r *ImageUploadRsp) Msg() *NmpMsg

type Listener 

type Listener struct {
	RspChan chan NmpRsp
	ErrChan chan error
	// contains filtered or unexported fields
}

func NewListener 

func NewListener() *Listener

func (*Listener) AfterTimeout 

func (nl *Listener) AfterTimeout(tmo time.Duration) <-chan time.Time

func (*Listener) Close 

func (nl *Listener) Close()

type LogClearReq 

type LogClearReq struct {
	NmpBase `codec:"-"`
}

func NewLogClearReq 

func NewLogClearReq() *LogClearReq

func (*LogClearReq) Msg 

func (r *LogClearReq) Msg() *NmpMsg

type LogClearRsp 

type LogClearRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewLogClearRsp 

func NewLogClearRsp() *LogClearRsp

func (*LogClearRsp) Msg 

func (r *LogClearRsp) Msg() *NmpMsg

type LogEntry 

type LogEntry struct {
	Index     uint32       `codec:"index"`
	Timestamp int64        `codec:"ts"`
	Module    uint8        `codec:"module"`
	Level     uint8        `codec:"level"`
	Type      LogEntryType `codec:"type"`
	ImgHash   []byte       `codec:"imghash"`
	Msg       []byte       `codec:"msg"`
}

type LogEntryType 

type LogEntryType int

func LogEntryTypeFromString 

func LogEntryTypeFromString(s string) (LogEntryType, error)

func (LogEntryType) MarshalBinary 

func (l LogEntryType) MarshalBinary() ([]byte, error)

func (LogEntryType) String 

func (l LogEntryType) String() string

func (*LogEntryType) UnmarshalBinary 

func (l *LogEntryType) UnmarshalBinary(data []byte) error

type LogLevelListReq 

type LogLevelListReq struct {
	NmpBase `codec:"-"`
}

func NewLogLevelListReq 

func NewLogLevelListReq() *LogLevelListReq

func (*LogLevelListReq) Msg 

func (r *LogLevelListReq) Msg() *NmpMsg

type LogLevelListRsp 

type LogLevelListRsp struct {
	NmpBase
	Rc  int            `codec:"rc"`
	Map map[string]int `codec:"level_map"`
}

func NewLogLevelListRsp 

func NewLogLevelListRsp() *LogLevelListRsp

func (*LogLevelListRsp) Msg 

func (r *LogLevelListRsp) Msg() *NmpMsg

type LogListReq 

type LogListReq struct {
	NmpBase `codec:"-"`
}

func NewLogListReq 

func NewLogListReq() *LogListReq

func (*LogListReq) Msg 

func (r *LogListReq) Msg() *NmpMsg

type LogListRsp 

type LogListRsp struct {
	NmpBase
	Rc   int      `codec:"rc"`
	List []string `codec:"log_list"`
}

func NewLogListRsp 

func NewLogListRsp() *LogListRsp

func (*LogListRsp) Msg 

func (r *LogListRsp) Msg() *NmpMsg

type LogModuleListReq 

type LogModuleListReq struct {
	NmpBase `codec:"-"`
}

func NewLogModuleListReq 

func NewLogModuleListReq() *LogModuleListReq

func (*LogModuleListReq) Msg 

func (r *LogModuleListReq) Msg() *NmpMsg

type LogModuleListRsp 

type LogModuleListRsp struct {
	NmpBase
	Rc  int            `codec:"rc"`
	Map map[string]int `codec:"module_map"`
}

func NewLogModuleListRsp 

func NewLogModuleListRsp() *LogModuleListRsp

func (*LogModuleListRsp) Msg 

func (r *LogModuleListRsp) Msg() *NmpMsg

type LogShowLog 

type LogShowLog struct {
	Name    string     `codec:"name"`
	Type    int        `codec:"type"`
	Entries []LogEntry `codec:"entries"`
}

type LogShowReq 

type LogShowReq struct {
	NmpBase   `codec:"-"`
	Name      string `codec:"log_name"`
	Timestamp int64  `codec:"ts"`
	Index     uint32 `codec:"index"`
}

func NewLogShowReq 

func NewLogShowReq() *LogShowReq

func (*LogShowReq) Msg 

func (r *LogShowReq) Msg() *NmpMsg

type LogShowRsp 

type LogShowRsp struct {
	NmpBase
	Rc        int          `codec:"rc" codec:",omitempty"`
	NextIndex uint32       `codec:"next_index"`
	Logs      []LogShowLog `codec:"logs"`
}

func NewLogShowRsp 

func NewLogShowRsp() *LogShowRsp

func (*LogShowRsp) Msg 

func (r *LogShowRsp) Msg() *NmpMsg

type MempoolStatReq 

type MempoolStatReq struct {
	NmpBase `codec:"-"`
}

func NewMempoolStatReq 

func NewMempoolStatReq() *MempoolStatReq

func (*MempoolStatReq) Msg 

func (r *MempoolStatReq) Msg() *NmpMsg

type MempoolStatRsp 

type MempoolStatRsp struct {
	NmpBase
	Rc     int                       `codec:"rc"`
	Mpools map[string]map[string]int `codec:"mpools"`
}

func NewMempoolStatRsp 

func NewMempoolStatRsp() *MempoolStatRsp

func (*MempoolStatRsp) Msg 

func (r *MempoolStatRsp) Msg() *NmpMsg

type NmpBase 

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

func (*NmpBase) Hdr 

func (b *NmpBase) Hdr() *NmpHdr

func (*NmpBase) SetHdr 

func (b *NmpBase) SetHdr(h *NmpHdr)

type NmpHdr 

type NmpHdr struct {
	Op    uint8 /* 3 bits of opcode */
	Flags uint8
	Len   uint16
	Group uint16
	Seq   uint8
	Id    uint8
}

func DecodeNmpHdr 

func DecodeNmpHdr(data []byte) (*NmpHdr, error)

func (*NmpHdr) Bytes 

func (hdr *NmpHdr) Bytes() []byte

type NmpMsg 

type NmpMsg struct {
	Hdr  NmpHdr
	Body interface{}
}

func MsgFromReq 

func MsgFromReq(r NmpReq) *NmpMsg

func NewNmpMsg 

func NewNmpMsg() *NmpMsg

type NmpReq 

type NmpReq interface {
	Hdr() *NmpHdr
	SetHdr(hdr *NmpHdr)

	Msg() *NmpMsg
}

Combine req + rsp.

type NmpRsp 

type NmpRsp interface {
	Hdr() *NmpHdr
	SetHdr(msg *NmpHdr)

	Msg() *NmpMsg
}

func DecodeRspBody 

func DecodeRspBody(hdr *NmpHdr, body []byte) (NmpRsp, error)

type Ogi 

type Ogi struct {
	Op    uint8
	Group uint16
	Id    uint8
}

Op-Group-Id

type Reassembler 

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

func NewReassembler 

func NewReassembler() *Reassembler

func (*Reassembler) RxFrag 

func (r *Reassembler) RxFrag(frag []byte) []byte

type ResetReq 

type ResetReq struct {
	NmpBase `codec:"-"`
}

func NewResetReq 

func NewResetReq() *ResetReq

func (*ResetReq) Msg 

func (r *ResetReq) Msg() *NmpMsg

type ResetRsp 

type ResetRsp struct {
	NmpBase
}

func NewResetRsp 

func NewResetRsp() *ResetRsp

func (*ResetRsp) Msg 

func (r *ResetRsp) Msg() *NmpMsg

type RunListReq 

type RunListReq struct {
	NmpBase `codec:"-"`
}

func NewRunListReq 

func NewRunListReq() *RunListReq

func (*RunListReq) Msg 

func (r *RunListReq) Msg() *NmpMsg

type RunListRsp 

type RunListRsp struct {
	NmpBase
	Rc   int      `codec:"rc"`
	List []string `codec:"run_list"`
}

func NewRunListRsp 

func NewRunListRsp() *RunListRsp

func (*RunListRsp) Msg 

func (r *RunListRsp) Msg() *NmpMsg

type RunTestReq 

type RunTestReq struct {
	NmpBase  `codec:"-"`
	Testname string `codec:"testname"`
	Token    string `codec:"token"`
}

func NewRunTestReq 

func NewRunTestReq() *RunTestReq

func (*RunTestReq) Msg 

func (r *RunTestReq) Msg() *NmpMsg

type RunTestRsp 

type RunTestRsp struct {
	NmpBase
	Rc int `codec:"rc"`
}

func NewRunTestRsp 

func NewRunTestRsp() *RunTestRsp

func (*RunTestRsp) Msg 

func (r *RunTestRsp) Msg() *NmpMsg

type ShellExecReq 

type ShellExecReq struct {
	NmpBase `codec:"-"`
	Argv    []string `codec:"argv"`
}

func NewShellExecReq 

func NewShellExecReq() *ShellExecReq

func (*ShellExecReq) Msg 

func (r *ShellExecReq) Msg() *NmpMsg

type ShellExecRsp 

type ShellExecRsp struct {
	NmpBase `codec:"-"`
	O       string `codec:"o"`
	Rc      int    `codec:"rc"`
}

func NewShellExecRsp 

func NewShellExecRsp() *ShellExecRsp

func (*ShellExecRsp) Msg 

func (r *ShellExecRsp) Msg() *NmpMsg

type SplitStatus 

type SplitStatus int
const (
	NOT_APPLICABLE SplitStatus = iota
	NOT_MATCHING
	MATCHING
)

func (SplitStatus) String 

func (sm SplitStatus) String() string

returns the enum as a string

type StatListReq 

type StatListReq struct {
	NmpBase `codec:"-"`
}

func NewStatListReq 

func NewStatListReq() *StatListReq

func (*StatListReq) Msg 

func (r *StatListReq) Msg() *NmpMsg

type StatListRsp 

type StatListRsp struct {
	NmpBase
	Rc   int      `codec:"rc"`
	List []string `codec:"stat_list"`
}

func NewStatListRsp 

func NewStatListRsp() *StatListRsp

func (*StatListRsp) Msg 

func (r *StatListRsp) Msg() *NmpMsg

type StatReadReq 

type StatReadReq struct {
	NmpBase `codec:"-"`
	Name    string `codec:"name"`
}

func NewStatReadReq 

func NewStatReadReq() *StatReadReq

func (*StatReadReq) Msg 

func (r *StatReadReq) Msg() *NmpMsg

type StatReadRsp 

type StatReadRsp struct {
	NmpBase
	Rc     int                    `codec:"rc"`
	Name   string                 `codec:"name"`
	Group  string                 `codec:"group"`
	Fields map[string]interface{} `codec:"fields"`
}

func NewStatReadRsp 

func NewStatReadRsp() *StatReadRsp

func (*StatReadRsp) Msg 

func (r *StatReadRsp) Msg() *NmpMsg

type TaskStatReq 

type TaskStatReq struct {
	NmpBase `codec:"-"`
}

func NewTaskStatReq 

func NewTaskStatReq() *TaskStatReq

func (*TaskStatReq) Msg 

func (r *TaskStatReq) Msg() *NmpMsg

type TaskStatRsp 

type TaskStatRsp struct {
	NmpBase
	Rc    int                       `codec:"rc"`
	Tasks map[string]map[string]int `codec:"tasks"`
}

func NewTaskStatRsp 

func NewTaskStatRsp() *TaskStatRsp

func (*TaskStatRsp) Msg 

func (r *TaskStatRsp) Msg() *NmpMsg

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.