gcplogtarget

type GCPLogEntry struct {
	// why was this here?? nolint:revive
	LogName  string `json:"logName"`
	Resource struct {
		Type   string            `json:"type"`
		Labels map[string]string `json:"labels"`
	} `json:"resource"`
	Timestamp string `json:"timestamp"`

	// The time the log entry was received by Logging.
	// Its important that `Timestamp` is optional in GCE log entry.
	ReceiveTimestamp string `json:"receiveTimestamp"`

	// Optional. The severity of the log entry. The default value is DEFAULT.
	// DEFAULT, DEBUG, INFO, NOTICE, WARNING, ERROR, CRITICAL, ALERT, EMERGENCY
	// https://cloud.google.com/logging/docs/reference/v2/rest/v2/LogEntry#LogSeverity
	Severity string `json:"severity"`

	// Optional. A map of key, value pairs that provides additional information about the log entry.
	// The labels can be user-defined or system-defined.
	Labels map[string]string `json:"labels"`

	TextPayload string `json:"textPayload"`
}

type Metrics struct {
	// contains filtered or unexported fields
}

type PullConfig struct {
	ProjectID            string            `river:"project_id,attr"`
	Subscription         string            `river:"subscription,attr"`
	Labels               map[string]string `river:"labels,attr,optional"`
	UseIncomingTimestamp bool              `river:"use_incoming_timestamp,attr,optional"`
	UseFullLine          bool              `river:"use_full_line,attr,optional"`
}

type PullTarget struct {
	// contains filtered or unexported fields
}

type PushConfig struct {
	Server               *fnet.ServerConfig `river:",squash"`
	PushTimeout          time.Duration      `river:"push_timeout,attr,optional"`
	Labels               map[string]string  `river:"labels,attr,optional"`
	UseIncomingTimestamp bool               `river:"use_incoming_timestamp,attr,optional"`
	UseFullLine          bool               `river:"use_full_line,attr,optional"`
}

type PushMessage struct {
	Message struct {
		Attributes       map[string]string `json:"attributes"`
		Data             string            `json:"data"`
		ID               string            `json:"message_id"`
		PublishTimestamp string            `json:"publish_time"`
	} `json:"message"`
	Subscription string `json:"subscription"`
}

type PushTarget struct {
	// contains filtered or unexported fields
}

type Target interface {
	Details() map[string]string
	Stop() error
}