tcp

package
v1.0.0-beta.3 Latest Latest
Warning

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

 Go to latest Published: May 19, 2021 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CouchDbOpenPlugin 

type CouchDbOpenPlugin struct {
	l9format.ServicePluginBase
}

func (CouchDbOpenPlugin) GetAddress 

func (plugin CouchDbOpenPlugin) GetAddress(event *l9format.L9Event) string

Helper to generate HTTP address

func (CouchDbOpenPlugin) GetDatabaseInfo 

func (plugin CouchDbOpenPlugin) GetDatabaseInfo(ctx context.Context, event *l9format.L9Event, dbNames []string) (dbInfo []DatabaseInfo)

Get database information from a list of names

func (CouchDbOpenPlugin) GetInfos 

func (plugin CouchDbOpenPlugin) GetInfos(ctx context.Context, event *l9format.L9Event, dbList []string) (hasLeak bool)

Iterate over the database list to get more informations

func (CouchDbOpenPlugin) GetName 

func (CouchDbOpenPlugin) GetName() string

func (CouchDbOpenPlugin) GetProtocols 

func (CouchDbOpenPlugin) GetProtocols() []string

func (CouchDbOpenPlugin) GetStage 

func (CouchDbOpenPlugin) GetStage() string

func (CouchDbOpenPlugin) GetVersion 

func (CouchDbOpenPlugin) GetVersion() (int, int, int)

func (CouchDbOpenPlugin) Run 

func (plugin CouchDbOpenPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) (hasLeak bool)

Gets a database list and runs futher steps

func (CouchDbOpenPlugin) TestOpen 

func (plugin CouchDbOpenPlugin) TestOpen(ctx context.Context, event *l9format.L9Event) bool

Check if data accessible or if only the schema is exposed

type DatabaseInfo 

type DatabaseInfo struct {
	Info struct {
		Name     string `json:"db_name"`
		DocCount int64  `json:"doc_count"`
		DiskSize int64  `json:"disk_size"`
	} `json:"info"`
}

Minimal structure returned from the info endpoint

type ElasticSearchCatIndicesResponse 

type ElasticSearchCatIndicesResponse []struct {
	Health    string `json:"health"`
	Status    string `json:"status"`
	Name      string `json:"index"`
	DocCount  string `json:"docs.count"`
	IndexSize string `json:"pri.store.size"`
}

type ElasticSearchCatNodesResponse 

type ElasticSearchCatNodesResponse struct {
	NodesSumary struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_nodes"`
	Nodes map[string]struct {
		Version         string `json:"version"`
		OperatingSystem struct {
			Name    string `json:"pretty_name"`
			Version string `json:"version"`
		} `json:"os"`
	} `json:"nodes"`
}

type ElasticSearchExplorePlugin 

type ElasticSearchExplorePlugin struct {
	l9format.ServicePluginBase
}

func (ElasticSearchExplorePlugin) GetName 

func (ElasticSearchExplorePlugin) GetName() string

func (ElasticSearchExplorePlugin) GetProtocols 

func (ElasticSearchExplorePlugin) GetProtocols() []string

func (ElasticSearchExplorePlugin) GetRansomNote 

func (plugin ElasticSearchExplorePlugin) GetRansomNote(ctx context.Context, url string, event *l9format.L9Event) (ransomNote string, found bool)

func (ElasticSearchExplorePlugin) GetStage 

func (ElasticSearchExplorePlugin) GetStage() string

func (ElasticSearchExplorePlugin) GetVersion 

func (ElasticSearchExplorePlugin) GetVersion() (int, int, int)

func (ElasticSearchExplorePlugin) Run 

func (plugin ElasticSearchExplorePlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) (hasLeak bool)

Get info

type ElasticSearchGreetResponse 

type ElasticSearchGreetResponse struct {
	Name        string `json:"name"`
	ClusterName string `json:"cluster_name"`
	ClusterUuid string `json:"cluster_uuid"`
	TagLine     string `json:"tagline"`
	Version     struct {
		Number                           string `json:"number"`
		BuildFlavor                      string `json:"build_flavor"`
		BuildType                        string `json:"build_type"`
		BuildHash                        string `json:"build_hash"`
		BuildDate                        string `json:"build_date"`
		BuildSnapshot                    bool   `json:"build_snapshot"`
		LuceneVersion                    string `json:"lucene_version"`
		MinimumWireCompatibilityVersion  string `json:"minimum_wire_compatibility_version"`
		MinimumIndexCompatibilityVersion string `json:"minimum_index_compatibility_version"`
	} `json:"version"`
}

First thing we tried, turns out node API has more info we like

type ElasticSearchOpenPlugin 

type ElasticSearchOpenPlugin struct {
	l9format.ServicePluginBase
}

func (ElasticSearchOpenPlugin) GetName 

func (ElasticSearchOpenPlugin) GetName() string

func (ElasticSearchOpenPlugin) GetProtocols 

func (ElasticSearchOpenPlugin) GetProtocols() []string

func (ElasticSearchOpenPlugin) GetStage 

func (ElasticSearchOpenPlugin) GetStage() string

func (ElasticSearchOpenPlugin) GetVersion 

func (ElasticSearchOpenPlugin) GetVersion() (int, int, int)

func (ElasticSearchOpenPlugin) Run 

func (plugin ElasticSearchOpenPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) (hasLeak bool)

Get info

type ElasticSearchResponse 

type ElasticSearchResponse struct {
	Hits struct {
		Hits []struct {
			Source json.RawMessage `json:"_source"`
		} `json:"hits"`
	} `json:"hits"`
}

type KafkaOpenPlugin 

type KafkaOpenPlugin struct {
	l9format.ServicePluginBase
}

func (KafkaOpenPlugin) GetName 

func (KafkaOpenPlugin) GetName() string

func (KafkaOpenPlugin) GetProtocols 

func (KafkaOpenPlugin) GetProtocols() []string

func (KafkaOpenPlugin) GetStage 

func (KafkaOpenPlugin) GetStage() string

func (KafkaOpenPlugin) GetVersion 

func (KafkaOpenPlugin) GetVersion() (int, int, int)

func (KafkaOpenPlugin) Run 

func (plugin KafkaOpenPlugin) Run(ctx context.Context, event *l9format.L9Event, pluginOptions map[string]string) (hasLeak bool)

Get info

type MongoCollectionDetails 

type MongoCollectionDetails struct {
	Count int64 `json:"count"`
	Size  int64 `json:"storageSize"`
}

type MongoOpenPlugin 

type MongoOpenPlugin struct {
	l9format.ServicePluginBase
}

func (MongoOpenPlugin) GetName 

func (MongoOpenPlugin) GetName() string

func (MongoOpenPlugin) GetProtocols 

func (MongoOpenPlugin) GetProtocols() []string

func (MongoOpenPlugin) GetStage 

func (MongoOpenPlugin) GetStage() string

func (MongoOpenPlugin) GetVersion 

func (MongoOpenPlugin) GetVersion() (int, int, int)

Implement interface :

func (MongoOpenPlugin) Run 

func (plugin MongoOpenPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) (hasLeak bool)

type MongoSchemaPlugin 

type MongoSchemaPlugin struct {
	l9format.ServicePluginBase
}

func (MongoSchemaPlugin) GetName 

func (MongoSchemaPlugin) GetName() string

func (MongoSchemaPlugin) GetProtocols 

func (MongoSchemaPlugin) GetProtocols() []string

func (MongoSchemaPlugin) GetStage 

func (MongoSchemaPlugin) GetStage() string

func (MongoSchemaPlugin) GetVersion 

func (MongoSchemaPlugin) GetVersion() (int, int, int)

func (MongoSchemaPlugin) Run 

func (plugin MongoSchemaPlugin) Run(ctx context.Context, event *l9format.L9Event, pluginOptions map[string]string) (hasLeak bool)

type MysqlSchemaPlugin 

type MysqlSchemaPlugin struct {
	l9format.ServicePluginBase
}

func (MysqlSchemaPlugin) GetName 

func (MysqlSchemaPlugin) GetName() string

func (MysqlSchemaPlugin) GetProtocols 

func (MysqlSchemaPlugin) GetProtocols() []string

func (MysqlSchemaPlugin) GetRansomNote 

func (MysqlSchemaPlugin) GetRansomNote(ctx context.Context, databaseName, tableName string, event *l9format.L9Event, db *sql.DB) (ransomNote string, found bool)

func (MysqlSchemaPlugin) GetStage 

func (MysqlSchemaPlugin) GetStage() string

func (MysqlSchemaPlugin) GetVersion 

func (MysqlSchemaPlugin) GetVersion() (int, int, int)

func (MysqlSchemaPlugin) RegisterMysql 

func (plugin MysqlSchemaPlugin) RegisterMysql()

TODO : Add Init() in the interface

func (MysqlSchemaPlugin) Run 

func (plugin MysqlSchemaPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) (hasLeak bool)

type MysqlWeakPlugin 

type MysqlWeakPlugin struct {
	l9format.ServicePluginBase
}

func (MysqlWeakPlugin) GetName 

func (MysqlWeakPlugin) GetName() string

func (MysqlWeakPlugin) GetProtocols 

func (MysqlWeakPlugin) GetProtocols() []string

func (MysqlWeakPlugin) GetStage 

func (MysqlWeakPlugin) GetStage() string

func (MysqlWeakPlugin) GetVersion 

func (MysqlWeakPlugin) GetVersion() (int, int, int)

func (MysqlWeakPlugin) RegisterMysql 

func (plugin MysqlWeakPlugin) RegisterMysql()

func (MysqlWeakPlugin) Run 

func (plugin MysqlWeakPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) bool

type RedisOpenPlugin 

type RedisOpenPlugin struct {
	l9format.ServicePluginBase
}

func (RedisOpenPlugin) GetName 

func (RedisOpenPlugin) GetName() string

func (RedisOpenPlugin) GetProtocols 

func (RedisOpenPlugin) GetProtocols() []string

func (RedisOpenPlugin) GetStage 

func (RedisOpenPlugin) GetStage() string

func (RedisOpenPlugin) GetVersion 

func (RedisOpenPlugin) GetVersion() (int, int, int)

func (RedisOpenPlugin) Run 

func (plugin RedisOpenPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) bool

type SSHOpenPlugin 

type SSHOpenPlugin struct {
	l9format.ServicePluginBase
}

func (SSHOpenPlugin) GetName 

func (SSHOpenPlugin) GetName() string

func (SSHOpenPlugin) GetProtocols 

func (SSHOpenPlugin) GetProtocols() []string

func (SSHOpenPlugin) GetStage 

func (SSHOpenPlugin) GetStage() string

func (SSHOpenPlugin) GetVersion 

func (SSHOpenPlugin) GetVersion() (int, int, int)

func (SSHOpenPlugin) Run 

func (plugin SSHOpenPlugin) Run(ctx context.Context, event *l9format.L9Event, options map[string]string) bool

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.