Documentation
¶
Index ¶
- 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 ParseIstioFromEnvoyWebLogMessage(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 StringToIntOrZero(target *string) int
- func WriteAndFlush(log string, res http.ResponseWriter) error
- type CommonProperties
- type Destination
- type Duration
- type EnvoyAlsServer
- type Request
- type Response
- type ResponseFlags
- type Session
- 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) RespondWithIstioWebLogFromEnvoyAls(e *kafka.Message) error
- func (ls *Session) RespondWithWebLog(e *kafka.Message) error
- type Shuttle
- 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)
- type TLSProperties
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ContainerToProc ¶
func IsAppMatch ¶
func ParseIstioFromEnvoyWebLogMessage ¶ added in v1.0.3
func RandomString ¶
func StringToIntOrZero ¶ added in v1.0.3
func WriteAndFlush ¶
func WriteAndFlush(log string, res http.ResponseWriter) error
Types ¶
type CommonProperties ¶ added in v1.0.3
type CommonProperties struct {
StartTime *time.Time `json:"start_time"`
TimeToLastRxByte *Duration `json:"time_to_last_rx_byte"`
TimeToFirstUpstreamTxByte *Duration `json:"time_to_first_upstream_tx_byte"`
TimeToLastUpstreamTxByte *Duration `json:"time_to_last_upstream_tx_byte"`
TimeToFirstUpstreamRxByte *Duration `json:"time_to_first_upstream_rx_byte"`
TimeToLastUpstreamRxByte *Duration `json:"time_to_last_upstream_rx_byte"`
TimeToFirstDownstreamTxByte *Duration `json:"time_to_first_downstream_tx_byte"`
TimeToLastDownstreamTxByte *Duration `json:"time_to_last_downstream_tx_byte"`
UpstreamCluster string `json:"upstream_cluster"`
ResponseFlags *ResponseFlags `json:"response_flags,omitempty"`
TLSProperties *TLSProperties `json:"tls_properties,omitempty"`
}
type Destination ¶
type Destination struct {
// contains filtered or unexported fields
}
type Duration ¶ added in v1.0.5
func (Duration) MarshalJSON ¶ added in v1.0.5
func (*Duration) StringMilliseconds ¶ added in v1.0.5
func (*Duration) UnmarshalJSON ¶ added in v1.0.5
type EnvoyAlsServer ¶ added in v1.0.3
type EnvoyAlsServer struct {
// contains filtered or unexported fields
}
func (*EnvoyAlsServer) Close ¶ added in v1.0.3
func (s *EnvoyAlsServer) Close()
func (*EnvoyAlsServer) StartEnvoyALSAdapter ¶ added in v1.0.3
func (s *EnvoyAlsServer) StartEnvoyALSAdapter(port int, producer events.LogProducer)
func (*EnvoyAlsServer) StreamAccessLogs ¶ added in v1.0.3
func (s *EnvoyAlsServer) StreamAccessLogs(stream v2.AccessLogService_StreamAccessLogsServer) error
type Request ¶ added in v1.0.3
type Request struct {
RequestMethod string `json:"request_method"`
Authority string `json:"authority"`
Path string `json:"path"`
UserAgent string `json:"user_agent"`
ForwardedFor string `json:"forwarded_for"`
RequestId string `json:"request_id"`
OriginalPath string `json:"original_path,omitempty"`
RequestHeadersBytes string `json:"request_headers_bytes"`
RequestBodyBytes *string `json:"request_body_bytes,omitempty"`
}
type ResponseFlags ¶ added in v1.0.3
type ResponseFlags struct {
FailedLocalHealthcheck bool `json:"failed_local_healthcheck,omitempty"`
NoHealthyUpstream bool `json:"no_healthy_upstream,omitempty"`
UpstreamRequestTimeout bool `json:"upstream_request_timeout,omitempty"`
LocalReset bool `json:"local_reset,omitempty"`
UpstreamRemoteReset bool `json:"upstream_remote_reset,omitempty"`
UpstreamConnectionFailure bool `json:"upstream_connection_failure,omitempty"`
UpstreamConnectionTermination bool `json:"upstream_connection_termination,omitempty"`
UpstreamOverflow bool `json:"upstream_overflow,omitempty"`
NoRouteFound bool `json:"no_route_found,omitempty"`
DelayInjected bool `json:"delay_injected,omitempty"`
FaultInjected bool `json:"fault_injected,omitempty"`
RateLimited bool `json:"rate_limited,omitempty"`
RateLimitServiceError bool `json:"rate_limit_service_error,omitempty"`
DownstreamConnectionTermination bool `json:"downstream_connection_termination,omitempty"`
UpstreamRetryLimitExceeded bool `json:"upstream_retry_limit_exceeded,omitempty"`
StreamIdleTimeout bool `json:"stream_idle_timeout,omitempty"`
InvalidEnvoyRequestHeaders bool `json:"invalid_envoy_request_headers,omitempty"`
DownstreamProtocolError bool `json:"downstream_protocol_error,omitempty"`
}
type Session ¶
type Session struct {
IsOpen bool
// contains filtered or unexported fields
}
func (*Session) ConsumeAndRespond ¶
func (*Session) RespondWithBuildLog ¶
func (*Session) RespondWithIstioWebLog ¶
func (*Session) RespondWithIstioWebLogFromEnvoyAls ¶ added in v1.0.3
type Shuttle ¶
type Shuttle struct {
// contains filtered or unexported fields
}
func (*Shuttle) EnableTestMode ¶
func (sh *Shuttle) EnableTestMode()
func (*Shuttle) PrintMetrics ¶
func (sh *Shuttle) PrintMetrics()
func (*Shuttle) RefreshRoutes ¶
func (sh *Shuttle) RefreshRoutes()
func (*Shuttle) RefreshTopics ¶
func (sh *Shuttle) RefreshTopics()
func (*Shuttle) SendMessage ¶
type TLSProperties ¶ added in v1.0.3
Click to show internal directories.
Click to hide internal directories.