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

shuttle

package

Go to main page

Versions in this module

v1

v1.0.5

Oct 7, 2020

Changes in this version

type CommonProperties

+ TimeToFirstDownstreamTxByte *Duration

+ TimeToFirstUpstreamRxByte *Duration

+ TimeToFirstUpstreamTxByte *Duration

+ TimeToLastDownstreamTxByte *Duration

+ TimeToLastUpstreamRxByte *Duration

+ type Duration struct

+ func (d *Duration) StringMilliseconds() string

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d Duration) MarshalJSON() ([]byte, error)

v1.0.4

Sep 9, 2020

v1.0.3

Aug 13, 2020

Changes in this version

+ func ParseIstioFromEnvoyWebLogMessage(data []byte, msg *events.LogSpec) bool

+ func StringToIntOrZero(target *string) int

+ type CommonProperties struct

+ ResponseFlags *ResponseFlags

+ StartTime *time.Time

+ TLSProperties *TLSProperties

+ TimeToLastRxByte *string

+ TimeToLastUpstreamTxByte *string

+ UpstreamCluster string

+ type EnvoyAlsServer struct

+ func (s *EnvoyAlsServer) Close()

+ func (s *EnvoyAlsServer) StartEnvoyALSAdapter(port int, producer events.LogProducer)

+ func (s *EnvoyAlsServer) StreamAccessLogs(stream v2.AccessLogService_StreamAccessLogsServer) error

+ type Request struct

+ Authority string

+ ForwardedFor string

+ OriginalPath string

+ Path string

+ RequestBodyBytes *string

+ RequestHeadersBytes string

+ RequestId string

+ RequestMethod string

+ UserAgent string

+ type Response struct

+ ResponseBodyBytes *string

+ ResponseCode *uint32

+ ResponseHeadersBytes string

+ type ResponseFlags struct

+ DelayInjected bool

+ DownstreamConnectionTermination bool

+ DownstreamProtocolError bool

+ FailedLocalHealthcheck bool

+ FaultInjected bool

+ InvalidEnvoyRequestHeaders bool

+ LocalReset bool

+ NoHealthyUpstream bool

+ NoRouteFound bool

+ RateLimitServiceError bool

+ RateLimited bool

+ StreamIdleTimeout bool

+ UpstreamConnectionFailure bool

+ UpstreamConnectionTermination bool

+ UpstreamOverflow bool

+ UpstreamRemoteReset bool

+ UpstreamRequestTimeout bool

+ UpstreamRetryLimitExceeded bool

type Session

+ func (ls *Session) RespondWithIstioWebLogFromEnvoyAls(e *kafka.Message) error

+ type TLSProperties struct

+ TLSSNIHostname *string

+ TLSVersion *string

v1.0.2

Mar 10, 2020

v1.0.1

Sep 4, 2019

Changes in this version

+ func ContainerToProc(container string) events.Process

+ func IsAppMatch(potential string, app_name string) bool

+ func KubernetesToHumanReadable(message string) string

+ func ParseBuildLogMessage(data []byte, msg *events.LogSpec) bool

+ func ParseIstioWebLogMessage(data []byte, msg *events.LogSpec) bool

+ func ParseWebLogMessage(data []byte, msg *events.LogSpec) bool

+ func RandomString(n int) string

+ func WriteAndFlush(log string, res http.ResponseWriter) error

+ type Destination struct

+ type Session struct

+ IsOpen bool

+ func (ls *Session) ConsumeAndRespond(kafkaAddrs []string, app string, space string, site string, req *http.Request, ...)

+ func (ls *Session) RespondWithAppLog(e *kafka.Message) error

+ func (ls *Session) RespondWithBuildLog(e *kafka.Message) error

+ func (ls *Session) RespondWithIstioWebLog(e *kafka.Message) error

+ func (ls *Session) RespondWithWebLog(e *kafka.Message) error

+ type Shuttle struct

+ func (sh *Shuttle) Close()

+ func (sh *Shuttle) EnableTestMode()

+ func (sh *Shuttle) Init(client *storage.Storage, kafkaAddrs []string, kafkaGroup string) error

+ func (sh *Shuttle) PrintMetrics()

+ func (sh *Shuttle) Refresh()

+ func (sh *Shuttle) RefreshRoutes()

+ func (sh *Shuttle) RefreshTopics()

+ func (sh *Shuttle) SendMessage(message events.LogSpec)