logmetadata

Documentation

Index

• type LogMetadataService
  • func NewLogMetadataService(k8sCfg *rest.Config, nodeName string, containerLogsDir string) (*LogMetadataService, error)
  • func (s *LogMetadataService) List(ctx context.Context, req *agentpb.LogMetadataListRequest) (*agentpb.LogMetadataList, error)
  • func (s *LogMetadataService) Shutdown()
  • func (s *LogMetadataService) Watch(req *agentpb.LogMetadataWatchRequest, ...) error

Types

type LogMetadataService

type LogMetadataService struct {
	agentpb.UnimplementedLogMetadataServiceServer
	// contains filtered or unexported fields
}

func NewLogMetadataService

func NewLogMetadataService(k8sCfg *rest.Config, nodeName string, containerLogsDir string) (*LogMetadataService, error)

Initialize new instance of LogMetadataService

func (*LogMetadataService) List

func (s *LogMetadataService) List(ctx context.Context, req *agentpb.LogMetadataListRequest) (*agentpb.LogMetadataList, error)

Implementation of List() in LogMetadataService

func (*LogMetadataService) Shutdown

func (s *LogMetadataService) Shutdown()

Initiate shutdown

func (*LogMetadataService) Watch

func (s *LogMetadataService) Watch(req *agentpb.LogMetadataWatchRequest, stream agentpb.LogMetadataService_WatchServer) error

Implementation of Watch() in LogMetadataService