route

Documentation

Index

• func NewEcho(socket *socket.WebSocket, core *CoreApi, config *config.Config, ...) *echo.Echo
• type CoreApi
  • func NewCore(config *config.Config, storage storage.StorageApi, ...) (*CoreApi, error)
  • func (c *CoreApi) CleanFile() error
  • func (c *CoreApi) CleanFileBySize() error
  • func (c *CoreApi) CleanFileByTime() error
  • func (c *CoreApi) CreateFile(file *storage.LogFile) (*storage.LogFile, error)
  • func (c *CoreApi) CreateFileId(md5 string) string
  • func (c *CoreApi) CreateLogGroupFile(file *storage.LogGroupFile) (*storage.LogGroupFile, error)
  • func (c *CoreApi) DeleteFile(fileId string) error
  • func (c *CoreApi) DeleteLogGroup(groupId string) error
  • func (c *CoreApi) GetFile(fileId string) (*storage.LogFile, error)
  • func (c *CoreApi) GetFileList(query *data.FileListQuery) (*data.Page[*data.LogData], error)
  • func (c *CoreApi) GetLogGroupList(query *data.FileListQuery) (*data.Page[*data.LogGroup], error)
  • func (c *CoreApi) GetMachineIdByFileName(name string) (string, error)
  • func (c *CoreApi) IsSelfMachine(machineId string) bool
  • func (c *CoreApi) ListFilesInGroup(groupId string) ([]*data.LogData, error)
• type EmptyReaderClose
  • func (e *EmptyReaderClose) Close() error
  • func (e *EmptyReaderClose) Read(p []byte) (n int, err error)
• type RcpCoreApi
  • func NewRpcCore(coreApi *CoreApi) *RcpCoreApi
  • func (r *RcpCoreApi) FindLogGroups(_ *http.Request, req *data.FileListQuery, res *data.Page[*data.LogGroup]) error
  • func (r *RcpCoreApi) FindLogs(_ *http.Request, req *data.FileListQuery, res *data.Page[*data.LogData]) error

Functions

func NewEcho

func NewEcho(socket *socket.WebSocket, core *CoreApi, config *config.Config, proxyManager *proxy.ProxyManager, staticConfig *config.StaticConfig) *echo.Echo

Types

type CoreApi

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

func NewCore

func NewCore(config *config.Config, storage storage.StorageApi, taskManager *task.TaskManager, data data.DataApi, addressManager *rpc.AddressManager, rpcManager *rpc.RpcManager) (*CoreApi, error)

func (*CoreApi) CleanFile

func (c *CoreApi) CleanFile() error

func (*CoreApi) CleanFileBySize

func (c *CoreApi) CleanFileBySize() error

func (*CoreApi) CleanFileByTime

func (c *CoreApi) CleanFileByTime() error

func (*CoreApi) CreateFile

func (c *CoreApi) CreateFile(file *storage.LogFile) (*storage.LogFile, error)

func (*CoreApi) CreateFileId

func (c *CoreApi) CreateFileId(md5 string) string

func (*CoreApi) CreateLogGroupFile

func (c *CoreApi) CreateLogGroupFile(file *storage.LogGroupFile) (*storage.LogGroupFile, error)

func (*CoreApi) DeleteFile

func (c *CoreApi) DeleteFile(fileId string) error

func (*CoreApi) DeleteLogGroup

func (c *CoreApi) DeleteLogGroup(groupId string) error

func (*CoreApi) GetFile

func (c *CoreApi) GetFile(fileId string) (*storage.LogFile, error)

func (*CoreApi) GetFileList

func (c *CoreApi) GetFileList(query *data.FileListQuery) (*data.Page[*data.LogData], error)

func (*CoreApi) GetLogGroupList

func (c *CoreApi) GetLogGroupList(query *data.FileListQuery) (*data.Page[*data.LogGroup], error)

func (*CoreApi) GetMachineIdByFileName

func (c *CoreApi) GetMachineIdByFileName(name string) (string, error)

func (*CoreApi) IsSelfMachine

func (c *CoreApi) IsSelfMachine(machineId string) bool

func (*CoreApi) ListFilesInGroup

func (c *CoreApi) ListFilesInGroup(groupId string) ([]*data.LogData, error)

type EmptyReaderClose

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

func (*EmptyReaderClose) Close

func (e *EmptyReaderClose) Close() error

func (*EmptyReaderClose) Read

func (e *EmptyReaderClose) Read(p []byte) (n int, err error)

type RcpCoreApi

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

func NewRpcCore

func NewRpcCore(coreApi *CoreApi) *RcpCoreApi

func (*RcpCoreApi) FindLogGroups

func (r *RcpCoreApi) FindLogGroups(_ *http.Request, req *data.FileListQuery, res *data.Page[*data.LogGroup]) error

func (*RcpCoreApi) FindLogs

func (r *RcpCoreApi) FindLogs(_ *http.Request, req *data.FileListQuery, res *data.Page[*data.LogData]) error