proccess

package

v0.0.0-...-58584ba Latest Latest Go to latest Published: Mar 22, 2023 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/melodywen/docker-trace-log

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ProcessLoad(ctx context.Context) error
type CollectingLogContainer
type DockerApi
- func NewDockerApi(ctx context.Context) *DockerApi
- func (d *DockerApi) CloseCli() error
- func (d *DockerApi) LoadCli()
type DockerContainer
- func NewDockerContainer(dockerApi *DockerApi) *DockerContainer
type DockerEvent
- func NewDockerEvent(api *DockerApi) *DockerEvent
- func (d *DockerEvent) Handler()
type LogInfo
type WriterLog
- func NewWriterLog(ctx context.Context) *WriterLog

Constants ¶

This section is empty.

Variables ¶

View Source

var LogsChan = make(chan *LogInfo, 100000)

View Source

var ReLoadContainerInfo = make(chan bool, 3)

Functions ¶

func ProcessLoad ¶

func ProcessLoad(ctx context.Context) error

ProcessLoad 加载进程

@return error

Types ¶

type CollectingLogContainer ¶

type CollectingLogContainer struct {
	Container       types.Container
	Ctx             context.Context
	Cancel          context.CancelFunc
	Regexp          string // 正则表达式
	RegexpDirection string // 正则的方向
}

type DockerApi ¶

type DockerApi struct {
	Ctx  context.Context
	Path string
	Cli  *client.Client
}

func NewDockerApi ¶

func NewDockerApi(ctx context.Context) *DockerApi

func (*DockerApi) CloseCli ¶

func (d *DockerApi) CloseCli() error

func (*DockerApi) LoadCli ¶

func (d *DockerApi) LoadCli()

type DockerContainer ¶

type DockerContainer struct {
	*DockerApi
	CurrentContainer          map[string]types.Container
	CollectingLogContainerMap map[string]*CollectingLogContainer
	IsChange                  bool
}

func NewDockerContainer ¶

func NewDockerContainer(dockerApi *DockerApi) *DockerContainer

func (*DockerContainer) AddContainerToCollectLog ¶

func (d *DockerContainer) AddContainerToCollectLog()

AddContainerToCollectLog 添加容器进行收集

func (*DockerContainer) CollectingLog ¶

func (d *DockerContainer) CollectingLog(name string, container types.Container)

CollectingLog 收集日志

@param name
@param container

func (*DockerContainer) DestroyContainerToCollectLog ¶

func (d *DockerContainer) DestroyContainerToCollectLog()

DestroyContainerToCollectLog 移除停掉的日志

func (d *DockerContainer) FilterContainer(name string, container *types.Container) bool

FilterContainer

@param name
@param container
@return bool

func (*DockerContainer) Handler ¶

func (d *DockerContainer) Handler()

func (*DockerContainer) Print ¶

func (d *DockerContainer) Print()

Print 打印日志

func (*DockerContainer) ReadCurrentContainerList ¶

func (d *DockerContainer) ReadCurrentContainerList()

ReadCurrentContainerList 读取当前日志列表

type DockerEvent ¶

type DockerEvent struct {
	*DockerApi
}

func NewDockerEvent ¶

func NewDockerEvent(api *DockerApi) *DockerEvent

NewDockerEvent

@param dockerApi
@return *DockerEvent

func (*DockerEvent) Handler ¶

func (d *DockerEvent) Handler()

Handler 处理函数

type LogInfo ¶

type LogInfo struct {
	StackName     string
	ServiceName   string
	ContainerName string
	LogTime       string
	Origin        string
	Index         string
}

type WriterLog ¶

type WriterLog struct {
	Ctx       context.Context
	Timeout   time.Duration
	MaxNumber int

	Database *mongo.Database
}

func NewWriterLog ¶

func NewWriterLog(ctx context.Context) *WriterLog

func (*WriterLog) CheckDB ¶

func (w *WriterLog) CheckDB()

func (*WriterLog) Connection ¶

func (w *WriterLog) Connection() *mongo.Database

func (*WriterLog) Handle ¶

func (w *WriterLog) Handle(logOne *LogInfo)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL