client

Documentation

Index

• type Client
  • func New(cc grpc.ClientConnInterface, id string) *Client
  • func (nc *Client) AddLogLines(ctx context.Context, lines ...*logspb.LogLine) error
  • func (nc *Client) BroadcastCommand(ctx context.Context, command string) error
  • func (nc *Client) DownloadFile(ctx context.Context, info *fspb.FileInfo, out io.Writer) error
  • func (nc *Client) Exploit(ctx context.Context, id string) (*epb.ExploitResponse, error)
  • func (nc *Client) GetServerState(ctx context.Context) (*epb.ServerState, error)
  • func (nc *Client) Heartbeat(ctx context.Context) (*epb.ServerState, error)
  • func (nc *Client) Leave(ctx context.Context) error
  • func (nc *Client) ListenBroadcasts(ctx context.Context) (<-chan *epb.BroadcastSubscribeResponse, error)
  • func (nc *Client) ListenSingleRuns(ctx context.Context) (<-chan *epb.SingleRunSubscribeResponse, error)
  • func (nc *Client) SearchLogLines(ctx context.Context, exploit string, version int64) (<-chan []*logspb.LogLine, error)
  • func (nc *Client) SetExploitDisabled(ctx context.Context, id string, disabled bool) error
  • func (nc *Client) SingleRun(ctx context.Context, exploitID string) error
  • func (nc *Client) UpdateExploit(ctx context.Context, state *epb.ExploitState) (*epb.ExploitState, error)
  • func (nc *Client) UploadFile(ctx context.Context, r io.Reader) (*fspb.FileInfo, error)
• type Config
  • func MustUnmarshalConfig() *Config

Types

type Client

type Client struct {
	ID     string
	Weight int
	// contains filtered or unexported fields
}

func New

func New(cc grpc.ClientConnInterface, id string) *Client

func (*Client) AddLogLines

func (nc *Client) AddLogLines(ctx context.Context, lines ...*logspb.LogLine) error

func (*Client) BroadcastCommand

func (nc *Client) BroadcastCommand(ctx context.Context, command string) error

func (*Client) DownloadFile

func (nc *Client) DownloadFile(ctx context.Context, info *fspb.FileInfo, out io.Writer) error

func (*Client) Exploit

func (nc *Client) Exploit(ctx context.Context, id string) (*epb.ExploitResponse, error)

func (*Client) GetServerState

func (nc *Client) GetServerState(ctx context.Context) (*epb.ServerState, error)

func (*Client) Heartbeat

func (nc *Client) Heartbeat(ctx context.Context) (*epb.ServerState, error)

func (*Client) Leave

func (nc *Client) Leave(ctx context.Context) error

func (*Client) ListenBroadcasts

func (nc *Client) ListenBroadcasts(ctx context.Context) (<-chan *epb.BroadcastSubscribeResponse, error)

func (*Client) ListenSingleRuns

func (nc *Client) ListenSingleRuns(ctx context.Context) (<-chan *epb.SingleRunSubscribeResponse, error)

func (*Client) SearchLogLines

func (nc *Client) SearchLogLines(ctx context.Context, exploit string, version int64) (<-chan []*logspb.LogLine, error)

func (*Client) SetExploitDisabled

func (nc *Client) SetExploitDisabled(ctx context.Context, id string, disabled bool) error

func (*Client) SingleRun

func (nc *Client) SingleRun(ctx context.Context, exploitID string) error

func (*Client) UpdateExploit

func (nc *Client) UpdateExploit(ctx context.Context, state *epb.ExploitState) (*epb.ExploitState, error)

func (*Client) UploadFile

func (nc *Client) UploadFile(ctx context.Context, r io.Reader) (*fspb.FileInfo, error)

type Config

type Config struct {
	Host        string `mapstructure:"host"`
	MetricsHost string `mapstructure:"metrics_host"`
	ExploitDir  string `mapstructure:"exploit_dir"`
	GrpcAuthKey string `mapstructure:"grpc_auth_key"`
	UseTLS      bool   `mapstructure:"use_tls"`
}

func MustUnmarshalConfig

func MustUnmarshalConfig() *Config