Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

services

package

Go to main page

Versions in this module

v0

v0.0.2

Dec 13, 2019

Changes in this version

type Configuration

+ Router *Router

+ type Match struct

+ Exclude []MatchResource

+ Target []MatchResource

+ type MatchResource string

+ type Router struct

+ ProjectID string

v0.0.1

Dec 12, 2019

Changes in this version

+ var ErrParsing = errors.New("not a valid log")

+ var ErrSkipFinding = errors.New("unsupported finding")

+ var ErrUnmarshal = errors.New("failed to unmarshal")

+ var ErrUnsupportedFinding = errors.New("unsupported finding")

+ var ErrValueNotFound = errors.New("value not found")

+ func CreateAncestors(members []string) *cloudresourcemanager.GetAncestryResponse

+ func GeneratePassword() (string, error)

+ func SendTurbinia(ctx context.Context, turbiniaProjectID, topic, zone string, diskNames []string) error

+ type BigQuery struct

+ func InitBigQuery(ctx context.Context, projectID string) (*BigQuery, error)

+ func NewBigQuery(cs BigQueryClient) *BigQuery

+ func (bq *BigQuery) RemoveDatasetPublicAccess(ctx context.Context, projectID, datasetID string) error

+ type BigQueryClient interface

+ DatasetMetadata func(ctx context.Context, projectID, datasetID string) (*bigquery.DatasetMetadata, error)

+ OverwriteDatasetMetadata func(ctx context.Context, projectID, datasetID string, ...) (*bigquery.DatasetMetadata, error)

+ type CloseBucket struct

+ DryRun bool

+ Resources *Resources

+ type CloseCloudSQL struct

+ DryRun bool

+ Resources *Resources

+ type ClosePublicDataset struct

+ DryRun bool

+ Resources *Resources

+ type CloudSQL struct

+ func NewCloudSQL(cc CloudSQLClient) *CloudSQL

+ func (s *CloudSQL) ClosePublicAccess(ctx context.Context, projectID, instance string, acls []*sqladmin.AclEntry) error

+ func (s *CloudSQL) InstanceDetails(ctx context.Context, projectID string, instance string) (*sqladmin.DatabaseInstance, error)

+ func (s *CloudSQL) IsPublic(acls []*sqladmin.AclEntry) bool

+ func (s *CloudSQL) RequireSSL(ctx context.Context, projectID string, instance string) error

+ func (s *CloudSQL) UpdateUserPassword(ctx context.Context, projectID, instance, host, name, password string) error

+ type CloudSQLClient interface

+ InstanceDetails func(context.Context, string, string) (*sqladmin.DatabaseInstance, error)

+ PatchInstance func(context.Context, string, string, *sqladmin.DatabaseInstance) (*sqladmin.Operation, error)

+ UpdateUser func(context.Context, string, string, string, string, *sqladmin.User) (*sqladmin.Operation, error)

+ WaitSQL func(string, *sqladmin.Operation) []error

+ type CloudSQLRequireSSL struct

+ DryRun bool

+ Resources *Resources

+ type CommandCenter struct

+ func NewCommandCenter(cc CommandCenterClient) *CommandCenter

+ func (r *CommandCenter) AddSecurityMarks(ctx context.Context, serviceID string, securityMarks map[string]string) (*crm.SecurityMarks, error)

+ type CommandCenterClient interface

+ AddSecurityMarks func(context.Context, *crm.UpdateSecurityMarksRequest) (*crm.SecurityMarks, error)

+ type ComputeClient interface

+ CreateSnapshot func(context.Context, string, string, string, *compute.Snapshot) (*compute.Operation, error)

+ DeleteAccessConfig func(ctx context.Context, ...) (*compute.Operation, error)

+ DeleteDiskSnapshot func(context.Context, string, string) (*compute.Operation, error)

+ DeleteInstance func(context.Context, string, string, string) (*compute.Operation, error)

+ DiskInsert func(context.Context, string, string, *compute.Disk) (*compute.Operation, error)

+ GetInstance func(ctx context.Context, project, zone, instance string) (*compute.Instance, error)

+ ListDisks func(context.Context, string, string) (*compute.DiskList, error)

+ ListProjectSnapshots func(context.Context, string) (*compute.SnapshotList, error)

+ SetLabels func(context.Context, string, string, *compute.GlobalSetLabelsRequest) (*compute.Operation, error)

+ StartInstance func(context.Context, string, string, string) (*compute.Operation, error)

+ StopInstance func(context.Context, string, string, string) (*compute.Operation, error)

+ WaitGlobal func(string, *compute.Operation) []error

+ WaitZone func(string, string, *compute.Operation) []error

+ type Configuration struct

+ CloseBucket *CloseBucket

+ CloseCloudSQL *CloseCloudSQL

+ ClosePublicDataset *ClosePublicDataset

+ CloudSQLRequireSSL *CloudSQLRequireSSL

+ CreateSnapshot *CreateSnapshot

+ DisableDashboard *DisableDashboard

+ DisableFirewall *DisableFirewall

+ EnableAuditLogs *EnableAuditLogs

+ EnableBucketOnlyPolicy *EnableBucketOnlyPolicy

+ PagerDuty *PagerDutyConfiguration

+ RemoveNonOrgMembers *RemoveNonOrgMembers

+ RemovePublicIP *RemovePublicIP

+ RevokeGrants *RevokeGrants

+ UpdatePassword *UpdatePassword

+ func NewConfiguration(file string) (*Configuration, error)

+ type Container struct

+ func NewContainer(client ContainerClient) *Container

+ func (c *Container) DisableDashboard(ctx context.Context, projectID, zone, clusterID string) (*container.Operation, error)

+ type ContainerClient interface

+ UpdateAddonsConfig func(context.Context, string, string, string, *container.SetAddonsConfigRequest) (*container.Operation, error)

+ type CreateSnapshot struct

+ DryRun bool

+ OutputDestinations []string

+ TargetSnapshotProjectID string

+ TargetSnapshotZone string

+ TurbiniaProjectID string

+ TurbiniaTopicName string

+ TurbiniaZone string

+ type DisableDashboard struct

+ DryRun bool

+ Resources *Resources

+ type DisableFirewall struct

+ DryRun bool

+ OutputDestinations []string

+ RemediationAction string

+ Resources *Resources

+ SourceRanges []string

+ type Email struct

+ func NewEmail(service EmailClient) *Email

+ func (m *Email) RenderTemplate(templateName string, templateContent interface{}) (string, error)

+ func (m *Email) Send(subject, from, body string, to []string) (*rest.Response, error)

+ type EmailClient interface

+ Send func(subject, from, body string, to []string) (*rest.Response, error)

+ type EmailResponse struct

+ Body string

+ StatusCode int

+ type EnableAuditLogs struct

+ DryRun bool

+ Resources *Resources

+ type EnableBucketOnlyPolicy struct

+ DryRun bool

+ Resources *Resources

+ type Firewall struct

+ func NewFirewall(client FirewallClient) *Firewall

+ func (f *Firewall) BlockSSH(ctx context.Context, projectID string, sourceRanges []string) error

+ func (f *Firewall) DeleteFirewallRule(ctx context.Context, projectID string, ruleID string) (*compute.Operation, error)

+ func (f *Firewall) DisableFirewallRule(ctx context.Context, projectID string, ruleID string, name string) (*compute.Operation, error)

+ func (f *Firewall) EnableFirewallRule(ctx context.Context, projectID string, ruleID string, name string) (*compute.Operation, error)

+ func (f *Firewall) FirewallRule(ctx context.Context, projectID string, ruleID string) (*compute.Firewall, error)

+ func (f *Firewall) UpdateFirewallRuleSourceRange(ctx context.Context, projectID string, ruleID string, name string, ...) error

+ func (f *Firewall) WaitGlobal(project string, op *compute.Operation) []error

+ type FirewallClient interface

+ DeleteFirewallRule func(context.Context, string, string) (*compute.Operation, error)

+ FirewallRule func(context.Context, string, string) (*compute.Firewall, error)

+ InsertFirewallRule func(context.Context, string, *compute.Firewall) (*compute.Operation, error)

+ PatchFirewallRule func(context.Context, string, string, *compute.Firewall) (*compute.Operation, error)

+ WaitGlobal func(string, *compute.Operation) []error

+ type Global struct

+ CloudSQL *CloudSQL

+ Configuration *Configuration

+ Container *Container

+ Firewall *Firewall

+ Host *Host

+ Logger *Logger

+ Resource *Resource

+ func New(ctx context.Context) (*Global, error)

+ type GoogleCloudDisk struct

+ DiskName string

+ Project string

+ Zone string

+ type Host struct

+ func NewHost(cs ComputeClient) *Host

+ func (h *Host) CopyDiskSnapshot(ctx context.Context, srcProjectID, dstProjectID, zone, name string) error

+ func (h *Host) CreateDiskSnapshot(ctx context.Context, projectID, zone, disk, name string) error

+ func (h *Host) DeleteDiskSnapshot(ctx context.Context, projectID, snapshot string) error

+ func (h *Host) DeleteInstance(ctx context.Context, projectID, zone, instance string) (*compute.Operation, error)

+ func (h *Host) DiskSnapshot(ctx context.Context, snapshotName, projectID string, disk *compute.Disk) (*compute.Snapshot, error)

+ func (h *Host) ListInstanceDisks(ctx context.Context, projectID, zone, instance string) ([]*compute.Disk, error)

+ func (h *Host) ListProjectSnapshots(ctx context.Context, projectID string) (*compute.SnapshotList, error)

+ func (h *Host) RemoveExternalIPs(ctx context.Context, project, zone, instance string) error

+ func (h *Host) SetSnapshotLabels(ctx context.Context, projectID, snapshotName string, disk *compute.Disk, ...) error

+ func (h *Host) StartInstance(ctx context.Context, projectID, zone, instance string) error

+ func (h *Host) StopInstance(ctx context.Context, projectID, zone, instance string) error

+ func (h *Host) WaitGlobal(project string, op *compute.Operation) []error

+ func (h *Host) WaitZone(project, zone string, op *compute.Operation) []error

+ type Logger struct

+ func NewLogger(l LoggerClient) *Logger

+ func (l *Logger) Close()

+ func (l *Logger) Debug(message string, a ...interface{})

+ func (l *Logger) Error(message string, a ...interface{})

+ func (l *Logger) Info(message string, a ...interface{})

+ func (l *Logger) Warning(message string, a ...interface{})

+ type LoggerClient interface

+ Close func()

+ Debug func(message string, a ...interface{})

+ Error func(message string, a ...interface{})

+ Info func(message string, a ...interface{})

+ Warning func(message string, a ...interface{})

+ type PagerDuty struct

+ func InitPagerDuty(apiKey string) *PagerDuty

+ func NewPagerDuty(cs PagerDutyClient) *PagerDuty

+ func (p *PagerDuty) CreateIncident(ctx context.Context, from, serviceID, title, body string) error

+ type PagerDutyClient interface

+ CreateIncident func(from, serviceID, title, body string) (*pagerduty.Incident, error)

+ type PagerDutyConfiguration struct

+ APIKey string

+ Enabled bool

+ From string

+ ServiceID string

+ type PubSub struct

+ func InitPubSub(ctx context.Context, projectID string) (*PubSub, error)

+ func NewPubSub(client PubSubClient) *PubSub

+ func (e *PubSub) Publish(ctx context.Context, topicID string, message *pubsub.Message) (string, error)

+ type PubSubClient interface

+ Publish func(context.Context, *pubsub.Topic, *pubsub.Message) (string, error)

+ Topic func(string) *pubsub.Topic

+ type RemoveNonOrgMembers struct

+ AllowDomains []string

+ DryRun bool

+ Resources *Resources

+ type RemovePublicIP struct

+ DryRun bool

+ Resources *Resources

+ type Resource struct

+ func NewResource(crm crmClient, s storageClient) *Resource

+ func (r *Resource) CheckMatches(ctx context.Context, project string, target, ignore []string) (bool, error)

+ func (r *Resource) EnableAuditLogs(ctx context.Context, projectID string) (*crm.Policy, error)

+ func (r *Resource) EnableBucketOnlyPolicy(ctx context.Context, bucketName string) error

+ func (r *Resource) GetProjectAncestry(ctx context.Context, projectID string) ([]string, error)

+ func (r *Resource) IfProjectInFolders(ctx context.Context, ids []string, projectID string, fn func() error) error

+ func (r *Resource) IfProjectInOrg(ctx context.Context, orgID, projectID string, fn func() error) error

+ func (r *Resource) IfProjectInProjects(ctx context.Context, ids []string, projectID string, fn func() error) error

+ func (r *Resource) IfProjectWithinResources(ctx context.Context, conf *Resources, projectID string, fn func() error) error

+ func (r *Resource) Organization(ctx context.Context, orgID string) (*crm.Organization, error)

+ func (r *Resource) OrganizationOnlyKeepUsersFromDomains(ctx context.Context, orgID string, allowDomains []string) ([]string, error)

+ func (r *Resource) PolicyOrganization(ctx context.Context, name string) (*crm.Policy, error)

+ func (r *Resource) ProjectOnlyKeepUsersFromDomains(ctx context.Context, projectID string, allowDomains []string) ([]string, error)

+ func (r *Resource) RemoveMembersFromBucket(ctx context.Context, bucketName string, members []string) error

+ func (r *Resource) RemoveUsersProject(ctx context.Context, projectID string, remove []string) error

+ type Resources struct

+ FolderIDs []string

+ OrganizationID string

+ ProjectIDs []string

+ type RevokeGrants struct

+ AllowDomains []string

+ DryRun bool

+ Resources *Resources

+ type StackDriverLog struct

+ InsertID string

+ LogName string

+ type TurbiniaRequest struct

+ Evidence []GoogleCloudDisk

+ RequestID string

+ Type string

+ type UpdatePassword struct

+ DryRun bool

+ Resources *Resources