Versions in this module Expand all Collapse all v0 v0.2.3 Jan 23, 2020 v0.2.2 Jan 15, 2020 v0.2.2-a Jan 15, 2020 v0.2.1 Jan 10, 2020 v0.2.0 Jan 9, 2020 v0.2.0-alpha Jan 10, 2020 v0.1.9 Jan 10, 2020 Changes in this version + var ErrIntOverflowTransport = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTransport = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTransport = fmt.Errorf("proto: unexpected end of group") + type AgentMessage struct + Logs []string + Metadata *AgentMetadata + Results []*TaskResult + func NewPopulatedAgentMessage(r randyTransport, easy bool) *AgentMessage + func (*AgentMessage) Descriptor() ([]byte, []int) + func (*AgentMessage) ProtoMessage() + func (m *AgentMessage) GetLogs() []string + func (m *AgentMessage) GetMetadata() *AgentMetadata + func (m *AgentMessage) GetResults() []*TaskResult + func (m *AgentMessage) Marshal() (dAtA []byte, err error) + func (m *AgentMessage) MarshalTo(dAtA []byte) (int, error) + func (m *AgentMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AgentMessage) Reset() + func (m *AgentMessage) Size() (n int) + func (m *AgentMessage) Unmarshal(dAtA []byte) error + func (m *AgentMessage) XXX_DiscardUnknown() + func (m *AgentMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AgentMessage) XXX_Merge(src proto.Message) + func (m *AgentMessage) XXX_Size() int + func (m *AgentMessage) XXX_Unmarshal(b []byte) error + func (this *AgentMessage) Equal(that interface{}) bool + func (this *AgentMessage) GoString() string + func (this *AgentMessage) String() string + type AgentMetadata struct + AgentID string + Hostname string + MachineUUID string + PrimaryIP string + PrimaryMAC string + SessionID string + func NewPopulatedAgentMetadata(r randyTransport, easy bool) *AgentMetadata + func (*AgentMetadata) Descriptor() ([]byte, []int) + func (*AgentMetadata) ProtoMessage() + func (m *AgentMetadata) GetAgentID() string + func (m *AgentMetadata) GetHostname() string + func (m *AgentMetadata) GetMachineUUID() string + func (m *AgentMetadata) GetPrimaryIP() string + func (m *AgentMetadata) GetPrimaryMAC() string + func (m *AgentMetadata) GetSessionID() string + func (m *AgentMetadata) Marshal() (dAtA []byte, err error) + func (m *AgentMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *AgentMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AgentMetadata) Reset() + func (m *AgentMetadata) Size() (n int) + func (m *AgentMetadata) Unmarshal(dAtA []byte) error + func (m *AgentMetadata) XXX_DiscardUnknown() + func (m *AgentMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AgentMetadata) XXX_Merge(src proto.Message) + func (m *AgentMetadata) XXX_Size() int + func (m *AgentMetadata) XXX_Unmarshal(b []byte) error + func (this *AgentMetadata) Equal(that interface{}) bool + func (this *AgentMetadata) GoString() string + func (this *AgentMetadata) String() string + type Server struct + func (srv *Server) ServeStatus(w http.ResponseWriter, req *http.Request) + func (srv Server) HandleAgent(ctx context.Context, msg AgentMessage) (*ServerMessage, error) + func (srv Server) HandleJSON(ctx context.Context, src io.Reader, dst io.Writer) error + func (srv Server) ServeHTTP(w http.ResponseWriter, req *http.Request) + type ServerMessage struct + Tasks []*Task + func NewPopulatedServerMessage(r randyTransport, easy bool) *ServerMessage + func (*ServerMessage) Descriptor() ([]byte, []int) + func (*ServerMessage) ProtoMessage() + func (m *ServerMessage) GetTasks() []*Task + func (m *ServerMessage) Marshal() (dAtA []byte, err error) + func (m *ServerMessage) MarshalTo(dAtA []byte) (int, error) + func (m *ServerMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServerMessage) Reset() + func (m *ServerMessage) Size() (n int) + func (m *ServerMessage) Unmarshal(dAtA []byte) error + func (m *ServerMessage) XXX_DiscardUnknown() + func (m *ServerMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServerMessage) XXX_Merge(src proto.Message) + func (m *ServerMessage) XXX_Size() int + func (m *ServerMessage) XXX_Unmarshal(b []byte) error + func (this *ServerMessage) Equal(that interface{}) bool + func (this *ServerMessage) GoString() string + func (this *ServerMessage) String() string + type Task struct + Content string + Id int64 + func NewPopulatedTask(r randyTransport, easy bool) *Task + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (m *Task) GetContent() string + func (m *Task) GetId() int64 + func (m *Task) Marshal() (dAtA []byte, err error) + func (m *Task) MarshalTo(dAtA []byte) (int, error) + func (m *Task) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Task) Reset() + func (m *Task) Size() (n int) + func (m *Task) Unmarshal(dAtA []byte) error + func (m *Task) XXX_DiscardUnknown() + func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Task) XXX_Merge(src proto.Message) + func (m *Task) XXX_Size() int + func (m *Task) XXX_Unmarshal(b []byte) error + func (this *Task) Equal(that interface{}) bool + func (this *Task) GoString() string + func (this *Task) String() string + type TaskResult struct + Error string + ExecStartTime *types.Timestamp + ExecStopTime *types.Timestamp + Id int64 + Output string + func NewPopulatedTaskResult(r randyTransport, easy bool) *TaskResult + func (*TaskResult) Descriptor() ([]byte, []int) + func (*TaskResult) ProtoMessage() + func (m *TaskResult) CloseWithError(err error) + func (m *TaskResult) GetError() string + func (m *TaskResult) GetExecStartTime() *types.Timestamp + func (m *TaskResult) GetExecStopTime() *types.Timestamp + func (m *TaskResult) GetId() int64 + func (m *TaskResult) GetOutput() string + func (m *TaskResult) Marshal() (dAtA []byte, err error) + func (m *TaskResult) MarshalTo(dAtA []byte) (int, error) + func (m *TaskResult) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TaskResult) Reset() + func (m *TaskResult) Size() (n int) + func (m *TaskResult) Start() + func (m *TaskResult) Unmarshal(dAtA []byte) error + func (m *TaskResult) XXX_DiscardUnknown() + func (m *TaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaskResult) XXX_Merge(src proto.Message) + func (m *TaskResult) XXX_Size() int + func (m *TaskResult) XXX_Unmarshal(b []byte) error + func (this *TaskResult) Equal(that interface{}) bool + func (this *TaskResult) GoString() string + func (this *TaskResult) String() string + type Teamserver interface + ClaimTasks func(context.Context, models.ClaimTasksRequest) ([]*ent.Task, error) + SubmitTaskResult func(context.Context, models.SubmitTaskResultRequest) error
Go to main page