nraySchema

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2020 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EnvironmentInformation 

type EnvironmentInformation struct {
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Os                   string   `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Pid                  string   `protobuf:"bytes,3,opt,name=pid,proto3" json:"pid,omitempty"`
	Processname          string   `protobuf:"bytes,4,opt,name=processname,proto3" json:"processname,omitempty"`
	Username             string   `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"`
	Cpumodelname         string   `protobuf:"bytes,6,opt,name=cpumodelname,proto3" json:"cpumodelname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EnvironmentInformation tells the server under which circumstances nodes are running

func (*EnvironmentInformation) Descriptor 

func (*EnvironmentInformation) Descriptor() ([]byte, []int)

func (*EnvironmentInformation) GetCpumodelname 

func (m *EnvironmentInformation) GetCpumodelname() string

func (*EnvironmentInformation) GetHostname 

func (m *EnvironmentInformation) GetHostname() string

func (*EnvironmentInformation) GetOs 

func (m *EnvironmentInformation) GetOs() string

func (*EnvironmentInformation) GetPid 

func (m *EnvironmentInformation) GetPid() string

func (*EnvironmentInformation) GetProcessname 

func (m *EnvironmentInformation) GetProcessname() string

func (*EnvironmentInformation) GetUsername 

func (m *EnvironmentInformation) GetUsername() string

func (*EnvironmentInformation) ProtoMessage 

func (*EnvironmentInformation) ProtoMessage()

func (*EnvironmentInformation) Reset 

func (m *EnvironmentInformation) Reset()

func (*EnvironmentInformation) String 

func (m *EnvironmentInformation) String() string

func (*EnvironmentInformation) XXX_DiscardUnknown 

func (m *EnvironmentInformation) XXX_DiscardUnknown()

func (*EnvironmentInformation) XXX_Marshal 

func (m *EnvironmentInformation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnvironmentInformation) XXX_Merge 

func (m *EnvironmentInformation) XXX_Merge(src proto.Message)

func (*EnvironmentInformation) XXX_Size 

func (m *EnvironmentInformation) XXX_Size() int

func (*EnvironmentInformation) XXX_Unmarshal 

func (m *EnvironmentInformation) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	NodeID      string               `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	NodeName    string               `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`
	Timestamp   *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Scannername string               `protobuf:"bytes,6,opt,name=scannername,proto3" json:"scannername,omitempty"`
	// Types that are valid to be assigned to EventData:
	//	*Event_Environment
	//	*Event_Result
	EventData            isEvent_EventData `protobuf_oneof:"EventData"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Event is a container for everything that happens at a node and should later on be handled by EventHandlers

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetEnvironment 

func (m *Event) GetEnvironment() *EnvironmentInformation

func (*Event) GetEventData 

func (m *Event) GetEventData() isEvent_EventData

func (*Event) GetNodeID 

func (m *Event) GetNodeID() string

func (*Event) GetNodeName 

func (m *Event) GetNodeName() string

func (*Event) GetResult 

func (m *Event) GetResult() *ScanResult

func (*Event) GetScannername 

func (m *Event) GetScannername() string

func (*Event) GetTimestamp 

func (m *Event) GetTimestamp() *timestamp.Timestamp

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Event_Environment 

type Event_Environment struct {
	Environment *EnvironmentInformation `protobuf:"bytes,7,opt,name=environment,proto3,oneof"`
}

type Event_Result 

type Event_Result struct {
	Result *ScanResult `protobuf:"bytes,8,opt,name=result,proto3,oneof"`
}

type Goodbye 

type Goodbye struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Node is going to exit

func (*Goodbye) Descriptor 

func (*Goodbye) Descriptor() ([]byte, []int)

func (*Goodbye) GetNodeID 

func (m *Goodbye) GetNodeID() string

func (*Goodbye) ProtoMessage 

func (*Goodbye) ProtoMessage()

func (*Goodbye) Reset 

func (m *Goodbye) Reset()

func (*Goodbye) String 

func (m *Goodbye) String() string

func (*Goodbye) XXX_DiscardUnknown 

func (m *Goodbye) XXX_DiscardUnknown()

func (*Goodbye) XXX_Marshal 

func (m *Goodbye) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Goodbye) XXX_Merge 

func (m *Goodbye) XXX_Merge(src proto.Message)

func (*Goodbye) XXX_Size 

func (m *Goodbye) XXX_Size() int

func (*Goodbye) XXX_Unmarshal 

func (m *Goodbye) XXX_Unmarshal(b []byte) error

type GoodbyeAck 

type GoodbyeAck struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Server ACKs the goodbye and signals if the node is allowed to exit

func (*GoodbyeAck) Descriptor 

func (*GoodbyeAck) Descriptor() ([]byte, []int)

func (*GoodbyeAck) GetOk 

func (m *GoodbyeAck) GetOk() bool

func (*GoodbyeAck) ProtoMessage 

func (*GoodbyeAck) ProtoMessage()

func (*GoodbyeAck) Reset 

func (m *GoodbyeAck) Reset()

func (*GoodbyeAck) String 

func (m *GoodbyeAck) String() string

func (*GoodbyeAck) XXX_DiscardUnknown 

func (m *GoodbyeAck) XXX_DiscardUnknown()

func (*GoodbyeAck) XXX_Marshal 

func (m *GoodbyeAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GoodbyeAck) XXX_Merge 

func (m *GoodbyeAck) XXX_Merge(src proto.Message)

func (*GoodbyeAck) XXX_Size 

func (m *GoodbyeAck) XXX_Size() int

func (*GoodbyeAck) XXX_Unmarshal 

func (m *GoodbyeAck) XXX_Unmarshal(b []byte) error

type Heartbeat 

type Heartbeat struct {
	NodeID               string               `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	BeatTime             *timestamp.Timestamp `protobuf:"bytes,2,opt,name=BeatTime,proto3" json:"BeatTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A heartbeat message that is sent regularly from any node to the server to signal that it is still alive

func (*Heartbeat) Descriptor 

func (*Heartbeat) Descriptor() ([]byte, []int)

func (*Heartbeat) GetBeatTime 

func (m *Heartbeat) GetBeatTime() *timestamp.Timestamp

func (*Heartbeat) GetNodeID 

func (m *Heartbeat) GetNodeID() string

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) String 

func (m *Heartbeat) String() string

func (*Heartbeat) XXX_DiscardUnknown 

func (m *Heartbeat) XXX_DiscardUnknown()

func (*Heartbeat) XXX_Marshal 

func (m *Heartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Heartbeat) XXX_Merge 

func (m *Heartbeat) XXX_Merge(src proto.Message)

func (*Heartbeat) XXX_Size 

func (m *Heartbeat) XXX_Size() int

func (*Heartbeat) XXX_Unmarshal 

func (m *Heartbeat) XXX_Unmarshal(b []byte) error

type HeartbeatAck 

type HeartbeatAck struct {
	Scanning             bool     `protobuf:"varint,1,opt,name=Scanning,proto3" json:"Scanning,omitempty"`
	Running              bool     `protobuf:"varint,2,opt,name=Running,proto3" json:"Running,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Acknowledgement of a heartbeat message. A server may indicate to stop scanning and if the scanner should exit

func (*HeartbeatAck) Descriptor 

func (*HeartbeatAck) Descriptor() ([]byte, []int)

func (*HeartbeatAck) GetRunning 

func (m *HeartbeatAck) GetRunning() bool

func (*HeartbeatAck) GetScanning 

func (m *HeartbeatAck) GetScanning() bool

func (*HeartbeatAck) ProtoMessage 

func (*HeartbeatAck) ProtoMessage()

func (*HeartbeatAck) Reset 

func (m *HeartbeatAck) Reset()

func (*HeartbeatAck) String 

func (m *HeartbeatAck) String() string

func (*HeartbeatAck) XXX_DiscardUnknown 

func (m *HeartbeatAck) XXX_DiscardUnknown()

func (*HeartbeatAck) XXX_Marshal 

func (m *HeartbeatAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartbeatAck) XXX_Merge 

func (m *HeartbeatAck) XXX_Merge(src proto.Message)

func (*HeartbeatAck) XXX_Size 

func (m *HeartbeatAck) XXX_Size() int

func (*HeartbeatAck) XXX_Unmarshal 

func (m *HeartbeatAck) XXX_Unmarshal(b []byte) error

type MoreWorkReply 

type MoreWorkReply struct {
	Batchid              uint64       `protobuf:"varint,1,opt,name=batchid,proto3" json:"batchid,omitempty"`
	Targets              *ScanTargets `protobuf:"bytes,3,opt,name=targets,proto3" json:"targets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Contains more work for a scanner

func (*MoreWorkReply) Descriptor 

func (*MoreWorkReply) Descriptor() ([]byte, []int)

func (*MoreWorkReply) GetBatchid 

func (m *MoreWorkReply) GetBatchid() uint64

func (*MoreWorkReply) GetTargets 

func (m *MoreWorkReply) GetTargets() *ScanTargets

func (*MoreWorkReply) ProtoMessage 

func (*MoreWorkReply) ProtoMessage()

func (*MoreWorkReply) Reset 

func (m *MoreWorkReply) Reset()

func (*MoreWorkReply) String 

func (m *MoreWorkReply) String() string

func (*MoreWorkReply) XXX_DiscardUnknown 

func (m *MoreWorkReply) XXX_DiscardUnknown()

func (*MoreWorkReply) XXX_Marshal 

func (m *MoreWorkReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MoreWorkReply) XXX_Merge 

func (m *MoreWorkReply) XXX_Merge(src proto.Message)

func (*MoreWorkReply) XXX_Size 

func (m *MoreWorkReply) XXX_Size() int

func (*MoreWorkReply) XXX_Unmarshal 

func (m *MoreWorkReply) XXX_Unmarshal(b []byte) error

type MoreWorkRequest 

type MoreWorkRequest struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by a node if it has no work

func (*MoreWorkRequest) Descriptor 

func (*MoreWorkRequest) Descriptor() ([]byte, []int)

func (*MoreWorkRequest) GetNodeID 

func (m *MoreWorkRequest) GetNodeID() string

func (*MoreWorkRequest) ProtoMessage 

func (*MoreWorkRequest) ProtoMessage()

func (*MoreWorkRequest) Reset 

func (m *MoreWorkRequest) Reset()

func (*MoreWorkRequest) String 

func (m *MoreWorkRequest) String() string

func (*MoreWorkRequest) XXX_DiscardUnknown 

func (m *MoreWorkRequest) XXX_DiscardUnknown()

func (*MoreWorkRequest) XXX_Marshal 

func (m *MoreWorkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MoreWorkRequest) XXX_Merge 

func (m *MoreWorkRequest) XXX_Merge(src proto.Message)

func (*MoreWorkRequest) XXX_Size 

func (m *MoreWorkRequest) XXX_Size() int

func (*MoreWorkRequest) XXX_Unmarshal 

func (m *MoreWorkRequest) XXX_Unmarshal(b []byte) error

type NodeRegister 

type NodeRegister struct {
	MachineID            string   `protobuf:"bytes,1,opt,name=machineID,proto3" json:"machineID,omitempty"`
	PreferredPool        int32    `protobuf:"varint,2,opt,name=preferredPool,proto3" json:"preferredPool,omitempty"`
	PreferredNodeName    string   `protobuf:"bytes,3,opt,name=preferredNodeName,proto3" json:"preferredNodeName,omitempty"`
	Envinfo              *Event   `protobuf:"bytes,4,opt,name=envinfo,proto3" json:"envinfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This message is sent every time a node registers at the server. It contains a unique node ID so there are not multiple scanner nodes running on the same machine

func (*NodeRegister) Descriptor 

func (*NodeRegister) Descriptor() ([]byte, []int)

func (*NodeRegister) GetEnvinfo 

func (m *NodeRegister) GetEnvinfo() *Event

func (*NodeRegister) GetMachineID 

func (m *NodeRegister) GetMachineID() string

func (*NodeRegister) GetPreferredNodeName 

func (m *NodeRegister) GetPreferredNodeName() string

func (*NodeRegister) GetPreferredPool 

func (m *NodeRegister) GetPreferredPool() int32

func (*NodeRegister) ProtoMessage 

func (*NodeRegister) ProtoMessage()

func (*NodeRegister) Reset 

func (m *NodeRegister) Reset()

func (*NodeRegister) String 

func (m *NodeRegister) String() string

func (*NodeRegister) XXX_DiscardUnknown 

func (m *NodeRegister) XXX_DiscardUnknown()

func (*NodeRegister) XXX_Marshal 

func (m *NodeRegister) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeRegister) XXX_Merge 

func (m *NodeRegister) XXX_Merge(src proto.Message)

func (*NodeRegister) XXX_Size 

func (m *NodeRegister) XXX_Size() int

func (*NodeRegister) XXX_Unmarshal 

func (m *NodeRegister) XXX_Unmarshal(b []byte) error

type NrayNodeMessage 

type NrayNodeMessage struct {
	// Types that are valid to be assigned to MessageContent:
	//	*NrayNodeMessage_NodeRegister
	//	*NrayNodeMessage_Heartbeat
	//	*NrayNodeMessage_MoreWork
	//	*NrayNodeMessage_WorkDone
	//	*NrayNodeMessage_Goodbye
	MessageContent       isNrayNodeMessage_MessageContent `protobuf_oneof:"MessageContent"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

Everything the nodes sends is packed in a nray node message

func (*NrayNodeMessage) Descriptor 

func (*NrayNodeMessage) Descriptor() ([]byte, []int)

func (*NrayNodeMessage) GetGoodbye 

func (m *NrayNodeMessage) GetGoodbye() *Goodbye

func (*NrayNodeMessage) GetHeartbeat 

func (m *NrayNodeMessage) GetHeartbeat() *Heartbeat

func (*NrayNodeMessage) GetMessageContent 

func (m *NrayNodeMessage) GetMessageContent() isNrayNodeMessage_MessageContent

func (*NrayNodeMessage) GetMoreWork 

func (m *NrayNodeMessage) GetMoreWork() *MoreWorkRequest

func (*NrayNodeMessage) GetNodeRegister 

func (m *NrayNodeMessage) GetNodeRegister() *NodeRegister

func (*NrayNodeMessage) GetWorkDone 

func (m *NrayNodeMessage) GetWorkDone() *WorkDone

func (*NrayNodeMessage) ProtoMessage 

func (*NrayNodeMessage) ProtoMessage()

func (*NrayNodeMessage) Reset 

func (m *NrayNodeMessage) Reset()

func (*NrayNodeMessage) String 

func (m *NrayNodeMessage) String() string

func (*NrayNodeMessage) XXX_DiscardUnknown 

func (m *NrayNodeMessage) XXX_DiscardUnknown()

func (*NrayNodeMessage) XXX_Marshal 

func (m *NrayNodeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NrayNodeMessage) XXX_Merge 

func (m *NrayNodeMessage) XXX_Merge(src proto.Message)

func (*NrayNodeMessage) XXX_OneofWrappers 

func (*NrayNodeMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NrayNodeMessage) XXX_Size 

func (m *NrayNodeMessage) XXX_Size() int

func (*NrayNodeMessage) XXX_Unmarshal 

func (m *NrayNodeMessage) XXX_Unmarshal(b []byte) error

type NrayNodeMessage_Goodbye 

type NrayNodeMessage_Goodbye struct {
	Goodbye *Goodbye `protobuf:"bytes,5,opt,name=goodbye,proto3,oneof"`
}

type NrayNodeMessage_Heartbeat 

type NrayNodeMessage_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,2,opt,name=heartbeat,proto3,oneof"`
}

type NrayNodeMessage_MoreWork 

type NrayNodeMessage_MoreWork struct {
	MoreWork *MoreWorkRequest `protobuf:"bytes,3,opt,name=moreWork,proto3,oneof"`
}

type NrayNodeMessage_NodeRegister 

type NrayNodeMessage_NodeRegister struct {
	NodeRegister *NodeRegister `protobuf:"bytes,1,opt,name=nodeRegister,proto3,oneof"`
}

type NrayNodeMessage_WorkDone 

type NrayNodeMessage_WorkDone struct {
	WorkDone *WorkDone `protobuf:"bytes,4,opt,name=workDone,proto3,oneof"`
}

type NrayServerMessage 

type NrayServerMessage struct {
	// Types that are valid to be assigned to MessageContent:
	//	*NrayServerMessage_RegisteredNode
	//	*NrayServerMessage_JobBatch
	//	*NrayServerMessage_HeartbeatAck
	//	*NrayServerMessage_WorkDoneAck
	//	*NrayServerMessage_GoodbyeAck
	//	*NrayServerMessage_NodeIsUnregistered
	MessageContent       isNrayServerMessage_MessageContent `protobuf_oneof:"MessageContent"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

Everything a server sends is packed in a nray server message

func (*NrayServerMessage) Descriptor 

func (*NrayServerMessage) Descriptor() ([]byte, []int)

func (*NrayServerMessage) GetGoodbyeAck 

func (m *NrayServerMessage) GetGoodbyeAck() *GoodbyeAck

func (*NrayServerMessage) GetHeartbeatAck 

func (m *NrayServerMessage) GetHeartbeatAck() *HeartbeatAck

func (*NrayServerMessage) GetJobBatch 

func (m *NrayServerMessage) GetJobBatch() *MoreWorkReply

func (*NrayServerMessage) GetMessageContent 

func (m *NrayServerMessage) GetMessageContent() isNrayServerMessage_MessageContent

func (*NrayServerMessage) GetNodeIsUnregistered 

func (m *NrayServerMessage) GetNodeIsUnregistered() *Unregistered

func (*NrayServerMessage) GetRegisteredNode 

func (m *NrayServerMessage) GetRegisteredNode() *RegisteredNode

func (*NrayServerMessage) GetWorkDoneAck 

func (m *NrayServerMessage) GetWorkDoneAck() *WorkDoneAck

func (*NrayServerMessage) ProtoMessage 

func (*NrayServerMessage) ProtoMessage()

func (*NrayServerMessage) Reset 

func (m *NrayServerMessage) Reset()

func (*NrayServerMessage) String 

func (m *NrayServerMessage) String() string

func (*NrayServerMessage) XXX_DiscardUnknown 

func (m *NrayServerMessage) XXX_DiscardUnknown()

func (*NrayServerMessage) XXX_Marshal 

func (m *NrayServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NrayServerMessage) XXX_Merge 

func (m *NrayServerMessage) XXX_Merge(src proto.Message)

func (*NrayServerMessage) XXX_OneofWrappers 

func (*NrayServerMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NrayServerMessage) XXX_Size 

func (m *NrayServerMessage) XXX_Size() int

func (*NrayServerMessage) XXX_Unmarshal 

func (m *NrayServerMessage) XXX_Unmarshal(b []byte) error

type NrayServerMessage_GoodbyeAck 

type NrayServerMessage_GoodbyeAck struct {
	GoodbyeAck *GoodbyeAck `protobuf:"bytes,5,opt,name=goodbyeAck,proto3,oneof"`
}

type NrayServerMessage_HeartbeatAck 

type NrayServerMessage_HeartbeatAck struct {
	HeartbeatAck *HeartbeatAck `protobuf:"bytes,3,opt,name=heartbeatAck,proto3,oneof"`
}

type NrayServerMessage_JobBatch 

type NrayServerMessage_JobBatch struct {
	JobBatch *MoreWorkReply `protobuf:"bytes,2,opt,name=jobBatch,proto3,oneof"`
}

type NrayServerMessage_NodeIsUnregistered 

type NrayServerMessage_NodeIsUnregistered struct {
	NodeIsUnregistered *Unregistered `protobuf:"bytes,6,opt,name=nodeIsUnregistered,proto3,oneof"`
}

type NrayServerMessage_RegisteredNode 

type NrayServerMessage_RegisteredNode struct {
	RegisteredNode *RegisteredNode `protobuf:"bytes,1,opt,name=registeredNode,proto3,oneof"`
}

type NrayServerMessage_WorkDoneAck 

type NrayServerMessage_WorkDoneAck struct {
	WorkDoneAck *WorkDoneAck `protobuf:"bytes,4,opt,name=workDoneAck,proto3,oneof"`
}

type PortScanResult 

type PortScanResult struct {
	Target               string   `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Open                 bool     `protobuf:"varint,3,opt,name=open,proto3" json:"open,omitempty"`
	Scantype             string   `protobuf:"bytes,4,opt,name=scantype,proto3" json:"scantype,omitempty"`
	Timeout              uint32   `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TCPScanResult contains the outcome of a TCP scan against a single port on a single host

func (*PortScanResult) Descriptor 

func (*PortScanResult) Descriptor() ([]byte, []int)

func (*PortScanResult) GetOpen 

func (m *PortScanResult) GetOpen() bool

func (*PortScanResult) GetPort 

func (m *PortScanResult) GetPort() uint32

func (*PortScanResult) GetScantype 

func (m *PortScanResult) GetScantype() string

func (*PortScanResult) GetTarget 

func (m *PortScanResult) GetTarget() string

func (*PortScanResult) GetTimeout 

func (m *PortScanResult) GetTimeout() uint32

func (*PortScanResult) ProtoMessage 

func (*PortScanResult) ProtoMessage()

func (*PortScanResult) Reset 

func (m *PortScanResult) Reset()

func (*PortScanResult) String 

func (m *PortScanResult) String() string

func (*PortScanResult) XXX_DiscardUnknown 

func (m *PortScanResult) XXX_DiscardUnknown()

func (*PortScanResult) XXX_Marshal 

func (m *PortScanResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PortScanResult) XXX_Merge 

func (m *PortScanResult) XXX_Merge(src proto.Message)

func (*PortScanResult) XXX_Size 

func (m *PortScanResult) XXX_Size() int

func (*PortScanResult) XXX_Unmarshal 

func (m *PortScanResult) XXX_Unmarshal(b []byte) error

type RegisteredNode 

type RegisteredNode struct {
	NodeID      string               `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	ServerClock *timestamp.Timestamp `protobuf:"bytes,2,opt,name=ServerClock,proto3" json:"ServerClock,omitempty"`
	//int32 pool = 3;
	Scannerconfig        []byte   `protobuf:"bytes,4,opt,name=scannerconfig,proto3" json:"scannerconfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This message tells the scanner that it is registered at the server and assigns a unique scanner ID as well as it carries the timestamp of the server, so nodes that have no correct clock can still perform somewhat accurate timestamping of events

func (*RegisteredNode) Descriptor 

func (*RegisteredNode) Descriptor() ([]byte, []int)

func (*RegisteredNode) GetNodeID 

func (m *RegisteredNode) GetNodeID() string

func (*RegisteredNode) GetScannerconfig 

func (m *RegisteredNode) GetScannerconfig() []byte

func (*RegisteredNode) GetServerClock 

func (m *RegisteredNode) GetServerClock() *timestamp.Timestamp

func (*RegisteredNode) ProtoMessage 

func (*RegisteredNode) ProtoMessage()

func (*RegisteredNode) Reset 

func (m *RegisteredNode) Reset()

func (*RegisteredNode) String 

func (m *RegisteredNode) String() string

func (*RegisteredNode) XXX_DiscardUnknown 

func (m *RegisteredNode) XXX_DiscardUnknown()

func (*RegisteredNode) XXX_Marshal 

func (m *RegisteredNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisteredNode) XXX_Merge 

func (m *RegisteredNode) XXX_Merge(src proto.Message)

func (*RegisteredNode) XXX_Size 

func (m *RegisteredNode) XXX_Size() int

func (*RegisteredNode) XXX_Unmarshal 

func (m *RegisteredNode) XXX_Unmarshal(b []byte) error

type ScanResult 

type ScanResult struct {
	Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	Port   uint32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*ScanResult_Portscan
	//	*ScanResult_Zgrabscan
	Result               isScanResult_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ScanResult) Descriptor 

func (*ScanResult) Descriptor() ([]byte, []int)

func (*ScanResult) GetPort 

func (m *ScanResult) GetPort() uint32

func (*ScanResult) GetPortscan 

func (m *ScanResult) GetPortscan() *PortScanResult

func (*ScanResult) GetResult 

func (m *ScanResult) GetResult() isScanResult_Result

func (*ScanResult) GetTarget 

func (m *ScanResult) GetTarget() string

func (*ScanResult) GetZgrabscan 

func (m *ScanResult) GetZgrabscan() *ZGrab2ScanResult

func (*ScanResult) ProtoMessage 

func (*ScanResult) ProtoMessage()

func (*ScanResult) Reset 

func (m *ScanResult) Reset()

func (*ScanResult) String 

func (m *ScanResult) String() string

func (*ScanResult) XXX_DiscardUnknown 

func (m *ScanResult) XXX_DiscardUnknown()

func (*ScanResult) XXX_Marshal 

func (m *ScanResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanResult) XXX_Merge 

func (m *ScanResult) XXX_Merge(src proto.Message)

func (*ScanResult) XXX_OneofWrappers 

func (*ScanResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ScanResult) XXX_Size 

func (m *ScanResult) XXX_Size() int

func (*ScanResult) XXX_Unmarshal 

func (m *ScanResult) XXX_Unmarshal(b []byte) error

type ScanResult_Portscan 

type ScanResult_Portscan struct {
	Portscan *PortScanResult `protobuf:"bytes,8,opt,name=portscan,proto3,oneof"`
}

type ScanResult_Zgrabscan 

type ScanResult_Zgrabscan struct {
	Zgrabscan *ZGrab2ScanResult `protobuf:"bytes,9,opt,name=zgrabscan,proto3,oneof"`
}

type ScanTargets 

type ScanTargets struct {
	Rhosts               []string `protobuf:"bytes,1,rep,name=rhosts,proto3" json:"rhosts,omitempty"`
	Tcpports             []uint32 `protobuf:"varint,2,rep,packed,name=tcpports,proto3" json:"tcpports,omitempty"`
	Udpports             []uint32 `protobuf:"varint,3,rep,packed,name=udpports,proto3" json:"udpports,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ScanTargets may be dnsNames/ips and ports. ip is encoded as byte array. dnsName is a FQDN and mustn't contain a protocol specification

func (*ScanTargets) Descriptor 

func (*ScanTargets) Descriptor() ([]byte, []int)

func (*ScanTargets) GetRhosts 

func (m *ScanTargets) GetRhosts() []string

func (*ScanTargets) GetTcpports 

func (m *ScanTargets) GetTcpports() []uint32

func (*ScanTargets) GetUdpports 

func (m *ScanTargets) GetUdpports() []uint32

func (*ScanTargets) ProtoMessage 

func (*ScanTargets) ProtoMessage()

func (*ScanTargets) Reset 

func (m *ScanTargets) Reset()

func (*ScanTargets) String 

func (m *ScanTargets) String() string

func (*ScanTargets) XXX_DiscardUnknown 

func (m *ScanTargets) XXX_DiscardUnknown()

func (*ScanTargets) XXX_Marshal 

func (m *ScanTargets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanTargets) XXX_Merge 

func (m *ScanTargets) XXX_Merge(src proto.Message)

func (*ScanTargets) XXX_Size 

func (m *ScanTargets) XXX_Size() int

func (*ScanTargets) XXX_Unmarshal 

func (m *ScanTargets) XXX_Unmarshal(b []byte) error

type Unregistered 

type Unregistered struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This message is sent by the server and indicates that the server does not know this node and that the node should register again

func (*Unregistered) Descriptor 

func (*Unregistered) Descriptor() ([]byte, []int)

func (*Unregistered) GetNodeID 

func (m *Unregistered) GetNodeID() string

func (*Unregistered) ProtoMessage 

func (*Unregistered) ProtoMessage()

func (*Unregistered) Reset 

func (m *Unregistered) Reset()

func (*Unregistered) String 

func (m *Unregistered) String() string

func (*Unregistered) XXX_DiscardUnknown 

func (m *Unregistered) XXX_DiscardUnknown()

func (*Unregistered) XXX_Marshal 

func (m *Unregistered) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Unregistered) XXX_Merge 

func (m *Unregistered) XXX_Merge(src proto.Message)

func (*Unregistered) XXX_Size 

func (m *Unregistered) XXX_Size() int

func (*Unregistered) XXX_Unmarshal 

func (m *Unregistered) XXX_Unmarshal(b []byte) error

type WorkDone 

type WorkDone struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Batchid              uint64   `protobuf:"varint,2,opt,name=batchid,proto3" json:"batchid,omitempty"`
	Events               []*Event `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Indicates that a node is done with a work batch and contains the results

func (*WorkDone) Descriptor 

func (*WorkDone) Descriptor() ([]byte, []int)

func (*WorkDone) GetBatchid 

func (m *WorkDone) GetBatchid() uint64

func (*WorkDone) GetEvents 

func (m *WorkDone) GetEvents() []*Event

func (*WorkDone) GetNodeID 

func (m *WorkDone) GetNodeID() string

func (*WorkDone) ProtoMessage 

func (*WorkDone) ProtoMessage()

func (*WorkDone) Reset 

func (m *WorkDone) Reset()

func (*WorkDone) String 

func (m *WorkDone) String() string

func (*WorkDone) XXX_DiscardUnknown 

func (m *WorkDone) XXX_DiscardUnknown()

func (*WorkDone) XXX_Marshal 

func (m *WorkDone) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkDone) XXX_Merge 

func (m *WorkDone) XXX_Merge(src proto.Message)

func (*WorkDone) XXX_Size 

func (m *WorkDone) XXX_Size() int

func (*WorkDone) XXX_Unmarshal 

func (m *WorkDone) XXX_Unmarshal(b []byte) error

type WorkDoneAck 

type WorkDoneAck struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Acknowledges a WorkDone packet

func (*WorkDoneAck) Descriptor 

func (*WorkDoneAck) Descriptor() ([]byte, []int)

func (*WorkDoneAck) ProtoMessage 

func (*WorkDoneAck) ProtoMessage()

func (*WorkDoneAck) Reset 

func (m *WorkDoneAck) Reset()

func (*WorkDoneAck) String 

func (m *WorkDoneAck) String() string

func (*WorkDoneAck) XXX_DiscardUnknown 

func (m *WorkDoneAck) XXX_DiscardUnknown()

func (*WorkDoneAck) XXX_Marshal 

func (m *WorkDoneAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkDoneAck) XXX_Merge 

func (m *WorkDoneAck) XXX_Merge(src proto.Message)

func (*WorkDoneAck) XXX_Size 

func (m *WorkDoneAck) XXX_Size() int

func (*WorkDoneAck) XXX_Unmarshal 

func (m *WorkDoneAck) XXX_Unmarshal(b []byte) error

type ZGrab2ScanResult 

type ZGrab2ScanResult struct {
	JsonResult           *_struct.Value `protobuf:"bytes,1,opt,name=jsonResult,proto3" json:"jsonResult,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ZGrab2ScanResult) Descriptor 

func (*ZGrab2ScanResult) Descriptor() ([]byte, []int)

func (*ZGrab2ScanResult) GetJsonResult 

func (m *ZGrab2ScanResult) GetJsonResult() *_struct.Value

func (*ZGrab2ScanResult) ProtoMessage 

func (*ZGrab2ScanResult) ProtoMessage()

func (*ZGrab2ScanResult) Reset 

func (m *ZGrab2ScanResult) Reset()

func (*ZGrab2ScanResult) String 

func (m *ZGrab2ScanResult) String() string

func (*ZGrab2ScanResult) XXX_DiscardUnknown 

func (m *ZGrab2ScanResult) XXX_DiscardUnknown()

func (*ZGrab2ScanResult) XXX_Marshal 

func (m *ZGrab2ScanResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ZGrab2ScanResult) XXX_Merge 

func (m *ZGrab2ScanResult) XXX_Merge(src proto.Message)

func (*ZGrab2ScanResult) XXX_Size 

func (m *ZGrab2ScanResult) XXX_Size() int

func (*ZGrab2ScanResult) XXX_Unmarshal 

func (m *ZGrab2ScanResult) XXX_Unmarshal(b []byte) error

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.