1
0
Fork 0
mirror of https://github.com/moby/moby.git synced 2022-11-09 12:21:53 -05:00

Optimize the function 'Context.Name()' and replace 'Context.ContainerName' that need to remove slash with 'Context.Name()'.

Signed-off-by: Yanqiang Miao <miao.yanqiang@zte.com.cn>

update

Signed-off-by: Yanqiang Miao <miao.yanqiang@zte.com.cn>

update

Signed-off-by: Yanqiang Miao <miao.yanqiang@zte.com.cn>
This commit is contained in:
Yanqiang Miao 2016-11-23 22:43:50 +08:00
parent 32229914c7
commit 52fd6e4664
4 changed files with 4 additions and 22 deletions

View file

@ -92,7 +92,7 @@ func (ctx *Context) FullID() string {
// Name returns the ContainerName without a preceding '/'. // Name returns the ContainerName without a preceding '/'.
func (ctx *Context) Name() string { func (ctx *Context) Name() string {
return ctx.ContainerName[1:] return strings.TrimPrefix(ctx.ContainerName, "/")
} }
// ImageID returns the ContainerImageID shortened to 12 characters. // ImageID returns the ContainerImageID shortened to 12 characters.

View file

@ -61,7 +61,7 @@ func New(ctx logger.Context) (logger.Logger, error) {
logrus.Debugf("logging driver etwLogs configured for container: %s.", ctx.ContainerID) logrus.Debugf("logging driver etwLogs configured for container: %s.", ctx.ContainerID)
return &etwLogs{ return &etwLogs{
containerName: fixContainerName(ctx.ContainerName), containerName: ctx.Name(),
imageName: ctx.ContainerImageName, imageName: ctx.ContainerImageName,
containerID: ctx.ContainerID, containerID: ctx.ContainerID,
imageID: ctx.ContainerImageID, imageID: ctx.ContainerImageID,
@ -99,14 +99,6 @@ func createLogMessage(etwLogger *etwLogs, msg *logger.Message) string {
msg.Line) msg.Line)
} }
// fixContainerName removes the initial '/' from the container name.
func fixContainerName(cntName string) string {
if len(cntName) > 0 && cntName[0] == '/' {
cntName = cntName[1:]
}
return cntName
}
func registerETWProvider() error { func registerETWProvider() error {
mu.Lock() mu.Lock()
defer mu.Unlock() defer mu.Unlock()

View file

@ -5,7 +5,6 @@
package gelf package gelf
import ( import (
"bytes"
"compress/flate" "compress/flate"
"encoding/json" "encoding/json"
"fmt" "fmt"
@ -54,9 +53,6 @@ func New(ctx logger.Context) (logger.Logger, error) {
return nil, fmt.Errorf("gelf: cannot access hostname to set source field") return nil, fmt.Errorf("gelf: cannot access hostname to set source field")
} }
// remove trailing slash from container name
containerName := bytes.TrimLeft([]byte(ctx.ContainerName), "/")
// parse log tag // parse log tag
tag, err := loggerutils.ParseLogTag(ctx, loggerutils.DefaultTemplate) tag, err := loggerutils.ParseLogTag(ctx, loggerutils.DefaultTemplate)
if err != nil { if err != nil {
@ -65,7 +61,7 @@ func New(ctx logger.Context) (logger.Logger, error) {
extra := map[string]interface{}{ extra := map[string]interface{}{
"_container_id": ctx.ContainerID, "_container_id": ctx.ContainerID,
"_container_name": string(containerName), "_container_name": ctx.Name(),
"_image_id": ctx.ContainerImageID, "_image_id": ctx.ContainerImageID,
"_image_name": ctx.ContainerImageName, "_image_name": ctx.ContainerImageName,
"_command": ctx.Command(), "_command": ctx.Command(),

View file

@ -62,12 +62,6 @@ func New(ctx logger.Context) (logger.Logger, error) {
if !journal.Enabled() { if !journal.Enabled() {
return nil, fmt.Errorf("journald is not enabled on this host") return nil, fmt.Errorf("journald is not enabled on this host")
} }
// Strip a leading slash so that people can search for
// CONTAINER_NAME=foo rather than CONTAINER_NAME=/foo.
name := ctx.ContainerName
if name[0] == '/' {
name = name[1:]
}
// parse log tag // parse log tag
tag, err := loggerutils.ParseLogTag(ctx, loggerutils.DefaultTemplate) tag, err := loggerutils.ParseLogTag(ctx, loggerutils.DefaultTemplate)
@ -78,7 +72,7 @@ func New(ctx logger.Context) (logger.Logger, error) {
vars := map[string]string{ vars := map[string]string{
"CONTAINER_ID": ctx.ContainerID[:12], "CONTAINER_ID": ctx.ContainerID[:12],
"CONTAINER_ID_FULL": ctx.ContainerID, "CONTAINER_ID_FULL": ctx.ContainerID,
"CONTAINER_NAME": name, "CONTAINER_NAME": ctx.Name(),
"CONTAINER_TAG": tag, "CONTAINER_TAG": tag,
} }
extraAttrs := ctx.ExtraAttributes(sanitizeKeyMod) extraAttrs := ctx.ExtraAttributes(sanitizeKeyMod)