Documentation ¶
Index ¶
- func Contains[T comparable](s []T, e T) bool
- func CopySelectedRowToClipboard(table *tview.Table, ConsumeMessage func(message string))
- func CreateMainInputLegend() *tview.Flex
- func CreatePropertyInfo(propertyName string, propertyValue string) *tview.InputField
- func CreateRunInfo(runeName string, info string) *tview.InputField
- func Init(cfgOption string, useMock bool)
- func OpenUI(dataSource api.KafkaDataSource)
- func RecoverAndExit(app *tview.Application)
- type ByOffsetThenPartition
- type DetailPage
- type MainPage
- func (m *MainPage) CreateMainPage(dataSource api.KafkaDataSource, pages *tview.Pages, app *tview.Application, ...) *tview.Flex
- func (m *MainPage) CurrentTimeString() string
- func (m *MainPage) FetchConsumerGroups(dataSource api.KafkaDataSource) []api.ConsumerGroup
- func (m *MainPage) FetchContexts(dataSource api.KafkaDataSource) []string
- func (m *MainPage) SetupTableInput(table *tview.Table, app *tview.Application, pages *tview.Pages, ...)
- func (m *MainPage) ShowNotification(message string)
- func (m *MainPage) UpdateMidFlexTitle(currentResouce string, amount int)
- func (m *MainPage) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource)
- func (m *MainPage) UpdateTableRoutine(app *tview.Application, table *tview.Table, timerView *tview.TextView, ...)
- type ResouceName
- type ResouceTopic
- func (r *ResouceTopic) FetchTopics(dataSource api.KafkaDataSource) map[string]api.Topic
- func (r ResouceTopic) GetName() string
- func (r *ResouceTopic) ShowTopicsInTable(table *tview.Table, topics map[string]api.Topic, search string)
- func (r *ResouceTopic) StartFetchingData()
- func (r *ResouceTopic) StopFetching()
- func (r *ResouceTopic) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)
- func (r *ResouceTopic) UpdateTableDataRoutine(ctx context.Context, dataSource api.KafkaDataSource)
- type Resource
- type ResourceContext
- func (c *ResourceContext) FetchContextRoutine(ctx context.Context, dataSource api.KafkaDataSource)
- func (rc *ResourceContext) FetchContexts(dataSource api.KafkaDataSource) []string
- func (r ResourceContext) GetName() string
- func (r ResourceContext) ShowContextsInTable(table *tview.Table, contexts map[string]string, search string)
- func (r *ResourceContext) StartFetchingData()
- func (r *ResourceContext) StopFetching()
- func (r *ResourceContext) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)
- type ResourceGroup
- func (g *ResourceGroup) FetchConsumerGroups(dataSource api.KafkaDataSource) []api.ConsumerGroup
- func (g *ResourceGroup) FetchGroupsRoutine(ctx context.Context, dataSource api.KafkaDataSource)
- func (r ResourceGroup) GetName() string
- func (r ResourceGroup) ShowConsumerGroups(table *tview.Table, cgs map[string]api.ConsumerGroup, search string)
- func (r *ResourceGroup) StartFetchingData()
- func (r *ResourceGroup) StopFetching()
- func (r *ResourceGroup) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)
- type SearchBar
- type SearchMode
- type TopicPage
- func (tp *TopicPage) CloseTopicPage()
- func (tp *TopicPage) CreateConsumeFlagsSection() *tview.Flex
- func (tp *TopicPage) CreateInputLegend() *tview.Flex
- func (tp *TopicPage) CreateInputSearch(onDone func()) *tview.Flex
- func (tp *TopicPage) CreateTopicInfoSection(topicName string, topicDetail api.Topic) *tview.Flex
- func (tp *TopicPage) CreateTopicPage(currentTopic string) *tview.Flex
- func (tp *TopicPage) PageConsumeTopic(topicName string, currentTopic api.Topic, flags api.ConsumeFlags)
- func (tp *TopicPage) RestartConsumer()
- func (tp *TopicPage) ShowNotification(message string)
- type UIEvent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CopySelectedRowToClipboard ¶
Function to copy the selected row of the table to the clipboard in CSV format
func CreateMainInputLegend ¶
func CreatePropertyInfo ¶
func CreatePropertyInfo(propertyName string, propertyValue string) *tview.InputField
func CreateRunInfo ¶
func CreateRunInfo(runeName string, info string) *tview.InputField
func OpenUI ¶
func OpenUI(dataSource api.KafkaDataSource)
func RecoverAndExit ¶ added in v0.1.24
func RecoverAndExit(app *tview.Application)
Types ¶
type ByOffsetThenPartition ¶
Implement the sort.Interface
func (ByOffsetThenPartition) Len ¶
func (a ByOffsetThenPartition) Len() int
func (ByOffsetThenPartition) Less ¶
func (a ByOffsetThenPartition) Less(i, j int) bool
func (ByOffsetThenPartition) Swap ¶
func (a ByOffsetThenPartition) Swap(i, j int)
type DetailPage ¶
type DetailPage struct {
// contains filtered or unexported fields
}
func NewDetailPage ¶
func NewDetailPage(app *tview.Application, pages *tview.Pages, value string) *DetailPage
func (*DetailPage) CreateInputLegend ¶
func (vp *DetailPage) CreateInputLegend() *tview.Flex
func (*DetailPage) Show ¶
func (vp *DetailPage) Show()
type MainPage ¶ added in v0.1.24
type MainPage struct { CurrentContextName string NotificationTextView *tview.TextView MidFlex *tview.Flex ContextInfo *tview.InputField CurrentSearchString string CurrentResource *Resource SearchBar *SearchBar }
func NewMainPage ¶ added in v0.1.24
func NewMainPage() *MainPage
func (*MainPage) CreateMainPage ¶ added in v0.1.24
func (*MainPage) CurrentTimeString ¶ added in v0.1.24
func (*MainPage) FetchConsumerGroups ¶ added in v0.1.24
func (m *MainPage) FetchConsumerGroups(dataSource api.KafkaDataSource) []api.ConsumerGroup
func (*MainPage) FetchContexts ¶ added in v0.1.24
func (m *MainPage) FetchContexts(dataSource api.KafkaDataSource) []string
func (*MainPage) SetupTableInput ¶ added in v0.1.24
func (m *MainPage) SetupTableInput(table *tview.Table, app *tview.Application, pages *tview.Pages, dataSource api.KafkaDataSource, msgChannel chan UIEvent)
func (*MainPage) ShowNotification ¶ added in v0.1.24
func (*MainPage) UpdateMidFlexTitle ¶ added in v0.1.24
func (*MainPage) UpdateTable ¶ added in v0.1.24
func (m *MainPage) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource)
func (*MainPage) UpdateTableRoutine ¶ added in v0.1.24
func (m *MainPage) UpdateTableRoutine(app *tview.Application, table *tview.Table, timerView *tview.TextView, dataSource api.KafkaDataSource)
type ResouceName ¶
type ResouceName []string // array because it can have multiple names
var ( Context ResouceName = []string{"context", "ctx", "kafka", "broker"} Topic ResouceName = []string{"topics", "ts"} ConsumerGroup ResouceName = []string{"consumergroups", "groups", "consumers", "cgs"} )
type ResouceTopic ¶ added in v0.1.27
type ResouceTopic struct { LastFetchedTopics map[string]api.Topic // contains filtered or unexported fields }
func NewResouceTopic ¶ added in v0.1.27
func NewResouceTopic(dataSource api.KafkaDataSource, onError func(err error), recoverFunc func()) *ResouceTopic
func (*ResouceTopic) FetchTopics ¶ added in v0.1.27
func (r *ResouceTopic) FetchTopics(dataSource api.KafkaDataSource) map[string]api.Topic
func (ResouceTopic) GetName ¶ added in v0.1.27
func (r ResouceTopic) GetName() string
func (*ResouceTopic) ShowTopicsInTable ¶ added in v0.1.27
func (*ResouceTopic) StartFetchingData ¶ added in v0.1.27
func (r *ResouceTopic) StartFetchingData()
func (*ResouceTopic) StopFetching ¶ added in v0.1.27
func (r *ResouceTopic) StopFetching()
func (*ResouceTopic) UpdateTable ¶ added in v0.1.27
func (r *ResouceTopic) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)
func (*ResouceTopic) UpdateTableDataRoutine ¶ added in v0.1.27
func (r *ResouceTopic) UpdateTableDataRoutine(ctx context.Context, dataSource api.KafkaDataSource)
type ResourceContext ¶ added in v0.1.27
type ResourceContext struct { FetchedContexts map[string]string Name string // contains filtered or unexported fields }
func NewResourceContext ¶ added in v0.1.27
func NewResourceContext(dataSource api.KafkaDataSource, onError func(err error), recoverFunc func()) *ResourceContext
func (*ResourceContext) FetchContextRoutine ¶ added in v0.1.27
func (c *ResourceContext) FetchContextRoutine(ctx context.Context, dataSource api.KafkaDataSource)
func (*ResourceContext) FetchContexts ¶ added in v0.1.27
func (rc *ResourceContext) FetchContexts(dataSource api.KafkaDataSource) []string
func (ResourceContext) GetName ¶ added in v0.1.27
func (r ResourceContext) GetName() string
func (ResourceContext) ShowContextsInTable ¶ added in v0.1.27
func (*ResourceContext) StartFetchingData ¶ added in v0.1.27
func (r *ResourceContext) StartFetchingData()
func (*ResourceContext) StopFetching ¶ added in v0.1.27
func (r *ResourceContext) StopFetching()
func (*ResourceContext) UpdateTable ¶ added in v0.1.27
func (r *ResourceContext) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)
type ResourceGroup ¶ added in v0.1.27
type ResourceGroup struct { FetchedConsumerGroups map[string]api.ConsumerGroup // contains filtered or unexported fields }
func NewResourceGroup ¶ added in v0.1.27
func NewResourceGroup(onError func(err error), dataSource api.KafkaDataSource, recoverFunc func()) *ResourceGroup
func (*ResourceGroup) FetchConsumerGroups ¶ added in v0.1.27
func (g *ResourceGroup) FetchConsumerGroups(dataSource api.KafkaDataSource) []api.ConsumerGroup
func (*ResourceGroup) FetchGroupsRoutine ¶ added in v0.1.27
func (g *ResourceGroup) FetchGroupsRoutine(ctx context.Context, dataSource api.KafkaDataSource)
func (ResourceGroup) GetName ¶ added in v0.1.27
func (r ResourceGroup) GetName() string
func (ResourceGroup) ShowConsumerGroups ¶ added in v0.1.27
func (r ResourceGroup) ShowConsumerGroups(table *tview.Table, cgs map[string]api.ConsumerGroup, search string)
func (*ResourceGroup) StartFetchingData ¶ added in v0.1.27
func (r *ResourceGroup) StartFetchingData()
func (*ResourceGroup) StopFetching ¶ added in v0.1.27
func (r *ResourceGroup) StopFetching()
func (*ResourceGroup) UpdateTable ¶ added in v0.1.27
func (r *ResourceGroup) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)
type SearchBar ¶ added in v0.1.24
type SearchBar struct { Table *tview.Table DataSource api.KafkaDataSource Pages *tview.Pages App *tview.Application Modal *tview.Modal DefaultLabel string SearchInput *tview.InputField CurrentMode SearchMode CurrentString string CurrentResource Resource UpdateTable func(newResource Resource, searchText string) // contains filtered or unexported fields }
func NewSearchBar ¶ added in v0.1.24
func (*SearchBar) CreateSearchInput ¶ added in v0.1.24
func (s *SearchBar) CreateSearchInput(msgChannel chan UIEvent) *tview.InputField
func (*SearchBar) ReceivingMessage ¶ added in v0.1.24
func (s *SearchBar) ReceivingMessage(app *tview.Application, table *tview.Table, searchInput *tview.InputField, msgChannel chan UIEvent)
type SearchMode ¶
type SearchMode string
const ( TableSearch SearchMode = "TableSearch" ResouceSearch SearchMode = "ResouceSearch" )
type TopicPage ¶
type TopicPage struct {
// contains filtered or unexported fields
}
func NewTopicPage ¶
func NewTopicPage(dataSource api.KafkaDataSource, pages *tview.Pages, app *tview.Application, msgChannel chan UIEvent) *TopicPage
func (*TopicPage) CloseTopicPage ¶
func (tp *TopicPage) CloseTopicPage()
func (*TopicPage) CreateConsumeFlagsSection ¶
func (*TopicPage) CreateInputLegend ¶
func (*TopicPage) CreateInputSearch ¶
func (*TopicPage) CreateTopicInfoSection ¶
func (*TopicPage) CreateTopicPage ¶
func (*TopicPage) PageConsumeTopic ¶
func (*TopicPage) RestartConsumer ¶
func (tp *TopicPage) RestartConsumer()
func (*TopicPage) ShowNotification ¶
Click to show internal directories.
Click to hide internal directories.