(ctx context.Context, driver string)
| 176 | } |
| 177 | |
| 178 | func (i *imlLogService) GetLogSource(ctx context.Context, driver string) (*Source, error) { |
| 179 | s, err := i.store.First(ctx, map[string]interface{}{"driver": driver}) |
| 180 | if err != nil { |
| 181 | return nil, err |
| 182 | } |
| 183 | return FromEntity(s), nil |
| 184 | } |
| 185 | |
| 186 | func (i *imlLogService) Logs(ctx context.Context, driver string, cluster string, conditions map[string]string, start time.Time, end time.Time, limit int64, offset int64) ([]*Item, int64, error) { |
| 187 | d, has := log_driver.GetDriver(driver) |
no test coverage detected