()
| 26 | } |
| 27 | |
| 28 | func (a *LogsAPI) now() time.Time { |
| 29 | if a.TimeNowFn != nil { |
| 30 | return a.TimeNowFn() |
| 31 | } |
| 32 | return dbtime.Now() |
| 33 | } |
| 34 | |
| 35 | func (a *LogsAPI) BatchCreateLogs(ctx context.Context, req *agentproto.BatchCreateLogsRequest) (*agentproto.BatchCreateLogsResponse, error) { |
| 36 | workspaceAgent, err := a.AgentFn(ctx) |