Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

gcp

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 6, 2022

Changes in this version

+ var ProjectID = flag.String("gcp.project", "", "Google ProjectID to listen for flows on")

+ var SampleRate = flag.Float64("gcp.sample", 1, "Sample rate of the vpc export (as defined in the VPC setup)")

+ var SourceSub = flag.String("gcp.sub", "", "Google Sub to listen for flows on")

v1.0.0-rc23

Jun 24, 2022

v0

v0.1.2

Sep 15, 2023

v0.1.1

Sep 15, 2023

v0.0.3

Sep 21, 2023

Changes in this version

+ const GCP_VPC_TYPE

+ const RECV_WINDOW

+ var ERROR_SLEEP_TIME = 20 * time.Second

+ type Connection struct

+ DestIP string

+ DestPort int

+ Protocol int

+ SrcIP string

+ SrcPort int

+ func (c *Connection) Save(in *kt.JCHF)

+ type GCELogLine struct

+ BytesRaw int64

+ InsertID string

+ LogName string

+ Payload *Payload

+ RecvTs time.Time

+ Resource *Resource

+ Timestamp time.Time

+ func (m *GCELogLine) GetVMName() (host string, err error)

+ func (m *GCELogLine) IsIn() bool

+ func (m *GCELogLine) IsInternal() bool

+ func (m *GCELogLine) IsValid() bool

+ func (m *GCELogLine) ToFlow(log logger.ContextL, flowSample uint32) (in *kt.JCHF, err error)

+ func (m *GCELogLine) ToJson() []byte

+ type GcpMetric struct

+ FlowsIn go_metrics.Meter

+ RateError go_metrics.Meter

+ RateInvalid go_metrics.Meter

+ type GcpVpc struct

+ func NewVpc(ctx context.Context, log logger.Underlying, registry go_metrics.Registry, ...) (*GcpVpc, error)

+ func (vpc *GcpVpc) Close()

+ func (vpc *GcpVpc) HttpInfo() map[string]float64

+ type Instance struct

+ ProjectID string

+ Region string

+ VMName string

+ Zone string

+ func (i *Instance) Save(in *kt.JCHF, direction string)

+ type Label struct

+ Location string

+ ProjectID string

+ SubnetworkID string

+ SubnetworkName string

+ func (l *Label) Save(in *kt.JCHF)

+ type Location struct

+ City string

+ Continent string

+ Country string

+ Region string

+ func (l *Location) Save(in *kt.JCHF, direction string)

+ type Payload struct

+ Bytes string

+ Connection *Connection

+ DestInstance *Instance

+ DestVPC *VPC

+ DstLocation *Location

+ EndTime time.Time

+ Pkts string

+ RTT string

+ Reporter string

+ SrcInstance *Instance

+ SrcLocation *Location

+ SrcVPC *VPC

+ StartTime time.Time

+ func (p *Payload) Save(in *kt.JCHF)

+ type Resource struct

+ Labels *Label

+ Type string

+ func (r *Resource) Save(in *kt.JCHF)

+ type VPC struct

+ Name string

+ ProjectID string

+ SubnetworkName string

+ func (v *VPC) Save(in *kt.JCHF, direction string)