proccess

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
  • func (d *DockerContainer) AddContainerToCollectLog()
  • func (d *DockerContainer) CollectingLog(name string, container types.Container)
  • func (d *DockerContainer) DestroyContainerToCollectLog()
  • func (d *DockerContainer) FilterContainer(name string, container *types.Container) bool
  • func (d *DockerContainer) Handler()
  • func (d *DockerContainer) Print()
  • func (d *DockerContainer) ReadCurrentContainerList()
• type DockerEvent
  • func NewDockerEvent(api *DockerApi) *DockerEvent
  • func (d *DockerEvent) Handler()
• type LogInfo
• type WriterLog
  • func NewWriterLog(ctx context.Context) *WriterLog
  • func (w *WriterLog) CheckDB()
  • func (w *WriterLog) Connection() *mongo.Database
  • func (w *WriterLog) Handle(logOne *LogInfo)

Variables

var LogsChan = make(chan *LogInfo, 100000)

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 (*DockerContainer) FilterContainer

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)