Sha256: 3c15d8464eee0d980130357b5f296f767af4cb5a5b8c017c4bb4a6b9b26ba0f5
Contents?: true
Size: 1.66 KB
Versions: 5
Compression:
Stored size: 1.66 KB
Contents
<div class="container mb-5">
<div class="row">
<%== partial 'consumers/consumer/title' %>
<%== partial 'consumers/consumer/commands', locals: { process: @process } %>
</div>
</div>
<% if @process.status == 'stopped' %>
<%== partial 'consumers/consumer/stopped' %>
<% end %>
<%== partial 'consumers/consumer/metrics' %>
<%== partial 'consumers/consumer/tabs' %>
<% if @pending_jobs.empty? %>
<%== partial 'consumers/consumer/no_jobs', locals: { type: 'pending' } %>
<% else %>
<div class="container">
<div class="row mb-5">
<div class="col-sm-12 table-responsive">
<table class="processes bg-white table table-hover table-bordered table-striped mb-0 align-middle">
<thead>
<tr class="align-middle">
<th rowspan="2"><%== sort_link(:topic) %></th>
<th rowspan="2"><%== sort_link(:consumer) %></th>
<th rowspan="2"><%== sort_link(:type) %></th>
<th rowspan="2"><%== sort_link(:messages) %></th>
<th colspan="3" class="text-center">Offsets</th>
<th rowspan="2"><%== sort_link('Started', :updated_at, rev: true) %></th>
</tr>
<tr class="align-middle">
<th><%== sort_link(:first_offset) %></th>
<th><%== sort_link(:last_offset) %></th>
<th><%== sort_link(:committed_offset) %></th>
</tr>
</thead>
<tbody>
<%==
render_each(
@pending_jobs,
'consumers/consumer/_job',
local: :job
)
%>
</tbody>
</table>
</div>
</div>
</div>
<% end %>
Version data entries
5 entries across 5 versions & 1 rubygems