tcp

package
v1.0.0-beta.1 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

func New 

func New() l9format.ServicePluginInterface

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) 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) 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.