Versions in this module Expand all Collapse all v0 v0.4.4 Feb 5, 2022 v0.4.3 Feb 5, 2022 v0.4.2 Feb 5, 2022 v0.4.1 Feb 5, 2022 v0.4.0 Apr 23, 2020 v0.3.1 Mar 14, 2020 v0.3.0 Mar 12, 2020 Changes in this version + var ErrIntOverflowTransport = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTransport = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrNoTransports = fmt.Errorf("cannot send message because no transports are configured") + var ErrTransportsFailed = fmt.Errorf("all available transports failed to send message") + 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 AgentMessageMultiWriter struct + Transports []AgentMessageWriter + func (w *AgentMessageMultiWriter) WriteAgentMessage(ctx context.Context, srv ServerMessageWriter, msg AgentMessage) error + type AgentMessageWriter interface + WriteAgentMessage func(context.Context, ServerMessageWriter, AgentMessage) error + 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 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 ServerMessageWriter interface + WriteServerMessage func(context.Context, ServerMessage) + 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 TaskExecutor interface + ExecuteTask func(ctx context.Context, output io.Writer, task *Task) error + 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) 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) 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 (result *TaskResult) CoerceStartTime() *time.Time + func (result *TaskResult) CoerceStopTime() *time.Time + func (this *TaskResult) Equal(that interface{}) bool + func (this *TaskResult) GoString() string + func (this *TaskResult) String() string + type Transport struct + func (t Transport) DecodeAgentMessage(data io.Reader) (msg AgentMessage, err error) + func (t Transport) DecodeServerMessage(data io.Reader) (msg ServerMessage, err error) + func (t Transport) EncodeAgentMessage(msg AgentMessage, w io.Writer) (err error) + func (t Transport) EncodeServerMessage(msg ServerMessage, w io.Writer) (err error)