Documentation
¶
Index ¶
- type AuthConfig
- type Config
- type MonitoredResource
- type Plugin
- func (p *Plugin) Config() any
- func (p *Plugin) Handler(next http.Handler) http.Handler
- func (p *Plugin) Init() error
- func (p *Plugin) PostInit() error
- func (p *Plugin) RunLogPhase(snapshot base.LogSnapshot) error
- func (p *Plugin) Send(log map[string]any)
- func (p *Plugin) SendBatch(ctx context.Context, entries []map[string]any, _ int) (int, error)
- func (p *Plugin) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthConfig ¶
type AuthConfig struct {
ClientEmail string `json:"client_email"`
PrivateKey string `json:"private_key"`
ProjectID string `json:"project_id"`
TokenURI string `json:"token_uri"`
Scope []string `json:"scope,omitempty"`
Scopes []string `json:"scopes,omitempty"`
EntriesURI string `json:"entries_uri,omitempty"`
}
type Config ¶
type Config struct {
AuthConfig *AuthConfig `json:"auth_config,omitempty"`
AuthFile string `json:"auth_file,omitempty"`
SSLVerify *bool `json:"ssl_verify,omitempty"`
Resource MonitoredResource `json:"resource"`
LogID string `json:"log_id,omitempty"`
LogFormat map[string]string `json:"log_format,omitempty"`
BatchMaxSize int `json:"batch_max_size,omitempty"`
InactiveTimeout int `json:"inactive_timeout,omitempty"`
BufferDuration int `json:"buffer_duration,omitempty"`
RetryDelay int `json:"retry_delay,omitempty"`
MaxRetryCount int `json:"max_retry_count,omitempty"`
MaxPendingEntries int `json:"max_pending_entries,omitempty"`
}
type MonitoredResource ¶
type Plugin ¶
type Plugin struct {
base.BaseLoggerPlugin
// contains filtered or unexported fields
}
func (*Plugin) RunLogPhase ¶
func (p *Plugin) RunLogPhase(snapshot base.LogSnapshot) error
Click to show internal directories.
Click to hide internal directories.